process

package
v0.60.0 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_datadog_process_process_proto protoreflect.FileDescriptor
View Source 
var File_datadog_process_workloadmeta_process_proto protoreflect.FileDescriptor

Functions

func RegisterProcessEntityStreamServer 

func RegisterProcessEntityStreamServer(s *grpc.Server, srv ProcessEntityStreamServer)

Types

type ContainerLanguageDetails added in v0.49.0 

type ContainerLanguageDetails struct {
	ContainerName string      `protobuf:"bytes,1,opt,name=containerName,proto3" json:"containerName,omitempty"`
	Languages     []*Language `protobuf:"bytes,2,rep,name=languages,proto3" json:"languages,omitempty"`
	// contains filtered or unexported fields
}

ContainerLanguageDetails contains the different languages used in a container

func (*ContainerLanguageDetails) Descriptor deprecated added in v0.49.0 

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

Deprecated: Use ContainerLanguageDetails.ProtoReflect.Descriptor instead.

func (*ContainerLanguageDetails) GetContainerName added in v0.49.0 

func (x *ContainerLanguageDetails) GetContainerName() string

func (*ContainerLanguageDetails) GetLanguages added in v0.49.0 

func (x *ContainerLanguageDetails) GetLanguages() []*Language

func (*ContainerLanguageDetails) ProtoMessage added in v0.49.0 

func (*ContainerLanguageDetails) ProtoMessage()

func (*ContainerLanguageDetails) ProtoReflect added in v0.49.0 

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

func (*ContainerLanguageDetails) Reset added in v0.49.0 

func (x *ContainerLanguageDetails) Reset()

func (*ContainerLanguageDetails) String added in v0.49.0 

func (x *ContainerLanguageDetails) String() string

type KubeOwnerInfo added in v0.49.0 

type KubeOwnerInfo struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Kind string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

KubeOwnerInfo holds metadata about the owner of the pod

func (*KubeOwnerInfo) Descriptor deprecated added in v0.49.0 

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

Deprecated: Use KubeOwnerInfo.ProtoReflect.Descriptor instead.

func (*KubeOwnerInfo) GetId added in v0.49.0 

func (x *KubeOwnerInfo) GetId() string

func (*KubeOwnerInfo) GetKind added in v0.49.0 

func (x *KubeOwnerInfo) GetKind() string

func (*KubeOwnerInfo) GetName added in v0.49.0 

func (x *KubeOwnerInfo) GetName() string

func (*KubeOwnerInfo) ProtoMessage added in v0.49.0 

func (*KubeOwnerInfo) ProtoMessage()

func (*KubeOwnerInfo) ProtoReflect added in v0.49.0 

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

func (*KubeOwnerInfo) Reset added in v0.49.0 

func (x *KubeOwnerInfo) Reset()

func (*KubeOwnerInfo) String added in v0.49.0 

func (x *KubeOwnerInfo) String() string

type Language 

type Language struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Language) Descriptor deprecated 

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

Deprecated: Use Language.ProtoReflect.Descriptor instead.

func (*Language) GetName 

func (x *Language) GetName() string

func (*Language) ProtoMessage 

func (*Language) ProtoMessage()

func (*Language) ProtoReflect 

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

func (*Language) Reset 

func (x *Language) Reset()

func (*Language) String 

func (x *Language) String() string

type ParentLanguageAnnotationRequest added in v0.49.0 

type ParentLanguageAnnotationRequest struct {
	PodDetails []*PodLanguageDetails `protobuf:"bytes,1,rep,name=podDetails,proto3" json:"podDetails,omitempty"`
	// contains filtered or unexported fields
}

ParentLanguageAnnotationRequest is sent from the Core-Agent to the Cluster-Agent to notify that a language was detected for a given container

func (*ParentLanguageAnnotationRequest) Descriptor deprecated added in v0.49.0 

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

Deprecated: Use ParentLanguageAnnotationRequest.ProtoReflect.Descriptor instead.

func (*ParentLanguageAnnotationRequest) GetPodDetails added in v0.49.0 

func (x *ParentLanguageAnnotationRequest) GetPodDetails() []*PodLanguageDetails

func (*ParentLanguageAnnotationRequest) ProtoMessage added in v0.49.0 

func (*ParentLanguageAnnotationRequest) ProtoMessage()

func (*ParentLanguageAnnotationRequest) ProtoReflect added in v0.49.0 

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

func (*ParentLanguageAnnotationRequest) Reset added in v0.49.0 

func (x *ParentLanguageAnnotationRequest) Reset()

func (*ParentLanguageAnnotationRequest) String added in v0.49.0 

func (x *ParentLanguageAnnotationRequest) String() string

type PodLanguageDetails added in v0.49.0 

type PodLanguageDetails struct {
	Namespace            string                      `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ContainerDetails     []*ContainerLanguageDetails `protobuf:"bytes,3,rep,name=containerDetails,proto3" json:"containerDetails,omitempty"`
	Ownerref             *KubeOwnerInfo              `protobuf:"bytes,4,opt,name=ownerref,proto3" json:"ownerref,omitempty"`
	InitContainerDetails []*ContainerLanguageDetails `protobuf:"bytes,5,rep,name=initContainerDetails,proto3" json:"initContainerDetails,omitempty"`
	// contains filtered or unexported fields
}

PodLanguageDetails holds the language metadata associated to a given pod

func (*PodLanguageDetails) Descriptor deprecated added in v0.49.0 

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

Deprecated: Use PodLanguageDetails.ProtoReflect.Descriptor instead.

func (*PodLanguageDetails) GetContainerDetails added in v0.49.0 

func (x *PodLanguageDetails) GetContainerDetails() []*ContainerLanguageDetails

func (*PodLanguageDetails) GetInitContainerDetails added in v0.49.0 

func (x *PodLanguageDetails) GetInitContainerDetails() []*ContainerLanguageDetails

func (*PodLanguageDetails) GetName added in v0.49.0 

func (x *PodLanguageDetails) GetName() string

func (*PodLanguageDetails) GetNamespace added in v0.49.0 

func (x *PodLanguageDetails) GetNamespace() string

func (*PodLanguageDetails) GetOwnerref added in v0.49.0 

func (x *PodLanguageDetails) GetOwnerref() *KubeOwnerInfo

func (*PodLanguageDetails) ProtoMessage added in v0.49.0 

func (*PodLanguageDetails) ProtoMessage()

func (*PodLanguageDetails) ProtoReflect added in v0.49.0 

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

func (*PodLanguageDetails) Reset added in v0.49.0 

func (x *PodLanguageDetails) Reset()

func (*PodLanguageDetails) String added in v0.49.0 

func (x *PodLanguageDetails) String() string

type ProcessEntityStreamClient 

type ProcessEntityStreamClient interface {
	StreamEntities(ctx context.Context, in *ProcessStreamEntitiesRequest, opts ...grpc.CallOption) (ProcessEntityStream_StreamEntitiesClient, error)
}

ProcessEntityStreamClient is the client API for ProcessEntityStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProcessEntityStreamClient 

func NewProcessEntityStreamClient(cc grpc.ClientConnInterface) ProcessEntityStreamClient

type ProcessEntityStreamServer 

type ProcessEntityStreamServer interface {
	StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error
}

ProcessEntityStreamServer is the server API for ProcessEntityStream service.

type ProcessEntityStream_StreamEntitiesClient 

type ProcessEntityStream_StreamEntitiesClient interface {
	Recv() (*ProcessStreamResponse, error)
	grpc.ClientStream
}

type ProcessEntityStream_StreamEntitiesServer 

type ProcessEntityStream_StreamEntitiesServer interface {
	Send(*ProcessStreamResponse) error
	grpc.ServerStream
}

type ProcessEventSet 

type ProcessEventSet struct {
	Pid          int32     `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Nspid        int32     `protobuf:"varint,2,opt,name=nspid,proto3" json:"nspid,omitempty"`
	ContainerID  string    `protobuf:"bytes,3,opt,name=containerID,proto3" json:"containerID,omitempty"`
	CreationTime int64     `protobuf:"varint,4,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	Language     *Language `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessEventSet) Descriptor deprecated 

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

Deprecated: Use ProcessEventSet.ProtoReflect.Descriptor instead.

func (*ProcessEventSet) GetContainerID added in v0.51.0 

func (x *ProcessEventSet) GetContainerID() string

func (*ProcessEventSet) GetCreationTime 

func (x *ProcessEventSet) GetCreationTime() int64

func (*ProcessEventSet) GetLanguage 

func (x *ProcessEventSet) GetLanguage() *Language

func (*ProcessEventSet) GetNspid 

func (x *ProcessEventSet) GetNspid() int32

func (*ProcessEventSet) GetPid 

func (x *ProcessEventSet) GetPid() int32

func (*ProcessEventSet) ProtoMessage 

func (*ProcessEventSet) ProtoMessage()

func (*ProcessEventSet) ProtoReflect 

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

func (*ProcessEventSet) Reset 

func (x *ProcessEventSet) Reset()

func (*ProcessEventSet) String 

func (x *ProcessEventSet) String() string

type ProcessEventUnset 

type ProcessEventUnset struct {
	Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessEventUnset) Descriptor deprecated 

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

Deprecated: Use ProcessEventUnset.ProtoReflect.Descriptor instead.

func (*ProcessEventUnset) GetPid 

func (x *ProcessEventUnset) GetPid() int32

func (*ProcessEventUnset) ProtoMessage 

func (*ProcessEventUnset) ProtoMessage()

func (*ProcessEventUnset) ProtoReflect 

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

func (*ProcessEventUnset) Reset 

func (x *ProcessEventUnset) Reset()

func (*ProcessEventUnset) String 

func (x *ProcessEventUnset) String() string

type ProcessStatRequest 

type ProcessStatRequest struct {
	Pids []int32 `protobuf:"varint,1,rep,packed,name=pids,proto3" json:"pids,omitempty"`
	// contains filtered or unexported fields
}

ProcessStatRequest is the request to get process stats.

func (*ProcessStatRequest) Descriptor deprecated 

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

Deprecated: Use ProcessStatRequest.ProtoReflect.Descriptor instead.

func (*ProcessStatRequest) GetPids 

func (x *ProcessStatRequest) GetPids() []int32

func (*ProcessStatRequest) ProtoMessage 

func (*ProcessStatRequest) ProtoMessage()

func (*ProcessStatRequest) ProtoReflect 

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

func (*ProcessStatRequest) Reset 

func (x *ProcessStatRequest) Reset()

func (*ProcessStatRequest) String 

func (x *ProcessStatRequest) String() string

type ProcessStreamEntitiesRequest 

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

func (*ProcessStreamEntitiesRequest) Descriptor deprecated 

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

Deprecated: Use ProcessStreamEntitiesRequest.ProtoReflect.Descriptor instead.

func (*ProcessStreamEntitiesRequest) ProtoMessage 

func (*ProcessStreamEntitiesRequest) ProtoMessage()

func (*ProcessStreamEntitiesRequest) ProtoReflect 

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

func (*ProcessStreamEntitiesRequest) Reset 

func (x *ProcessStreamEntitiesRequest) Reset()

func (*ProcessStreamEntitiesRequest) String 

func (x *ProcessStreamEntitiesRequest) String() string

type ProcessStreamResponse 

type ProcessStreamResponse struct {
	EventID     int32                `protobuf:"varint,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	SetEvents   []*ProcessEventSet   `protobuf:"bytes,2,rep,name=setEvents,proto3" json:"setEvents,omitempty"`
	UnsetEvents []*ProcessEventUnset `protobuf:"bytes,3,rep,name=unsetEvents,proto3" json:"unsetEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessStreamResponse) Descriptor deprecated 

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

Deprecated: Use ProcessStreamResponse.ProtoReflect.Descriptor instead.

func (*ProcessStreamResponse) GetEventID 

func (x *ProcessStreamResponse) GetEventID() int32

func (*ProcessStreamResponse) GetSetEvents 

func (x *ProcessStreamResponse) GetSetEvents() []*ProcessEventSet

func (*ProcessStreamResponse) GetUnsetEvents 

func (x *ProcessStreamResponse) GetUnsetEvents() []*ProcessEventUnset

func (*ProcessStreamResponse) ProtoMessage 

func (*ProcessStreamResponse) ProtoMessage()

func (*ProcessStreamResponse) ProtoReflect 

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

func (*ProcessStreamResponse) Reset 

func (x *ProcessStreamResponse) Reset()

func (*ProcessStreamResponse) String 

func (x *ProcessStreamResponse) String() string

type UnimplementedProcessEntityStreamServer 

type UnimplementedProcessEntityStreamServer struct {
}

UnimplementedProcessEntityStreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessEntityStreamServer) StreamEntities 

func (*UnimplementedProcessEntityStreamServer) StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error

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.