Documentation ¶
Overview ¶
Package pbgo is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAgentHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAgentHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentClient) error
- func RegisterAgentHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAgentHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentServer) error
- func RegisterAgentSecureHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAgentSecureHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentSecureClient) error
- func RegisterAgentSecureHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAgentSecureHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentSecureServer) error
- func RegisterAgentSecureServer(s *grpc.Server, srv AgentSecureServer)
- func RegisterAgentServer(s *grpc.Server, srv AgentServer)
- func RegisterProcessEntityStreamServer(s *grpc.Server, srv ProcessEntityStreamServer)
- type AgentClient
- type AgentSecureClient
- type AgentSecureServer
- type AgentSecure_TaggerStreamEntitiesClient
- type AgentSecure_TaggerStreamEntitiesServer
- type AgentSecure_WorkloadmetaStreamEntitiesClient
- type AgentSecure_WorkloadmetaStreamEntitiesServer
- type AgentServer
- type CaptureTriggerRequest
- func (*CaptureTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureTriggerRequest) GetCompressed() bool
- func (x *CaptureTriggerRequest) GetDuration() string
- func (x *CaptureTriggerRequest) GetPath() string
- func (*CaptureTriggerRequest) ProtoMessage()
- func (x *CaptureTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *CaptureTriggerRequest) Reset()
- func (x *CaptureTriggerRequest) String() string
- type CaptureTriggerResponse
- func (*CaptureTriggerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureTriggerResponse) GetPath() string
- func (*CaptureTriggerResponse) ProtoMessage()
- func (x *CaptureTriggerResponse) ProtoReflect() protoreflect.Message
- func (x *CaptureTriggerResponse) Reset()
- func (x *CaptureTriggerResponse) String() string
- type Client
- func (*Client) Descriptor() ([]byte, []int)deprecated
- func (x *Client) GetCapabilities() []byte
- func (x *Client) GetClientAgent() *ClientAgent
- func (x *Client) GetClientTracer() *ClientTracer
- func (x *Client) GetId() string
- func (x *Client) GetIsAgent() bool
- func (x *Client) GetIsTracer() bool
- func (x *Client) GetLastSeen() uint64
- func (x *Client) GetProducts() []string
- func (x *Client) GetState() *ClientState
- func (*Client) ProtoMessage()
- func (x *Client) ProtoReflect() protoreflect.Message
- func (x *Client) Reset()
- func (x *Client) String() string
- type ClientAgent
- func (*ClientAgent) Descriptor() ([]byte, []int)deprecated
- func (x *ClientAgent) GetClusterId() string
- func (x *ClientAgent) GetClusterName() string
- func (x *ClientAgent) GetCwsWorkloads() []string
- func (x *ClientAgent) GetName() string
- func (x *ClientAgent) GetVersion() string
- func (*ClientAgent) ProtoMessage()
- func (x *ClientAgent) ProtoReflect() protoreflect.Message
- func (x *ClientAgent) Reset()
- func (x *ClientAgent) String() string
- type ClientGetConfigsRequest
- func (*ClientGetConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClientGetConfigsRequest) GetCachedTargetFiles() []*TargetFileMeta
- func (x *ClientGetConfigsRequest) GetClient() *Client
- func (*ClientGetConfigsRequest) ProtoMessage()
- func (x *ClientGetConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *ClientGetConfigsRequest) Reset()
- func (x *ClientGetConfigsRequest) String() string
- type ClientGetConfigsResponse
- func (*ClientGetConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClientGetConfigsResponse) GetClientConfigs() []string
- func (x *ClientGetConfigsResponse) GetRoots() [][]byte
- func (x *ClientGetConfigsResponse) GetTargetFiles() []*File
- func (x *ClientGetConfigsResponse) GetTargets() []byte
- func (*ClientGetConfigsResponse) ProtoMessage()
- func (x *ClientGetConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *ClientGetConfigsResponse) Reset()
- func (x *ClientGetConfigsResponse) String() string
- type ClientState
- func (*ClientState) Descriptor() ([]byte, []int)deprecated
- func (x *ClientState) GetBackendClientState() []byte
- func (x *ClientState) GetConfigStates() []*ConfigState
- func (x *ClientState) GetError() string
- func (x *ClientState) GetHasError() bool
- func (x *ClientState) GetRootVersion() uint64
- func (x *ClientState) GetTargetsVersion() uint64
- func (*ClientState) ProtoMessage()
- func (x *ClientState) ProtoReflect() protoreflect.Message
- func (x *ClientState) Reset()
- func (x *ClientState) String() string
- type ClientTracer
- func (*ClientTracer) Descriptor() ([]byte, []int)deprecated
- func (x *ClientTracer) GetAppVersion() string
- func (x *ClientTracer) GetEnv() string
- func (x *ClientTracer) GetExtraServices() []string
- func (x *ClientTracer) GetLanguage() string
- func (x *ClientTracer) GetRuntimeId() string
- func (x *ClientTracer) GetService() string
- func (x *ClientTracer) GetTags() []string
- func (x *ClientTracer) GetTracerVersion() string
- func (*ClientTracer) ProtoMessage()
- func (x *ClientTracer) ProtoReflect() protoreflect.Message
- func (x *ClientTracer) Reset()
- func (x *ClientTracer) String() string
- type ConfigMetas
- func (*ConfigMetas) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigMetas) GetDelegatedTargets() []*DelegatedMeta
- func (x *ConfigMetas) GetRoots() []*TopMeta
- func (x *ConfigMetas) GetSnapshot() *TopMeta
- func (x *ConfigMetas) GetTimestamp() *TopMeta
- func (x *ConfigMetas) GetTopTargets() *TopMeta
- func (*ConfigMetas) ProtoMessage()
- func (x *ConfigMetas) ProtoReflect() protoreflect.Message
- func (x *ConfigMetas) Reset()
- func (x *ConfigMetas) String() string
- type ConfigState
- func (*ConfigState) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigState) GetApplyError() string
- func (x *ConfigState) GetApplyState() uint64
- func (x *ConfigState) GetId() string
- func (x *ConfigState) GetProduct() string
- func (x *ConfigState) GetVersion() uint64
- func (*ConfigState) ProtoMessage()
- func (x *ConfigState) ProtoReflect() protoreflect.Message
- func (x *ConfigState) Reset()
- func (x *ConfigState) String() string
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- func (x *Container) GetCollectorTags() []string
- func (x *Container) GetEntityId() *WorkloadmetaEntityId
- func (x *Container) GetEntityMeta() *EntityMeta
- func (x *Container) GetEnvVars() map[string]string
- func (x *Container) GetHostname() string
- func (x *Container) GetImage() *ContainerImage
- func (x *Container) GetNetworkIps() map[string]string
- func (x *Container) GetPid() int32
- func (x *Container) GetPorts() []*ContainerPort
- func (x *Container) GetRuntime() Runtime
- func (x *Container) GetState() *ContainerState
- func (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (x *Container) String() string
- type ContainerHealth
- func (ContainerHealth) Descriptor() protoreflect.EnumDescriptor
- func (x ContainerHealth) Enum() *ContainerHealth
- func (ContainerHealth) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContainerHealth) Number() protoreflect.EnumNumber
- func (x ContainerHealth) String() string
- func (ContainerHealth) Type() protoreflect.EnumType
- type ContainerImage
- func (*ContainerImage) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerImage) GetId() string
- func (x *ContainerImage) GetName() string
- func (x *ContainerImage) GetRawName() string
- func (x *ContainerImage) GetShortName() string
- func (x *ContainerImage) GetTag() string
- func (*ContainerImage) ProtoMessage()
- func (x *ContainerImage) ProtoReflect() protoreflect.Message
- func (x *ContainerImage) Reset()
- func (x *ContainerImage) String() string
- type ContainerPort
- func (*ContainerPort) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerPort) GetName() string
- func (x *ContainerPort) GetPort() int32
- func (x *ContainerPort) GetProtocol() string
- func (*ContainerPort) ProtoMessage()
- func (x *ContainerPort) ProtoReflect() protoreflect.Message
- func (x *ContainerPort) Reset()
- func (x *ContainerPort) String() string
- type ContainerState
- func (*ContainerState) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerState) GetCreatedAt() int64
- func (x *ContainerState) GetExitCode() uint32
- func (x *ContainerState) GetFinishedAt() int64
- func (x *ContainerState) GetHealth() ContainerHealth
- func (x *ContainerState) GetRunning() bool
- func (x *ContainerState) GetStartedAt() int64
- func (x *ContainerState) GetStatus() ContainerStatus
- func (*ContainerState) ProtoMessage()
- func (x *ContainerState) ProtoReflect() protoreflect.Message
- func (x *ContainerState) Reset()
- func (x *ContainerState) String() string
- type ContainerStatus
- func (ContainerStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ContainerStatus) Enum() *ContainerStatus
- func (ContainerStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContainerStatus) Number() protoreflect.EnumNumber
- func (x ContainerStatus) String() string
- func (ContainerStatus) Type() protoreflect.EnumType
- type DelegatedMeta
- func (*DelegatedMeta) Descriptor() ([]byte, []int)deprecated
- func (x *DelegatedMeta) GetRaw() []byte
- func (x *DelegatedMeta) GetRole() string
- func (x *DelegatedMeta) GetVersion() uint64
- func (*DelegatedMeta) ProtoMessage()
- func (x *DelegatedMeta) ProtoReflect() protoreflect.Message
- func (x *DelegatedMeta) Reset()
- func (x *DelegatedMeta) String() string
- type DirectorMetas
- func (*DirectorMetas) Descriptor() ([]byte, []int)deprecated
- func (x *DirectorMetas) GetRoots() []*TopMeta
- func (x *DirectorMetas) GetSnapshot() *TopMeta
- func (x *DirectorMetas) GetTargets() *TopMeta
- func (x *DirectorMetas) GetTimestamp() *TopMeta
- func (*DirectorMetas) ProtoMessage()
- func (x *DirectorMetas) ProtoReflect() protoreflect.Message
- func (x *DirectorMetas) Reset()
- func (x *DirectorMetas) String() string
- type ECSLaunchType
- func (ECSLaunchType) Descriptor() protoreflect.EnumDescriptor
- func (x ECSLaunchType) Enum() *ECSLaunchType
- func (ECSLaunchType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ECSLaunchType) Number() protoreflect.EnumNumber
- func (x ECSLaunchType) String() string
- func (ECSLaunchType) Type() protoreflect.EnumType
- type ECSTask
- func (*ECSTask) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTask) GetAvailabilityZone() string
- func (x *ECSTask) GetClusterName() string
- func (x *ECSTask) GetContainerInstanceTags() map[string]string
- func (x *ECSTask) GetContainers() []*OrchestratorContainer
- func (x *ECSTask) GetEntityId() *WorkloadmetaEntityId
- func (x *ECSTask) GetEntityMeta() *EntityMeta
- func (x *ECSTask) GetFamily() string
- func (x *ECSTask) GetLaunchType() ECSLaunchType
- func (x *ECSTask) GetRegion() string
- func (x *ECSTask) GetTags() map[string]string
- func (x *ECSTask) GetVersion() string
- func (*ECSTask) ProtoMessage()
- func (x *ECSTask) ProtoReflect() protoreflect.Message
- func (x *ECSTask) Reset()
- func (x *ECSTask) String() string
- type Entity
- func (*Entity) Descriptor() ([]byte, []int)deprecated
- func (x *Entity) GetHash() string
- func (x *Entity) GetHighCardinalityTags() []string
- func (x *Entity) GetId() *EntityId
- func (x *Entity) GetLowCardinalityTags() []string
- func (x *Entity) GetOrchestratorCardinalityTags() []string
- func (x *Entity) GetStandardTags() []string
- func (*Entity) ProtoMessage()
- func (x *Entity) ProtoReflect() protoreflect.Message
- func (x *Entity) Reset()
- func (x *Entity) String() string
- type EntityId
- type EntityMeta
- func (*EntityMeta) Descriptor() ([]byte, []int)deprecated
- func (x *EntityMeta) GetAnnotations() map[string]string
- func (x *EntityMeta) GetLabels() map[string]string
- func (x *EntityMeta) GetName() string
- func (x *EntityMeta) GetNamespace() string
- func (*EntityMeta) ProtoMessage()
- func (x *EntityMeta) ProtoReflect() protoreflect.Message
- func (x *EntityMeta) Reset()
- func (x *EntityMeta) String() string
- type EventType
- type FetchEntityRequest
- func (*FetchEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEntityRequest) GetCardinality() TagCardinality
- func (x *FetchEntityRequest) GetId() *EntityId
- func (*FetchEntityRequest) ProtoMessage()
- func (x *FetchEntityRequest) ProtoReflect() protoreflect.Message
- func (x *FetchEntityRequest) Reset()
- func (x *FetchEntityRequest) String() string
- type FetchEntityResponse
- func (*FetchEntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEntityResponse) GetCardinality() TagCardinality
- func (x *FetchEntityResponse) GetId() *EntityId
- func (x *FetchEntityResponse) GetTags() []string
- func (*FetchEntityResponse) ProtoMessage()
- func (x *FetchEntityResponse) ProtoReflect() protoreflect.Message
- func (x *FetchEntityResponse) Reset()
- func (x *FetchEntityResponse) String() string
- type File
- type FileMetaState
- func (*FileMetaState) Descriptor() ([]byte, []int)deprecated
- func (x *FileMetaState) GetHash() string
- func (x *FileMetaState) GetVersion() uint64
- func (*FileMetaState) ProtoMessage()
- func (x *FileMetaState) ProtoReflect() protoreflect.Message
- func (x *FileMetaState) Reset()
- func (x *FileMetaState) String() string
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetContainerName() string
- func (x *Filter) GetImage() string
- func (x *Filter) GetKubeNamespace() string
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type GetStateConfigResponse
- func (*GetStateConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateConfigResponse) GetActiveClients() []*Client
- func (x *GetStateConfigResponse) GetConfigState() map[string]*FileMetaState
- func (x *GetStateConfigResponse) GetDirectorState() map[string]*FileMetaState
- func (x *GetStateConfigResponse) GetTargetFilenames() map[string]string
- func (*GetStateConfigResponse) ProtoMessage()
- func (x *GetStateConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetStateConfigResponse) Reset()
- func (x *GetStateConfigResponse) String() string
- type HostnameReply
- type HostnameRequest
- type KubernetesPod
- func (*KubernetesPod) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesPod) GetContainers() []*OrchestratorContainer
- func (x *KubernetesPod) GetEntityId() *WorkloadmetaEntityId
- func (x *KubernetesPod) GetEntityMeta() *EntityMeta
- func (x *KubernetesPod) GetIp() string
- func (x *KubernetesPod) GetKubeServices() []string
- func (x *KubernetesPod) GetNamespaceLabels() map[string]string
- func (x *KubernetesPod) GetOwners() []*KubernetesPodOwner
- func (x *KubernetesPod) GetPersistentVolumeClaimNames() []string
- func (x *KubernetesPod) GetPhase() string
- func (x *KubernetesPod) GetPriorityClass() string
- func (x *KubernetesPod) GetQosClass() string
- func (x *KubernetesPod) GetReady() bool
- func (*KubernetesPod) ProtoMessage()
- func (x *KubernetesPod) ProtoReflect() protoreflect.Message
- func (x *KubernetesPod) Reset()
- func (x *KubernetesPod) String() string
- type KubernetesPodOwner
- func (*KubernetesPodOwner) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesPodOwner) GetId() string
- func (x *KubernetesPodOwner) GetKind() string
- func (x *KubernetesPodOwner) GetName() string
- func (*KubernetesPodOwner) ProtoMessage()
- func (x *KubernetesPodOwner) ProtoReflect() protoreflect.Message
- func (x *KubernetesPodOwner) Reset()
- func (x *KubernetesPodOwner) String() string
- type Language
- type LatestConfigsRequest
- func (*LatestConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LatestConfigsRequest) GetActiveClients() []*Client
- func (x *LatestConfigsRequest) GetAgentVersion() string
- func (x *LatestConfigsRequest) GetBackendClientState() []byte
- func (x *LatestConfigsRequest) GetCurrentConfigRootVersion() uint64
- func (x *LatestConfigsRequest) GetCurrentConfigSnapshotVersion() uint64
- func (x *LatestConfigsRequest) GetCurrentDirectorRootVersion() uint64
- func (x *LatestConfigsRequest) GetError() string
- func (x *LatestConfigsRequest) GetHasError() bool
- func (x *LatestConfigsRequest) GetHostname() string
- func (x *LatestConfigsRequest) GetNewProducts() []string
- func (x *LatestConfigsRequest) GetOrgUuid() string
- func (x *LatestConfigsRequest) GetProducts() []string
- func (x *LatestConfigsRequest) GetTraceAgentEnv() string
- func (*LatestConfigsRequest) ProtoMessage()
- func (x *LatestConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *LatestConfigsRequest) Reset()
- func (x *LatestConfigsRequest) String() string
- type LatestConfigsResponse
- func (*LatestConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LatestConfigsResponse) GetConfigMetas() *ConfigMetas
- func (x *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas
- func (x *LatestConfigsResponse) GetTargetFiles() []*File
- func (*LatestConfigsResponse) ProtoMessage()
- func (x *LatestConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *LatestConfigsResponse) Reset()
- func (x *LatestConfigsResponse) String() string
- type OrchestratorContainer
- func (*OrchestratorContainer) Descriptor() ([]byte, []int)deprecated
- func (x *OrchestratorContainer) GetId() string
- func (x *OrchestratorContainer) GetImage() *ContainerImage
- func (x *OrchestratorContainer) GetName() string
- func (*OrchestratorContainer) ProtoMessage()
- func (x *OrchestratorContainer) ProtoReflect() protoreflect.Message
- func (x *OrchestratorContainer) Reset()
- func (x *OrchestratorContainer) String() string
- type OrgDataResponse
- type OrgStatusResponse
- func (*OrgStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OrgStatusResponse) GetAuthorized() bool
- func (x *OrgStatusResponse) GetEnabled() bool
- func (*OrgStatusResponse) ProtoMessage()
- func (x *OrgStatusResponse) ProtoReflect() protoreflect.Message
- func (x *OrgStatusResponse) Reset()
- func (x *OrgStatusResponse) String() string
- type ProcessEntityStreamClient
- type ProcessEntityStreamServer
- type ProcessEntityStream_StreamEntitiesClient
- type ProcessEntityStream_StreamEntitiesServer
- type ProcessEventSet
- func (*ProcessEventSet) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessEventSet) GetContainerId() string
- func (x *ProcessEventSet) GetCreationTime() int64
- func (x *ProcessEventSet) GetLanguage() *Language
- func (x *ProcessEventSet) GetNspid() int32
- func (x *ProcessEventSet) GetPid() int32
- func (*ProcessEventSet) ProtoMessage()
- func (x *ProcessEventSet) ProtoReflect() protoreflect.Message
- func (x *ProcessEventSet) Reset()
- func (x *ProcessEventSet) String() string
- type ProcessEventUnset
- type ProcessStatRequest
- func (*ProcessStatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessStatRequest) GetPids() []int32
- func (*ProcessStatRequest) ProtoMessage()
- func (x *ProcessStatRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessStatRequest) Reset()
- func (x *ProcessStatRequest) String() string
- type ProcessStreamEntitiesRequest
- func (*ProcessStreamEntitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (*ProcessStreamEntitiesRequest) ProtoMessage()
- func (x *ProcessStreamEntitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessStreamEntitiesRequest) Reset()
- func (x *ProcessStreamEntitiesRequest) String() string
- type ProcessStreamResponse
- func (*ProcessStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessStreamResponse) GetEventID() int32
- func (x *ProcessStreamResponse) GetSetEvents() []*ProcessEventSet
- func (x *ProcessStreamResponse) GetUnsetEvents() []*ProcessEventUnset
- func (*ProcessStreamResponse) ProtoMessage()
- func (x *ProcessStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ProcessStreamResponse) Reset()
- func (x *ProcessStreamResponse) String() string
- type Runtime
- type StreamTagsEvent
- func (*StreamTagsEvent) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTagsEvent) GetEntity() *Entity
- func (x *StreamTagsEvent) GetType() EventType
- func (*StreamTagsEvent) ProtoMessage()
- func (x *StreamTagsEvent) ProtoReflect() protoreflect.Message
- func (x *StreamTagsEvent) Reset()
- func (x *StreamTagsEvent) String() string
- type StreamTagsRequest
- func (*StreamTagsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTagsRequest) GetCardinality() TagCardinality
- func (x *StreamTagsRequest) GetExcludeFilter() *Filter
- func (x *StreamTagsRequest) GetIncludeFilter() *Filter
- func (*StreamTagsRequest) ProtoMessage()
- func (x *StreamTagsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamTagsRequest) Reset()
- func (x *StreamTagsRequest) String() string
- type StreamTagsResponse
- func (*StreamTagsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTagsResponse) GetEvents() []*StreamTagsEvent
- func (*StreamTagsResponse) ProtoMessage()
- func (x *StreamTagsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamTagsResponse) Reset()
- func (x *StreamTagsResponse) String() string
- type TagCardinality
- func (TagCardinality) Descriptor() protoreflect.EnumDescriptor
- func (x TagCardinality) Enum() *TagCardinality
- func (TagCardinality) EnumDescriptor() ([]byte, []int)deprecated
- func (x TagCardinality) Number() protoreflect.EnumNumber
- func (x TagCardinality) String() string
- func (TagCardinality) Type() protoreflect.EnumType
- type TaggerState
- func (*TaggerState) Descriptor() ([]byte, []int)deprecated
- func (x *TaggerState) GetPidMap() map[int32]string
- func (x *TaggerState) GetState() map[string]*Entity
- func (*TaggerState) ProtoMessage()
- func (x *TaggerState) ProtoReflect() protoreflect.Message
- func (x *TaggerState) Reset()
- func (x *TaggerState) String() string
- type TaggerStateResponse
- func (*TaggerStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaggerStateResponse) GetLoaded() bool
- func (*TaggerStateResponse) ProtoMessage()
- func (x *TaggerStateResponse) ProtoReflect() protoreflect.Message
- func (x *TaggerStateResponse) Reset()
- func (x *TaggerStateResponse) String() string
- type TargetFileHash
- func (*TargetFileHash) Descriptor() ([]byte, []int)deprecated
- func (x *TargetFileHash) GetAlgorithm() string
- func (x *TargetFileHash) GetHash() string
- func (*TargetFileHash) ProtoMessage()
- func (x *TargetFileHash) ProtoReflect() protoreflect.Message
- func (x *TargetFileHash) Reset()
- func (x *TargetFileHash) String() string
- type TargetFileMeta
- func (*TargetFileMeta) Descriptor() ([]byte, []int)deprecated
- func (x *TargetFileMeta) GetHashes() []*TargetFileHash
- func (x *TargetFileMeta) GetLength() int64
- func (x *TargetFileMeta) GetPath() string
- func (*TargetFileMeta) ProtoMessage()
- func (x *TargetFileMeta) ProtoReflect() protoreflect.Message
- func (x *TargetFileMeta) Reset()
- func (x *TargetFileMeta) String() string
- type TopMeta
- type TracerPredicateV1
- func (*TracerPredicateV1) Descriptor() ([]byte, []int)deprecated
- func (x *TracerPredicateV1) GetAppVersion() string
- func (x *TracerPredicateV1) GetClientID() string
- func (x *TracerPredicateV1) GetEnvironment() string
- func (x *TracerPredicateV1) GetLanguage() string
- func (x *TracerPredicateV1) GetRuntimeID() string
- func (x *TracerPredicateV1) GetService() string
- func (x *TracerPredicateV1) GetTracerVersion() string
- func (*TracerPredicateV1) ProtoMessage()
- func (x *TracerPredicateV1) ProtoReflect() protoreflect.Message
- func (x *TracerPredicateV1) Reset()
- func (x *TracerPredicateV1) String() string
- type TracerPredicates
- func (*TracerPredicates) Descriptor() ([]byte, []int)deprecated
- func (x *TracerPredicates) GetTracerPredicatesV1() []*TracerPredicateV1
- func (*TracerPredicates) ProtoMessage()
- func (x *TracerPredicates) ProtoReflect() protoreflect.Message
- func (x *TracerPredicates) Reset()
- func (x *TracerPredicates) String() string
- type UnimplementedAgentSecureServer
- func (*UnimplementedAgentSecureServer) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
- func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)
- func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)
- func (*UnimplementedAgentSecureServer) GetConfigState(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
- func (*UnimplementedAgentSecureServer) TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
- func (*UnimplementedAgentSecureServer) TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error
- func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, AgentSecure_WorkloadmetaStreamEntitiesServer) error
- type UnimplementedAgentServer
- type UnimplementedProcessEntityStreamServer
- type UnixDogstatsdMsg
- func (*UnixDogstatsdMsg) Descriptor() ([]byte, []int)deprecated
- func (x *UnixDogstatsdMsg) GetAncillary() []byte
- func (x *UnixDogstatsdMsg) GetAncillarySize() int32
- func (x *UnixDogstatsdMsg) GetPayload() []byte
- func (x *UnixDogstatsdMsg) GetPayloadSize() int32
- func (x *UnixDogstatsdMsg) GetPid() int32
- func (x *UnixDogstatsdMsg) GetTimestamp() int64
- func (*UnixDogstatsdMsg) ProtoMessage()
- func (x *UnixDogstatsdMsg) ProtoReflect() protoreflect.Message
- func (x *UnixDogstatsdMsg) Reset()
- func (x *UnixDogstatsdMsg) String() string
- type WorkloadmetaEntityId
- func (*WorkloadmetaEntityId) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadmetaEntityId) GetId() string
- func (x *WorkloadmetaEntityId) GetKind() WorkloadmetaKind
- func (*WorkloadmetaEntityId) ProtoMessage()
- func (x *WorkloadmetaEntityId) ProtoReflect() protoreflect.Message
- func (x *WorkloadmetaEntityId) Reset()
- func (x *WorkloadmetaEntityId) String() string
- type WorkloadmetaEvent
- func (*WorkloadmetaEvent) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadmetaEvent) GetContainer() *Container
- func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask
- func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod
- func (x *WorkloadmetaEvent) GetType() WorkloadmetaEventType
- func (*WorkloadmetaEvent) ProtoMessage()
- func (x *WorkloadmetaEvent) ProtoReflect() protoreflect.Message
- func (x *WorkloadmetaEvent) Reset()
- func (x *WorkloadmetaEvent) String() string
- type WorkloadmetaEventType
- func (WorkloadmetaEventType) Descriptor() protoreflect.EnumDescriptor
- func (x WorkloadmetaEventType) Enum() *WorkloadmetaEventType
- func (WorkloadmetaEventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkloadmetaEventType) Number() protoreflect.EnumNumber
- func (x WorkloadmetaEventType) String() string
- func (WorkloadmetaEventType) Type() protoreflect.EnumType
- type WorkloadmetaFilter
- func (*WorkloadmetaFilter) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadmetaFilter) GetEventType() WorkloadmetaEventType
- func (x *WorkloadmetaFilter) GetKinds() []WorkloadmetaKind
- func (x *WorkloadmetaFilter) GetSource() WorkloadmetaSource
- func (*WorkloadmetaFilter) ProtoMessage()
- func (x *WorkloadmetaFilter) ProtoReflect() protoreflect.Message
- func (x *WorkloadmetaFilter) Reset()
- func (x *WorkloadmetaFilter) String() string
- type WorkloadmetaKind
- func (WorkloadmetaKind) Descriptor() protoreflect.EnumDescriptor
- func (x WorkloadmetaKind) Enum() *WorkloadmetaKind
- func (WorkloadmetaKind) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkloadmetaKind) Number() protoreflect.EnumNumber
- func (x WorkloadmetaKind) String() string
- func (WorkloadmetaKind) Type() protoreflect.EnumType
- type WorkloadmetaSource
- func (WorkloadmetaSource) Descriptor() protoreflect.EnumDescriptor
- func (x WorkloadmetaSource) Enum() *WorkloadmetaSource
- func (WorkloadmetaSource) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkloadmetaSource) Number() protoreflect.EnumNumber
- func (x WorkloadmetaSource) String() string
- func (WorkloadmetaSource) Type() protoreflect.EnumType
- type WorkloadmetaStreamRequest
- func (*WorkloadmetaStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadmetaStreamRequest) GetFilter() *WorkloadmetaFilter
- func (*WorkloadmetaStreamRequest) ProtoMessage()
- func (x *WorkloadmetaStreamRequest) ProtoReflect() protoreflect.Message
- func (x *WorkloadmetaStreamRequest) Reset()
- func (x *WorkloadmetaStreamRequest) String() string
- type WorkloadmetaStreamResponse
- func (*WorkloadmetaStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadmetaStreamResponse) GetEvents() []*WorkloadmetaEvent
- func (*WorkloadmetaStreamResponse) ProtoMessage()
- func (x *WorkloadmetaStreamResponse) ProtoReflect() protoreflect.Message
- func (x *WorkloadmetaStreamResponse) Reset()
- func (x *WorkloadmetaStreamResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( EventType_name = map[int32]string{ 0: "ADDED", 1: "MODIFIED", 2: "DELETED", } EventType_value = map[string]int32{ "ADDED": 0, "MODIFIED": 1, "DELETED": 2, } )
Enum value maps for EventType.
var ( TagCardinality_name = map[int32]string{ 0: "LOW", 1: "ORCHESTRATOR", 2: "HIGH", } TagCardinality_value = map[string]int32{ "LOW": 0, "ORCHESTRATOR": 1, "HIGH": 2, } )
Enum value maps for TagCardinality.
var ( WorkloadmetaKind_name = map[int32]string{ 0: "CONTAINER", 1: "KUBERNETES_POD", 2: "ECS_TASK", } WorkloadmetaKind_value = map[string]int32{ "CONTAINER": 0, "KUBERNETES_POD": 1, "ECS_TASK": 2, } )
Enum value maps for WorkloadmetaKind.
var ( WorkloadmetaSource_name = map[int32]string{ 0: "ALL", 1: "RUNTIME", 2: "NODE_ORCHESTRATOR", 3: "CLUSTER_ORCHESTRATOR", } WorkloadmetaSource_value = map[string]int32{ "ALL": 0, "RUNTIME": 1, "NODE_ORCHESTRATOR": 2, "CLUSTER_ORCHESTRATOR": 3, } )
Enum value maps for WorkloadmetaSource.
var ( WorkloadmetaEventType_name = map[int32]string{ 0: "EVENT_TYPE_ALL", 1: "EVENT_TYPE_SET", 2: "EVENT_TYPE_UNSET", } WorkloadmetaEventType_value = map[string]int32{ "EVENT_TYPE_ALL": 0, "EVENT_TYPE_SET": 1, "EVENT_TYPE_UNSET": 2, } )
Enum value maps for WorkloadmetaEventType.
var ( Runtime_name = map[int32]string{ 0: "DOCKER", 1: "CONTAINERD", 2: "PODMAN", 3: "CRIO", 4: "GARDEN", 5: "ECS_FARGATE", } Runtime_value = map[string]int32{ "DOCKER": 0, "CONTAINERD": 1, "PODMAN": 2, "CRIO": 3, "GARDEN": 4, "ECS_FARGATE": 5, } )
Enum value maps for Runtime.
var ( ContainerStatus_name = map[int32]string{ 0: "CONTAINER_STATUS_UNKNOWN", 1: "CONTAINER_STATUS_CREATED", 2: "CONTAINER_STATUS_RUNNING", 3: "CONTAINER_STATUS_RESTARTING", 4: "CONTAINER_STATUS_PAUSED", 5: "CONTAINER_STATUS_STOPPED", } ContainerStatus_value = map[string]int32{ "CONTAINER_STATUS_UNKNOWN": 0, "CONTAINER_STATUS_CREATED": 1, "CONTAINER_STATUS_RUNNING": 2, "CONTAINER_STATUS_RESTARTING": 3, "CONTAINER_STATUS_PAUSED": 4, "CONTAINER_STATUS_STOPPED": 5, } )
Enum value maps for ContainerStatus.
var ( ContainerHealth_name = map[int32]string{ 0: "CONTAINER_HEALTH_UNKNOWN", 1: "CONTAINER_HEALTH_HEALTHY", 2: "CONTAINER_HEALTH_UNHEALTHY", } ContainerHealth_value = map[string]int32{ "CONTAINER_HEALTH_UNKNOWN": 0, "CONTAINER_HEALTH_HEALTHY": 1, "CONTAINER_HEALTH_UNHEALTHY": 2, } )
Enum value maps for ContainerHealth.
var ( ECSLaunchType_name = map[int32]string{ 0: "EC2", 1: "FARGATE", } ECSLaunchType_value = map[string]int32{ "EC2": 0, "FARGATE": 1, } )
Enum value maps for ECSLaunchType.
var File_datadog_api_v1_api_proto protoreflect.FileDescriptor
var File_datadog_model_v1_model_proto protoreflect.FileDescriptor
var File_datadog_process_process_proto protoreflect.FileDescriptor
var File_datadog_process_workloadmeta_process_proto protoreflect.FileDescriptor
var File_datadog_remoteconfig_remoteconfig_proto protoreflect.FileDescriptor
var File_datadog_workloadmeta_workloadmeta_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentHandler ¶
RegisterAgentHandler registers the http handlers for service Agent to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAgentHandlerClient ¶
func RegisterAgentHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentClient) error
RegisterAgentHandlerClient registers the http handlers for service Agent to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentClient" to call the correct interceptors.
func RegisterAgentHandlerFromEndpoint ¶
func RegisterAgentHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAgentHandlerFromEndpoint is same as RegisterAgentHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAgentHandlerServer ¶
func RegisterAgentHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentServer) error
RegisterAgentHandlerServer registers the http handlers for service Agent to "mux". UnaryRPC :call AgentServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func RegisterAgentSecureHandler ¶
func RegisterAgentSecureHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAgentSecureHandler registers the http handlers for service AgentSecure to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAgentSecureHandlerClient ¶
func RegisterAgentSecureHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentSecureClient) error
RegisterAgentSecureHandlerClient registers the http handlers for service AgentSecure to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentSecureClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentSecureClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentSecureClient" to call the correct interceptors.
func RegisterAgentSecureHandlerFromEndpoint ¶
func RegisterAgentSecureHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAgentSecureHandlerFromEndpoint is same as RegisterAgentSecureHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAgentSecureHandlerServer ¶
func RegisterAgentSecureHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentSecureServer) error
RegisterAgentSecureHandlerServer registers the http handlers for service AgentSecure to "mux". UnaryRPC :call AgentSecureServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func RegisterAgentSecureServer ¶
func RegisterAgentSecureServer(s *grpc.Server, srv AgentSecureServer)
func RegisterAgentServer ¶
func RegisterAgentServer(s *grpc.Server, srv AgentServer)
func RegisterProcessEntityStreamServer ¶ added in v0.47.0
func RegisterProcessEntityStreamServer(s *grpc.Server, srv ProcessEntityStreamServer)
Types ¶
type AgentClient ¶
type AgentClient interface { // get the hostname GetHostname(ctx context.Context, in *HostnameRequest, opts ...grpc.CallOption) (*HostnameReply, error) }
AgentClient is the client API for Agent service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAgentClient ¶
func NewAgentClient(cc grpc.ClientConnInterface) AgentClient
type AgentSecureClient ¶
type AgentSecureClient interface { // subscribes to added, removed, or changed entities in the Tagger // and streams them to clients as events. // can be called through the HTTP gateway, and events will be streamed as JSON: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities // { // "result": { // "entity": { // "id": { // "prefix": "kubernetes_pod_uid", // "uid": "4025461f832caf3fceb7fc2a32f879c6" // }, // "hash": "cad4fc8fc409fcc1", // "lowCardinalityTags": [ // "kube_namespace:kube-system", // "pod_phase:running" // ] // } // } // } TaggerStreamEntities(ctx context.Context, in *StreamTagsRequest, opts ...grpc.CallOption) (AgentSecure_TaggerStreamEntitiesClient, error) // fetches an entity from the Tagger with the desired cardinality tags. // can be called through the HTTP gateway, and entity will be returned as JSON: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \ // https://localhost:5001/v1/grpc/tagger/fetch_entity // { // "id": { // "prefix": "kubernetes_pod_uid", // "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507" // }, // "tags": [ // "kube_namespace:kube-system", // "pod_phase:running", // "kube_deployment:coredns", // "kube_service:kube-dns" // ] // } TaggerFetchEntity(ctx context.Context, in *FetchEntityRequest, opts ...grpc.CallOption) (*FetchEntityResponse, error) // Trigger a dogstatsd capture. Only one capture can be triggered at a time. // Can be called through the HTTP gateway, and entity will be returned as JSON: // // TODO: add the curl code here DogstatsdCaptureTrigger(ctx context.Context, in *CaptureTriggerRequest, opts ...grpc.CallOption) (*CaptureTriggerResponse, error) // Trigger a dogstatsd capture. Only one capture can be triggered at a time. // Can be called through the HTTP gateway, and entity will be returned as JSON: // // TODO: add the curl code here DogstatsdSetTaggerState(ctx context.Context, in *TaggerState, opts ...grpc.CallOption) (*TaggerStateResponse, error) ClientGetConfigs(ctx context.Context, in *ClientGetConfigsRequest, opts ...grpc.CallOption) (*ClientGetConfigsResponse, error) GetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetStateConfigResponse, error) // Subscribes to added, removed, or changed entities in the Workloadmeta and // streams them to clients as events. // Can be called through the HTTP gateway, and events will be streamed as JSON. // Example call that receives all the events: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k https://localhost:5001/v1/grpc/workloadmeta/stream_entities // // Example call that receives only unset events: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"filter":{"eventType":2}}' \ // https://localhost:5001/v1/grpc/workloadmeta/stream_entities // // Example call that receives only from the cluster orchestrator: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"filter":{"source":3}}' \ // https://localhost:5001/v1/grpc/workloadmeta/stream_entities WorkloadmetaStreamEntities(ctx context.Context, in *WorkloadmetaStreamRequest, opts ...grpc.CallOption) (AgentSecure_WorkloadmetaStreamEntitiesClient, error) }
AgentSecureClient is the client API for AgentSecure service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAgentSecureClient ¶
func NewAgentSecureClient(cc grpc.ClientConnInterface) AgentSecureClient
type AgentSecureServer ¶
type AgentSecureServer interface { // subscribes to added, removed, or changed entities in the Tagger // and streams them to clients as events. // can be called through the HTTP gateway, and events will be streamed as JSON: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities // { // "result": { // "entity": { // "id": { // "prefix": "kubernetes_pod_uid", // "uid": "4025461f832caf3fceb7fc2a32f879c6" // }, // "hash": "cad4fc8fc409fcc1", // "lowCardinalityTags": [ // "kube_namespace:kube-system", // "pod_phase:running" // ] // } // } // } TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error // fetches an entity from the Tagger with the desired cardinality tags. // can be called through the HTTP gateway, and entity will be returned as JSON: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \ // https://localhost:5001/v1/grpc/tagger/fetch_entity // { // "id": { // "prefix": "kubernetes_pod_uid", // "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507" // }, // "tags": [ // "kube_namespace:kube-system", // "pod_phase:running", // "kube_deployment:coredns", // "kube_service:kube-dns" // ] // } TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error) // Trigger a dogstatsd capture. Only one capture can be triggered at a time. // Can be called through the HTTP gateway, and entity will be returned as JSON: // // TODO: add the curl code here DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error) // Trigger a dogstatsd capture. Only one capture can be triggered at a time. // Can be called through the HTTP gateway, and entity will be returned as JSON: // // TODO: add the curl code here DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error) GetConfigState(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error) // Subscribes to added, removed, or changed entities in the Workloadmeta and // streams them to clients as events. // Can be called through the HTTP gateway, and events will be streamed as JSON. // Example call that receives all the events: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k https://localhost:5001/v1/grpc/workloadmeta/stream_entities // // Example call that receives only unset events: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"filter":{"eventType":2}}' \ // https://localhost:5001/v1/grpc/workloadmeta/stream_entities // // Example call that receives only from the cluster orchestrator: // // $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \ // -XPOST -k -H "Content-Type: application/json" \ // --data '{"filter":{"source":3}}' \ // https://localhost:5001/v1/grpc/workloadmeta/stream_entities WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, AgentSecure_WorkloadmetaStreamEntitiesServer) error }
AgentSecureServer is the server API for AgentSecure service.
type AgentSecure_TaggerStreamEntitiesClient ¶
type AgentSecure_TaggerStreamEntitiesClient interface { Recv() (*StreamTagsResponse, error) grpc.ClientStream }
type AgentSecure_TaggerStreamEntitiesServer ¶
type AgentSecure_TaggerStreamEntitiesServer interface { Send(*StreamTagsResponse) error grpc.ServerStream }
type AgentSecure_WorkloadmetaStreamEntitiesClient ¶
type AgentSecure_WorkloadmetaStreamEntitiesClient interface { Recv() (*WorkloadmetaStreamResponse, error) grpc.ClientStream }
type AgentSecure_WorkloadmetaStreamEntitiesServer ¶
type AgentSecure_WorkloadmetaStreamEntitiesServer interface { Send(*WorkloadmetaStreamResponse) error grpc.ServerStream }
type AgentServer ¶
type AgentServer interface { // get the hostname GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error) }
AgentServer is the server API for Agent service.
type CaptureTriggerRequest ¶
type CaptureTriggerRequest struct { Duration string `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Compressed bool `protobuf:"varint,3,opt,name=compressed,proto3" json:"compressed,omitempty"` // contains filtered or unexported fields }
Dogstatsd capture types
func (*CaptureTriggerRequest) Descriptor
deprecated
func (*CaptureTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CaptureTriggerRequest.ProtoReflect.Descriptor instead.
func (*CaptureTriggerRequest) GetCompressed ¶
func (x *CaptureTriggerRequest) GetCompressed() bool
func (*CaptureTriggerRequest) GetDuration ¶
func (x *CaptureTriggerRequest) GetDuration() string
func (*CaptureTriggerRequest) GetPath ¶
func (x *CaptureTriggerRequest) GetPath() string
func (*CaptureTriggerRequest) ProtoMessage ¶
func (*CaptureTriggerRequest) ProtoMessage()
func (*CaptureTriggerRequest) ProtoReflect ¶
func (x *CaptureTriggerRequest) ProtoReflect() protoreflect.Message
func (*CaptureTriggerRequest) Reset ¶
func (x *CaptureTriggerRequest) Reset()
func (*CaptureTriggerRequest) String ¶
func (x *CaptureTriggerRequest) String() string
type CaptureTriggerResponse ¶
type CaptureTriggerResponse struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*CaptureTriggerResponse) Descriptor
deprecated
func (*CaptureTriggerResponse) Descriptor() ([]byte, []int)
Deprecated: Use CaptureTriggerResponse.ProtoReflect.Descriptor instead.
func (*CaptureTriggerResponse) GetPath ¶
func (x *CaptureTriggerResponse) GetPath() string
func (*CaptureTriggerResponse) ProtoMessage ¶
func (*CaptureTriggerResponse) ProtoMessage()
func (*CaptureTriggerResponse) ProtoReflect ¶
func (x *CaptureTriggerResponse) ProtoReflect() protoreflect.Message
func (*CaptureTriggerResponse) Reset ¶
func (x *CaptureTriggerResponse) Reset()
func (*CaptureTriggerResponse) String ¶
func (x *CaptureTriggerResponse) String() string
type Client ¶
type Client struct { State *ClientState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Products []string `protobuf:"bytes,3,rep,name=products,proto3" json:"products,omitempty"` IsTracer bool `protobuf:"varint,6,opt,name=is_tracer,json=isTracer,proto3" json:"is_tracer,omitempty"` ClientTracer *ClientTracer `protobuf:"bytes,7,opt,name=client_tracer,json=clientTracer,proto3" json:"client_tracer,omitempty"` IsAgent bool `protobuf:"varint,8,opt,name=is_agent,json=isAgent,proto3" json:"is_agent,omitempty"` ClientAgent *ClientAgent `protobuf:"bytes,9,opt,name=client_agent,json=clientAgent,proto3" json:"client_agent,omitempty"` LastSeen uint64 `protobuf:"varint,10,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"` Capabilities []byte `protobuf:"bytes,11,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // contains filtered or unexported fields }
func (*Client) Descriptor
deprecated
func (*Client) GetCapabilities ¶
func (*Client) GetClientAgent ¶
func (x *Client) GetClientAgent() *ClientAgent
func (*Client) GetClientTracer ¶
func (x *Client) GetClientTracer() *ClientTracer
func (*Client) GetIsAgent ¶
func (*Client) GetIsTracer ¶
func (*Client) GetLastSeen ¶
func (*Client) GetProducts ¶
func (*Client) GetState ¶
func (x *Client) GetState() *ClientState
func (*Client) ProtoMessage ¶
func (*Client) ProtoMessage()
func (*Client) ProtoReflect ¶
func (x *Client) ProtoReflect() protoreflect.Message
type ClientAgent ¶
type ClientAgent struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` ClusterId string `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` CwsWorkloads []string `protobuf:"bytes,5,rep,name=cws_workloads,json=cwsWorkloads,proto3" json:"cws_workloads,omitempty"` // contains filtered or unexported fields }
func (*ClientAgent) Descriptor
deprecated
func (*ClientAgent) Descriptor() ([]byte, []int)
Deprecated: Use ClientAgent.ProtoReflect.Descriptor instead.
func (*ClientAgent) GetClusterId ¶
func (x *ClientAgent) GetClusterId() string
func (*ClientAgent) GetClusterName ¶
func (x *ClientAgent) GetClusterName() string
func (*ClientAgent) GetCwsWorkloads ¶
func (x *ClientAgent) GetCwsWorkloads() []string
func (*ClientAgent) GetName ¶
func (x *ClientAgent) GetName() string
func (*ClientAgent) GetVersion ¶
func (x *ClientAgent) GetVersion() string
func (*ClientAgent) ProtoMessage ¶
func (*ClientAgent) ProtoMessage()
func (*ClientAgent) ProtoReflect ¶
func (x *ClientAgent) ProtoReflect() protoreflect.Message
func (*ClientAgent) Reset ¶
func (x *ClientAgent) Reset()
func (*ClientAgent) String ¶
func (x *ClientAgent) String() string
type ClientGetConfigsRequest ¶
type ClientGetConfigsRequest struct { Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` CachedTargetFiles []*TargetFileMeta `protobuf:"bytes,2,rep,name=cached_target_files,json=cachedTargetFiles,proto3" json:"cached_target_files,omitempty"` // contains filtered or unexported fields }
func (*ClientGetConfigsRequest) Descriptor
deprecated
func (*ClientGetConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClientGetConfigsRequest.ProtoReflect.Descriptor instead.
func (*ClientGetConfigsRequest) GetCachedTargetFiles ¶
func (x *ClientGetConfigsRequest) GetCachedTargetFiles() []*TargetFileMeta
func (*ClientGetConfigsRequest) GetClient ¶
func (x *ClientGetConfigsRequest) GetClient() *Client
func (*ClientGetConfigsRequest) ProtoMessage ¶
func (*ClientGetConfigsRequest) ProtoMessage()
func (*ClientGetConfigsRequest) ProtoReflect ¶
func (x *ClientGetConfigsRequest) ProtoReflect() protoreflect.Message
func (*ClientGetConfigsRequest) Reset ¶
func (x *ClientGetConfigsRequest) Reset()
func (*ClientGetConfigsRequest) String ¶
func (x *ClientGetConfigsRequest) String() string
type ClientGetConfigsResponse ¶
type ClientGetConfigsResponse struct { Roots [][]byte `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"` Targets []byte `protobuf:"bytes,2,opt,name=targets,proto3" json:"targets,omitempty"` TargetFiles []*File `protobuf:"bytes,3,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"` ClientConfigs []string `protobuf:"bytes,4,rep,name=client_configs,json=clientConfigs,proto3" json:"client_configs,omitempty"` // contains filtered or unexported fields }
func (*ClientGetConfigsResponse) Descriptor
deprecated
func (*ClientGetConfigsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClientGetConfigsResponse.ProtoReflect.Descriptor instead.
func (*ClientGetConfigsResponse) GetClientConfigs ¶
func (x *ClientGetConfigsResponse) GetClientConfigs() []string
func (*ClientGetConfigsResponse) GetRoots ¶
func (x *ClientGetConfigsResponse) GetRoots() [][]byte
func (*ClientGetConfigsResponse) GetTargetFiles ¶
func (x *ClientGetConfigsResponse) GetTargetFiles() []*File
func (*ClientGetConfigsResponse) GetTargets ¶
func (x *ClientGetConfigsResponse) GetTargets() []byte
func (*ClientGetConfigsResponse) ProtoMessage ¶
func (*ClientGetConfigsResponse) ProtoMessage()
func (*ClientGetConfigsResponse) ProtoReflect ¶
func (x *ClientGetConfigsResponse) ProtoReflect() protoreflect.Message
func (*ClientGetConfigsResponse) Reset ¶
func (x *ClientGetConfigsResponse) Reset()
func (*ClientGetConfigsResponse) String ¶
func (x *ClientGetConfigsResponse) String() string
type ClientState ¶
type ClientState struct { RootVersion uint64 `protobuf:"varint,1,opt,name=root_version,json=rootVersion,proto3" json:"root_version,omitempty"` TargetsVersion uint64 `protobuf:"varint,2,opt,name=targets_version,json=targetsVersion,proto3" json:"targets_version,omitempty"` ConfigStates []*ConfigState `protobuf:"bytes,3,rep,name=config_states,json=configStates,proto3" json:"config_states,omitempty"` HasError bool `protobuf:"varint,4,opt,name=has_error,json=hasError,proto3" json:"has_error,omitempty"` Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` BackendClientState []byte `protobuf:"bytes,6,opt,name=backend_client_state,json=backendClientState,proto3" json:"backend_client_state,omitempty"` // contains filtered or unexported fields }
func (*ClientState) Descriptor
deprecated
func (*ClientState) Descriptor() ([]byte, []int)
Deprecated: Use ClientState.ProtoReflect.Descriptor instead.
func (*ClientState) GetBackendClientState ¶
func (x *ClientState) GetBackendClientState() []byte
func (*ClientState) GetConfigStates ¶
func (x *ClientState) GetConfigStates() []*ConfigState
func (*ClientState) GetError ¶
func (x *ClientState) GetError() string
func (*ClientState) GetHasError ¶
func (x *ClientState) GetHasError() bool
func (*ClientState) GetRootVersion ¶
func (x *ClientState) GetRootVersion() uint64
func (*ClientState) GetTargetsVersion ¶
func (x *ClientState) GetTargetsVersion() uint64
func (*ClientState) ProtoMessage ¶
func (*ClientState) ProtoMessage()
func (*ClientState) ProtoReflect ¶
func (x *ClientState) ProtoReflect() protoreflect.Message
func (*ClientState) Reset ¶
func (x *ClientState) Reset()
func (*ClientState) String ¶
func (x *ClientState) String() string
type ClientTracer ¶
type ClientTracer struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` Language string `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"` TracerVersion string `protobuf:"bytes,3,opt,name=tracer_version,json=tracerVersion,proto3" json:"tracer_version,omitempty"` Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"` ExtraServices []string `protobuf:"bytes,8,rep,name=extra_services,json=extraServices,proto3" json:"extra_services,omitempty"` Env string `protobuf:"bytes,5,opt,name=env,proto3" json:"env,omitempty"` AppVersion string `protobuf:"bytes,6,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"` Tags []string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*ClientTracer) Descriptor
deprecated
func (*ClientTracer) Descriptor() ([]byte, []int)
Deprecated: Use ClientTracer.ProtoReflect.Descriptor instead.
func (*ClientTracer) GetAppVersion ¶
func (x *ClientTracer) GetAppVersion() string
func (*ClientTracer) GetEnv ¶
func (x *ClientTracer) GetEnv() string
func (*ClientTracer) GetExtraServices ¶
func (x *ClientTracer) GetExtraServices() []string
func (*ClientTracer) GetLanguage ¶
func (x *ClientTracer) GetLanguage() string
func (*ClientTracer) GetRuntimeId ¶
func (x *ClientTracer) GetRuntimeId() string
func (*ClientTracer) GetService ¶
func (x *ClientTracer) GetService() string
func (*ClientTracer) GetTags ¶
func (x *ClientTracer) GetTags() []string
func (*ClientTracer) GetTracerVersion ¶
func (x *ClientTracer) GetTracerVersion() string
func (*ClientTracer) ProtoMessage ¶
func (*ClientTracer) ProtoMessage()
func (*ClientTracer) ProtoReflect ¶
func (x *ClientTracer) ProtoReflect() protoreflect.Message
func (*ClientTracer) Reset ¶
func (x *ClientTracer) Reset()
func (*ClientTracer) String ¶
func (x *ClientTracer) String() string
type ConfigMetas ¶
type ConfigMetas struct { Roots []*TopMeta `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"` Timestamp *TopMeta `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Snapshot *TopMeta `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"` TopTargets *TopMeta `protobuf:"bytes,4,opt,name=topTargets,proto3" json:"topTargets,omitempty"` DelegatedTargets []*DelegatedMeta `protobuf:"bytes,5,rep,name=delegatedTargets,proto3" json:"delegatedTargets,omitempty"` // contains filtered or unexported fields }
func (*ConfigMetas) Descriptor
deprecated
func (*ConfigMetas) Descriptor() ([]byte, []int)
Deprecated: Use ConfigMetas.ProtoReflect.Descriptor instead.
func (*ConfigMetas) GetDelegatedTargets ¶
func (x *ConfigMetas) GetDelegatedTargets() []*DelegatedMeta
func (*ConfigMetas) GetRoots ¶
func (x *ConfigMetas) GetRoots() []*TopMeta
func (*ConfigMetas) GetSnapshot ¶
func (x *ConfigMetas) GetSnapshot() *TopMeta
func (*ConfigMetas) GetTimestamp ¶
func (x *ConfigMetas) GetTimestamp() *TopMeta
func (*ConfigMetas) GetTopTargets ¶
func (x *ConfigMetas) GetTopTargets() *TopMeta
func (*ConfigMetas) ProtoMessage ¶
func (*ConfigMetas) ProtoMessage()
func (*ConfigMetas) ProtoReflect ¶
func (x *ConfigMetas) ProtoReflect() protoreflect.Message
func (*ConfigMetas) Reset ¶
func (x *ConfigMetas) Reset()
func (*ConfigMetas) String ¶
func (x *ConfigMetas) String() string
type ConfigState ¶
type ConfigState struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` Product string `protobuf:"bytes,3,opt,name=product,proto3" json:"product,omitempty"` ApplyState uint64 `protobuf:"varint,4,opt,name=apply_state,json=applyState,proto3" json:"apply_state,omitempty"` ApplyError string `protobuf:"bytes,5,opt,name=apply_error,json=applyError,proto3" json:"apply_error,omitempty"` // contains filtered or unexported fields }
func (*ConfigState) Descriptor
deprecated
func (*ConfigState) Descriptor() ([]byte, []int)
Deprecated: Use ConfigState.ProtoReflect.Descriptor instead.
func (*ConfigState) GetApplyError ¶
func (x *ConfigState) GetApplyError() string
func (*ConfigState) GetApplyState ¶
func (x *ConfigState) GetApplyState() uint64
func (*ConfigState) GetId ¶
func (x *ConfigState) GetId() string
func (*ConfigState) GetProduct ¶
func (x *ConfigState) GetProduct() string
func (*ConfigState) GetVersion ¶
func (x *ConfigState) GetVersion() uint64
func (*ConfigState) ProtoMessage ¶
func (*ConfigState) ProtoMessage()
func (*ConfigState) ProtoReflect ¶
func (x *ConfigState) ProtoReflect() protoreflect.Message
func (*ConfigState) Reset ¶
func (x *ConfigState) Reset()
func (*ConfigState) String ¶
func (x *ConfigState) String() string
type Container ¶
type Container struct { EntityId *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"` EntityMeta *EntityMeta `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"` EnvVars map[string]string `` /* 155-byte string literal not displayed */ Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"` Image *ContainerImage `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"` NetworkIps map[string]string `` /* 161-byte string literal not displayed */ Pid int32 `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"` Ports []*ContainerPort `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"` Runtime Runtime `protobuf:"varint,9,opt,name=runtime,proto3,enum=datadog.workloadmeta.Runtime" json:"runtime,omitempty"` State *ContainerState `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"` CollectorTags []string `protobuf:"bytes,11,rep,name=collectorTags,proto3" json:"collectorTags,omitempty"` // contains filtered or unexported fields }
func (*Container) Descriptor
deprecated
func (*Container) GetCollectorTags ¶
func (*Container) GetEntityId ¶
func (x *Container) GetEntityId() *WorkloadmetaEntityId
func (*Container) GetEntityMeta ¶
func (x *Container) GetEntityMeta() *EntityMeta
func (*Container) GetEnvVars ¶
func (*Container) GetHostname ¶
func (*Container) GetImage ¶
func (x *Container) GetImage() *ContainerImage
func (*Container) GetNetworkIps ¶
func (*Container) GetPorts ¶
func (x *Container) GetPorts() []*ContainerPort
func (*Container) GetRuntime ¶
func (*Container) GetState ¶
func (x *Container) GetState() *ContainerState
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) ProtoReflect ¶
func (x *Container) ProtoReflect() protoreflect.Message
type ContainerHealth ¶
type ContainerHealth int32
const ( ContainerHealth_CONTAINER_HEALTH_UNKNOWN ContainerHealth = 0 ContainerHealth_CONTAINER_HEALTH_HEALTHY ContainerHealth = 1 ContainerHealth_CONTAINER_HEALTH_UNHEALTHY ContainerHealth = 2 )
func (ContainerHealth) Descriptor ¶
func (ContainerHealth) Descriptor() protoreflect.EnumDescriptor
func (ContainerHealth) Enum ¶
func (x ContainerHealth) Enum() *ContainerHealth
func (ContainerHealth) EnumDescriptor
deprecated
func (ContainerHealth) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContainerHealth.Descriptor instead.
func (ContainerHealth) Number ¶
func (x ContainerHealth) Number() protoreflect.EnumNumber
func (ContainerHealth) String ¶
func (x ContainerHealth) String() string
func (ContainerHealth) Type ¶
func (ContainerHealth) Type() protoreflect.EnumType
type ContainerImage ¶
type ContainerImage struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` RawName string `protobuf:"bytes,2,opt,name=rawName,proto3" json:"rawName,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` ShortName string `protobuf:"bytes,4,opt,name=shortName,proto3" json:"shortName,omitempty"` Tag string `protobuf:"bytes,5,opt,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*ContainerImage) Descriptor
deprecated
func (*ContainerImage) Descriptor() ([]byte, []int)
Deprecated: Use ContainerImage.ProtoReflect.Descriptor instead.
func (*ContainerImage) GetId ¶
func (x *ContainerImage) GetId() string
func (*ContainerImage) GetName ¶
func (x *ContainerImage) GetName() string
func (*ContainerImage) GetRawName ¶
func (x *ContainerImage) GetRawName() string
func (*ContainerImage) GetShortName ¶
func (x *ContainerImage) GetShortName() string
func (*ContainerImage) GetTag ¶
func (x *ContainerImage) GetTag() string
func (*ContainerImage) ProtoMessage ¶
func (*ContainerImage) ProtoMessage()
func (*ContainerImage) ProtoReflect ¶
func (x *ContainerImage) ProtoReflect() protoreflect.Message
func (*ContainerImage) Reset ¶
func (x *ContainerImage) Reset()
func (*ContainerImage) String ¶
func (x *ContainerImage) String() string
type ContainerPort ¶
type ContainerPort struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` // contains filtered or unexported fields }
func (*ContainerPort) Descriptor
deprecated
func (*ContainerPort) Descriptor() ([]byte, []int)
Deprecated: Use ContainerPort.ProtoReflect.Descriptor instead.
func (*ContainerPort) GetName ¶
func (x *ContainerPort) GetName() string
func (*ContainerPort) GetPort ¶
func (x *ContainerPort) GetPort() int32
func (*ContainerPort) GetProtocol ¶
func (x *ContainerPort) GetProtocol() string
func (*ContainerPort) ProtoMessage ¶
func (*ContainerPort) ProtoMessage()
func (*ContainerPort) ProtoReflect ¶
func (x *ContainerPort) ProtoReflect() protoreflect.Message
func (*ContainerPort) Reset ¶
func (x *ContainerPort) Reset()
func (*ContainerPort) String ¶
func (x *ContainerPort) String() string
type ContainerState ¶
type ContainerState struct { Running bool `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"` Status ContainerStatus `protobuf:"varint,2,opt,name=status,proto3,enum=datadog.workloadmeta.ContainerStatus" json:"status,omitempty"` Health ContainerHealth `protobuf:"varint,3,opt,name=health,proto3,enum=datadog.workloadmeta.ContainerHealth" json:"health,omitempty"` CreatedAt int64 `protobuf:"varint,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"` StartedAt int64 `protobuf:"varint,5,opt,name=startedAt,proto3" json:"startedAt,omitempty"` FinishedAt int64 `protobuf:"varint,6,opt,name=finishedAt,proto3" json:"finishedAt,omitempty"` ExitCode uint32 `protobuf:"varint,7,opt,name=exitCode,proto3" json:"exitCode,omitempty"` // contains filtered or unexported fields }
func (*ContainerState) Descriptor
deprecated
func (*ContainerState) Descriptor() ([]byte, []int)
Deprecated: Use ContainerState.ProtoReflect.Descriptor instead.
func (*ContainerState) GetCreatedAt ¶
func (x *ContainerState) GetCreatedAt() int64
func (*ContainerState) GetExitCode ¶
func (x *ContainerState) GetExitCode() uint32
func (*ContainerState) GetFinishedAt ¶
func (x *ContainerState) GetFinishedAt() int64
func (*ContainerState) GetHealth ¶
func (x *ContainerState) GetHealth() ContainerHealth
func (*ContainerState) GetRunning ¶
func (x *ContainerState) GetRunning() bool
func (*ContainerState) GetStartedAt ¶
func (x *ContainerState) GetStartedAt() int64
func (*ContainerState) GetStatus ¶
func (x *ContainerState) GetStatus() ContainerStatus
func (*ContainerState) ProtoMessage ¶
func (*ContainerState) ProtoMessage()
func (*ContainerState) ProtoReflect ¶
func (x *ContainerState) ProtoReflect() protoreflect.Message
func (*ContainerState) Reset ¶
func (x *ContainerState) Reset()
func (*ContainerState) String ¶
func (x *ContainerState) String() string
type ContainerStatus ¶
type ContainerStatus int32
const ( ContainerStatus_CONTAINER_STATUS_UNKNOWN ContainerStatus = 0 ContainerStatus_CONTAINER_STATUS_CREATED ContainerStatus = 1 ContainerStatus_CONTAINER_STATUS_RUNNING ContainerStatus = 2 ContainerStatus_CONTAINER_STATUS_RESTARTING ContainerStatus = 3 ContainerStatus_CONTAINER_STATUS_PAUSED ContainerStatus = 4 ContainerStatus_CONTAINER_STATUS_STOPPED ContainerStatus = 5 )
func (ContainerStatus) Descriptor ¶
func (ContainerStatus) Descriptor() protoreflect.EnumDescriptor
func (ContainerStatus) Enum ¶
func (x ContainerStatus) Enum() *ContainerStatus
func (ContainerStatus) EnumDescriptor
deprecated
func (ContainerStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContainerStatus.Descriptor instead.
func (ContainerStatus) Number ¶
func (x ContainerStatus) Number() protoreflect.EnumNumber
func (ContainerStatus) String ¶
func (x ContainerStatus) String() string
func (ContainerStatus) Type ¶
func (ContainerStatus) Type() protoreflect.EnumType
type DelegatedMeta ¶
type DelegatedMeta struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"` Raw []byte `protobuf:"bytes,3,opt,name=raw,proto3" json:"raw,omitempty"` // contains filtered or unexported fields }
func (*DelegatedMeta) Descriptor
deprecated
func (*DelegatedMeta) Descriptor() ([]byte, []int)
Deprecated: Use DelegatedMeta.ProtoReflect.Descriptor instead.
func (*DelegatedMeta) GetRaw ¶
func (x *DelegatedMeta) GetRaw() []byte
func (*DelegatedMeta) GetRole ¶
func (x *DelegatedMeta) GetRole() string
func (*DelegatedMeta) GetVersion ¶
func (x *DelegatedMeta) GetVersion() uint64
func (*DelegatedMeta) ProtoMessage ¶
func (*DelegatedMeta) ProtoMessage()
func (*DelegatedMeta) ProtoReflect ¶
func (x *DelegatedMeta) ProtoReflect() protoreflect.Message
func (*DelegatedMeta) Reset ¶
func (x *DelegatedMeta) Reset()
func (*DelegatedMeta) String ¶
func (x *DelegatedMeta) String() string
type DirectorMetas ¶
type DirectorMetas struct { Roots []*TopMeta `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"` Timestamp *TopMeta `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Snapshot *TopMeta `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"` Targets *TopMeta `protobuf:"bytes,4,opt,name=targets,proto3" json:"targets,omitempty"` // contains filtered or unexported fields }
func (*DirectorMetas) Descriptor
deprecated
func (*DirectorMetas) Descriptor() ([]byte, []int)
Deprecated: Use DirectorMetas.ProtoReflect.Descriptor instead.
func (*DirectorMetas) GetRoots ¶
func (x *DirectorMetas) GetRoots() []*TopMeta
func (*DirectorMetas) GetSnapshot ¶
func (x *DirectorMetas) GetSnapshot() *TopMeta
func (*DirectorMetas) GetTargets ¶
func (x *DirectorMetas) GetTargets() *TopMeta
func (*DirectorMetas) GetTimestamp ¶
func (x *DirectorMetas) GetTimestamp() *TopMeta
func (*DirectorMetas) ProtoMessage ¶
func (*DirectorMetas) ProtoMessage()
func (*DirectorMetas) ProtoReflect ¶
func (x *DirectorMetas) ProtoReflect() protoreflect.Message
func (*DirectorMetas) Reset ¶
func (x *DirectorMetas) Reset()
func (*DirectorMetas) String ¶
func (x *DirectorMetas) String() string
type ECSLaunchType ¶
type ECSLaunchType int32
const ( ECSLaunchType_EC2 ECSLaunchType = 0 ECSLaunchType_FARGATE ECSLaunchType = 1 )
func (ECSLaunchType) Descriptor ¶
func (ECSLaunchType) Descriptor() protoreflect.EnumDescriptor
func (ECSLaunchType) Enum ¶
func (x ECSLaunchType) Enum() *ECSLaunchType
func (ECSLaunchType) EnumDescriptor
deprecated
func (ECSLaunchType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ECSLaunchType.Descriptor instead.
func (ECSLaunchType) Number ¶
func (x ECSLaunchType) Number() protoreflect.EnumNumber
func (ECSLaunchType) String ¶
func (x ECSLaunchType) String() string
func (ECSLaunchType) Type ¶
func (ECSLaunchType) Type() protoreflect.EnumType
type ECSTask ¶
type ECSTask struct { EntityId *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"` EntityMeta *EntityMeta `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ ContainerInstanceTags map[string]string `` /* 183-byte string literal not displayed */ ClusterName string `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"` Region string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"` AvailabilityZone string `protobuf:"bytes,7,opt,name=availabilityZone,proto3" json:"availabilityZone,omitempty"` Family string `protobuf:"bytes,8,opt,name=family,proto3" json:"family,omitempty"` Version string `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"` LaunchType ECSLaunchType `protobuf:"varint,10,opt,name=launchType,proto3,enum=datadog.workloadmeta.ECSLaunchType" json:"launchType,omitempty"` Containers []*OrchestratorContainer `protobuf:"bytes,11,rep,name=containers,proto3" json:"containers,omitempty"` // contains filtered or unexported fields }
func (*ECSTask) Descriptor
deprecated
func (*ECSTask) GetAvailabilityZone ¶
func (*ECSTask) GetClusterName ¶
func (*ECSTask) GetContainerInstanceTags ¶
func (*ECSTask) GetContainers ¶
func (x *ECSTask) GetContainers() []*OrchestratorContainer
func (*ECSTask) GetEntityId ¶
func (x *ECSTask) GetEntityId() *WorkloadmetaEntityId
func (*ECSTask) GetEntityMeta ¶
func (x *ECSTask) GetEntityMeta() *EntityMeta
func (*ECSTask) GetLaunchType ¶
func (x *ECSTask) GetLaunchType() ECSLaunchType
func (*ECSTask) GetVersion ¶
func (*ECSTask) ProtoMessage ¶
func (*ECSTask) ProtoMessage()
func (*ECSTask) ProtoReflect ¶
func (x *ECSTask) ProtoReflect() protoreflect.Message
type Entity ¶
type Entity struct { Id *EntityId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` HighCardinalityTags []string `protobuf:"bytes,3,rep,name=highCardinalityTags,proto3" json:"highCardinalityTags,omitempty"` OrchestratorCardinalityTags []string `protobuf:"bytes,4,rep,name=orchestratorCardinalityTags,proto3" json:"orchestratorCardinalityTags,omitempty"` LowCardinalityTags []string `protobuf:"bytes,5,rep,name=lowCardinalityTags,proto3" json:"lowCardinalityTags,omitempty"` StandardTags []string `protobuf:"bytes,6,rep,name=standardTags,proto3" json:"standardTags,omitempty"` // contains filtered or unexported fields }
func (*Entity) Descriptor
deprecated
func (*Entity) GetHighCardinalityTags ¶
func (*Entity) GetLowCardinalityTags ¶
func (*Entity) GetOrchestratorCardinalityTags ¶
func (*Entity) GetStandardTags ¶
func (*Entity) ProtoMessage ¶
func (*Entity) ProtoMessage()
func (*Entity) ProtoReflect ¶
func (x *Entity) ProtoReflect() protoreflect.Message
type EntityId ¶
type EntityId struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*EntityId) Descriptor
deprecated
func (*EntityId) ProtoMessage ¶
func (*EntityId) ProtoMessage()
func (*EntityId) ProtoReflect ¶
func (x *EntityId) ProtoReflect() protoreflect.Message
type EntityMeta ¶
type EntityMeta struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Annotations map[string]string `` /* 163-byte string literal not displayed */ Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EntityMeta) Descriptor
deprecated
func (*EntityMeta) Descriptor() ([]byte, []int)
Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.
func (*EntityMeta) GetAnnotations ¶
func (x *EntityMeta) GetAnnotations() map[string]string
func (*EntityMeta) GetLabels ¶
func (x *EntityMeta) GetLabels() map[string]string
func (*EntityMeta) GetName ¶
func (x *EntityMeta) GetName() string
func (*EntityMeta) GetNamespace ¶
func (x *EntityMeta) GetNamespace() string
func (*EntityMeta) ProtoMessage ¶
func (*EntityMeta) ProtoMessage()
func (*EntityMeta) ProtoReflect ¶
func (x *EntityMeta) ProtoReflect() protoreflect.Message
func (*EntityMeta) Reset ¶
func (x *EntityMeta) Reset()
func (*EntityMeta) String ¶
func (x *EntityMeta) String() string
type EventType ¶
type EventType int32
func (EventType) Descriptor ¶
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
func (EventType) Number ¶
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶
func (EventType) Type() protoreflect.EnumType
type FetchEntityRequest ¶
type FetchEntityRequest struct { Id *EntityId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Cardinality TagCardinality `protobuf:"varint,2,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"` // contains filtered or unexported fields }
func (*FetchEntityRequest) Descriptor
deprecated
func (*FetchEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchEntityRequest.ProtoReflect.Descriptor instead.
func (*FetchEntityRequest) GetCardinality ¶
func (x *FetchEntityRequest) GetCardinality() TagCardinality
func (*FetchEntityRequest) GetId ¶
func (x *FetchEntityRequest) GetId() *EntityId
func (*FetchEntityRequest) ProtoMessage ¶
func (*FetchEntityRequest) ProtoMessage()
func (*FetchEntityRequest) ProtoReflect ¶
func (x *FetchEntityRequest) ProtoReflect() protoreflect.Message
func (*FetchEntityRequest) Reset ¶
func (x *FetchEntityRequest) Reset()
func (*FetchEntityRequest) String ¶
func (x *FetchEntityRequest) String() string
type FetchEntityResponse ¶
type FetchEntityResponse struct { Id *EntityId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Cardinality TagCardinality `protobuf:"varint,2,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*FetchEntityResponse) Descriptor
deprecated
func (*FetchEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchEntityResponse.ProtoReflect.Descriptor instead.
func (*FetchEntityResponse) GetCardinality ¶
func (x *FetchEntityResponse) GetCardinality() TagCardinality
func (*FetchEntityResponse) GetId ¶
func (x *FetchEntityResponse) GetId() *EntityId
func (*FetchEntityResponse) GetTags ¶
func (x *FetchEntityResponse) GetTags() []string
func (*FetchEntityResponse) ProtoMessage ¶
func (*FetchEntityResponse) ProtoMessage()
func (*FetchEntityResponse) ProtoReflect ¶
func (x *FetchEntityResponse) ProtoReflect() protoreflect.Message
func (*FetchEntityResponse) Reset ¶
func (x *FetchEntityResponse) Reset()
func (*FetchEntityResponse) String ¶
func (x *FetchEntityResponse) String() string
type File ¶
type File struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Raw []byte `protobuf:"bytes,2,opt,name=raw,proto3" json:"raw,omitempty"` // contains filtered or unexported fields }
func (*File) Descriptor
deprecated
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) ProtoReflect ¶
func (x *File) ProtoReflect() protoreflect.Message
type FileMetaState ¶
type FileMetaState struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*FileMetaState) Descriptor
deprecated
func (*FileMetaState) Descriptor() ([]byte, []int)
Deprecated: Use FileMetaState.ProtoReflect.Descriptor instead.
func (*FileMetaState) GetHash ¶
func (x *FileMetaState) GetHash() string
func (*FileMetaState) GetVersion ¶
func (x *FileMetaState) GetVersion() uint64
func (*FileMetaState) ProtoMessage ¶
func (*FileMetaState) ProtoMessage()
func (*FileMetaState) ProtoReflect ¶
func (x *FileMetaState) ProtoReflect() protoreflect.Message
func (*FileMetaState) Reset ¶
func (x *FileMetaState) Reset()
func (*FileMetaState) String ¶
func (x *FileMetaState) String() string
type Filter ¶
type Filter struct { KubeNamespace string `protobuf:"bytes,1,opt,name=kubeNamespace,proto3" json:"kubeNamespace,omitempty"` Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"` ContainerName string `protobuf:"bytes,3,opt,name=containerName,proto3" json:"containerName,omitempty"` // contains filtered or unexported fields }
func (*Filter) Descriptor
deprecated
func (*Filter) GetContainerName ¶
func (*Filter) GetKubeNamespace ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type GetStateConfigResponse ¶
type GetStateConfigResponse struct { ConfigState map[string]*FileMetaState `` /* 182-byte string literal not displayed */ DirectorState map[string]*FileMetaState `` /* 188-byte string literal not displayed */ TargetFilenames map[string]string `` /* 194-byte string literal not displayed */ ActiveClients []*Client `protobuf:"bytes,4,rep,name=active_clients,json=activeClients,proto3" json:"active_clients,omitempty"` // contains filtered or unexported fields }
func (*GetStateConfigResponse) Descriptor
deprecated
func (*GetStateConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStateConfigResponse.ProtoReflect.Descriptor instead.
func (*GetStateConfigResponse) GetActiveClients ¶
func (x *GetStateConfigResponse) GetActiveClients() []*Client
func (*GetStateConfigResponse) GetConfigState ¶
func (x *GetStateConfigResponse) GetConfigState() map[string]*FileMetaState
func (*GetStateConfigResponse) GetDirectorState ¶
func (x *GetStateConfigResponse) GetDirectorState() map[string]*FileMetaState
func (*GetStateConfigResponse) GetTargetFilenames ¶
func (x *GetStateConfigResponse) GetTargetFilenames() map[string]string
func (*GetStateConfigResponse) ProtoMessage ¶
func (*GetStateConfigResponse) ProtoMessage()
func (*GetStateConfigResponse) ProtoReflect ¶
func (x *GetStateConfigResponse) ProtoReflect() protoreflect.Message
func (*GetStateConfigResponse) Reset ¶
func (x *GetStateConfigResponse) Reset()
func (*GetStateConfigResponse) String ¶
func (x *GetStateConfigResponse) String() string
type HostnameReply ¶
type HostnameReply struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // contains filtered or unexported fields }
The response message containing the requested hostname
func (*HostnameReply) Descriptor
deprecated
func (*HostnameReply) Descriptor() ([]byte, []int)
Deprecated: Use HostnameReply.ProtoReflect.Descriptor instead.
func (*HostnameReply) GetHostname ¶
func (x *HostnameReply) GetHostname() string
func (*HostnameReply) ProtoMessage ¶
func (*HostnameReply) ProtoMessage()
func (*HostnameReply) ProtoReflect ¶
func (x *HostnameReply) ProtoReflect() protoreflect.Message
func (*HostnameReply) Reset ¶
func (x *HostnameReply) Reset()
func (*HostnameReply) String ¶
func (x *HostnameReply) String() string
type HostnameRequest ¶
type HostnameRequest struct {
// contains filtered or unexported fields
}
func (*HostnameRequest) Descriptor
deprecated
func (*HostnameRequest) Descriptor() ([]byte, []int)
Deprecated: Use HostnameRequest.ProtoReflect.Descriptor instead.
func (*HostnameRequest) ProtoMessage ¶
func (*HostnameRequest) ProtoMessage()
func (*HostnameRequest) ProtoReflect ¶
func (x *HostnameRequest) ProtoReflect() protoreflect.Message
func (*HostnameRequest) Reset ¶
func (x *HostnameRequest) Reset()
func (*HostnameRequest) String ¶
func (x *HostnameRequest) String() string
type KubernetesPod ¶
type KubernetesPod struct { EntityId *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"` EntityMeta *EntityMeta `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"` Owners []*KubernetesPodOwner `protobuf:"bytes,3,rep,name=owners,proto3" json:"owners,omitempty"` PersistentVolumeClaimNames []string `protobuf:"bytes,4,rep,name=persistentVolumeClaimNames,proto3" json:"persistentVolumeClaimNames,omitempty"` Containers []*OrchestratorContainer `protobuf:"bytes,5,rep,name=containers,proto3" json:"containers,omitempty"` Ready bool `protobuf:"varint,6,opt,name=ready,proto3" json:"ready,omitempty"` Phase string `protobuf:"bytes,7,opt,name=phase,proto3" json:"phase,omitempty"` Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"` PriorityClass string `protobuf:"bytes,9,opt,name=priorityClass,proto3" json:"priorityClass,omitempty"` QosClass string `protobuf:"bytes,10,opt,name=qosClass,proto3" json:"qosClass,omitempty"` KubeServices []string `protobuf:"bytes,11,rep,name=kubeServices,proto3" json:"kubeServices,omitempty"` NamespaceLabels map[string]string `` /* 172-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KubernetesPod) Descriptor
deprecated
func (*KubernetesPod) Descriptor() ([]byte, []int)
Deprecated: Use KubernetesPod.ProtoReflect.Descriptor instead.
func (*KubernetesPod) GetContainers ¶
func (x *KubernetesPod) GetContainers() []*OrchestratorContainer
func (*KubernetesPod) GetEntityId ¶
func (x *KubernetesPod) GetEntityId() *WorkloadmetaEntityId
func (*KubernetesPod) GetEntityMeta ¶
func (x *KubernetesPod) GetEntityMeta() *EntityMeta
func (*KubernetesPod) GetIp ¶
func (x *KubernetesPod) GetIp() string
func (*KubernetesPod) GetKubeServices ¶
func (x *KubernetesPod) GetKubeServices() []string
func (*KubernetesPod) GetNamespaceLabels ¶
func (x *KubernetesPod) GetNamespaceLabels() map[string]string
func (*KubernetesPod) GetOwners ¶
func (x *KubernetesPod) GetOwners() []*KubernetesPodOwner
func (*KubernetesPod) GetPersistentVolumeClaimNames ¶
func (x *KubernetesPod) GetPersistentVolumeClaimNames() []string
func (*KubernetesPod) GetPhase ¶
func (x *KubernetesPod) GetPhase() string
func (*KubernetesPod) GetPriorityClass ¶
func (x *KubernetesPod) GetPriorityClass() string
func (*KubernetesPod) GetQosClass ¶
func (x *KubernetesPod) GetQosClass() string
func (*KubernetesPod) GetReady ¶
func (x *KubernetesPod) GetReady() bool
func (*KubernetesPod) ProtoMessage ¶
func (*KubernetesPod) ProtoMessage()
func (*KubernetesPod) ProtoReflect ¶
func (x *KubernetesPod) ProtoReflect() protoreflect.Message
func (*KubernetesPod) Reset ¶
func (x *KubernetesPod) Reset()
func (*KubernetesPod) String ¶
func (x *KubernetesPod) String() string
type KubernetesPodOwner ¶
type KubernetesPodOwner struct { Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*KubernetesPodOwner) Descriptor
deprecated
func (*KubernetesPodOwner) Descriptor() ([]byte, []int)
Deprecated: Use KubernetesPodOwner.ProtoReflect.Descriptor instead.
func (*KubernetesPodOwner) GetId ¶
func (x *KubernetesPodOwner) GetId() string
func (*KubernetesPodOwner) GetKind ¶
func (x *KubernetesPodOwner) GetKind() string
func (*KubernetesPodOwner) GetName ¶
func (x *KubernetesPodOwner) GetName() string
func (*KubernetesPodOwner) ProtoMessage ¶
func (*KubernetesPodOwner) ProtoMessage()
func (*KubernetesPodOwner) ProtoReflect ¶
func (x *KubernetesPodOwner) ProtoReflect() protoreflect.Message
func (*KubernetesPodOwner) Reset ¶
func (x *KubernetesPodOwner) Reset()
func (*KubernetesPodOwner) String ¶
func (x *KubernetesPodOwner) String() string
type Language ¶ added in v0.47.0
type Language struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Language) Descriptor
deprecated
added in
v0.47.0
func (*Language) ProtoMessage ¶ added in v0.47.0
func (*Language) ProtoMessage()
func (*Language) ProtoReflect ¶ added in v0.47.0
func (x *Language) ProtoReflect() protoreflect.Message
type LatestConfigsRequest ¶
type LatestConfigsRequest struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` AgentVersion string `protobuf:"bytes,2,opt,name=agentVersion,proto3" json:"agentVersion,omitempty"` // timestamp and snapshot versions move in tandem so they are the same. CurrentConfigSnapshotVersion uint64 `` /* 150-byte string literal not displayed */ CurrentConfigRootVersion uint64 `` /* 138-byte string literal not displayed */ CurrentDirectorRootVersion uint64 `` /* 144-byte string literal not displayed */ Products []string `protobuf:"bytes,4,rep,name=products,proto3" json:"products,omitempty"` NewProducts []string `protobuf:"bytes,5,rep,name=new_products,json=newProducts,proto3" json:"new_products,omitempty"` ActiveClients []*Client `protobuf:"bytes,6,rep,name=active_clients,json=activeClients,proto3" json:"active_clients,omitempty"` BackendClientState []byte `protobuf:"bytes,10,opt,name=backend_client_state,json=backendClientState,proto3" json:"backend_client_state,omitempty"` HasError bool `protobuf:"varint,11,opt,name=has_error,json=hasError,proto3" json:"has_error,omitempty"` Error string `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"` TraceAgentEnv string `protobuf:"bytes,13,opt,name=trace_agent_env,json=traceAgentEnv,proto3" json:"trace_agent_env,omitempty"` OrgUuid string `protobuf:"bytes,14,opt,name=org_uuid,json=orgUuid,proto3" json:"org_uuid,omitempty"` // contains filtered or unexported fields }
func (*LatestConfigsRequest) Descriptor
deprecated
func (*LatestConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LatestConfigsRequest.ProtoReflect.Descriptor instead.
func (*LatestConfigsRequest) GetActiveClients ¶
func (x *LatestConfigsRequest) GetActiveClients() []*Client
func (*LatestConfigsRequest) GetAgentVersion ¶
func (x *LatestConfigsRequest) GetAgentVersion() string
func (*LatestConfigsRequest) GetBackendClientState ¶
func (x *LatestConfigsRequest) GetBackendClientState() []byte
func (*LatestConfigsRequest) GetCurrentConfigRootVersion ¶
func (x *LatestConfigsRequest) GetCurrentConfigRootVersion() uint64
func (*LatestConfigsRequest) GetCurrentConfigSnapshotVersion ¶
func (x *LatestConfigsRequest) GetCurrentConfigSnapshotVersion() uint64
func (*LatestConfigsRequest) GetCurrentDirectorRootVersion ¶
func (x *LatestConfigsRequest) GetCurrentDirectorRootVersion() uint64
func (*LatestConfigsRequest) GetError ¶
func (x *LatestConfigsRequest) GetError() string
func (*LatestConfigsRequest) GetHasError ¶
func (x *LatestConfigsRequest) GetHasError() bool
func (*LatestConfigsRequest) GetHostname ¶
func (x *LatestConfigsRequest) GetHostname() string
func (*LatestConfigsRequest) GetNewProducts ¶
func (x *LatestConfigsRequest) GetNewProducts() []string
func (*LatestConfigsRequest) GetOrgUuid ¶
func (x *LatestConfigsRequest) GetOrgUuid() string
func (*LatestConfigsRequest) GetProducts ¶
func (x *LatestConfigsRequest) GetProducts() []string
func (*LatestConfigsRequest) GetTraceAgentEnv ¶
func (x *LatestConfigsRequest) GetTraceAgentEnv() string
func (*LatestConfigsRequest) ProtoMessage ¶
func (*LatestConfigsRequest) ProtoMessage()
func (*LatestConfigsRequest) ProtoReflect ¶
func (x *LatestConfigsRequest) ProtoReflect() protoreflect.Message
func (*LatestConfigsRequest) Reset ¶
func (x *LatestConfigsRequest) Reset()
func (*LatestConfigsRequest) String ¶
func (x *LatestConfigsRequest) String() string
type LatestConfigsResponse ¶
type LatestConfigsResponse struct { ConfigMetas *ConfigMetas `protobuf:"bytes,1,opt,name=config_metas,json=configMetas,proto3" json:"config_metas,omitempty"` DirectorMetas *DirectorMetas `protobuf:"bytes,2,opt,name=director_metas,json=directorMetas,proto3" json:"director_metas,omitempty"` TargetFiles []*File `protobuf:"bytes,3,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"` // contains filtered or unexported fields }
func (*LatestConfigsResponse) Descriptor
deprecated
func (*LatestConfigsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LatestConfigsResponse.ProtoReflect.Descriptor instead.
func (*LatestConfigsResponse) GetConfigMetas ¶
func (x *LatestConfigsResponse) GetConfigMetas() *ConfigMetas
func (*LatestConfigsResponse) GetDirectorMetas ¶
func (x *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas
func (*LatestConfigsResponse) GetTargetFiles ¶
func (x *LatestConfigsResponse) GetTargetFiles() []*File
func (*LatestConfigsResponse) ProtoMessage ¶
func (*LatestConfigsResponse) ProtoMessage()
func (*LatestConfigsResponse) ProtoReflect ¶
func (x *LatestConfigsResponse) ProtoReflect() protoreflect.Message
func (*LatestConfigsResponse) Reset ¶
func (x *LatestConfigsResponse) Reset()
func (*LatestConfigsResponse) String ¶
func (x *LatestConfigsResponse) String() string
type OrchestratorContainer ¶
type OrchestratorContainer 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"` Image *ContainerImage `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"` // contains filtered or unexported fields }
func (*OrchestratorContainer) Descriptor
deprecated
func (*OrchestratorContainer) Descriptor() ([]byte, []int)
Deprecated: Use OrchestratorContainer.ProtoReflect.Descriptor instead.
func (*OrchestratorContainer) GetId ¶
func (x *OrchestratorContainer) GetId() string
func (*OrchestratorContainer) GetImage ¶
func (x *OrchestratorContainer) GetImage() *ContainerImage
func (*OrchestratorContainer) GetName ¶
func (x *OrchestratorContainer) GetName() string
func (*OrchestratorContainer) ProtoMessage ¶
func (*OrchestratorContainer) ProtoMessage()
func (*OrchestratorContainer) ProtoReflect ¶
func (x *OrchestratorContainer) ProtoReflect() protoreflect.Message
func (*OrchestratorContainer) Reset ¶
func (x *OrchestratorContainer) Reset()
func (*OrchestratorContainer) String ¶
func (x *OrchestratorContainer) String() string
type OrgDataResponse ¶
type OrgDataResponse struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // contains filtered or unexported fields }
func (*OrgDataResponse) Descriptor
deprecated
func (*OrgDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use OrgDataResponse.ProtoReflect.Descriptor instead.
func (*OrgDataResponse) GetUuid ¶
func (x *OrgDataResponse) GetUuid() string
func (*OrgDataResponse) ProtoMessage ¶
func (*OrgDataResponse) ProtoMessage()
func (*OrgDataResponse) ProtoReflect ¶
func (x *OrgDataResponse) ProtoReflect() protoreflect.Message
func (*OrgDataResponse) Reset ¶
func (x *OrgDataResponse) Reset()
func (*OrgDataResponse) String ¶
func (x *OrgDataResponse) String() string
type OrgStatusResponse ¶ added in v0.47.0
type OrgStatusResponse struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` Authorized bool `protobuf:"varint,2,opt,name=authorized,proto3" json:"authorized,omitempty"` // contains filtered or unexported fields }
func (*OrgStatusResponse) Descriptor
deprecated
added in
v0.47.0
func (*OrgStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use OrgStatusResponse.ProtoReflect.Descriptor instead.
func (*OrgStatusResponse) GetAuthorized ¶ added in v0.47.0
func (x *OrgStatusResponse) GetAuthorized() bool
func (*OrgStatusResponse) GetEnabled ¶ added in v0.47.0
func (x *OrgStatusResponse) GetEnabled() bool
func (*OrgStatusResponse) ProtoMessage ¶ added in v0.47.0
func (*OrgStatusResponse) ProtoMessage()
func (*OrgStatusResponse) ProtoReflect ¶ added in v0.47.0
func (x *OrgStatusResponse) ProtoReflect() protoreflect.Message
func (*OrgStatusResponse) Reset ¶ added in v0.47.0
func (x *OrgStatusResponse) Reset()
func (*OrgStatusResponse) String ¶ added in v0.47.0
func (x *OrgStatusResponse) String() string
type ProcessEntityStreamClient ¶ added in v0.47.0
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 ¶ added in v0.47.0
func NewProcessEntityStreamClient(cc grpc.ClientConnInterface) ProcessEntityStreamClient
type ProcessEntityStreamServer ¶ added in v0.47.0
type ProcessEntityStreamServer interface {
StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error
}
ProcessEntityStreamServer is the server API for ProcessEntityStream service.
type ProcessEntityStream_StreamEntitiesClient ¶ added in v0.47.0
type ProcessEntityStream_StreamEntitiesClient interface { Recv() (*ProcessStreamResponse, error) grpc.ClientStream }
type ProcessEntityStream_StreamEntitiesServer ¶ added in v0.47.0
type ProcessEntityStream_StreamEntitiesServer interface { Send(*ProcessStreamResponse) error grpc.ServerStream }
type ProcessEventSet ¶ added in v0.47.0
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
added in
v0.47.0
func (*ProcessEventSet) Descriptor() ([]byte, []int)
Deprecated: Use ProcessEventSet.ProtoReflect.Descriptor instead.
func (*ProcessEventSet) GetContainerId ¶ added in v0.47.0
func (x *ProcessEventSet) GetContainerId() string
func (*ProcessEventSet) GetCreationTime ¶ added in v0.47.0
func (x *ProcessEventSet) GetCreationTime() int64
func (*ProcessEventSet) GetLanguage ¶ added in v0.47.0
func (x *ProcessEventSet) GetLanguage() *Language
func (*ProcessEventSet) GetNspid ¶ added in v0.47.0
func (x *ProcessEventSet) GetNspid() int32
func (*ProcessEventSet) GetPid ¶ added in v0.47.0
func (x *ProcessEventSet) GetPid() int32
func (*ProcessEventSet) ProtoMessage ¶ added in v0.47.0
func (*ProcessEventSet) ProtoMessage()
func (*ProcessEventSet) ProtoReflect ¶ added in v0.47.0
func (x *ProcessEventSet) ProtoReflect() protoreflect.Message
func (*ProcessEventSet) Reset ¶ added in v0.47.0
func (x *ProcessEventSet) Reset()
func (*ProcessEventSet) String ¶ added in v0.47.0
func (x *ProcessEventSet) String() string
type ProcessEventUnset ¶ added in v0.47.0
type ProcessEventUnset struct { Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` // contains filtered or unexported fields }
func (*ProcessEventUnset) Descriptor
deprecated
added in
v0.47.0
func (*ProcessEventUnset) Descriptor() ([]byte, []int)
Deprecated: Use ProcessEventUnset.ProtoReflect.Descriptor instead.
func (*ProcessEventUnset) GetPid ¶ added in v0.47.0
func (x *ProcessEventUnset) GetPid() int32
func (*ProcessEventUnset) ProtoMessage ¶ added in v0.47.0
func (*ProcessEventUnset) ProtoMessage()
func (*ProcessEventUnset) ProtoReflect ¶ added in v0.47.0
func (x *ProcessEventUnset) ProtoReflect() protoreflect.Message
func (*ProcessEventUnset) Reset ¶ added in v0.47.0
func (x *ProcessEventUnset) Reset()
func (*ProcessEventUnset) String ¶ added in v0.47.0
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 ¶ added in v0.47.0
type ProcessStreamEntitiesRequest struct {
// contains filtered or unexported fields
}
func (*ProcessStreamEntitiesRequest) Descriptor
deprecated
added in
v0.47.0
func (*ProcessStreamEntitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessStreamEntitiesRequest.ProtoReflect.Descriptor instead.
func (*ProcessStreamEntitiesRequest) ProtoMessage ¶ added in v0.47.0
func (*ProcessStreamEntitiesRequest) ProtoMessage()
func (*ProcessStreamEntitiesRequest) ProtoReflect ¶ added in v0.47.0
func (x *ProcessStreamEntitiesRequest) ProtoReflect() protoreflect.Message
func (*ProcessStreamEntitiesRequest) Reset ¶ added in v0.47.0
func (x *ProcessStreamEntitiesRequest) Reset()
func (*ProcessStreamEntitiesRequest) String ¶ added in v0.47.0
func (x *ProcessStreamEntitiesRequest) String() string
type ProcessStreamResponse ¶ added in v0.47.0
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
added in
v0.47.0
func (*ProcessStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessStreamResponse.ProtoReflect.Descriptor instead.
func (*ProcessStreamResponse) GetEventID ¶ added in v0.47.0
func (x *ProcessStreamResponse) GetEventID() int32
func (*ProcessStreamResponse) GetSetEvents ¶ added in v0.47.0
func (x *ProcessStreamResponse) GetSetEvents() []*ProcessEventSet
func (*ProcessStreamResponse) GetUnsetEvents ¶ added in v0.47.0
func (x *ProcessStreamResponse) GetUnsetEvents() []*ProcessEventUnset
func (*ProcessStreamResponse) ProtoMessage ¶ added in v0.47.0
func (*ProcessStreamResponse) ProtoMessage()
func (*ProcessStreamResponse) ProtoReflect ¶ added in v0.47.0
func (x *ProcessStreamResponse) ProtoReflect() protoreflect.Message
func (*ProcessStreamResponse) Reset ¶ added in v0.47.0
func (x *ProcessStreamResponse) Reset()
func (*ProcessStreamResponse) String ¶ added in v0.47.0
func (x *ProcessStreamResponse) String() string
type Runtime ¶
type Runtime int32
func (Runtime) Descriptor ¶
func (Runtime) Descriptor() protoreflect.EnumDescriptor
func (Runtime) EnumDescriptor
deprecated
func (Runtime) Number ¶
func (x Runtime) Number() protoreflect.EnumNumber
func (Runtime) Type ¶
func (Runtime) Type() protoreflect.EnumType
type StreamTagsEvent ¶
type StreamTagsEvent struct { Type EventType `protobuf:"varint,1,opt,name=type,proto3,enum=datadog.model.v1.EventType" json:"type,omitempty"` Entity *Entity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"` // contains filtered or unexported fields }
func (*StreamTagsEvent) Descriptor
deprecated
func (*StreamTagsEvent) Descriptor() ([]byte, []int)
Deprecated: Use StreamTagsEvent.ProtoReflect.Descriptor instead.
func (*StreamTagsEvent) GetEntity ¶
func (x *StreamTagsEvent) GetEntity() *Entity
func (*StreamTagsEvent) GetType ¶
func (x *StreamTagsEvent) GetType() EventType
func (*StreamTagsEvent) ProtoMessage ¶
func (*StreamTagsEvent) ProtoMessage()
func (*StreamTagsEvent) ProtoReflect ¶
func (x *StreamTagsEvent) ProtoReflect() protoreflect.Message
func (*StreamTagsEvent) Reset ¶
func (x *StreamTagsEvent) Reset()
func (*StreamTagsEvent) String ¶
func (x *StreamTagsEvent) String() string
type StreamTagsRequest ¶
type StreamTagsRequest struct { Cardinality TagCardinality `protobuf:"varint,1,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"` IncludeFilter *Filter `protobuf:"bytes,2,opt,name=includeFilter,proto3" json:"includeFilter,omitempty"` ExcludeFilter *Filter `protobuf:"bytes,3,opt,name=excludeFilter,proto3" json:"excludeFilter,omitempty"` // contains filtered or unexported fields }
func (*StreamTagsRequest) Descriptor
deprecated
func (*StreamTagsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamTagsRequest.ProtoReflect.Descriptor instead.
func (*StreamTagsRequest) GetCardinality ¶
func (x *StreamTagsRequest) GetCardinality() TagCardinality
func (*StreamTagsRequest) GetExcludeFilter ¶
func (x *StreamTagsRequest) GetExcludeFilter() *Filter
func (*StreamTagsRequest) GetIncludeFilter ¶
func (x *StreamTagsRequest) GetIncludeFilter() *Filter
func (*StreamTagsRequest) ProtoMessage ¶
func (*StreamTagsRequest) ProtoMessage()
func (*StreamTagsRequest) ProtoReflect ¶
func (x *StreamTagsRequest) ProtoReflect() protoreflect.Message
func (*StreamTagsRequest) Reset ¶
func (x *StreamTagsRequest) Reset()
func (*StreamTagsRequest) String ¶
func (x *StreamTagsRequest) String() string
type StreamTagsResponse ¶
type StreamTagsResponse struct { Events []*StreamTagsEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*StreamTagsResponse) Descriptor
deprecated
func (*StreamTagsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamTagsResponse.ProtoReflect.Descriptor instead.
func (*StreamTagsResponse) GetEvents ¶
func (x *StreamTagsResponse) GetEvents() []*StreamTagsEvent
func (*StreamTagsResponse) ProtoMessage ¶
func (*StreamTagsResponse) ProtoMessage()
func (*StreamTagsResponse) ProtoReflect ¶
func (x *StreamTagsResponse) ProtoReflect() protoreflect.Message
func (*StreamTagsResponse) Reset ¶
func (x *StreamTagsResponse) Reset()
func (*StreamTagsResponse) String ¶
func (x *StreamTagsResponse) String() string
type TagCardinality ¶
type TagCardinality int32
const ( TagCardinality_LOW TagCardinality = 0 TagCardinality_ORCHESTRATOR TagCardinality = 1 TagCardinality_HIGH TagCardinality = 2 )
func (TagCardinality) Descriptor ¶
func (TagCardinality) Descriptor() protoreflect.EnumDescriptor
func (TagCardinality) Enum ¶
func (x TagCardinality) Enum() *TagCardinality
func (TagCardinality) EnumDescriptor
deprecated
func (TagCardinality) EnumDescriptor() ([]byte, []int)
Deprecated: Use TagCardinality.Descriptor instead.
func (TagCardinality) Number ¶
func (x TagCardinality) Number() protoreflect.EnumNumber
func (TagCardinality) String ¶
func (x TagCardinality) String() string
func (TagCardinality) Type ¶
func (TagCardinality) Type() protoreflect.EnumType
type TaggerState ¶
type TaggerState struct { State map[string]*Entity `` /* 151-byte string literal not displayed */ PidMap map[int32]string `` /* 154-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TaggerState) Descriptor
deprecated
func (*TaggerState) Descriptor() ([]byte, []int)
Deprecated: Use TaggerState.ProtoReflect.Descriptor instead.
func (*TaggerState) GetPidMap ¶
func (x *TaggerState) GetPidMap() map[int32]string
func (*TaggerState) GetState ¶
func (x *TaggerState) GetState() map[string]*Entity
func (*TaggerState) ProtoMessage ¶
func (*TaggerState) ProtoMessage()
func (*TaggerState) ProtoReflect ¶
func (x *TaggerState) ProtoReflect() protoreflect.Message
func (*TaggerState) Reset ¶
func (x *TaggerState) Reset()
func (*TaggerState) String ¶
func (x *TaggerState) String() string
type TaggerStateResponse ¶
type TaggerStateResponse struct { Loaded bool `protobuf:"varint,1,opt,name=loaded,proto3" json:"loaded,omitempty"` // contains filtered or unexported fields }
func (*TaggerStateResponse) Descriptor
deprecated
func (*TaggerStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaggerStateResponse.ProtoReflect.Descriptor instead.
func (*TaggerStateResponse) GetLoaded ¶
func (x *TaggerStateResponse) GetLoaded() bool
func (*TaggerStateResponse) ProtoMessage ¶
func (*TaggerStateResponse) ProtoMessage()
func (*TaggerStateResponse) ProtoReflect ¶
func (x *TaggerStateResponse) ProtoReflect() protoreflect.Message
func (*TaggerStateResponse) Reset ¶
func (x *TaggerStateResponse) Reset()
func (*TaggerStateResponse) String ¶
func (x *TaggerStateResponse) String() string
type TargetFileHash ¶
type TargetFileHash struct { Algorithm string `protobuf:"bytes,1,opt,name=algorithm,proto3" json:"algorithm,omitempty"` Hash string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*TargetFileHash) Descriptor
deprecated
func (*TargetFileHash) Descriptor() ([]byte, []int)
Deprecated: Use TargetFileHash.ProtoReflect.Descriptor instead.
func (*TargetFileHash) GetAlgorithm ¶
func (x *TargetFileHash) GetAlgorithm() string
func (*TargetFileHash) GetHash ¶
func (x *TargetFileHash) GetHash() string
func (*TargetFileHash) ProtoMessage ¶
func (*TargetFileHash) ProtoMessage()
func (*TargetFileHash) ProtoReflect ¶
func (x *TargetFileHash) ProtoReflect() protoreflect.Message
func (*TargetFileHash) Reset ¶
func (x *TargetFileHash) Reset()
func (*TargetFileHash) String ¶
func (x *TargetFileHash) String() string
type TargetFileMeta ¶
type TargetFileMeta struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Length int64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"` Hashes []*TargetFileHash `protobuf:"bytes,3,rep,name=hashes,proto3" json:"hashes,omitempty"` // contains filtered or unexported fields }
func (*TargetFileMeta) Descriptor
deprecated
func (*TargetFileMeta) Descriptor() ([]byte, []int)
Deprecated: Use TargetFileMeta.ProtoReflect.Descriptor instead.
func (*TargetFileMeta) GetHashes ¶
func (x *TargetFileMeta) GetHashes() []*TargetFileHash
func (*TargetFileMeta) GetLength ¶
func (x *TargetFileMeta) GetLength() int64
func (*TargetFileMeta) GetPath ¶
func (x *TargetFileMeta) GetPath() string
func (*TargetFileMeta) ProtoMessage ¶
func (*TargetFileMeta) ProtoMessage()
func (*TargetFileMeta) ProtoReflect ¶
func (x *TargetFileMeta) ProtoReflect() protoreflect.Message
func (*TargetFileMeta) Reset ¶
func (x *TargetFileMeta) Reset()
func (*TargetFileMeta) String ¶
func (x *TargetFileMeta) String() string
type TopMeta ¶
type TopMeta struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Raw []byte `protobuf:"bytes,2,opt,name=raw,proto3" json:"raw,omitempty"` // contains filtered or unexported fields }
func (*TopMeta) Descriptor
deprecated
func (*TopMeta) GetVersion ¶
func (*TopMeta) ProtoMessage ¶
func (*TopMeta) ProtoMessage()
func (*TopMeta) ProtoReflect ¶
func (x *TopMeta) ProtoReflect() protoreflect.Message
type TracerPredicateV1 ¶
type TracerPredicateV1 struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` Environment string `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"` AppVersion string `protobuf:"bytes,4,opt,name=appVersion,proto3" json:"appVersion,omitempty"` TracerVersion string `protobuf:"bytes,5,opt,name=tracerVersion,proto3" json:"tracerVersion,omitempty"` Language string `protobuf:"bytes,6,opt,name=language,proto3" json:"language,omitempty"` RuntimeID string `protobuf:"bytes,7,opt,name=runtimeID,proto3" json:"runtimeID,omitempty"` // contains filtered or unexported fields }
func (*TracerPredicateV1) Descriptor
deprecated
func (*TracerPredicateV1) Descriptor() ([]byte, []int)
Deprecated: Use TracerPredicateV1.ProtoReflect.Descriptor instead.
func (*TracerPredicateV1) GetAppVersion ¶
func (x *TracerPredicateV1) GetAppVersion() string
func (*TracerPredicateV1) GetClientID ¶
func (x *TracerPredicateV1) GetClientID() string
func (*TracerPredicateV1) GetEnvironment ¶
func (x *TracerPredicateV1) GetEnvironment() string
func (*TracerPredicateV1) GetLanguage ¶
func (x *TracerPredicateV1) GetLanguage() string
func (*TracerPredicateV1) GetRuntimeID ¶
func (x *TracerPredicateV1) GetRuntimeID() string
func (*TracerPredicateV1) GetService ¶
func (x *TracerPredicateV1) GetService() string
func (*TracerPredicateV1) GetTracerVersion ¶
func (x *TracerPredicateV1) GetTracerVersion() string
func (*TracerPredicateV1) ProtoMessage ¶
func (*TracerPredicateV1) ProtoMessage()
func (*TracerPredicateV1) ProtoReflect ¶
func (x *TracerPredicateV1) ProtoReflect() protoreflect.Message
func (*TracerPredicateV1) Reset ¶
func (x *TracerPredicateV1) Reset()
func (*TracerPredicateV1) String ¶
func (x *TracerPredicateV1) String() string
type TracerPredicates ¶
type TracerPredicates struct { TracerPredicatesV1 []*TracerPredicateV1 `protobuf:"bytes,1,rep,name=tracer_predicates_v1,json=tracerPredicatesV1,proto3" json:"tracer_predicates_v1,omitempty"` // contains filtered or unexported fields }
func (*TracerPredicates) Descriptor
deprecated
func (*TracerPredicates) Descriptor() ([]byte, []int)
Deprecated: Use TracerPredicates.ProtoReflect.Descriptor instead.
func (*TracerPredicates) GetTracerPredicatesV1 ¶
func (x *TracerPredicates) GetTracerPredicatesV1() []*TracerPredicateV1
func (*TracerPredicates) ProtoMessage ¶
func (*TracerPredicates) ProtoMessage()
func (*TracerPredicates) ProtoReflect ¶
func (x *TracerPredicates) ProtoReflect() protoreflect.Message
func (*TracerPredicates) Reset ¶
func (x *TracerPredicates) Reset()
func (*TracerPredicates) String ¶
func (x *TracerPredicates) String() string
type UnimplementedAgentSecureServer ¶
type UnimplementedAgentSecureServer struct { }
UnimplementedAgentSecureServer can be embedded to have forward compatible implementations.
func (*UnimplementedAgentSecureServer) ClientGetConfigs ¶
func (*UnimplementedAgentSecureServer) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger ¶
func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)
func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState ¶
func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)
func (*UnimplementedAgentSecureServer) GetConfigState ¶
func (*UnimplementedAgentSecureServer) GetConfigState(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
func (*UnimplementedAgentSecureServer) TaggerFetchEntity ¶
func (*UnimplementedAgentSecureServer) TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
func (*UnimplementedAgentSecureServer) TaggerStreamEntities ¶
func (*UnimplementedAgentSecureServer) TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error
func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities ¶
func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, AgentSecure_WorkloadmetaStreamEntitiesServer) error
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct { }
UnimplementedAgentServer can be embedded to have forward compatible implementations.
func (*UnimplementedAgentServer) GetHostname ¶
func (*UnimplementedAgentServer) GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error)
type UnimplementedProcessEntityStreamServer ¶ added in v0.47.0
type UnimplementedProcessEntityStreamServer struct { }
UnimplementedProcessEntityStreamServer can be embedded to have forward compatible implementations.
func (*UnimplementedProcessEntityStreamServer) StreamEntities ¶ added in v0.47.0
func (*UnimplementedProcessEntityStreamServer) StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error
type UnixDogstatsdMsg ¶
type UnixDogstatsdMsg struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` PayloadSize int32 `protobuf:"varint,2,opt,name=payloadSize,proto3" json:"payloadSize,omitempty"` Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` Pid int32 `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"` AncillarySize int32 `protobuf:"varint,5,opt,name=ancillarySize,proto3" json:"ancillarySize,omitempty"` Ancillary []byte `protobuf:"bytes,6,opt,name=ancillary,proto3" json:"ancillary,omitempty"` // contains filtered or unexported fields }
UDS Capture The message contains the payload and the ancillary info
func (*UnixDogstatsdMsg) Descriptor
deprecated
func (*UnixDogstatsdMsg) Descriptor() ([]byte, []int)
Deprecated: Use UnixDogstatsdMsg.ProtoReflect.Descriptor instead.
func (*UnixDogstatsdMsg) GetAncillary ¶
func (x *UnixDogstatsdMsg) GetAncillary() []byte
func (*UnixDogstatsdMsg) GetAncillarySize ¶
func (x *UnixDogstatsdMsg) GetAncillarySize() int32
func (*UnixDogstatsdMsg) GetPayload ¶
func (x *UnixDogstatsdMsg) GetPayload() []byte
func (*UnixDogstatsdMsg) GetPayloadSize ¶
func (x *UnixDogstatsdMsg) GetPayloadSize() int32
func (*UnixDogstatsdMsg) GetPid ¶
func (x *UnixDogstatsdMsg) GetPid() int32
func (*UnixDogstatsdMsg) GetTimestamp ¶
func (x *UnixDogstatsdMsg) GetTimestamp() int64
func (*UnixDogstatsdMsg) ProtoMessage ¶
func (*UnixDogstatsdMsg) ProtoMessage()
func (*UnixDogstatsdMsg) ProtoReflect ¶
func (x *UnixDogstatsdMsg) ProtoReflect() protoreflect.Message
func (*UnixDogstatsdMsg) Reset ¶
func (x *UnixDogstatsdMsg) Reset()
func (*UnixDogstatsdMsg) String ¶
func (x *UnixDogstatsdMsg) String() string
type WorkloadmetaEntityId ¶
type WorkloadmetaEntityId struct { Kind WorkloadmetaKind `protobuf:"varint,1,opt,name=kind,proto3,enum=datadog.workloadmeta.WorkloadmetaKind" json:"kind,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*WorkloadmetaEntityId) Descriptor
deprecated
func (*WorkloadmetaEntityId) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaEntityId.ProtoReflect.Descriptor instead.
func (*WorkloadmetaEntityId) GetId ¶
func (x *WorkloadmetaEntityId) GetId() string
func (*WorkloadmetaEntityId) GetKind ¶
func (x *WorkloadmetaEntityId) GetKind() WorkloadmetaKind
func (*WorkloadmetaEntityId) ProtoMessage ¶
func (*WorkloadmetaEntityId) ProtoMessage()
func (*WorkloadmetaEntityId) ProtoReflect ¶
func (x *WorkloadmetaEntityId) ProtoReflect() protoreflect.Message
func (*WorkloadmetaEntityId) Reset ¶
func (x *WorkloadmetaEntityId) Reset()
func (*WorkloadmetaEntityId) String ¶
func (x *WorkloadmetaEntityId) String() string
type WorkloadmetaEvent ¶
type WorkloadmetaEvent struct { Type WorkloadmetaEventType `protobuf:"varint,1,opt,name=type,proto3,enum=datadog.workloadmeta.WorkloadmetaEventType" json:"type,omitempty"` Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` KubernetesPod *KubernetesPod `protobuf:"bytes,3,opt,name=kubernetesPod,proto3" json:"kubernetesPod,omitempty"` EcsTask *ECSTask `protobuf:"bytes,4,opt,name=ecsTask,proto3" json:"ecsTask,omitempty"` // contains filtered or unexported fields }
func (*WorkloadmetaEvent) Descriptor
deprecated
func (*WorkloadmetaEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaEvent.ProtoReflect.Descriptor instead.
func (*WorkloadmetaEvent) GetContainer ¶
func (x *WorkloadmetaEvent) GetContainer() *Container
func (*WorkloadmetaEvent) GetEcsTask ¶
func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask
func (*WorkloadmetaEvent) GetKubernetesPod ¶
func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod
func (*WorkloadmetaEvent) GetType ¶
func (x *WorkloadmetaEvent) GetType() WorkloadmetaEventType
func (*WorkloadmetaEvent) ProtoMessage ¶
func (*WorkloadmetaEvent) ProtoMessage()
func (*WorkloadmetaEvent) ProtoReflect ¶
func (x *WorkloadmetaEvent) ProtoReflect() protoreflect.Message
func (*WorkloadmetaEvent) Reset ¶
func (x *WorkloadmetaEvent) Reset()
func (*WorkloadmetaEvent) String ¶
func (x *WorkloadmetaEvent) String() string
type WorkloadmetaEventType ¶
type WorkloadmetaEventType int32
const ( WorkloadmetaEventType_EVENT_TYPE_ALL WorkloadmetaEventType = 0 WorkloadmetaEventType_EVENT_TYPE_SET WorkloadmetaEventType = 1 WorkloadmetaEventType_EVENT_TYPE_UNSET WorkloadmetaEventType = 2 )
func (WorkloadmetaEventType) Descriptor ¶
func (WorkloadmetaEventType) Descriptor() protoreflect.EnumDescriptor
func (WorkloadmetaEventType) Enum ¶
func (x WorkloadmetaEventType) Enum() *WorkloadmetaEventType
func (WorkloadmetaEventType) EnumDescriptor
deprecated
func (WorkloadmetaEventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaEventType.Descriptor instead.
func (WorkloadmetaEventType) Number ¶
func (x WorkloadmetaEventType) Number() protoreflect.EnumNumber
func (WorkloadmetaEventType) String ¶
func (x WorkloadmetaEventType) String() string
func (WorkloadmetaEventType) Type ¶
func (WorkloadmetaEventType) Type() protoreflect.EnumType
type WorkloadmetaFilter ¶
type WorkloadmetaFilter struct { Kinds []WorkloadmetaKind `protobuf:"varint,1,rep,packed,name=kinds,proto3,enum=datadog.workloadmeta.WorkloadmetaKind" json:"kinds,omitempty"` Source WorkloadmetaSource `protobuf:"varint,2,opt,name=source,proto3,enum=datadog.workloadmeta.WorkloadmetaSource" json:"source,omitempty"` EventType WorkloadmetaEventType `protobuf:"varint,3,opt,name=eventType,proto3,enum=datadog.workloadmeta.WorkloadmetaEventType" json:"eventType,omitempty"` // contains filtered or unexported fields }
func (*WorkloadmetaFilter) Descriptor
deprecated
func (*WorkloadmetaFilter) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaFilter.ProtoReflect.Descriptor instead.
func (*WorkloadmetaFilter) GetEventType ¶
func (x *WorkloadmetaFilter) GetEventType() WorkloadmetaEventType
func (*WorkloadmetaFilter) GetKinds ¶
func (x *WorkloadmetaFilter) GetKinds() []WorkloadmetaKind
func (*WorkloadmetaFilter) GetSource ¶
func (x *WorkloadmetaFilter) GetSource() WorkloadmetaSource
func (*WorkloadmetaFilter) ProtoMessage ¶
func (*WorkloadmetaFilter) ProtoMessage()
func (*WorkloadmetaFilter) ProtoReflect ¶
func (x *WorkloadmetaFilter) ProtoReflect() protoreflect.Message
func (*WorkloadmetaFilter) Reset ¶
func (x *WorkloadmetaFilter) Reset()
func (*WorkloadmetaFilter) String ¶
func (x *WorkloadmetaFilter) String() string
type WorkloadmetaKind ¶
type WorkloadmetaKind int32
const ( WorkloadmetaKind_CONTAINER WorkloadmetaKind = 0 WorkloadmetaKind_KUBERNETES_POD WorkloadmetaKind = 1 WorkloadmetaKind_ECS_TASK WorkloadmetaKind = 2 )
func (WorkloadmetaKind) Descriptor ¶
func (WorkloadmetaKind) Descriptor() protoreflect.EnumDescriptor
func (WorkloadmetaKind) Enum ¶
func (x WorkloadmetaKind) Enum() *WorkloadmetaKind
func (WorkloadmetaKind) EnumDescriptor
deprecated
func (WorkloadmetaKind) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaKind.Descriptor instead.
func (WorkloadmetaKind) Number ¶
func (x WorkloadmetaKind) Number() protoreflect.EnumNumber
func (WorkloadmetaKind) String ¶
func (x WorkloadmetaKind) String() string
func (WorkloadmetaKind) Type ¶
func (WorkloadmetaKind) Type() protoreflect.EnumType
type WorkloadmetaSource ¶
type WorkloadmetaSource int32
const ( WorkloadmetaSource_ALL WorkloadmetaSource = 0 WorkloadmetaSource_RUNTIME WorkloadmetaSource = 1 WorkloadmetaSource_NODE_ORCHESTRATOR WorkloadmetaSource = 2 WorkloadmetaSource_CLUSTER_ORCHESTRATOR WorkloadmetaSource = 3 )
func (WorkloadmetaSource) Descriptor ¶
func (WorkloadmetaSource) Descriptor() protoreflect.EnumDescriptor
func (WorkloadmetaSource) Enum ¶
func (x WorkloadmetaSource) Enum() *WorkloadmetaSource
func (WorkloadmetaSource) EnumDescriptor
deprecated
func (WorkloadmetaSource) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaSource.Descriptor instead.
func (WorkloadmetaSource) Number ¶
func (x WorkloadmetaSource) Number() protoreflect.EnumNumber
func (WorkloadmetaSource) String ¶
func (x WorkloadmetaSource) String() string
func (WorkloadmetaSource) Type ¶
func (WorkloadmetaSource) Type() protoreflect.EnumType
type WorkloadmetaStreamRequest ¶
type WorkloadmetaStreamRequest struct { Filter *WorkloadmetaFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*WorkloadmetaStreamRequest) Descriptor
deprecated
func (*WorkloadmetaStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaStreamRequest.ProtoReflect.Descriptor instead.
func (*WorkloadmetaStreamRequest) GetFilter ¶
func (x *WorkloadmetaStreamRequest) GetFilter() *WorkloadmetaFilter
func (*WorkloadmetaStreamRequest) ProtoMessage ¶
func (*WorkloadmetaStreamRequest) ProtoMessage()
func (*WorkloadmetaStreamRequest) ProtoReflect ¶
func (x *WorkloadmetaStreamRequest) ProtoReflect() protoreflect.Message
func (*WorkloadmetaStreamRequest) Reset ¶
func (x *WorkloadmetaStreamRequest) Reset()
func (*WorkloadmetaStreamRequest) String ¶
func (x *WorkloadmetaStreamRequest) String() string
type WorkloadmetaStreamResponse ¶
type WorkloadmetaStreamResponse struct { Events []*WorkloadmetaEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*WorkloadmetaStreamResponse) Descriptor
deprecated
func (*WorkloadmetaStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadmetaStreamResponse.ProtoReflect.Descriptor instead.
func (*WorkloadmetaStreamResponse) GetEvents ¶
func (x *WorkloadmetaStreamResponse) GetEvents() []*WorkloadmetaEvent
func (*WorkloadmetaStreamResponse) ProtoMessage ¶
func (*WorkloadmetaStreamResponse) ProtoMessage()
func (*WorkloadmetaStreamResponse) ProtoReflect ¶
func (x *WorkloadmetaStreamResponse) ProtoReflect() protoreflect.Message
func (*WorkloadmetaStreamResponse) Reset ¶
func (x *WorkloadmetaStreamResponse) Reset()
func (*WorkloadmetaStreamResponse) String ¶
func (x *WorkloadmetaStreamResponse) String() string