v3

package
v0.0.0-...-ec791aa Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ContinuousProfilingCauseType_name = map[int32]string{
		0: "ProcessCPU",
		1: "ProcessThreadCount",
		2: "SystemLoad",
		3: "HTTPErrorRate",
		4: "HTTPAvgResponseTime",
	}
	ContinuousProfilingCauseType_value = map[string]int32{
		"ProcessCPU":          0,
		"ProcessThreadCount":  1,
		"SystemLoad":          2,
		"HTTPErrorRate":       3,
		"HTTPAvgResponseTime": 4,
	}
)

Enum value maps for ContinuousProfilingCauseType.

View Source 
var (
	EBPFProfilingStackType_name = map[int32]string{
		0: "PROCESS_KERNEL_SPACE",
		1: "PROCESS_USER_SPACE",
	}
	EBPFProfilingStackType_value = map[string]int32{
		"PROCESS_KERNEL_SPACE": 0,
		"PROCESS_USER_SPACE":   1,
	}
)

Enum value maps for EBPFProfilingStackType.

View Source 
var File_ebpf_profiling_Continuous_proto protoreflect.FileDescriptor
View Source 
var File_ebpf_profiling_Profile_proto protoreflect.FileDescriptor

Functions

func RegisterContinuousProfilingServiceServer 

func RegisterContinuousProfilingServiceServer(s grpc.ServiceRegistrar, srv ContinuousProfilingServiceServer)

func RegisterEBPFProfilingServiceServer 

func RegisterEBPFProfilingServiceServer(s grpc.ServiceRegistrar, srv EBPFProfilingServiceServer)

Types

type ContinuousNetworkProfilingTask 

type ContinuousNetworkProfilingTask struct {
	SamplingURIRegexes []string `protobuf:"bytes,1,rep,name=samplingURIRegexes,proto3" json:"samplingURIRegexes,omitempty"`
	// contains filtered or unexported fields
}

eBPF Network profiling task

func (*ContinuousNetworkProfilingTask) Descriptor deprecated 

func (*ContinuousNetworkProfilingTask) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousNetworkProfilingTask.ProtoReflect.Descriptor instead.

func (*ContinuousNetworkProfilingTask) GetSamplingURIRegexes 

func (x *ContinuousNetworkProfilingTask) GetSamplingURIRegexes() []string

func (*ContinuousNetworkProfilingTask) ProtoMessage 

func (*ContinuousNetworkProfilingTask) ProtoMessage()

func (*ContinuousNetworkProfilingTask) ProtoReflect 

func (x *ContinuousNetworkProfilingTask) ProtoReflect() protoreflect.Message

func (*ContinuousNetworkProfilingTask) Reset 

func (x *ContinuousNetworkProfilingTask) Reset()

func (*ContinuousNetworkProfilingTask) String 

func (x *ContinuousNetworkProfilingTask) String() string

type ContinuousOffCPUProfilingTask 

type ContinuousOffCPUProfilingTask struct {
	// contains filtered or unexported fields
}

eBPF off CPU profiling task

func (*ContinuousOffCPUProfilingTask) Descriptor deprecated 

func (*ContinuousOffCPUProfilingTask) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousOffCPUProfilingTask.ProtoReflect.Descriptor instead.

func (*ContinuousOffCPUProfilingTask) ProtoMessage 

func (*ContinuousOffCPUProfilingTask) ProtoMessage()

func (*ContinuousOffCPUProfilingTask) ProtoReflect 

func (x *ContinuousOffCPUProfilingTask) ProtoReflect() protoreflect.Message

func (*ContinuousOffCPUProfilingTask) Reset 

func (x *ContinuousOffCPUProfilingTask) Reset()

func (*ContinuousOffCPUProfilingTask) String 

func (x *ContinuousOffCPUProfilingTask) String() string

type ContinuousOnCPUProfilingTask 

type ContinuousOnCPUProfilingTask struct {
	// contains filtered or unexported fields
}

eBPF on CPU profiling task

func (*ContinuousOnCPUProfilingTask) Descriptor deprecated 

func (*ContinuousOnCPUProfilingTask) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousOnCPUProfilingTask.ProtoReflect.Descriptor instead.

func (*ContinuousOnCPUProfilingTask) ProtoMessage 

