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 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 (*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 (*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 (*EBPFKubernetesProcessDownstream) GetPid

func (*EBPFKubernetesProcessDownstream) ProtoMessage

func (*EBPFKubernetesProcessDownstream) ProtoMessage()

func (*EBPFKubernetesProcessDownstream) ProtoReflect

func (*EBPFKubernetesProcessDownstream) Reset

func (*EBPFKubernetesProcessDownstream) 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 (*EBPFKubernetesProcessMetadata) GetPid

func (*EBPFKubernetesProcessMetadata) GetProperties

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

func (*EBPFKubernetesProcessMetadata) ProtoMessage

func (*EBPFKubernetesProcessMetadata) ProtoMessage()

func (*EBPFKubernetesProcessMetadata) ProtoReflect

func (*EBPFKubernetesProcessMetadata) Reset

func (x *EBPFKubernetesProcessMetadata) Reset()

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

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

func (*EBPFReportProcessDownstream) ProtoMessage()

func (*EBPFReportProcessDownstream) ProtoReflect

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

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.

Jump to

Keyboard shortcuts

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