process

package
v0.76.0-rc.3 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProcessEntityStream_StreamEntities_FullMethodName = "/datadog.process.ProcessEntityStream/StreamEntities"
)

Variables

View Source 
var File_datadog_process_process_proto protoreflect.FileDescriptor
View Source 
var File_datadog_process_workloadmeta_process_proto protoreflect.FileDescriptor
View Source 
var ProcessEntityStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "datadog.process.ProcessEntityStream",
	HandlerType: (*ProcessEntityStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamEntities",
			Handler:       _ProcessEntityStream_StreamEntities_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "datadog/process/workloadmeta_process.proto",
}

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

Functions

func RegisterProcessEntityStreamServer 

func RegisterProcessEntityStreamServer(s grpc.ServiceRegistrar, 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) (grpc.ServerStreamingClient[ProcessStreamResponse], error)
}

ProcessEntityStreamClient is the client API for ProcessEntityStream 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 NewProcessEntityStreamClient 

func NewProcessEntityStreamClient(cc grpc.ClientConnInterface) ProcessEntityStreamClient

type ProcessEntityStreamServer 

type ProcessEntityStreamServer interface {
	StreamEntities(*ProcessStreamEntitiesRequest, grpc.ServerStreamingServer[ProcessStreamResponse]) error
	// contains filtered or unexported methods
}

ProcessEntityStreamServer is the server API for ProcessEntityStream service. All implementations must embed UnimplementedProcessEntityStreamServer for forward compatibility.

type ProcessEntityStream_StreamEntitiesClient 

type ProcessEntityStream_StreamEntitiesClient = grpc.ServerStreamingClient[ProcessStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProcessEntityStream_StreamEntitiesServer 

type ProcessEntityStream_StreamEntitiesServer = grpc.ServerStreamingServer[ProcessStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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 must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedProcessEntityStreamServer) StreamEntities 

func (UnimplementedProcessEntityStreamServer) StreamEntities(*ProcessStreamEntitiesRequest, grpc.ServerStreamingServer[ProcessStreamResponse]) error

type UnsafeProcessEntityStreamServer 

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

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