func (*ContinuousOnCPUProfilingTask) ProtoMessage()

func (*ContinuousOnCPUProfilingTask) ProtoReflect 

func (x *ContinuousOnCPUProfilingTask) ProtoReflect() protoreflect.Message

func (*ContinuousOnCPUProfilingTask) Reset 

func (x *ContinuousOnCPUProfilingTask) Reset()

func (*ContinuousOnCPUProfilingTask) String 

func (x *ContinuousOnCPUProfilingTask) String() string

type ContinuousProfilingCause 

type ContinuousProfilingCause struct {
	Type ContinuousProfilingCauseType `protobuf:"varint,1,opt,name=type,proto3,enum=skywalking.v3.ContinuousProfilingCauseType" json:"type,omitempty"`
	// Types that are assignable to Cause:
	//	*ContinuousProfilingCause_SingleValue
	//	*ContinuousProfilingCause_Uri
	Cause isContinuousProfilingCause_Cause `protobuf_oneof:"cause"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingCause) Descriptor deprecated 

func (*ContinuousProfilingCause) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingCause.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingCause) GetCause 

func (m *ContinuousProfilingCause) GetCause() isContinuousProfilingCause_Cause

func (*ContinuousProfilingCause) GetSingleValue 

func (x *ContinuousProfilingCause) GetSingleValue() *ContinuousProfilingSingleValueCause

func (*ContinuousProfilingCause) GetType 

func (x *ContinuousProfilingCause) GetType() ContinuousProfilingCauseType

func (*ContinuousProfilingCause) GetUri 

func (x *ContinuousProfilingCause) GetUri() *ContinuousProfilingURICause

func (*ContinuousProfilingCause) ProtoMessage 

func (*ContinuousProfilingCause) ProtoMessage()

func (*ContinuousProfilingCause) ProtoReflect 

func (x *ContinuousProfilingCause) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingCause) Reset 

func (x *ContinuousProfilingCause) Reset()

func (*ContinuousProfilingCause) String 

func (x *ContinuousProfilingCause) String() string

type ContinuousProfilingCauseType 

type ContinuousProfilingCauseType int32
const (
	// Current process CPU usage percent(0-100).
	ContinuousProfilingCauseType_ProcessCPU ContinuousProfilingCauseType = 0
	// The number of threads in the process.
	ContinuousProfilingCauseType_ProcessThreadCount ContinuousProfilingCauseType = 1
	// System load value.
	ContinuousProfilingCauseType_SystemLoad ContinuousProfilingCauseType = 2
	// Process response error rate(0-100).
	// HTTP response codes in [500-600) are considered errors.
	// Formula: ErrorCount / TotalCount * 100
	ContinuousProfilingCauseType_HTTPErrorRate ContinuousProfilingCauseType = 3
	// Process response average time(ms).
	// Formula: TotalResponseTime(ms) / TotalCount
	ContinuousProfilingCauseType_HTTPAvgResponseTime ContinuousProfilingCauseType = 4
)

func (ContinuousProfilingCauseType) Descriptor 

func (ContinuousProfilingCauseType) Descriptor() protoreflect.EnumDescriptor

func (ContinuousProfilingCauseType) Enum 

func (x ContinuousProfilingCauseType) Enum() *ContinuousProfilingCauseType

func (ContinuousProfilingCauseType) EnumDescriptor deprecated 

func (ContinuousProfilingCauseType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingCauseType.Descriptor instead.

func (ContinuousProfilingCauseType) Number 

func (x ContinuousProfilingCauseType) Number() protoreflect.EnumNumber

func (ContinuousProfilingCauseType) String 

func (x ContinuousProfilingCauseType) String() string

func (ContinuousProfilingCauseType) Type 

func (ContinuousProfilingCauseType) Type() protoreflect.EnumType

type ContinuousProfilingCause_SingleValue 

type ContinuousProfilingCause_SingleValue struct {
	SingleValue *ContinuousProfilingSingleValueCause `protobuf:"bytes,2,opt,name=singleValue,proto3,oneof"`
}

type ContinuousProfilingCause_Uri 

type ContinuousProfilingCause_Uri struct {
	Uri *ContinuousProfilingURICause `protobuf:"bytes,3,opt,name=uri,proto3,oneof"`
}

type ContinuousProfilingPolicyQuery 

type ContinuousProfilingPolicyQuery struct {

	// current agent contains service and policies
	Policies []*ContinuousProfilingServicePolicyQuery `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingPolicyQuery) Descriptor deprecated 

func (*ContinuousProfilingPolicyQuery) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingPolicyQuery.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingPolicyQuery) GetPolicies 

func (x *ContinuousProfilingPolicyQuery) GetPolicies() []*ContinuousProfilingServicePolicyQuery

func (*ContinuousProfilingPolicyQuery) ProtoMessage 

func (*ContinuousProfilingPolicyQuery) ProtoMessage()

func (*ContinuousProfilingPolicyQuery) ProtoReflect 

func (x *ContinuousProfilingPolicyQuery) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingPolicyQuery) Reset 

func (x *ContinuousProfilingPolicyQuery) Reset()

func (*ContinuousProfilingPolicyQuery) String 

func (x *ContinuousProfilingPolicyQuery) String() string

type ContinuousProfilingReport 

type ContinuousProfilingReport struct {

	// over threshold process entity
	Layer        string `protobuf:"bytes,1,opt,name=layer,proto3" json:"layer,omitempty"`
	ServiceName  string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	InstanceName string `protobuf:"bytes,3,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	ProcessName  string `protobuf:"bytes,4,opt,name=processName,proto3" json:"processName,omitempty"`
	// reached thresholds causes
	Causes []*ContinuousProfilingCause `protobuf:"bytes,5,rep,name=causes,proto3" json:"causes,omitempty"`
	// The execution duration for this triggered profiling.
	// This is set at the agent side.
	Duration int32 `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// target profiling task
	//
	// Types that are assignable to TargetTask:
	//	*ContinuousProfilingReport_OnCPU
	//	*ContinuousProfilingReport_OffCPU
	//	*ContinuousProfilingReport_Network
	TargetTask isContinuousProfilingReport_TargetTask `protobuf_oneof:"targetTask"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingReport) Descriptor deprecated 

func (*ContinuousProfilingReport) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingReport.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingReport) GetCauses 

func (x *ContinuousProfilingReport) GetCauses() []*ContinuousProfilingCause

func (*ContinuousProfilingReport) GetDuration 

func (x *ContinuousProfilingReport) GetDuration() int32

func (*ContinuousProfilingReport) GetInstanceName 

func (x *ContinuousProfilingReport) GetInstanceName() string

func (*ContinuousProfilingReport) GetLayer 

func (x *ContinuousProfilingReport) GetLayer() string

func (*ContinuousProfilingReport) GetNetwork 

func (x *ContinuousProfilingReport) GetNetwork() *ContinuousNetworkProfilingTask

func (*ContinuousProfilingReport) GetOffCPU 

func (x *ContinuousProfilingReport) GetOffCPU() *ContinuousOffCPUProfilingTask

func (*ContinuousProfilingReport) GetOnCPU 

func (x *ContinuousProfilingReport) GetOnCPU() *ContinuousOnCPUProfilingTask

func (*ContinuousProfilingReport) GetProcessName 

func (x *ContinuousProfilingReport) GetProcessName() string

func (*ContinuousProfilingReport) GetServiceName 

func (x *ContinuousProfilingReport) GetServiceName() string

func (*ContinuousProfilingReport) GetTargetTask 

func (m *ContinuousProfilingReport) GetTargetTask() isContinuousProfilingReport_TargetTask

func (*ContinuousProfilingReport) ProtoMessage 

func (*ContinuousProfilingReport) ProtoMessage()

func (*ContinuousProfilingReport) ProtoReflect 

func (x *ContinuousProfilingReport) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingReport) Reset 

func (x *ContinuousProfilingReport) Reset()

func (*ContinuousProfilingReport) String 

func (x *ContinuousProfilingReport) String() string

type ContinuousProfilingReport_Network 

type ContinuousProfilingReport_Network struct {
	Network *ContinuousNetworkProfilingTask `protobuf:"bytes,9,opt,name=network,proto3,oneof"`
}

type ContinuousProfilingReport_OffCPU 

type ContinuousProfilingReport_OffCPU struct {
	OffCPU *ContinuousOffCPUProfilingTask `protobuf:"bytes,8,opt,name=offCPU,proto3,oneof"`
}

type ContinuousProfilingReport_OnCPU 

type ContinuousProfilingReport_OnCPU struct {
	OnCPU *ContinuousOnCPUProfilingTask `protobuf:"bytes,7,opt,name=onCPU,proto3,oneof"`
}

type ContinuousProfilingServiceClient 

type ContinuousProfilingServiceClient interface {
	// Query continuous profiling policy
	QueryPolicies(ctx context.Context, in *ContinuousProfilingPolicyQuery, opts ...grpc.CallOption) (*v3.Commands, error)
	// Report the profiling task when the policy threshold is reached
	// Use the returned task ID to perform the profiling task through
	// EBPFProfilingService#collectProfilingData.
	ReportProfilingTask(ctx context.Context, in *ContinuousProfilingReport, opts ...grpc.CallOption) (*v3.Commands, error)
}

ContinuousProfilingServiceClient is the client API for ContinuousProfilingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewContinuousProfilingServiceClient 

func NewContinuousProfilingServiceClient(cc grpc.ClientConnInterface) ContinuousProfilingServiceClient

type ContinuousProfilingServicePolicyQuery 

type ContinuousProfilingServicePolicyQuery struct {

	// service name of the each process
	ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	// UUID represents the version(hash/shasum) of the current policies for the
	// service. This is blank in the initialization stage and is set through the
	// `ContinuousProfilingPolicyQuery` command response for the following rounds
	// of queries.
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingServicePolicyQuery) Descriptor deprecated 

func (*ContinuousProfilingServicePolicyQuery) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingServicePolicyQuery.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingServicePolicyQuery) GetServiceName 

func (x *ContinuousProfilingServicePolicyQuery) GetServiceName() string

func (*ContinuousProfilingServicePolicyQuery) GetUuid 

func (x *ContinuousProfilingServicePolicyQuery) GetUuid() string

func (*ContinuousProfilingServicePolicyQuery) ProtoMessage 

func (*ContinuousProfilingServicePolicyQuery) ProtoMessage()

func (*ContinuousProfilingServicePolicyQuery) ProtoReflect 

func (x *ContinuousProfilingServicePolicyQuery) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingServicePolicyQuery) Reset 

func (x *ContinuousProfilingServicePolicyQuery) Reset()

func (*ContinuousProfilingServicePolicyQuery) String 

func (x *ContinuousProfilingServicePolicyQuery) String() string

type ContinuousProfilingServiceServer 

type ContinuousProfilingServiceServer interface {
	// Query continuous profiling policy
	QueryPolicies(context.Context, *ContinuousProfilingPolicyQuery) (*v3.Commands, error)
	// Report the profiling task when the policy threshold is reached
	// Use the returned task ID to perform the profiling task through
	// EBPFProfilingService#collectProfilingData.
	ReportProfilingTask(context.Context, *ContinuousProfilingReport) (*v3.Commands, error)
	// contains filtered or unexported methods
}

ContinuousProfilingServiceServer is the server API for ContinuousProfilingService service. All implementations must embed UnimplementedContinuousProfilingServiceServer for forward compatibility

type ContinuousProfilingSingleValueCause 

type ContinuousProfilingSingleValueCause struct {
	Threshold float64 `protobuf:"fixed64,1,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Current   float64 `protobuf:"fixed64,2,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingSingleValueCause) Descriptor deprecated 

func (*ContinuousProfilingSingleValueCause) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingSingleValueCause.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingSingleValueCause) GetCurrent 

func (x *ContinuousProfilingSingleValueCause) GetCurrent() float64

func (*ContinuousProfilingSingleValueCause) GetThreshold 

func (x *ContinuousProfilingSingleValueCause) GetThreshold() float64

func (*ContinuousProfilingSingleValueCause) ProtoMessage 

func (*ContinuousProfilingSingleValueCause) ProtoMessage()

func (*ContinuousProfilingSingleValueCause) ProtoReflect 

func (x *ContinuousProfilingSingleValueCause) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingSingleValueCause) Reset 

func (x *ContinuousProfilingSingleValueCause) Reset()

func (*ContinuousProfilingSingleValueCause) String 

func (x *ContinuousProfilingSingleValueCause) String() string

type ContinuousProfilingURICause 

type ContinuousProfilingURICause struct {

	// Types that are assignable to Uri:
	//	*ContinuousProfilingURICause_Regex
	//	*ContinuousProfilingURICause_Path
	Uri       isContinuousProfilingURICause_Uri `protobuf_oneof:"uri"`
	Threshold float64                           `protobuf:"fixed64,3,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Current   float64                           `protobuf:"fixed64,4,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinuousProfilingURICause) Descriptor deprecated 

func (*ContinuousProfilingURICause) Descriptor() ([]byte, []int)

Deprecated: Use ContinuousProfilingURICause.ProtoReflect.Descriptor instead.

func (*ContinuousProfilingURICause) GetCurrent 

func (x *ContinuousProfilingURICause) GetCurrent() float64

func (*ContinuousProfilingURICause) GetPath 

func (x *ContinuousProfilingURICause) GetPath() string

func (*ContinuousProfilingURICause) GetRegex 

func (x *ContinuousProfilingURICause) GetRegex() string

func (*ContinuousProfilingURICause) GetThreshold 

func (x *ContinuousProfilingURICause) GetThreshold() float64

func (*ContinuousProfilingURICause) GetUri 

func (m *ContinuousProfilingURICause) GetUri() isContinuousProfilingURICause_Uri

func (*ContinuousProfilingURICause) ProtoMessage 

func (*ContinuousProfilingURICause) ProtoMessage()

func (*ContinuousProfilingURICause) ProtoReflect 

func (x *ContinuousProfilingURICause) ProtoReflect() protoreflect.Message

func (*ContinuousProfilingURICause) Reset 

func (x *ContinuousProfilingURICause) Reset()

func (*ContinuousProfilingURICause) String 

func (x *ContinuousProfilingURICause) String() string

type ContinuousProfilingURICause_Path 

type ContinuousProfilingURICause_Path struct {
	Path string `protobuf:"bytes,2,opt,name=path,proto3,oneof"`
}

type ContinuousProfilingURICause_Regex 

type ContinuousProfilingURICause_Regex struct {
	Regex string `protobuf:"bytes,1,opt,name=regex,proto3,oneof"`
}

type EBPFOffCPUProfiling 

type EBPFOffCPUProfiling struct {

	// stack data in one task(thread)
	Stacks []*EBPFProfilingStackMetadata `protobuf:"bytes,1,rep,name=stacks,proto3" json:"stacks,omitempty"`
	// total count of the process is switched to off cpu by the scheduler.
	SwitchCount int32 `protobuf:"varint,2,opt,name=switchCount,proto3" json:"switchCount,omitempty"`
	// where time(nanoseconds) is spent waiting while blocked on I/O, locks,
	// timers, paging/swapping, etc.
	Duration int64 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFOffCPUProfiling) Descriptor deprecated 

func (*EBPFOffCPUProfiling) Descriptor() ([]byte, []int)

Deprecated: Use EBPFOffCPUProfiling.ProtoReflect.Descriptor instead.

func (*EBPFOffCPUProfiling) GetDuration 

func (x *EBPFOffCPUProfiling) GetDuration() int64

func (*EBPFOffCPUProfiling) GetStacks 

func (x *EBPFOffCPUProfiling) GetStacks() []*EBPFProfilingStackMetadata

func (*EBPFOffCPUProfiling) GetSwitchCount 

func (x *EBPFOffCPUProfiling) GetSwitchCount() int32

func (*EBPFOffCPUProfiling) ProtoMessage 

func (*EBPFOffCPUProfiling) ProtoMessage()

func (*EBPFOffCPUProfiling) ProtoReflect 

func (x *EBPFOffCPUProfiling) ProtoReflect() protoreflect.Message

func (*EBPFOffCPUProfiling) Reset 

func (x *EBPFOffCPUProfiling) Reset()

func (*EBPFOffCPUProfiling) String 

func (x *EBPFOffCPUProfiling) String() string

type EBPFOnCPUProfiling 

type EBPFOnCPUProfiling struct {

	// stack data in one task(thread)
	Stacks []*EBPFProfilingStackMetadata `protobuf:"bytes,1,rep,name=stacks,proto3" json:"stacks,omitempty"`
	// stack counts
	DumpCount int32 `protobuf:"varint,2,opt,name=dumpCount,proto3" json:"dumpCount,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFOnCPUProfiling) Descriptor deprecated 

func (*EBPFOnCPUProfiling) Descriptor() ([]byte, []int)

Deprecated: Use EBPFOnCPUProfiling.ProtoReflect.Descriptor instead.

func (*EBPFOnCPUProfiling) GetDumpCount 

func (x *EBPFOnCPUProfiling) GetDumpCount() int32

func (*EBPFOnCPUProfiling) GetStacks 

func (x *EBPFOnCPUProfiling) GetStacks() []*EBPFProfilingStackMetadata

func (*EBPFOnCPUProfiling) ProtoMessage 

func (*EBPFOnCPUProfiling) ProtoMessage()

func (*EBPFOnCPUProfiling) ProtoReflect 

func (x *EBPFOnCPUProfiling) ProtoReflect() protoreflect.Message

func (*EBPFOnCPUProfiling) Reset 

func (x *EBPFOnCPUProfiling) Reset()

func (*EBPFOnCPUProfiling) String 

func (x *EBPFOnCPUProfiling) String() string

type EBPFProfilingData 

type EBPFProfilingData struct {

	// task metadata
	Task *EBPFProfilingTaskMetadata `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// profiling data
	//
	// Types that are assignable to Profiling:
	//	*EBPFProfilingData_OnCPU
	//	*EBPFProfilingData_OffCPU
	Profiling isEBPFProfilingData_Profiling `protobuf_oneof:"profiling"`
	// contains filtered or unexported fields
}

func (*EBPFProfilingData) Descriptor deprecated 

func (*EBPFProfilingData) Descriptor() ([]byte, []int)

Deprecated: Use EBPFProfilingData.ProtoReflect.Descriptor instead.

func (*EBPFProfilingData) GetOffCPU 

func (x *EBPFProfilingData) GetOffCPU() *EBPFOffCPUProfiling

func (*EBPFProfilingData) GetOnCPU 

func (x *EBPFProfilingData) GetOnCPU() *EBPFOnCPUProfiling

func (*EBPFProfilingData) GetProfiling 

func (m *EBPFProfilingData) GetProfiling() isEBPFProfilingData_Profiling

func (*EBPFProfilingData) GetTask 

func (x *EBPFProfilingData) GetTask() *EBPFProfilingTaskMetadata

func (*EBPFProfilingData) ProtoMessage 

func (*EBPFProfilingData) ProtoMessage()

func (*EBPFProfilingData) ProtoReflect 

func (x *EBPFProfilingData) ProtoReflect() protoreflect.Message

func (*EBPFProfilingData) Reset 

func (x *EBPFProfilingData) Reset()

func (*EBPFProfilingData) String 

func (x *EBPFProfilingData) String() string

type EBPFProfilingData_OffCPU 

type EBPFProfilingData_OffCPU struct {
	OffCPU *EBPFOffCPUProfiling `protobuf:"bytes,3,opt,name=offCPU,proto3,oneof"`
}

type EBPFProfilingData_OnCPU 

type EBPFProfilingData_OnCPU struct {
	OnCPU *EBPFOnCPUProfiling `protobuf:"bytes,2,opt,name=onCPU,proto3,oneof"`
}

type EBPFProfilingServiceClient 

type EBPFProfilingServiceClient interface {
	// Query profiling (start or stop) tasks
	QueryTasks(ctx context.Context, in *EBPFProfilingTaskQuery, opts ...grpc.CallOption) (*v3.Commands, error)
	// collect profiling data
	CollectProfilingData(ctx context.Context, opts ...grpc.CallOption) (EBPFProfilingService_CollectProfilingDataClient, error)
}

EBPFProfilingServiceClient is the client API for EBPFProfilingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEBPFProfilingServiceClient 

func NewEBPFProfilingServiceClient(cc grpc.ClientConnInterface) EBPFProfilingServiceClient

type EBPFProfilingServiceServer 

type EBPFProfilingServiceServer interface {
	// Query profiling (start or stop) tasks
	QueryTasks(context.Context, *EBPFProfilingTaskQuery) (*v3.Commands, error)
	// collect profiling data
	CollectProfilingData(EBPFProfilingService_CollectProfilingDataServer) error
	// contains filtered or unexported methods
}

EBPFProfilingServiceServer is the server API for EBPFProfilingService service. All implementations must embed UnimplementedEBPFProfilingServiceServer for forward compatibility

type EBPFProfilingService_CollectProfilingDataClient 

type EBPFProfilingService_CollectProfilingDataClient interface {
	Send(*EBPFProfilingData) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type EBPFProfilingService_CollectProfilingDataServer 

type EBPFProfilingService_CollectProfilingDataServer interface {
	SendAndClose(*v3.Commands) error
	Recv() (*EBPFProfilingData, error)
	grpc.ServerStream
}

type EBPFProfilingStackMetadata 

type EBPFProfilingStackMetadata struct {

	// stack type
	StackType EBPFProfilingStackType `protobuf:"varint,1,opt,name=stackType,proto3,enum=skywalking.v3.EBPFProfilingStackType" json:"stackType,omitempty"`
	// stack id from kernel provide
	StackId int32 `protobuf:"varint,2,opt,name=stackId,proto3" json:"stackId,omitempty"`
	// stack symbols
	StackSymbols []string `protobuf:"bytes,3,rep,name=stackSymbols,proto3" json:"stackSymbols,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProfilingStackMetadata) Descriptor deprecated 

func (*EBPFProfilingStackMetadata) Descriptor() ([]byte, []int)

Deprecated: Use EBPFProfilingStackMetadata.ProtoReflect.Descriptor instead.

func (*EBPFProfilingStackMetadata) GetStackId 

func (x *EBPFProfilingStackMetadata) GetStackId() int32

func (*EBPFProfilingStackMetadata) GetStackSymbols 

func (x *EBPFProfilingStackMetadata) GetStackSymbols() []string

func (*EBPFProfilingStackMetadata) GetStackType 

func (x *EBPFProfilingStackMetadata) GetStackType() EBPFProfilingStackType

func (*EBPFProfilingStackMetadata) ProtoMessage 

func (*EBPFProfilingStackMetadata) ProtoMessage()

func (*EBPFProfilingStackMetadata) ProtoReflect 

func (x *EBPFProfilingStackMetadata) ProtoReflect() protoreflect.Message

func (*EBPFProfilingStackMetadata) Reset 

func (x *EBPFProfilingStackMetadata) Reset()

func (*EBPFProfilingStackMetadata) String 

func (x *EBPFProfilingStackMetadata) String() string

type EBPFProfilingStackType 

type EBPFProfilingStackType int32
const (
	EBPFProfilingStackType_PROCESS_KERNEL_SPACE EBPFProfilingStackType = 0
	EBPFProfilingStackType_PROCESS_USER_SPACE   EBPFProfilingStackType = 1
)

func (EBPFProfilingStackType) Descriptor 

func (EBPFProfilingStackType) Descriptor() protoreflect.EnumDescriptor

func (EBPFProfilingStackType) Enum 

func (x EBPFProfilingStackType) Enum() *EBPFProfilingStackType

func (EBPFProfilingStackType) EnumDescriptor deprecated 

func (EBPFProfilingStackType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EBPFProfilingStackType.Descriptor instead.

func (EBPFProfilingStackType) Number 

func (x EBPFProfilingStackType) Number() protoreflect.EnumNumber

func (EBPFProfilingStackType) String 

func (x EBPFProfilingStackType) String() string

func (EBPFProfilingStackType) Type 

func (EBPFProfilingStackType) Type() protoreflect.EnumType

type EBPFProfilingTaskMetadata 

type EBPFProfilingTaskMetadata struct {

	// profiling task id
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	// profiling process id
	ProcessId string `protobuf:"bytes,2,opt,name=processId,proto3" json:"processId,omitempty"`
	// the start time of this profiling process
	ProfilingStartTime int64 `protobuf:"varint,3,opt,name=profilingStartTime,proto3" json:"profilingStartTime,omitempty"`
	// report time
	CurrentTime int64 `protobuf:"varint,4,opt,name=currentTime,proto3" json:"currentTime,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProfilingTaskMetadata) Descriptor deprecated 

func (*EBPFProfilingTaskMetadata) Descriptor() ([]byte, []int)

Deprecated: Use EBPFProfilingTaskMetadata.ProtoReflect.Descriptor instead.

func (*EBPFProfilingTaskMetadata) GetCurrentTime 

func (x *EBPFProfilingTaskMetadata) GetCurrentTime() int64

func (*EBPFProfilingTaskMetadata) GetProcessId 

func (x *EBPFProfilingTaskMetadata) GetProcessId() string

func (*EBPFProfilingTaskMetadata) GetProfilingStartTime 

func (x *EBPFProfilingTaskMetadata) GetProfilingStartTime() int64

func (*EBPFProfilingTaskMetadata) GetTaskId 

func (x *EBPFProfilingTaskMetadata) GetTaskId() string

func (*EBPFProfilingTaskMetadata) ProtoMessage 

func (*EBPFProfilingTaskMetadata) ProtoMessage()

func (*EBPFProfilingTaskMetadata) ProtoReflect 

func (x *EBPFProfilingTaskMetadata) ProtoReflect() protoreflect.Message

func (*EBPFProfilingTaskMetadata) Reset 

func (x *EBPFProfilingTaskMetadata) Reset()

func (*EBPFProfilingTaskMetadata) String 

func (x *EBPFProfilingTaskMetadata) String() string

type EBPFProfilingTaskQuery 

type EBPFProfilingTaskQuery struct {

	// rover instance id
	RoverInstanceId string `protobuf:"bytes,1,opt,name=roverInstanceId,proto3" json:"roverInstanceId,omitempty"`
	// latest task update time
	LatestUpdateTime int64 `protobuf:"varint,2,opt,name=latestUpdateTime,proto3" json:"latestUpdateTime,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProfilingTaskQuery) Descriptor deprecated 

func (*EBPFProfilingTaskQuery) Descriptor() ([]byte, []int)

Deprecated: Use EBPFProfilingTaskQuery.ProtoReflect.Descriptor instead.

func (*EBPFProfilingTaskQuery) GetLatestUpdateTime 

func (x *EBPFProfilingTaskQuery) GetLatestUpdateTime() int64

func (*EBPFProfilingTaskQuery) GetRoverInstanceId 

func (x *EBPFProfilingTaskQuery) GetRoverInstanceId() string

func (*EBPFProfilingTaskQuery) ProtoMessage 

func (*EBPFProfilingTaskQuery) ProtoMessage()

func (*EBPFProfilingTaskQuery) ProtoReflect 

func (x *EBPFProfilingTaskQuery) ProtoReflect() protoreflect.Message

func (*EBPFProfilingTaskQuery) Reset 

func (x *EBPFProfilingTaskQuery) Reset()

func (*EBPFProfilingTaskQuery) String 

func (x *EBPFProfilingTaskQuery) String() string

type UnimplementedContinuousProfilingServiceServer 

type UnimplementedContinuousProfilingServiceServer struct {
}

UnimplementedContinuousProfilingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContinuousProfilingServiceServer) QueryPolicies 

func (UnimplementedContinuousProfilingServiceServer) QueryPolicies(context.Context, *ContinuousProfilingPolicyQuery) (*v3.Commands, error)

func (UnimplementedContinuousProfilingServiceServer) ReportProfilingTask 

func (UnimplementedContinuousProfilingServiceServer) ReportProfilingTask(context.Context, *ContinuousProfilingReport) (*v3.Commands, error)

type UnimplementedEBPFProfilingServiceServer 

type UnimplementedEBPFProfilingServiceServer struct {
}

UnimplementedEBPFProfilingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEBPFProfilingServiceServer) CollectProfilingData 

func (UnimplementedEBPFProfilingServiceServer) CollectProfilingData(EBPFProfilingService_CollectProfilingDataServer) error

func (UnimplementedEBPFProfilingServiceServer) QueryTasks 

func (UnimplementedEBPFProfilingServiceServer) QueryTasks(context.Context, *EBPFProfilingTaskQuery) (*v3.Commands, error)

type UnsafeContinuousProfilingServiceServer 

type UnsafeContinuousProfilingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeContinuousProfilingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContinuousProfilingServiceServer will result in compilation errors.

type UnsafeEBPFProfilingServiceServer 

type UnsafeEBPFProfilingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeEBPFProfilingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EBPFProfilingServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.