v3

package
v0.0.0-...-6cb6b35 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 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 (*ContinuousNetworkProfilingTask) Reset

func (x *ContinuousNetworkProfilingTask) Reset()

func (*ContinuousNetworkProfilingTask) 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 (*ContinuousOffCPUProfilingTask) Reset

func (x *ContinuousOffCPUProfilingTask) Reset()

func (*ContinuousOffCPUProfilingTask) 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 (*ContinuousOnCPUProfilingTask) Reset

func (x *ContinuousOnCPUProfilingTask) Reset()

func (*ContinuousOnCPUProfilingTask) 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 (*ContinuousProfilingCause) GetType

func (*ContinuousProfilingCause) GetUri

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) Enum

func (ContinuousProfilingCauseType) EnumDescriptor deprecated

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

Deprecated: Use ContinuousProfilingCauseType.Descriptor instead.

func (ContinuousProfilingCauseType) Number

func (ContinuousProfilingCauseType) String

func (ContinuousProfilingCauseType) Type

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 (*ContinuousProfilingPolicyQuery) ProtoMessage

func (*ContinuousProfilingPolicyQuery) ProtoMessage()

func (*ContinuousProfilingPolicyQuery) ProtoReflect

func (*ContinuousProfilingPolicyQuery) Reset

func (x *ContinuousProfilingPolicyQuery) Reset()

func (*ContinuousProfilingPolicyQuery) 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 (*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 (*ContinuousProfilingReport) GetOffCPU

func (*ContinuousProfilingReport) GetOnCPU

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 (*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.

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 (*ContinuousProfilingServicePolicyQuery) ProtoMessage

func (*ContinuousProfilingServicePolicyQuery) ProtoMessage()

func (*ContinuousProfilingServicePolicyQuery) ProtoReflect

func (*ContinuousProfilingServicePolicyQuery) Reset

func (*ContinuousProfilingServicePolicyQuery) 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 (*ContinuousProfilingSingleValueCause) GetThreshold

func (x *ContinuousProfilingSingleValueCause) GetThreshold() float64

func (*ContinuousProfilingSingleValueCause) ProtoMessage

func (*ContinuousProfilingSingleValueCause) ProtoMessage()

func (*ContinuousProfilingSingleValueCause) ProtoReflect

func (*ContinuousProfilingSingleValueCause) Reset

func (*ContinuousProfilingSingleValueCause) 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 (*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 (*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 (*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 (*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.

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 (*EBPFProfilingStackMetadata) ProtoMessage

func (*EBPFProfilingStackMetadata) ProtoMessage()

func (*EBPFProfilingStackMetadata) ProtoReflect

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) Enum

func (EBPFProfilingStackType) EnumDescriptor deprecated

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

Deprecated: Use EBPFProfilingStackType.Descriptor instead.

func (EBPFProfilingStackType) Number

func (EBPFProfilingStackType) String

func (x EBPFProfilingStackType) String() string

func (EBPFProfilingStackType) Type

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 (*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) ReportProfilingTask

type UnimplementedEBPFProfilingServiceServer

type UnimplementedEBPFProfilingServiceServer struct {
}

UnimplementedEBPFProfilingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEBPFProfilingServiceServer) CollectProfilingData

func (UnimplementedEBPFProfilingServiceServer) QueryTasks

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL