v3

package
v0.0.0-...-edee327 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 9 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EBPFProcessService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.EBPFProcessService",
	HandlerType: (*EBPFProcessServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "reportProcesses",
			Handler:    _EBPFProcessService_ReportProcesses_Handler,
		},
		{
			MethodName: "keepAlive",
			Handler:    _EBPFProcessService_KeepAlive_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ebpf/profiling/Process.proto",
}

EBPFProcessService_ServiceDesc is the grpc.ServiceDesc for EBPFProcessService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_ebpf_profiling_Process_proto protoreflect.FileDescriptor

Functions

func RegisterEBPFProcessServiceServer 

func RegisterEBPFProcessServiceServer(s grpc.ServiceRegistrar, srv EBPFProcessServiceServer)

Types

type EBPFHostProcessDownstream 

type EBPFHostProcessDownstream struct {
	Pid            int32                      `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	EntityMetadata *EBPFProcessEntityMetadata `protobuf:"bytes,2,opt,name=entityMetadata,proto3" json:"entityMetadata,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFHostProcessDownstream) Descriptor deprecated 

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

Deprecated: Use EBPFHostProcessDownstream.ProtoReflect.Descriptor instead.

func (*EBPFHostProcessDownstream) GetEntityMetadata 

func (x *EBPFHostProcessDownstream) GetEntityMetadata() *EBPFProcessEntityMetadata

func (*EBPFHostProcessDownstream) GetPid 

func (x *EBPFHostProcessDownstream) GetPid() int32

func (*EBPFHostProcessDownstream) ProtoMessage 

func (*EBPFHostProcessDownstream) ProtoMessage()

func (*EBPFHostProcessDownstream) ProtoReflect 

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

func (*EBPFHostProcessDownstream) Reset 

func (x *EBPFHostProcessDownstream) Reset()

func (*EBPFHostProcessDownstream) String 

func (x *EBPFHostProcessDownstream) String() string

type EBPFHostProcessMetadata 

type EBPFHostProcessMetadata struct {

	// [required] Entity metadata
	// Must ensure that entity information is unique at the time of reporting
	Entity *EBPFProcessEntityMetadata `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// [required] The Process id of the host
	Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// [optional] properties of the process
	Properties []*v3.KeyStringValuePair `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFHostProcessMetadata) Descriptor deprecated 

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

Deprecated: Use EBPFHostProcessMetadata.ProtoReflect.Descriptor instead.

func (*EBPFHostProcessMetadata) GetEntity 

func (x *EBPFHostProcessMetadata) GetEntity() *EBPFProcessEntityMetadata

func (*EBPFHostProcessMetadata) GetPid 

func (x *EBPFHostProcessMetadata) GetPid() int32

func (*EBPFHostProcessMetadata) GetProperties 

func (x *EBPFHostProcessMetadata) GetProperties() []*v3.KeyStringValuePair

func (*EBPFHostProcessMetadata) ProtoMessage 

func (*EBPFHostProcessMetadata) ProtoMessage()

func (*EBPFHostProcessMetadata) ProtoReflect 

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

func (*EBPFHostProcessMetadata) Reset 

func (x *EBPFHostProcessMetadata) Reset()

func (*EBPFHostProcessMetadata) String 

func (x *EBPFHostProcessMetadata) String() string

type EBPFKubernetesProcessDownstream 

type EBPFKubernetesProcessDownstream struct {
	Pid            int32                      `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	EntityMetadata *EBPFProcessEntityMetadata `protobuf:"bytes,2,opt,name=entityMetadata,proto3" json:"entityMetadata,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes process downstream

func (*EBPFKubernetesProcessDownstream) Descriptor deprecated 

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

Deprecated: Use EBPFKubernetesProcessDownstream.ProtoReflect.Descriptor instead.

func (*EBPFKubernetesProcessDownstream) GetEntityMetadata 

func (x *EBPFKubernetesProcessDownstream) GetEntityMetadata() *EBPFProcessEntityMetadata

func (*EBPFKubernetesProcessDownstream) GetPid 

func (x *EBPFKubernetesProcessDownstream) GetPid() int32

func (*EBPFKubernetesProcessDownstream) ProtoMessage 

func (*EBPFKubernetesProcessDownstream) ProtoMessage()

func (*EBPFKubernetesProcessDownstream) ProtoReflect 

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

func (*EBPFKubernetesProcessDownstream) Reset 

func (x *EBPFKubernetesProcessDownstream) Reset()

func (*EBPFKubernetesProcessDownstream) String 

func (x *EBPFKubernetesProcessDownstream) String() string

type EBPFKubernetesProcessMetadata 

type EBPFKubernetesProcessMetadata struct {

	// [required] Entity metadata
	// Must ensure that entity information is unique at the time of reporting
	Entity *EBPFProcessEntityMetadata `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// [required] The Process id of the host
	Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// [optional] properties of the process
	Properties []*v3.KeyStringValuePair `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes process metadata

func (*EBPFKubernetesProcessMetadata) Descriptor deprecated 

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

Deprecated: Use EBPFKubernetesProcessMetadata.ProtoReflect.Descriptor instead.

func (*EBPFKubernetesProcessMetadata) GetEntity 

func (x *EBPFKubernetesProcessMetadata) GetEntity() *EBPFProcessEntityMetadata

func (*EBPFKubernetesProcessMetadata) GetPid 

func (x *EBPFKubernetesProcessMetadata) GetPid() int32

func (*EBPFKubernetesProcessMetadata) GetProperties 

func (x *EBPFKubernetesProcessMetadata) GetProperties() []*v3.KeyStringValuePair

func (*EBPFKubernetesProcessMetadata) ProtoMessage 

func (*EBPFKubernetesProcessMetadata) ProtoMessage()

func (*EBPFKubernetesProcessMetadata) ProtoReflect 

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

func (*EBPFKubernetesProcessMetadata) Reset 

func (x *EBPFKubernetesProcessMetadata) Reset()

func (*EBPFKubernetesProcessMetadata) String 

func (x *EBPFKubernetesProcessMetadata) String() string

type EBPFProcessDownstream 

type EBPFProcessDownstream struct {

	// Generated process id
	ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"`
	// Locate the process by basic information
	//
	// Types that are assignable to Process:
	//
	//	*EBPFProcessDownstream_HostProcess
	//	*EBPFProcessDownstream_K8SProcess
	Process isEBPFProcessDownstream_Process `protobuf_oneof:"process"`
	// contains filtered or unexported fields
}

func (*EBPFProcessDownstream) Descriptor deprecated 

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

Deprecated: Use EBPFProcessDownstream.ProtoReflect.Descriptor instead.

func (*EBPFProcessDownstream) GetHostProcess 

func (x *EBPFProcessDownstream) GetHostProcess() *EBPFHostProcessDownstream

func (*EBPFProcessDownstream) GetK8SProcess 

func (x *EBPFProcessDownstream) GetK8SProcess() *EBPFKubernetesProcessDownstream

func (*EBPFProcessDownstream) GetProcess 

func (m *EBPFProcessDownstream) GetProcess() isEBPFProcessDownstream_Process

func (*EBPFProcessDownstream) GetProcessId 

func (x *EBPFProcessDownstream) GetProcessId() string

func (*EBPFProcessDownstream) ProtoMessage 

func (*EBPFProcessDownstream) ProtoMessage()

func (*EBPFProcessDownstream) ProtoReflect 

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

func (*EBPFProcessDownstream) Reset 

func (x *EBPFProcessDownstream) Reset()

func (*EBPFProcessDownstream) String 

func (x *EBPFProcessDownstream) String() string

type EBPFProcessDownstream_HostProcess 

type EBPFProcessDownstream_HostProcess struct {
	HostProcess *EBPFHostProcessDownstream `protobuf:"bytes,2,opt,name=hostProcess,proto3,oneof"`
}

type EBPFProcessDownstream_K8SProcess 

type EBPFProcessDownstream_K8SProcess struct {
	K8SProcess *EBPFKubernetesProcessDownstream `protobuf:"bytes,3,opt,name=k8sProcess,proto3,oneof"`
}

type EBPFProcessEntityMetadata 

type EBPFProcessEntityMetadata struct {

	// [required] Process belong layer name which define in the backend
	Layer string `protobuf:"bytes,1,opt,name=layer,proto3" json:"layer,omitempty"`
	// [required] Process belong service name
	ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	// [required] Process belong service instance name
	InstanceName string `protobuf:"bytes,3,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	// [required] Process name
	ProcessName string `protobuf:"bytes,4,opt,name=processName,proto3" json:"processName,omitempty"`
	// Process labels for aggregate from service
	Labels []string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

Process Entity metadata

func (*EBPFProcessEntityMetadata) Descriptor deprecated 

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

Deprecated: Use EBPFProcessEntityMetadata.ProtoReflect.Descriptor instead.

func (*EBPFProcessEntityMetadata) GetInstanceName 

func (x *EBPFProcessEntityMetadata) GetInstanceName() string

func (*EBPFProcessEntityMetadata) GetLabels 

func (x *EBPFProcessEntityMetadata) GetLabels() []string

func (*EBPFProcessEntityMetadata) GetLayer 

func (x *EBPFProcessEntityMetadata) GetLayer() string

func (*EBPFProcessEntityMetadata) GetProcessName 

func (x *EBPFProcessEntityMetadata) GetProcessName() string

func (*EBPFProcessEntityMetadata) GetServiceName 

func (x *EBPFProcessEntityMetadata) GetServiceName() string

func (*EBPFProcessEntityMetadata) ProtoMessage 

func (*EBPFProcessEntityMetadata) ProtoMessage()

func (*EBPFProcessEntityMetadata) ProtoReflect 

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

func (*EBPFProcessEntityMetadata) Reset 

func (x *EBPFProcessEntityMetadata) Reset()

func (*EBPFProcessEntityMetadata) String 

func (x *EBPFProcessEntityMetadata) String() string

type EBPFProcessPingPkg 

type EBPFProcessPingPkg struct {

	// Process entity
	EntityMetadata *EBPFProcessEntityMetadata `protobuf:"bytes,1,opt,name=entityMetadata,proto3" json:"entityMetadata,omitempty"`
	// Minimize necessary properties
	Properties []*v3.KeyStringValuePair `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProcessPingPkg) Descriptor deprecated 

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

Deprecated: Use EBPFProcessPingPkg.ProtoReflect.Descriptor instead.

func (*EBPFProcessPingPkg) GetEntityMetadata 

func (x *EBPFProcessPingPkg) GetEntityMetadata() *EBPFProcessEntityMetadata

func (*EBPFProcessPingPkg) GetProperties 

func (x *EBPFProcessPingPkg) GetProperties() []*v3.KeyStringValuePair

func (*EBPFProcessPingPkg) ProtoMessage 

func (*EBPFProcessPingPkg) ProtoMessage()

func (*EBPFProcessPingPkg) ProtoReflect 

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

func (*EBPFProcessPingPkg) Reset 

func (x *EBPFProcessPingPkg) Reset()

func (*EBPFProcessPingPkg) String 

func (x *EBPFProcessPingPkg) String() string

type EBPFProcessPingPkgList 

type EBPFProcessPingPkgList struct {
	Processes []*EBPFProcessPingPkg `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// An ID generated by eBPF agent, should be unique globally.
	EbpfAgentID string `protobuf:"bytes,2,opt,name=ebpfAgentID,proto3" json:"ebpfAgentID,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProcessPingPkgList) Descriptor deprecated 

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

Deprecated: Use EBPFProcessPingPkgList.ProtoReflect.Descriptor instead.

func (*EBPFProcessPingPkgList) GetEbpfAgentID 

func (x *EBPFProcessPingPkgList) GetEbpfAgentID() string

func (*EBPFProcessPingPkgList) GetProcesses 

func (x *EBPFProcessPingPkgList) GetProcesses() []*EBPFProcessPingPkg

func (*EBPFProcessPingPkgList) ProtoMessage 

func (*EBPFProcessPingPkgList) ProtoMessage()

func (*EBPFProcessPingPkgList) ProtoReflect 

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

func (*EBPFProcessPingPkgList) Reset 

func (x *EBPFProcessPingPkgList) Reset()

func (*EBPFProcessPingPkgList) String 

func (x *EBPFProcessPingPkgList) String() string

type EBPFProcessProperties 

type EBPFProcessProperties struct {

	// The Process metadata
	//
	// Types that are assignable to Metadata:
	//
	//	*EBPFProcessProperties_HostProcess
	//	*EBPFProcessProperties_K8SProcess
	Metadata isEBPFProcessProperties_Metadata `protobuf_oneof:"metadata"`
	// contains filtered or unexported fields
}

func (*EBPFProcessProperties) Descriptor deprecated 

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

Deprecated: Use EBPFProcessProperties.ProtoReflect.Descriptor instead.

func (*EBPFProcessProperties) GetHostProcess 

func (x *EBPFProcessProperties) GetHostProcess() *EBPFHostProcessMetadata

func (*EBPFProcessProperties) GetK8SProcess 

func (x *EBPFProcessProperties) GetK8SProcess() *EBPFKubernetesProcessMetadata

func (*EBPFProcessProperties) GetMetadata 

func (m *EBPFProcessProperties) GetMetadata() isEBPFProcessProperties_Metadata

func (*EBPFProcessProperties) ProtoMessage 

func (*EBPFProcessProperties) ProtoMessage()

func (*EBPFProcessProperties) ProtoReflect 

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

func (*EBPFProcessProperties) Reset 

func (x *EBPFProcessProperties) Reset()

func (*EBPFProcessProperties) String 

func (x *EBPFProcessProperties) String() string

type EBPFProcessProperties_HostProcess 

type EBPFProcessProperties_HostProcess struct {
	HostProcess *EBPFHostProcessMetadata `protobuf:"bytes,1,opt,name=hostProcess,proto3,oneof"`
}

type EBPFProcessProperties_K8SProcess 

type EBPFProcessProperties_K8SProcess struct {
	K8SProcess *EBPFKubernetesProcessMetadata `protobuf:"bytes,2,opt,name=k8sProcess,proto3,oneof"`
}

type EBPFProcessReportList 

type EBPFProcessReportList struct {
	Processes []*EBPFProcessProperties `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// An ID generated by eBPF agent, should be unique globally.
	EbpfAgentID string `protobuf:"bytes,2,opt,name=ebpfAgentID,proto3" json:"ebpfAgentID,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFProcessReportList) Descriptor deprecated 

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

Deprecated: Use EBPFProcessReportList.ProtoReflect.Descriptor instead.

func (*EBPFProcessReportList) GetEbpfAgentID 

func (x *EBPFProcessReportList) GetEbpfAgentID() string

func (*EBPFProcessReportList) GetProcesses 

func (x *EBPFProcessReportList) GetProcesses() []*EBPFProcessProperties

func (*EBPFProcessReportList) ProtoMessage 

func (*EBPFProcessReportList) ProtoMessage()

func (*EBPFProcessReportList) ProtoReflect 

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

func (*EBPFProcessReportList) Reset 

func (x *EBPFProcessReportList) Reset()

func (*EBPFProcessReportList) String 

func (x *EBPFProcessReportList) String() string

type EBPFProcessServiceClient 

type EBPFProcessServiceClient interface {
	// Report discovered process in Rover
	ReportProcesses(ctx context.Context, in *EBPFProcessReportList, opts ...grpc.CallOption) (*EBPFReportProcessDownstream, error)
	// Keep the process alive in the backend.
	KeepAlive(ctx context.Context, in *EBPFProcessPingPkgList, opts ...grpc.CallOption) (*v3.Commands, error)
}

EBPFProcessServiceClient is the client API for EBPFProcessService 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 NewEBPFProcessServiceClient 

func NewEBPFProcessServiceClient(cc grpc.ClientConnInterface) EBPFProcessServiceClient

type EBPFProcessServiceServer 

type EBPFProcessServiceServer interface {
	// Report discovered process in Rover
	ReportProcesses(context.Context, *EBPFProcessReportList) (*EBPFReportProcessDownstream, error)
	// Keep the process alive in the backend.
	KeepAlive(context.Context, *EBPFProcessPingPkgList) (*v3.Commands, error)
	// contains filtered or unexported methods
}

EBPFProcessServiceServer is the server API for EBPFProcessService service. All implementations must embed UnimplementedEBPFProcessServiceServer for forward compatibility

type EBPFReportProcessDownstream 

type EBPFReportProcessDownstream struct {
	Processes []*EBPFProcessDownstream `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*EBPFReportProcessDownstream) Descriptor deprecated 

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

Deprecated: Use EBPFReportProcessDownstream.ProtoReflect.Descriptor instead.

func (*EBPFReportProcessDownstream) GetProcesses 

func (x *EBPFReportProcessDownstream) GetProcesses() []*EBPFProcessDownstream

func (*EBPFReportProcessDownstream) ProtoMessage 

func (*EBPFReportProcessDownstream) ProtoMessage()

func (*EBPFReportProcessDownstream) ProtoReflect 

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

func (*EBPFReportProcessDownstream) Reset 

func (x *EBPFReportProcessDownstream) Reset()

func (*EBPFReportProcessDownstream) String 

func (x *EBPFReportProcessDownstream) String() string

type UnimplementedEBPFProcessServiceServer 

type UnimplementedEBPFProcessServiceServer struct {
}

UnimplementedEBPFProcessServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEBPFProcessServiceServer) KeepAlive 

func (UnimplementedEBPFProcessServiceServer) KeepAlive(context.Context, *EBPFProcessPingPkgList) (*v3.Commands, error)

func (UnimplementedEBPFProcessServiceServer) ReportProcesses 

func (UnimplementedEBPFProcessServiceServer) ReportProcesses(context.Context, *EBPFProcessReportList) (*EBPFReportProcessDownstream, error)

type UnsafeEBPFProcessServiceServer 

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

UnsafeEBPFProcessServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EBPFProcessServiceServer 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.