process

package
v0.48.0-rc.7 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2023 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 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 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 

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.