Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAgentSecureServer(s grpc.ServiceRegistrar, srv AgentSecureServer)
- func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
- func RegisterFlareProviderServer(s grpc.ServiceRegistrar, srv FlareProviderServer)
- func RegisterStatusProviderServer(s grpc.ServiceRegistrar, srv StatusProviderServer)
- func RegisterTelemetryProviderServer(s grpc.ServiceRegistrar, srv TelemetryProviderServer)
- type AdvancedADIdentifier
- func (*AdvancedADIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *AdvancedADIdentifier) GetKubeEndpoints() *KubeEndpointsIdentifier
- func (x *AdvancedADIdentifier) GetKubeService() *KubeNamespacedName
- func (*AdvancedADIdentifier) ProtoMessage()
- func (x *AdvancedADIdentifier) ProtoReflect() protoreflect.Message
- func (x *AdvancedADIdentifier) Reset()
- func (x *AdvancedADIdentifier) String() string
- type AgentClient
- type AgentSecureClient
- type AgentSecureServer
- type AgentSecure_AutodiscoveryStreamConfigClient
- type AgentSecure_AutodiscoveryStreamConfigServer
- type AgentSecure_CreateConfigSubscriptionClient
- type AgentSecure_CreateConfigSubscriptionServer
- type AgentSecure_StreamConfigEventsClient
- type AgentSecure_StreamConfigEventsServer
- type AgentSecure_TaggerStreamEntitiesClient
- type AgentSecure_TaggerStreamEntitiesServer
- type AgentSecure_WorkloadmetaStreamEntitiesClient
- type AgentSecure_WorkloadmetaStreamEntitiesServer
- type AgentServer
- type AutodiscoveryStreamResponse
- func (*AutodiscoveryStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AutodiscoveryStreamResponse) GetConfigs() []*Config
- func (*AutodiscoveryStreamResponse) ProtoMessage()
- func (x *AutodiscoveryStreamResponse) ProtoReflect() protoreflect.Message
- func (x *AutodiscoveryStreamResponse) Reset()
- func (x *AutodiscoveryStreamResponse) String() string
- 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) GetClientUpdater() *ClientUpdater
- func (x *Client) GetId() string
- func (x *Client) GetIsAgent() bool
- func (x *Client) GetIsTracer() bool
- func (x *Client) GetIsUpdater() bool
- func (x *Client) GetLastSeen() uint64
- func (x *Client) GetProducts() []string
- func (x *Client) GetState() *ClientState
- func (z *Client) MarshalMsg(b []byte) (o []byte, err error)
- func (z *Client) Msgsize() (s int)
- func (*Client) ProtoMessage()
- func (x *Client) ProtoReflect() protoreflect.Message
- func (x *Client) Reset()
- func (x *Client) String() string
- func (z *Client) UnmarshalMsg(bts []byte) (o []byte, err error)
- 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 (z *ClientAgent) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientAgent) Msgsize() (s int)
- func (*ClientAgent) ProtoMessage()
- func (x *ClientAgent) ProtoReflect() protoreflect.Message
- func (x *ClientAgent) Reset()
- func (x *ClientAgent) String() string
- func (z *ClientAgent) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ClientGetConfigsRequest
- func (*ClientGetConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClientGetConfigsRequest) GetCachedTargetFiles() []*TargetFileMeta
- func (x *ClientGetConfigsRequest) GetClient() *Client
- func (z *ClientGetConfigsRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientGetConfigsRequest) Msgsize() (s int)
- func (*ClientGetConfigsRequest) ProtoMessage()
- func (x *ClientGetConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *ClientGetConfigsRequest) Reset()
- func (x *ClientGetConfigsRequest) String() string
- func (z *ClientGetConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ClientGetConfigsResponse
- func (*ClientGetConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClientGetConfigsResponse) GetClientConfigs() []string
- func (x *ClientGetConfigsResponse) GetConfigStatus() ConfigStatus
- func (x *ClientGetConfigsResponse) GetRoots() [][]byte
- func (x *ClientGetConfigsResponse) GetTargetFiles() []*File
- func (x *ClientGetConfigsResponse) GetTargets() []byte
- func (z *ClientGetConfigsResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientGetConfigsResponse) Msgsize() (s int)
- func (*ClientGetConfigsResponse) ProtoMessage()
- func (x *ClientGetConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *ClientGetConfigsResponse) Reset()
- func (x *ClientGetConfigsResponse) String() string
- func (z *ClientGetConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- 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 (z *ClientState) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientState) Msgsize() (s int)
- func (*ClientState) ProtoMessage()
- func (x *ClientState) ProtoReflect() protoreflect.Message
- func (x *ClientState) Reset()
- func (x *ClientState) String() string
- func (z *ClientState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ClientTracer
- func (*ClientTracer) Descriptor() ([]byte, []int)deprecated
- func (x *ClientTracer) GetAppVersion() string
- func (x *ClientTracer) GetContainerTags() []string
- func (x *ClientTracer) GetEnv() string
- func (x *ClientTracer) GetExtraServices() []string
- func (x *ClientTracer) GetLanguage() string
- func (x *ClientTracer) GetProcessTags() []string
- func (x *ClientTracer) GetRuntimeId() string
- func (x *ClientTracer) GetService() string
- func (x *ClientTracer) GetTags() []string
- func (x *ClientTracer) GetTracerVersion() string
- func (z *ClientTracer) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientTracer) Msgsize() (s int)
- func (*ClientTracer) ProtoMessage()
- func (x *ClientTracer) ProtoReflect() protoreflect.Message
- func (x *ClientTracer) Reset()
- func (x *ClientTracer) String() string
- func (z *ClientTracer) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ClientUpdater
- func (*ClientUpdater) Descriptor() ([]byte, []int)deprecated
- func (x *ClientUpdater) GetAvailableDiskSpace() uint64
- func (x *ClientUpdater) GetPackages() []*PackageState
- func (x *ClientUpdater) GetSecretsPubKey() string
- func (x *ClientUpdater) GetTags() []string
- func (z *ClientUpdater) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ClientUpdater) Msgsize() (s int)
- func (*ClientUpdater) ProtoMessage()
- func (x *ClientUpdater) ProtoReflect() protoreflect.Message
- func (x *ClientUpdater) Reset()
- func (x *ClientUpdater) String() string
- func (z *ClientUpdater) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Config
- func (*Config) Descriptor() ([]byte, []int)deprecated
- func (x *Config) GetAdIdentifiers() []string
- func (x *Config) GetAdvancedAdIdentifiers() []*AdvancedADIdentifier
- func (x *Config) GetClusterCheck() bool
- func (x *Config) GetEventType() ConfigEventType
- func (x *Config) GetIgnoreAutodiscoveryTags() bool
- func (x *Config) GetInitConfig() []byte
- func (x *Config) GetInstances() [][]byte
- func (x *Config) GetLogsConfig() []byte
- func (x *Config) GetLogsExcluded() bool
- func (x *Config) GetMetricConfig() []byte
- func (x *Config) GetMetricsExcluded() bool
- func (x *Config) GetName() string
- func (x *Config) GetNodeName() string
- func (x *Config) GetProvider() string
- func (x *Config) GetServiceId() string
- func (x *Config) GetSource() string
- func (x *Config) GetTaggerEntity() string
- func (*Config) ProtoMessage()
- func (x *Config) ProtoReflect() protoreflect.Message
- func (x *Config) Reset()
- func (x *Config) String() string
- type ConfigEvent
- func (*ConfigEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigEvent) GetEvent() isConfigEvent_Event
- func (x *ConfigEvent) GetSnapshot() *ConfigSnapshot
- func (x *ConfigEvent) GetUpdate() *ConfigUpdate
- func (*ConfigEvent) ProtoMessage()
- func (x *ConfigEvent) ProtoReflect() protoreflect.Message
- func (x *ConfigEvent) Reset()
- func (x *ConfigEvent) String() string
- type ConfigEventType
- func (ConfigEventType) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigEventType) Enum() *ConfigEventType
- func (ConfigEventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConfigEventType) Number() protoreflect.EnumNumber
- func (x ConfigEventType) String() string
- func (ConfigEventType) Type() protoreflect.EnumType
- type ConfigEvent_Snapshot
- type ConfigEvent_Update
- 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 (z *ConfigMetas) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ConfigMetas) Msgsize() (s int)
- func (*ConfigMetas) ProtoMessage()
- func (x *ConfigMetas) ProtoReflect() protoreflect.Message
- func (x *ConfigMetas) Reset()
- func (x *ConfigMetas) String() string
- func (z *ConfigMetas) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSetting
- func (*ConfigSetting) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSetting) GetKey() string
- func (x *ConfigSetting) GetSource() string
- func (x *ConfigSetting) GetValue() *structpb.Value
- func (*ConfigSetting) ProtoMessage()
- func (x *ConfigSetting) ProtoReflect() protoreflect.Message
- func (x *ConfigSetting) Reset()
- func (x *ConfigSetting) String() string
- type ConfigSnapshot
- func (*ConfigSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSnapshot) GetOrigin() string
- func (x *ConfigSnapshot) GetSequenceId() int32
- func (x *ConfigSnapshot) GetSettings() []*ConfigSetting
- func (*ConfigSnapshot) ProtoMessage()
- func (x *ConfigSnapshot) ProtoReflect() protoreflect.Message
- func (x *ConfigSnapshot) Reset()
- func (x *ConfigSnapshot) 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 (z *ConfigState) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ConfigState) Msgsize() (s int)
- func (*ConfigState) ProtoMessage()
- func (x *ConfigState) ProtoReflect() protoreflect.Message
- func (x *ConfigState) Reset()
- func (x *ConfigState) String() string
- func (z *ConfigState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigStatus
- func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigStatus) Enum() *ConfigStatus
- func (ConfigStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (z ConfigStatus) MarshalMsg(b []byte) (o []byte, err error)
- func (z ConfigStatus) Msgsize() (s int)
- func (x ConfigStatus) Number() protoreflect.EnumNumber
- func (x ConfigStatus) String() string
- func (ConfigStatus) Type() protoreflect.EnumType
- func (z *ConfigStatus) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigStreamRequest
- func (*ConfigStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigStreamRequest) GetName() string
- func (*ConfigStreamRequest) ProtoMessage()
- func (x *ConfigStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigStreamRequest) Reset()
- func (x *ConfigStreamRequest) String() string
- type ConfigSubscriptionProducts
- func (ConfigSubscriptionProducts) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigSubscriptionProducts) Enum() *ConfigSubscriptionProducts
- func (ConfigSubscriptionProducts) EnumDescriptor() ([]byte, []int)deprecated
- func (z ConfigSubscriptionProducts) MarshalMsg(b []byte) (o []byte, err error)
- func (z ConfigSubscriptionProducts) Msgsize() (s int)
- func (x ConfigSubscriptionProducts) Number() protoreflect.EnumNumber
- func (x ConfigSubscriptionProducts) String() string
- func (ConfigSubscriptionProducts) Type() protoreflect.EnumType
- func (z *ConfigSubscriptionProducts) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSubscriptionRequest
- func (*ConfigSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSubscriptionRequest) GetAction() ConfigSubscriptionRequest_Action
- func (x *ConfigSubscriptionRequest) GetProducts() ConfigSubscriptionProducts
- func (x *ConfigSubscriptionRequest) GetRuntimeId() string
- func (z ConfigSubscriptionRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z ConfigSubscriptionRequest) Msgsize() (s int)
- func (*ConfigSubscriptionRequest) ProtoMessage()
- func (x *ConfigSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigSubscriptionRequest) Reset()
- func (x *ConfigSubscriptionRequest) String() string
- func (z *ConfigSubscriptionRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSubscriptionRequest_Action
- func (ConfigSubscriptionRequest_Action) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigSubscriptionRequest_Action) Enum() *ConfigSubscriptionRequest_Action
- func (ConfigSubscriptionRequest_Action) EnumDescriptor() ([]byte, []int)deprecated
- func (z ConfigSubscriptionRequest_Action) MarshalMsg(b []byte) (o []byte, err error)
- func (z ConfigSubscriptionRequest_Action) Msgsize() (s int)
- func (x ConfigSubscriptionRequest_Action) Number() protoreflect.EnumNumber
- func (x ConfigSubscriptionRequest_Action) String() string
- func (ConfigSubscriptionRequest_Action) Type() protoreflect.EnumType
- func (z *ConfigSubscriptionRequest_Action) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSubscriptionResponse
- func (*ConfigSubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSubscriptionResponse) GetClient() *Client
- func (x *ConfigSubscriptionResponse) GetMatchedConfigs() []string
- func (x *ConfigSubscriptionResponse) GetTargetFiles() []*File
- func (z *ConfigSubscriptionResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ConfigSubscriptionResponse) Msgsize() (s int)
- func (*ConfigSubscriptionResponse) ProtoMessage()
- func (x *ConfigSubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigSubscriptionResponse) Reset()
- func (x *ConfigSubscriptionResponse) String() string
- func (z *ConfigSubscriptionResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSubscriptionState
- func (*ConfigSubscriptionState) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSubscriptionState) GetSubscriptionId() uint64
- func (x *ConfigSubscriptionState) GetTrackedClients() []*ConfigSubscriptionState_TrackedClient
- func (z *ConfigSubscriptionState) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ConfigSubscriptionState) Msgsize() (s int)
- func (*ConfigSubscriptionState) ProtoMessage()
- func (x *ConfigSubscriptionState) ProtoReflect() protoreflect.Message
- func (x *ConfigSubscriptionState) Reset()
- func (x *ConfigSubscriptionState) String() string
- func (z *ConfigSubscriptionState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigSubscriptionState_TrackedClient
- func (*ConfigSubscriptionState_TrackedClient) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSubscriptionState_TrackedClient) GetProducts() ConfigSubscriptionProducts
- func (x *ConfigSubscriptionState_TrackedClient) GetRuntimeId() string
- func (x *ConfigSubscriptionState_TrackedClient) GetSeenAny() bool
- func (z ConfigSubscriptionState_TrackedClient) MarshalMsg(b []byte) (o []byte, err error)
- func (z ConfigSubscriptionState_TrackedClient) Msgsize() (s int)
- func (*ConfigSubscriptionState_TrackedClient) ProtoMessage()
- func (x *ConfigSubscriptionState_TrackedClient) ProtoReflect() protoreflect.Message
- func (x *ConfigSubscriptionState_TrackedClient) Reset()
- func (x *ConfigSubscriptionState_TrackedClient) String() string
- func (z *ConfigSubscriptionState_TrackedClient) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ConfigUpdate
- func (*ConfigUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigUpdate) GetOrigin() string
- func (x *ConfigUpdate) GetSequenceId() int32
- func (x *ConfigUpdate) GetSetting() *ConfigSetting
- func (*ConfigUpdate) ProtoMessage()
- func (x *ConfigUpdate) ProtoReflect() protoreflect.Message
- func (x *ConfigUpdate) Reset()
- func (x *ConfigUpdate) String() string
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- func (x *Container) GetCgroupPath() string
- 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) GetOwner() *WorkloadmetaEntityId
- func (x *Container) GetPid() int32
- func (x *Container) GetPorts() []*ContainerPort
- func (x *Container) GetResolvedAllocatedResources() []*ContainerAllocatedResource
- func (x *Container) GetResources() *ContainerResources
- 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 ContainerAllocatedResource
- func (*ContainerAllocatedResource) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerAllocatedResource) GetID() string
- func (x *ContainerAllocatedResource) GetName() string
- func (*ContainerAllocatedResource) ProtoMessage()
- func (x *ContainerAllocatedResource) ProtoReflect() protoreflect.Message
- func (x *ContainerAllocatedResource) Reset()
- func (x *ContainerAllocatedResource) 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) GetRepoDigest() 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 ContainerResources
- func (*ContainerResources) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerResources) GetCpuLimit() float64
- func (x *ContainerResources) GetCpuRequest() float64
- func (x *ContainerResources) GetMemoryLimit() uint64
- func (x *ContainerResources) GetMemoryRequest() uint64
- func (*ContainerResources) ProtoMessage()
- func (x *ContainerResources) ProtoReflect() protoreflect.Message
- func (x *ContainerResources) Reset()
- func (x *ContainerResources) String() string
- type ContainerState
- func (*ContainerState) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerState) GetCreatedAt() int64
- func (x *ContainerState) GetExitCode() int64
- 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 Crd
- func (*Crd) Descriptor() ([]byte, []int)deprecated
- func (x *Crd) GetEnityId() *WorkloadmetaEntityId
- func (x *Crd) GetEntityMeta() *EntityMeta
- func (x *Crd) GetGroup() string
- func (x *Crd) GetKind() string
- func (x *Crd) GetVersion() string
- func (*Crd) ProtoMessage()
- func (x *Crd) ProtoReflect() protoreflect.Message
- func (x *Crd) Reset()
- func (x *Crd) String() string
- type DelegatedMeta
- func (*DelegatedMeta) Descriptor() ([]byte, []int)deprecated
- func (x *DelegatedMeta) GetRaw() []byte
- func (x *DelegatedMeta) GetRole() string
- func (x *DelegatedMeta) GetVersion() uint64
- func (z *DelegatedMeta) MarshalMsg(b []byte) (o []byte, err error)
- func (z *DelegatedMeta) Msgsize() (s int)
- func (*DelegatedMeta) ProtoMessage()
- func (x *DelegatedMeta) ProtoReflect() protoreflect.Message
- func (x *DelegatedMeta) Reset()
- func (x *DelegatedMeta) String() string
- func (z *DelegatedMeta) UnmarshalMsg(bts []byte) (o []byte, err error)
- type DeprecatedFilter
- func (*DeprecatedFilter) Descriptor() ([]byte, []int)deprecated
- func (x *DeprecatedFilter) GetContainerName() string
- func (x *DeprecatedFilter) GetImage() string
- func (x *DeprecatedFilter) GetKubeNamespace() string
- func (*DeprecatedFilter) ProtoMessage()
- func (x *DeprecatedFilter) ProtoReflect() protoreflect.Message
- func (x *DeprecatedFilter) Reset()
- func (x *DeprecatedFilter) 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 (z *DirectorMetas) MarshalMsg(b []byte) (o []byte, err error)
- func (z *DirectorMetas) Msgsize() (s int)
- func (*DirectorMetas) ProtoMessage()
- func (x *DirectorMetas) ProtoReflect() protoreflect.Message
- func (x *DirectorMetas) Reset()
- func (x *DirectorMetas) String() string
- func (z *DirectorMetas) UnmarshalMsg(bts []byte) (o []byte, err error)
- 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) GetAwsAccountID() 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
- func (*File) Descriptor() ([]byte, []int)deprecated
- func (x *File) GetPath() string
- func (x *File) GetRaw() []byte
- func (z *File) MarshalMsg(b []byte) (o []byte, err error)
- func (z *File) Msgsize() (s int)
- func (*File) ProtoMessage()
- func (x *File) ProtoReflect() protoreflect.Message
- func (x *File) Reset()
- func (x *File) String() string
- func (z *File) UnmarshalMsg(bts []byte) (o []byte, err error)
- type FileMetaState
- func (*FileMetaState) Descriptor() ([]byte, []int)deprecated
- func (x *FileMetaState) GetHash() string
- func (x *FileMetaState) GetVersion() uint64
- func (z FileMetaState) MarshalMsg(b []byte) (o []byte, err error)
- func (z FileMetaState) Msgsize() (s int)
- func (*FileMetaState) ProtoMessage()
- func (x *FileMetaState) ProtoReflect() protoreflect.Message
- func (x *FileMetaState) Reset()
- func (x *FileMetaState) String() string
- func (z *FileMetaState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type FilterContainer
- func (*FilterContainer) Descriptor() ([]byte, []int)deprecated
- func (x *FilterContainer) GetEcsTask() *FilterECSTask
- func (x *FilterContainer) GetId() string
- func (x *FilterContainer) GetImage() *FilterImage
- func (x *FilterContainer) GetName() string
- func (x *FilterContainer) GetOwner() isFilterContainer_Owner
- func (x *FilterContainer) GetPod() *FilterPod
- func (*FilterContainer) ProtoMessage()
- func (x *FilterContainer) ProtoReflect() protoreflect.Message
- func (x *FilterContainer) Reset()
- func (x *FilterContainer) String() string
- type FilterContainer_EcsTask
- type FilterContainer_Pod
- type FilterECSTask
- func (*FilterECSTask) Descriptor() ([]byte, []int)deprecated
- func (x *FilterECSTask) GetArn() string
- func (x *FilterECSTask) GetId() string
- func (*FilterECSTask) ProtoMessage()
- func (x *FilterECSTask) ProtoReflect() protoreflect.Message
- func (x *FilterECSTask) Reset()
- func (x *FilterECSTask) String() string
- type FilterImage
- type FilterKubeEndpoint
- func (*FilterKubeEndpoint) Descriptor() ([]byte, []int)deprecated
- func (x *FilterKubeEndpoint) GetAnnotations() map[string]string
- func (x *FilterKubeEndpoint) GetName() string
- func (x *FilterKubeEndpoint) GetNamespace() string
- func (*FilterKubeEndpoint) ProtoMessage()
- func (x *FilterKubeEndpoint) ProtoReflect() protoreflect.Message
- func (x *FilterKubeEndpoint) Reset()
- func (x *FilterKubeEndpoint) String() string
- type FilterKubeService
- func (*FilterKubeService) Descriptor() ([]byte, []int)deprecated
- func (x *FilterKubeService) GetAnnotations() map[string]string
- func (x *FilterKubeService) GetName() string
- func (x *FilterKubeService) GetNamespace() string
- func (*FilterKubeService) ProtoMessage()
- func (x *FilterKubeService) ProtoReflect() protoreflect.Message
- func (x *FilterKubeService) Reset()
- func (x *FilterKubeService) String() string
- type FilterPod
- func (*FilterPod) Descriptor() ([]byte, []int)deprecated
- func (x *FilterPod) GetAnnotations() map[string]string
- func (x *FilterPod) GetId() string
- func (x *FilterPod) GetName() string
- func (x *FilterPod) GetNamespace() string
- func (*FilterPod) ProtoMessage()
- func (x *FilterPod) ProtoReflect() protoreflect.Message
- func (x *FilterPod) Reset()
- func (x *FilterPod) String() string
- type FilterProcess
- func (*FilterProcess) Descriptor() ([]byte, []int)deprecated
- func (x *FilterProcess) GetArgs() []string
- func (x *FilterProcess) GetCmdline() string
- func (x *FilterProcess) GetLogFile() string
- func (x *FilterProcess) GetName() string
- func (*FilterProcess) ProtoMessage()
- func (x *FilterProcess) ProtoReflect() protoreflect.Message
- func (x *FilterProcess) Reset()
- func (x *FilterProcess) String() string
- type FlareProviderClient
- type FlareProviderServer
- type GenerateContainerIDFromOriginInfoRequest
- func (*GenerateContainerIDFromOriginInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateContainerIDFromOriginInfoRequest) GetExternalData() *GenerateContainerIDFromOriginInfoRequest_ExternalData
- func (x *GenerateContainerIDFromOriginInfoRequest) GetLocalData() *GenerateContainerIDFromOriginInfoRequest_LocalData
- func (*GenerateContainerIDFromOriginInfoRequest) ProtoMessage()
- func (x *GenerateContainerIDFromOriginInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GenerateContainerIDFromOriginInfoRequest) Reset()
- func (x *GenerateContainerIDFromOriginInfoRequest) String() string
- type GenerateContainerIDFromOriginInfoRequest_ExternalData
- func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetContainerName() string
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetInit() bool
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetPodUID() string
- func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoMessage()
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoReflect() protoreflect.Message
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) Reset()
- func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) String() string
- type GenerateContainerIDFromOriginInfoRequest_LocalData
- func (*GenerateContainerIDFromOriginInfoRequest_LocalData) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetContainerID() string
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetInode() uint64
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetPodUID() string
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetProcessID() uint32
- func (*GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoMessage()
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoReflect() protoreflect.Message
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) Reset()
- func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) String() string
- type GenerateContainerIDFromOriginInfoResponse
- func (*GenerateContainerIDFromOriginInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateContainerIDFromOriginInfoResponse) GetContainerID() string
- func (*GenerateContainerIDFromOriginInfoResponse) ProtoMessage()
- func (x *GenerateContainerIDFromOriginInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GenerateContainerIDFromOriginInfoResponse) Reset()
- func (x *GenerateContainerIDFromOriginInfoResponse) String() string
- type GetFlareFilesRequest
- type GetFlareFilesResponse
- func (*GetFlareFilesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetFlareFilesResponse) GetFiles() map[string][]byte
- func (*GetFlareFilesResponse) ProtoMessage()
- func (x *GetFlareFilesResponse) ProtoReflect() protoreflect.Message
- func (x *GetFlareFilesResponse) Reset()
- func (x *GetFlareFilesResponse) 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) GetConfigSubscriptionStates() []*ConfigSubscriptionState
- func (x *GetStateConfigResponse) GetDirectorState() map[string]*FileMetaState
- func (x *GetStateConfigResponse) GetTargetFilenames() map[string]string
- func (z *GetStateConfigResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *GetStateConfigResponse) Msgsize() (s int)
- func (*GetStateConfigResponse) ProtoMessage()
- func (x *GetStateConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetStateConfigResponse) Reset()
- func (x *GetStateConfigResponse) String() string
- func (z *GetStateConfigResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type GetStatusDetailsRequest
- type GetStatusDetailsResponse
- func (*GetStatusDetailsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusDetailsResponse) GetMainSection() *StatusSection
- func (x *GetStatusDetailsResponse) GetNamedSections() map[string]*StatusSection
- func (*GetStatusDetailsResponse) ProtoMessage()
- func (x *GetStatusDetailsResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusDetailsResponse) Reset()
- func (x *GetStatusDetailsResponse) String() string
- type GetTelemetryRequest
- type GetTelemetryResponse
- func (*GetTelemetryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTelemetryResponse) GetPayload() isGetTelemetryResponse_Payload
- func (x *GetTelemetryResponse) GetPromText() string
- func (*GetTelemetryResponse) ProtoMessage()
- func (x *GetTelemetryResponse) ProtoReflect() protoreflect.Message
- func (x *GetTelemetryResponse) Reset()
- func (x *GetTelemetryResponse) String() string
- type GetTelemetryResponse_PromText
- type HostTagReply
- func (*HostTagReply) Descriptor() ([]byte, []int)deprecated
- func (x *HostTagReply) GetGoogleCloudPlatform() []string
- func (x *HostTagReply) GetSystem() []string
- func (*HostTagReply) ProtoMessage()
- func (x *HostTagReply) ProtoReflect() protoreflect.Message
- func (x *HostTagReply) Reset()
- func (x *HostTagReply) String() string
- type HostTagRequest
- type HostnameReply
- type HostnameRequest
- type InjectionState
- func (InjectionState) Descriptor() protoreflect.EnumDescriptor
- func (x InjectionState) Enum() *InjectionState
- func (InjectionState) EnumDescriptor() ([]byte, []int)deprecated
- func (x InjectionState) Number() protoreflect.EnumNumber
- func (x InjectionState) String() string
- func (InjectionState) Type() protoreflect.EnumType
- type KubeEndpointsIdentifier
- func (*KubeEndpointsIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *KubeEndpointsIdentifier) GetKubeNamespacedName() *KubeNamespacedName
- func (x *KubeEndpointsIdentifier) GetResolve() string
- func (*KubeEndpointsIdentifier) ProtoMessage()
- func (x *KubeEndpointsIdentifier) ProtoReflect() protoreflect.Message
- func (x *KubeEndpointsIdentifier) Reset()
- func (x *KubeEndpointsIdentifier) String() string
- type KubeNamespacedName
- func (*KubeNamespacedName) Descriptor() ([]byte, []int)deprecated
- func (x *KubeNamespacedName) GetName() string
- func (x *KubeNamespacedName) GetNamespace() string
- func (*KubeNamespacedName) ProtoMessage()
- func (x *KubeNamespacedName) ProtoReflect() protoreflect.Message
- func (x *KubeNamespacedName) Reset()
- func (x *KubeNamespacedName) String() string
- 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) GetEphemeralContainers() []*OrchestratorContainer
- func (x *KubernetesPod) GetInitContainers() []*OrchestratorContainer
- 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 (x *KubernetesPod) GetRuntimeClass() string
- 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) GetAgentUuid() string
- 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) GetTags() []string
- func (x *LatestConfigsRequest) GetTraceAgentEnv() string
- func (z *LatestConfigsRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *LatestConfigsRequest) Msgsize() (s int)
- func (*LatestConfigsRequest) ProtoMessage()
- func (x *LatestConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *LatestConfigsRequest) Reset()
- func (x *LatestConfigsRequest) String() string
- func (z *LatestConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type LatestConfigsResponse
- func (*LatestConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LatestConfigsResponse) GetConfigMetas() *ConfigMetas
- func (x *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas
- func (x *LatestConfigsResponse) GetTargetFiles() []*File
- func (z *LatestConfigsResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *LatestConfigsResponse) Msgsize() (s int)
- func (*LatestConfigsResponse) ProtoMessage()
- func (x *LatestConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *LatestConfigsResponse) Reset()
- func (x *LatestConfigsResponse) String() string
- func (z *LatestConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- 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
- func (*OrgDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OrgDataResponse) GetUuid() string
- func (z OrgDataResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z OrgDataResponse) Msgsize() (s int)
- func (*OrgDataResponse) ProtoMessage()
- func (x *OrgDataResponse) ProtoReflect() protoreflect.Message
- func (x *OrgDataResponse) Reset()
- func (x *OrgDataResponse) String() string
- func (z *OrgDataResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type OrgStatusResponse
- func (*OrgStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OrgStatusResponse) GetAuthorized() bool
- func (x *OrgStatusResponse) GetEnabled() bool
- func (z OrgStatusResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z OrgStatusResponse) Msgsize() (s int)
- func (*OrgStatusResponse) ProtoMessage()
- func (x *OrgStatusResponse) ProtoReflect() protoreflect.Message
- func (x *OrgStatusResponse) Reset()
- func (x *OrgStatusResponse) String() string
- func (z *OrgStatusResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type PackageState
- func (*PackageState) Descriptor() ([]byte, []int)deprecated
- func (x *PackageState) GetExperimentConfigVersion() string
- func (x *PackageState) GetExperimentVersion() string
- func (x *PackageState) GetPackage() string
- func (x *PackageState) GetRunningConfigVersion() string
- func (x *PackageState) GetRunningVersion() string
- func (x *PackageState) GetStableConfigVersion() string
- func (x *PackageState) GetStableVersion() string
- func (x *PackageState) GetTask() *PackageStateTask
- func (z *PackageState) MarshalMsg(b []byte) (o []byte, err error)
- func (z *PackageState) Msgsize() (s int)
- func (*PackageState) ProtoMessage()
- func (x *PackageState) ProtoReflect() protoreflect.Message
- func (x *PackageState) Reset()
- func (x *PackageState) String() string
- func (z *PackageState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type PackageStateTask
- func (*PackageStateTask) Descriptor() ([]byte, []int)deprecated
- func (x *PackageStateTask) GetError() *TaskError
- func (x *PackageStateTask) GetId() string
- func (x *PackageStateTask) GetState() TaskState
- func (z *PackageStateTask) MarshalMsg(b []byte) (o []byte, err error)
- func (z *PackageStateTask) Msgsize() (s int)
- func (*PackageStateTask) ProtoMessage()
- func (x *PackageStateTask) ProtoReflect() protoreflect.Message
- func (x *PackageStateTask) Reset()
- func (x *PackageStateTask) String() string
- func (z *PackageStateTask) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Process
- func (*Process) Descriptor() ([]byte, []int)deprecated
- func (x *Process) GetCmdline() []string
- func (x *Process) GetComm() string
- func (x *Process) GetContainerId() string
- func (x *Process) GetCreationTime() int64
- func (x *Process) GetCwd() string
- func (x *Process) GetEntityId() *WorkloadmetaEntityId
- func (x *Process) GetExe() string
- func (x *Process) GetGids() []int32
- func (x *Process) GetInjectionState() InjectionState
- func (x *Process) GetLanguage() *Language
- func (x *Process) GetName() string
- func (x *Process) GetNspid() int32
- func (x *Process) GetOwner() *WorkloadmetaEntityId
- func (x *Process) GetPid() int32
- func (x *Process) GetPpid() int32
- func (x *Process) GetService() *Service
- func (x *Process) GetUids() []int32
- func (*Process) ProtoMessage()
- func (x *Process) ProtoReflect() protoreflect.Message
- func (x *Process) Reset()
- func (x *Process) String() string
- type RefreshRemoteAgentRequest
- func (*RefreshRemoteAgentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshRemoteAgentRequest) GetSessionId() string
- func (*RefreshRemoteAgentRequest) ProtoMessage()
- func (x *RefreshRemoteAgentRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshRemoteAgentRequest) Reset()
- func (x *RefreshRemoteAgentRequest) String() string
- type RefreshRemoteAgentResponse
- type RegisterRemoteAgentRequest
- func (*RegisterRemoteAgentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRemoteAgentRequest) GetApiEndpointUri() string
- func (x *RegisterRemoteAgentRequest) GetDisplayName() string
- func (x *RegisterRemoteAgentRequest) GetFlavor() string
- func (x *RegisterRemoteAgentRequest) GetPid() string
- func (x *RegisterRemoteAgentRequest) GetServices() []string
- func (*RegisterRemoteAgentRequest) ProtoMessage()
- func (x *RegisterRemoteAgentRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRemoteAgentRequest) Reset()
- func (x *RegisterRemoteAgentRequest) String() string
- type RegisterRemoteAgentResponse
- func (*RegisterRemoteAgentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRemoteAgentResponse) GetRecommendedRefreshIntervalSecs() uint32
- func (x *RegisterRemoteAgentResponse) GetSessionId() string
- func (*RegisterRemoteAgentResponse) ProtoMessage()
- func (x *RegisterRemoteAgentResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterRemoteAgentResponse) Reset()
- func (x *RegisterRemoteAgentResponse) String() string
- type ResetStateConfigResponse
- func (*ResetStateConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (z ResetStateConfigResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z ResetStateConfigResponse) Msgsize() (s int)
- func (*ResetStateConfigResponse) ProtoMessage()
- func (x *ResetStateConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ResetStateConfigResponse) Reset()
- func (x *ResetStateConfigResponse) String() string
- func (z *ResetStateConfigResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Runtime
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetAdditionalGeneratedNames() []string
- func (x *Service) GetApmInstrumentation() bool
- func (x *Service) GetGeneratedName() string
- func (x *Service) GetGeneratedNameSource() string
- func (x *Service) GetTcpPorts() []int32
- func (x *Service) GetTracerMetadata() []*TracerMetadata
- func (x *Service) GetUdpPorts() []int32
- func (x *Service) GetUst() *UST
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type StatusProviderClient
- type StatusProviderServer
- type StatusSection
- 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() *DeprecatedFilter
- func (x *StreamTagsRequest) GetIncludeFilter() *DeprecatedFilter
- func (x *StreamTagsRequest) GetPrefixes() []string
- func (x *StreamTagsRequest) GetStreamingID() string
- 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) GetDuration() int64
- 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 (z TargetFileHash) MarshalMsg(b []byte) (o []byte, err error)
- func (z TargetFileHash) Msgsize() (s int)
- func (*TargetFileHash) ProtoMessage()
- func (x *TargetFileHash) ProtoReflect() protoreflect.Message
- func (x *TargetFileHash) Reset()
- func (x *TargetFileHash) String() string
- func (z *TargetFileHash) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TargetFileMeta
- func (*TargetFileMeta) Descriptor() ([]byte, []int)deprecated
- func (x *TargetFileMeta) GetHashes() []*TargetFileHash
- func (x *TargetFileMeta) GetLength() int64
- func (x *TargetFileMeta) GetPath() string
- func (z *TargetFileMeta) MarshalMsg(b []byte) (o []byte, err error)
- func (z *TargetFileMeta) Msgsize() (s int)
- func (*TargetFileMeta) ProtoMessage()
- func (x *TargetFileMeta) ProtoReflect() protoreflect.Message
- func (x *TargetFileMeta) Reset()
- func (x *TargetFileMeta) String() string
- func (z *TargetFileMeta) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TaskError
- func (*TaskError) Descriptor() ([]byte, []int)deprecated
- func (x *TaskError) GetCode() uint64
- func (x *TaskError) GetMessage() string
- func (z TaskError) MarshalMsg(b []byte) (o []byte, err error)
- func (z TaskError) Msgsize() (s int)
- func (*TaskError) ProtoMessage()
- func (x *TaskError) ProtoReflect() protoreflect.Message
- func (x *TaskError) Reset()
- func (x *TaskError) String() string
- func (z *TaskError) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TaskState
- func (TaskState) Descriptor() protoreflect.EnumDescriptor
- func (x TaskState) Enum() *TaskState
- func (TaskState) EnumDescriptor() ([]byte, []int)deprecated
- func (z TaskState) MarshalMsg(b []byte) (o []byte, err error)
- func (z TaskState) Msgsize() (s int)
- func (x TaskState) Number() protoreflect.EnumNumber
- func (x TaskState) String() string
- func (TaskState) Type() protoreflect.EnumType
- func (z *TaskState) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TelemetryProviderClient
- type TelemetryProviderServer
- type TopMeta
- func (*TopMeta) Descriptor() ([]byte, []int)deprecated
- func (x *TopMeta) GetRaw() []byte
- func (x *TopMeta) GetVersion() uint64
- func (z *TopMeta) MarshalMsg(b []byte) (o []byte, err error)
- func (z *TopMeta) Msgsize() (s int)
- func (*TopMeta) ProtoMessage()
- func (x *TopMeta) ProtoReflect() protoreflect.Message
- func (x *TopMeta) Reset()
- func (x *TopMeta) String() string
- func (z *TopMeta) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TracerMetadata
- func (*TracerMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TracerMetadata) GetRuntimeId() string
- func (x *TracerMetadata) GetServiceName() string
- func (*TracerMetadata) ProtoMessage()
- func (x *TracerMetadata) ProtoReflect() protoreflect.Message
- func (x *TracerMetadata) Reset()
- func (x *TracerMetadata) String() string
- 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 (z *TracerPredicateV1) MarshalMsg(b []byte) (o []byte, err error)
- func (z *TracerPredicateV1) Msgsize() (s int)
- func (*TracerPredicateV1) ProtoMessage()
- func (x *TracerPredicateV1) ProtoReflect() protoreflect.Message
- func (x *TracerPredicateV1) Reset()
- func (x *TracerPredicateV1) String() string
- func (z *TracerPredicateV1) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TracerPredicates
- func (*TracerPredicates) Descriptor() ([]byte, []int)deprecated
- func (x *TracerPredicates) GetTracerPredicatesV1() []*TracerPredicateV1
- func (z *TracerPredicates) MarshalMsg(b []byte) (o []byte, err error)
- func (z *TracerPredicates) Msgsize() (s int)
- func (*TracerPredicates) ProtoMessage()
- func (x *TracerPredicates) ProtoReflect() protoreflect.Message
- func (x *TracerPredicates) Reset()
- func (x *TracerPredicates) String() string
- func (z *TracerPredicates) UnmarshalMsg(bts []byte) (o []byte, err error)
- type UST
- type UnimplementedAgentSecureServer
- func (UnimplementedAgentSecureServer) AutodiscoveryStreamConfig(*emptypb.Empty, grpc.ServerStreamingServer[AutodiscoveryStreamResponse]) error
- func (UnimplementedAgentSecureServer) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
- func (UnimplementedAgentSecureServer) ClientGetConfigsHA(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
- func (UnimplementedAgentSecureServer) CreateConfigSubscription(...) 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) GetConfigStateHA(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
- func (UnimplementedAgentSecureServer) GetHostTags(context.Context, *HostTagRequest) (*HostTagReply, error)
- func (UnimplementedAgentSecureServer) RefreshRemoteAgent(context.Context, *RefreshRemoteAgentRequest) (*RefreshRemoteAgentResponse, error)
- func (UnimplementedAgentSecureServer) RegisterRemoteAgent(context.Context, *RegisterRemoteAgentRequest) (*RegisterRemoteAgentResponse, error)
- func (UnimplementedAgentSecureServer) ResetConfigState(context.Context, *emptypb.Empty) (*ResetStateConfigResponse, error)
- func (UnimplementedAgentSecureServer) StreamConfigEvents(*ConfigStreamRequest, grpc.ServerStreamingServer[ConfigEvent]) error
- func (UnimplementedAgentSecureServer) TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
- func (UnimplementedAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo(context.Context, *GenerateContainerIDFromOriginInfoRequest) (*GenerateContainerIDFromOriginInfoResponse, error)
- func (UnimplementedAgentSecureServer) TaggerStreamEntities(*StreamTagsRequest, grpc.ServerStreamingServer[StreamTagsResponse]) error
- func (UnimplementedAgentSecureServer) WorkloadFilterEvaluate(context.Context, *WorkloadFilterEvaluateRequest) (*WorkloadFilterEvaluateResponse, error)
- func (UnimplementedAgentSecureServer) WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, ...) error
- type UnimplementedAgentServer
- type UnimplementedFlareProviderServer
- type UnimplementedStatusProviderServer
- type UnimplementedTelemetryProviderServer
- 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 UnsafeAgentSecureServer
- type UnsafeAgentServer
- type UnsafeFlareProviderServer
- type UnsafeStatusProviderServer
- type UnsafeTelemetryProviderServer
- type WorkloadFilterEvaluateRequest
- func (*WorkloadFilterEvaluateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadFilterEvaluateRequest) GetContainer() *FilterContainer
- func (x *WorkloadFilterEvaluateRequest) GetKubeEndpoint() *FilterKubeEndpoint
- func (x *WorkloadFilterEvaluateRequest) GetKubeService() *FilterKubeService
- func (x *WorkloadFilterEvaluateRequest) GetPod() *FilterPod
- func (x *WorkloadFilterEvaluateRequest) GetProcess() *FilterProcess
- func (x *WorkloadFilterEvaluateRequest) GetProgramName() string
- func (x *WorkloadFilterEvaluateRequest) GetWorkload() isWorkloadFilterEvaluateRequest_Workload
- func (*WorkloadFilterEvaluateRequest) ProtoMessage()
- func (x *WorkloadFilterEvaluateRequest) ProtoReflect() protoreflect.Message
- func (x *WorkloadFilterEvaluateRequest) Reset()
- func (x *WorkloadFilterEvaluateRequest) String() string
- type WorkloadFilterEvaluateRequest_Container
- type WorkloadFilterEvaluateRequest_KubeEndpoint
- type WorkloadFilterEvaluateRequest_KubeService
- type WorkloadFilterEvaluateRequest_Pod
- type WorkloadFilterEvaluateRequest_Process
- type WorkloadFilterEvaluateResponse
- func (*WorkloadFilterEvaluateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadFilterEvaluateResponse) GetError() string
- func (x *WorkloadFilterEvaluateResponse) GetResult() WorkloadFilterResult
- func (*WorkloadFilterEvaluateResponse) ProtoMessage()
- func (x *WorkloadFilterEvaluateResponse) ProtoReflect() protoreflect.Message
- func (x *WorkloadFilterEvaluateResponse) Reset()
- func (x *WorkloadFilterEvaluateResponse) String() string
- type WorkloadFilterResult
- func (WorkloadFilterResult) Descriptor() protoreflect.EnumDescriptor
- func (x WorkloadFilterResult) Enum() *WorkloadFilterResult
- func (WorkloadFilterResult) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkloadFilterResult) Number() protoreflect.EnumNumber
- func (x WorkloadFilterResult) String() string
- func (WorkloadFilterResult) Type() protoreflect.EnumType
- 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) GetCrd() *Crd
- func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask
- func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod
- func (x *WorkloadmetaEvent) GetProcess() *Process
- 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 ¶
const ( AgentSecure_TaggerStreamEntities_FullMethodName = "/datadog.api.v1.AgentSecure/TaggerStreamEntities" AgentSecure_TaggerGenerateContainerIDFromOriginInfo_FullMethodName = "/datadog.api.v1.AgentSecure/TaggerGenerateContainerIDFromOriginInfo" AgentSecure_TaggerFetchEntity_FullMethodName = "/datadog.api.v1.AgentSecure/TaggerFetchEntity" AgentSecure_DogstatsdCaptureTrigger_FullMethodName = "/datadog.api.v1.AgentSecure/DogstatsdCaptureTrigger" AgentSecure_DogstatsdSetTaggerState_FullMethodName = "/datadog.api.v1.AgentSecure/DogstatsdSetTaggerState" AgentSecure_ClientGetConfigs_FullMethodName = "/datadog.api.v1.AgentSecure/ClientGetConfigs" AgentSecure_GetConfigState_FullMethodName = "/datadog.api.v1.AgentSecure/GetConfigState" AgentSecure_ClientGetConfigsHA_FullMethodName = "/datadog.api.v1.AgentSecure/ClientGetConfigsHA" AgentSecure_GetConfigStateHA_FullMethodName = "/datadog.api.v1.AgentSecure/GetConfigStateHA" AgentSecure_CreateConfigSubscription_FullMethodName = "/datadog.api.v1.AgentSecure/CreateConfigSubscription" AgentSecure_ResetConfigState_FullMethodName = "/datadog.api.v1.AgentSecure/ResetConfigState" AgentSecure_WorkloadmetaStreamEntities_FullMethodName = "/datadog.api.v1.AgentSecure/WorkloadmetaStreamEntities" AgentSecure_RegisterRemoteAgent_FullMethodName = "/datadog.api.v1.AgentSecure/RegisterRemoteAgent" AgentSecure_RefreshRemoteAgent_FullMethodName = "/datadog.api.v1.AgentSecure/RefreshRemoteAgent" AgentSecure_AutodiscoveryStreamConfig_FullMethodName = "/datadog.api.v1.AgentSecure/AutodiscoveryStreamConfig" AgentSecure_GetHostTags_FullMethodName = "/datadog.api.v1.AgentSecure/GetHostTags" AgentSecure_StreamConfigEvents_FullMethodName = "/datadog.api.v1.AgentSecure/StreamConfigEvents" AgentSecure_WorkloadFilterEvaluate_FullMethodName = "/datadog.api.v1.AgentSecure/WorkloadFilterEvaluate" )
const (
Agent_GetHostname_FullMethodName = "/datadog.api.v1.Agent/GetHostname"
)
const (
FlareProvider_GetFlareFiles_FullMethodName = "/datadog.remoteagent.flare.v1.FlareProvider/GetFlareFiles"
)
const (
StatusProvider_GetStatusDetails_FullMethodName = "/datadog.remoteagent.status.v1.StatusProvider/GetStatusDetails"
)
const (
TelemetryProvider_GetTelemetry_FullMethodName = "/datadog.remoteagent.telemetry.v1.TelemetryProvider/GetTelemetry"
)
Variables ¶
var ( ConfigEventType_name = map[int32]string{ 0: "SCHEDULE", 1: "UNSCHEDULE", } ConfigEventType_value = map[string]int32{ "SCHEDULE": 0, "UNSCHEDULE": 1, } )
Enum value maps for ConfigEventType.
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 ( TaskState_name = map[int32]string{ 0: "IDLE", 1: "RUNNING", 2: "DONE", 3: "INVALID_STATE", 4: "ERROR", } TaskState_value = map[string]int32{ "IDLE": 0, "RUNNING": 1, "DONE": 2, "INVALID_STATE": 3, "ERROR": 4, } )
Enum value maps for TaskState.
var ( ConfigSubscriptionProducts_name = map[int32]string{ 0: "INVALID", 1: "LIVE_DEBUGGING", } ConfigSubscriptionProducts_value = map[string]int32{ "INVALID": 0, "LIVE_DEBUGGING": 1, } )
Enum value maps for ConfigSubscriptionProducts.
var ( ConfigStatus_name = map[int32]string{ 0: "CONFIG_STATUS_OK", 1: "CONFIG_STATUS_EXPIRED", } ConfigStatus_value = map[string]int32{ "CONFIG_STATUS_OK": 0, "CONFIG_STATUS_EXPIRED": 1, } )
Enum value maps for ConfigStatus.
var ( ConfigSubscriptionRequest_Action_name = map[int32]string{ 0: "INVALID", 1: "TRACK", 2: "UNTRACK", } ConfigSubscriptionRequest_Action_value = map[string]int32{ "INVALID": 0, "TRACK": 1, "UNTRACK": 2, } )
Enum value maps for ConfigSubscriptionRequest_Action.
var ( WorkloadFilterResult_name = map[int32]string{ 0: "UNKNOWN", 1: "INCLUDE", 2: "EXCLUDE", } WorkloadFilterResult_value = map[string]int32{ "UNKNOWN": 0, "INCLUDE": 1, "EXCLUDE": 2, } )
Enum value maps for WorkloadFilterResult.
var ( WorkloadmetaKind_name = map[int32]string{ 0: "CONTAINER", 1: "KUBERNETES_POD", 2: "ECS_TASK", 3: "PROCESS", 4: "CRD", } WorkloadmetaKind_value = map[string]int32{ "CONTAINER": 0, "KUBERNETES_POD": 1, "ECS_TASK": 2, "PROCESS": 3, "CRD": 4, } )
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", 6: "UNKNOWN", } Runtime_value = map[string]int32{ "DOCKER": 0, "CONTAINERD": 1, "PODMAN": 2, "CRIO": 3, "GARDEN": 4, "ECS_FARGATE": 5, "UNKNOWN": 6, } )
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 ( InjectionState_name = map[int32]string{ 0: "INJECTION_UNKNOWN", 1: "INJECTION_INJECTED", 2: "INJECTION_NOT_INJECTED", } InjectionState_value = map[string]int32{ "INJECTION_UNKNOWN": 0, "INJECTION_INJECTED": 1, "INJECTION_NOT_INJECTED": 2, } )
Enum value maps for InjectionState.
var AgentSecure_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.api.v1.AgentSecure", HandlerType: (*AgentSecureServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "TaggerGenerateContainerIDFromOriginInfo", Handler: _AgentSecure_TaggerGenerateContainerIDFromOriginInfo_Handler, }, { MethodName: "TaggerFetchEntity", Handler: _AgentSecure_TaggerFetchEntity_Handler, }, { MethodName: "DogstatsdCaptureTrigger", Handler: _AgentSecure_DogstatsdCaptureTrigger_Handler, }, { MethodName: "DogstatsdSetTaggerState", Handler: _AgentSecure_DogstatsdSetTaggerState_Handler, }, { MethodName: "ClientGetConfigs", Handler: _AgentSecure_ClientGetConfigs_Handler, }, { MethodName: "GetConfigState", Handler: _AgentSecure_GetConfigState_Handler, }, { MethodName: "ClientGetConfigsHA", Handler: _AgentSecure_ClientGetConfigsHA_Handler, }, { MethodName: "GetConfigStateHA", Handler: _AgentSecure_GetConfigStateHA_Handler, }, { MethodName: "ResetConfigState", Handler: _AgentSecure_ResetConfigState_Handler, }, { MethodName: "RegisterRemoteAgent", Handler: _AgentSecure_RegisterRemoteAgent_Handler, }, { MethodName: "RefreshRemoteAgent", Handler: _AgentSecure_RefreshRemoteAgent_Handler, }, { MethodName: "GetHostTags", Handler: _AgentSecure_GetHostTags_Handler, }, { MethodName: "WorkloadFilterEvaluate", Handler: _AgentSecure_WorkloadFilterEvaluate_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "TaggerStreamEntities", Handler: _AgentSecure_TaggerStreamEntities_Handler, ServerStreams: true, }, { StreamName: "CreateConfigSubscription", Handler: _AgentSecure_CreateConfigSubscription_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "WorkloadmetaStreamEntities", Handler: _AgentSecure_WorkloadmetaStreamEntities_Handler, ServerStreams: true, }, { StreamName: "AutodiscoveryStreamConfig", Handler: _AgentSecure_AutodiscoveryStreamConfig_Handler, ServerStreams: true, }, { StreamName: "StreamConfigEvents", Handler: _AgentSecure_StreamConfigEvents_Handler, ServerStreams: true, }, }, Metadata: "datadog/api/v1/api.proto", }
AgentSecure_ServiceDesc is the grpc.ServiceDesc for AgentSecure service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Agent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.api.v1.Agent", HandlerType: (*AgentServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetHostname", Handler: _Agent_GetHostname_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datadog/api/v1/api.proto", }
Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_datadog_api_v1_api_proto protoreflect.FileDescriptor
var File_datadog_autodiscovery_autodiscovery_proto protoreflect.FileDescriptor
var File_datadog_model_v1_model_proto protoreflect.FileDescriptor
var File_datadog_remoteagent_flare_proto protoreflect.FileDescriptor
var File_datadog_remoteagent_remoteagent_proto protoreflect.FileDescriptor
var File_datadog_remoteagent_status_proto protoreflect.FileDescriptor
var File_datadog_remoteagent_telemetry_proto protoreflect.FileDescriptor
var File_datadog_remoteconfig_remoteconfig_proto protoreflect.FileDescriptor
var File_datadog_workloadfilter_workloadfilter_proto protoreflect.FileDescriptor
var File_datadog_workloadmeta_workloadmeta_proto protoreflect.FileDescriptor
var FlareProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.remoteagent.flare.v1.FlareProvider", HandlerType: (*FlareProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetFlareFiles", Handler: _FlareProvider_GetFlareFiles_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datadog/remoteagent/flare.proto", }
FlareProvider_ServiceDesc is the grpc.ServiceDesc for FlareProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StatusProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.remoteagent.status.v1.StatusProvider", HandlerType: (*StatusProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetStatusDetails", Handler: _StatusProvider_GetStatusDetails_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datadog/remoteagent/status.proto", }
StatusProvider_ServiceDesc is the grpc.ServiceDesc for StatusProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TelemetryProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.remoteagent.telemetry.v1.TelemetryProvider", HandlerType: (*TelemetryProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetTelemetry", Handler: _TelemetryProvider_GetTelemetry_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datadog/remoteagent/telemetry.proto", }
TelemetryProvider_ServiceDesc is the grpc.ServiceDesc for TelemetryProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAgentSecureServer ¶
func RegisterAgentSecureServer(s grpc.ServiceRegistrar, srv AgentSecureServer)
func RegisterAgentServer ¶
func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
func RegisterFlareProviderServer ¶ added in v0.73.0
func RegisterFlareProviderServer(s grpc.ServiceRegistrar, srv FlareProviderServer)
func RegisterStatusProviderServer ¶ added in v0.73.0
func RegisterStatusProviderServer(s grpc.ServiceRegistrar, srv StatusProviderServer)
func RegisterTelemetryProviderServer ¶ added in v0.73.0
func RegisterTelemetryProviderServer(s grpc.ServiceRegistrar, srv TelemetryProviderServer)
Types ¶
type AdvancedADIdentifier ¶ added in v0.62.0
type AdvancedADIdentifier struct {
KubeService *KubeNamespacedName `protobuf:"bytes,1,opt,name=kubeService,proto3" json:"kubeService,omitempty"`
KubeEndpoints *KubeEndpointsIdentifier `protobuf:"bytes,2,opt,name=kubeEndpoints,proto3" json:"kubeEndpoints,omitempty"`
// contains filtered or unexported fields
}
func (*AdvancedADIdentifier) Descriptor
deprecated
added in
v0.62.0
func (*AdvancedADIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use AdvancedADIdentifier.ProtoReflect.Descriptor instead.
func (*AdvancedADIdentifier) GetKubeEndpoints ¶ added in v0.62.0
func (x *AdvancedADIdentifier) GetKubeEndpoints() *KubeEndpointsIdentifier
func (*AdvancedADIdentifier) GetKubeService ¶ added in v0.62.0
func (x *AdvancedADIdentifier) GetKubeService() *KubeNamespacedName
func (*AdvancedADIdentifier) ProtoMessage ¶ added in v0.62.0
func (*AdvancedADIdentifier) ProtoMessage()
func (*AdvancedADIdentifier) ProtoReflect ¶ added in v0.62.0
func (x *AdvancedADIdentifier) ProtoReflect() protoreflect.Message
func (*AdvancedADIdentifier) Reset ¶ added in v0.62.0
func (x *AdvancedADIdentifier) Reset()
func (*AdvancedADIdentifier) String ¶ added in v0.62.0
func (x *AdvancedADIdentifier) String() string
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
The greeting service definition.
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.
TaggerStreamEntities(ctx context.Context, in *StreamTagsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamTagsResponse], error)
// Generates a container ID from Origin Info.
TaggerGenerateContainerIDFromOriginInfo(ctx context.Context, in *GenerateContainerIDFromOriginInfoRequest, opts ...grpc.CallOption) (*GenerateContainerIDFromOriginInfoResponse, error)
// fetches an entity from the Tagger with the desired cardinality tags.
TaggerFetchEntity(ctx context.Context, in *FetchEntityRequest, opts ...grpc.CallOption) (*FetchEntityResponse, error)
// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
DogstatsdCaptureTrigger(ctx context.Context, in *CaptureTriggerRequest, opts ...grpc.CallOption) (*CaptureTriggerResponse, error)
// Set the tagger state for dogstatsd.
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)
ClientGetConfigsHA(ctx context.Context, in *ClientGetConfigsRequest, opts ...grpc.CallOption) (*ClientGetConfigsResponse, error)
GetConfigStateHA(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetStateConfigResponse, error)
CreateConfigSubscription(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ConfigSubscriptionRequest, ConfigSubscriptionResponse], error)
ResetConfigState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ResetStateConfigResponse, error)
// Subscribes to added, removed, or changed entities in the Workloadmeta and
// streams them to clients as events.
WorkloadmetaStreamEntities(ctx context.Context, in *WorkloadmetaStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WorkloadmetaStreamResponse], error)
// Registers a remote agent.
RegisterRemoteAgent(ctx context.Context, in *RegisterRemoteAgentRequest, opts ...grpc.CallOption) (*RegisterRemoteAgentResponse, error)
// Refresh a remote agent.
RefreshRemoteAgent(ctx context.Context, in *RefreshRemoteAgentRequest, opts ...grpc.CallOption) (*RefreshRemoteAgentResponse, error)
// Subscribes to autodiscovery config updates
AutodiscoveryStreamConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AutodiscoveryStreamResponse], error)
// Get the host tags
GetHostTags(ctx context.Context, in *HostTagRequest, opts ...grpc.CallOption) (*HostTagReply, error)
// Streams config events to the remote agent.
StreamConfigEvents(ctx context.Context, in *ConfigStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConfigEvent], error)
// Evaluates a workloadfilter rule on behalf of remote agents.
WorkloadFilterEvaluate(ctx context.Context, in *WorkloadFilterEvaluateRequest, opts ...grpc.CallOption) (*WorkloadFilterEvaluateResponse, error)
}
AgentSecureClient is the client API for AgentSecure service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func 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.
TaggerStreamEntities(*StreamTagsRequest, grpc.ServerStreamingServer[StreamTagsResponse]) error
// Generates a container ID from Origin Info.
TaggerGenerateContainerIDFromOriginInfo(context.Context, *GenerateContainerIDFromOriginInfoRequest) (*GenerateContainerIDFromOriginInfoResponse, error)
// fetches an entity from the Tagger with the desired cardinality tags.
TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)
// Set the tagger state for dogstatsd.
DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)
ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
GetConfigState(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
ClientGetConfigsHA(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
GetConfigStateHA(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
CreateConfigSubscription(grpc.BidiStreamingServer[ConfigSubscriptionRequest, ConfigSubscriptionResponse]) error
ResetConfigState(context.Context, *emptypb.Empty) (*ResetStateConfigResponse, error)
// Subscribes to added, removed, or changed entities in the Workloadmeta and
// streams them to clients as events.
WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, grpc.ServerStreamingServer[WorkloadmetaStreamResponse]) error
// Registers a remote agent.
RegisterRemoteAgent(context.Context, *RegisterRemoteAgentRequest) (*RegisterRemoteAgentResponse, error)
// Refresh a remote agent.
RefreshRemoteAgent(context.Context, *RefreshRemoteAgentRequest) (*RefreshRemoteAgentResponse, error)
// Subscribes to autodiscovery config updates
AutodiscoveryStreamConfig(*emptypb.Empty, grpc.ServerStreamingServer[AutodiscoveryStreamResponse]) error
// Get the host tags
GetHostTags(context.Context, *HostTagRequest) (*HostTagReply, error)
// Streams config events to the remote agent.
StreamConfigEvents(*ConfigStreamRequest, grpc.ServerStreamingServer[ConfigEvent]) error
// Evaluates a workloadfilter rule on behalf of remote agents.
WorkloadFilterEvaluate(context.Context, *WorkloadFilterEvaluateRequest) (*WorkloadFilterEvaluateResponse, error)
// contains filtered or unexported methods
}
AgentSecureServer is the server API for AgentSecure service. All implementations must embed UnimplementedAgentSecureServer for forward compatibility.
type AgentSecure_AutodiscoveryStreamConfigClient ¶ added in v0.62.0
type AgentSecure_AutodiscoveryStreamConfigClient = grpc.ServerStreamingClient[AutodiscoveryStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_AutodiscoveryStreamConfigServer ¶ added in v0.62.0
type AgentSecure_AutodiscoveryStreamConfigServer = grpc.ServerStreamingServer[AutodiscoveryStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_CreateConfigSubscriptionClient ¶ added in v0.73.0
type AgentSecure_CreateConfigSubscriptionClient = grpc.BidiStreamingClient[ConfigSubscriptionRequest, ConfigSubscriptionResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_CreateConfigSubscriptionServer ¶ added in v0.73.0
type AgentSecure_CreateConfigSubscriptionServer = grpc.BidiStreamingServer[ConfigSubscriptionRequest, ConfigSubscriptionResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_StreamConfigEventsClient ¶ added in v0.71.0
type AgentSecure_StreamConfigEventsClient = grpc.ServerStreamingClient[ConfigEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_StreamConfigEventsServer ¶ added in v0.71.0
type AgentSecure_StreamConfigEventsServer = grpc.ServerStreamingServer[ConfigEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_TaggerStreamEntitiesClient ¶
type AgentSecure_TaggerStreamEntitiesClient = grpc.ServerStreamingClient[StreamTagsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_TaggerStreamEntitiesServer ¶
type AgentSecure_TaggerStreamEntitiesServer = grpc.ServerStreamingServer[StreamTagsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_WorkloadmetaStreamEntitiesClient ¶
type AgentSecure_WorkloadmetaStreamEntitiesClient = grpc.ServerStreamingClient[WorkloadmetaStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentSecure_WorkloadmetaStreamEntitiesServer ¶
type AgentSecure_WorkloadmetaStreamEntitiesServer = grpc.ServerStreamingServer[WorkloadmetaStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentServer ¶
type AgentServer interface {
// get the hostname
GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error)
// contains filtered or unexported methods
}
AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility.
The greeting service definition.
type AutodiscoveryStreamResponse ¶ added in v0.62.0
type AutodiscoveryStreamResponse struct {
Configs []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
// contains filtered or unexported fields
}
func (*AutodiscoveryStreamResponse) Descriptor
deprecated
added in
v0.62.0
func (*AutodiscoveryStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use AutodiscoveryStreamResponse.ProtoReflect.Descriptor instead.
func (*AutodiscoveryStreamResponse) GetConfigs ¶ added in v0.62.0
func (x *AutodiscoveryStreamResponse) GetConfigs() []*Config
func (*AutodiscoveryStreamResponse) ProtoMessage ¶ added in v0.62.0
func (*AutodiscoveryStreamResponse) ProtoMessage()
func (*AutodiscoveryStreamResponse) ProtoReflect ¶ added in v0.62.0
func (x *AutodiscoveryStreamResponse) ProtoReflect() protoreflect.Message
func (*AutodiscoveryStreamResponse) Reset ¶ added in v0.62.0
func (x *AutodiscoveryStreamResponse) Reset()
func (*AutodiscoveryStreamResponse) String ¶ added in v0.62.0
func (x *AutodiscoveryStreamResponse) String() string
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"`
IsUpdater bool `protobuf:"varint,14,opt,name=is_updater,json=isUpdater,proto3" json:"is_updater,omitempty"`
ClientUpdater *ClientUpdater `protobuf:"bytes,15,opt,name=client_updater,json=clientUpdater,proto3" json:"client_updater,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) GetClientUpdater ¶ added in v0.52.0
func (x *Client) GetClientUpdater() *ClientUpdater
func (*Client) GetIsAgent ¶
func (*Client) GetIsTracer ¶
func (*Client) GetIsUpdater ¶ added in v0.52.0
func (*Client) GetLastSeen ¶
func (*Client) GetProducts ¶
func (*Client) GetState ¶
func (x *Client) GetState() *ClientState
func (*Client) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
func (*Client) Msgsize ¶
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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) MarshalMsg ¶
func (z *ClientAgent) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientAgent) Msgsize ¶
func (z *ClientAgent) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ClientAgent) UnmarshalMsg ¶
func (z *ClientAgent) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z *ClientGetConfigsRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientGetConfigsRequest) Msgsize ¶
func (z *ClientGetConfigsRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ClientGetConfigsRequest) UnmarshalMsg ¶
func (z *ClientGetConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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"`
ConfigStatus ConfigStatus `` /* 131-byte string literal not displayed */
// 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) GetConfigStatus ¶ added in v0.65.0
func (x *ClientGetConfigsResponse) GetConfigStatus() ConfigStatus
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) MarshalMsg ¶
func (z *ClientGetConfigsResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientGetConfigsResponse) Msgsize ¶
func (z *ClientGetConfigsResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ClientGetConfigsResponse) UnmarshalMsg ¶
func (z *ClientGetConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z *ClientState) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientState) Msgsize ¶
func (z *ClientState) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ClientState) UnmarshalMsg ¶
func (z *ClientState) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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"`
ProcessTags []string `protobuf:"bytes,9,rep,name=process_tags,json=processTags,proto3" json:"process_tags,omitempty"`
ContainerTags []string `protobuf:"bytes,10,rep,name=container_tags,json=containerTags,proto3" json:"container_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) GetContainerTags ¶ added in v0.66.0
func (x *ClientTracer) GetContainerTags() []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) GetProcessTags ¶ added in v0.66.0
func (x *ClientTracer) GetProcessTags() []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) MarshalMsg ¶
func (z *ClientTracer) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientTracer) Msgsize ¶
func (z *ClientTracer) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ClientTracer) UnmarshalMsg ¶
func (z *ClientTracer) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ClientUpdater ¶ added in v0.52.0
type ClientUpdater struct {
Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
Packages []*PackageState `protobuf:"bytes,2,rep,name=packages,proto3" json:"packages,omitempty"`
AvailableDiskSpace uint64 `protobuf:"varint,3,opt,name=available_disk_space,json=availableDiskSpace,proto3" json:"available_disk_space,omitempty"`
SecretsPubKey string `protobuf:"bytes,4,opt,name=secrets_pub_key,json=secretsPubKey,proto3" json:"secrets_pub_key,omitempty"`
// contains filtered or unexported fields
}
func (*ClientUpdater) Descriptor
deprecated
added in
v0.52.0
func (*ClientUpdater) Descriptor() ([]byte, []int)
Deprecated: Use ClientUpdater.ProtoReflect.Descriptor instead.
func (*ClientUpdater) GetAvailableDiskSpace ¶ added in v0.60.0
func (x *ClientUpdater) GetAvailableDiskSpace() uint64
func (*ClientUpdater) GetPackages ¶ added in v0.52.0
func (x *ClientUpdater) GetPackages() []*PackageState
func (*ClientUpdater) GetSecretsPubKey ¶ added in v0.76.0
func (x *ClientUpdater) GetSecretsPubKey() string
func (*ClientUpdater) GetTags ¶ added in v0.52.0
func (x *ClientUpdater) GetTags() []string
func (*ClientUpdater) MarshalMsg ¶ added in v0.52.0
func (z *ClientUpdater) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientUpdater) Msgsize ¶ added in v0.52.0
func (z *ClientUpdater) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ClientUpdater) ProtoMessage ¶ added in v0.52.0
func (*ClientUpdater) ProtoMessage()
func (*ClientUpdater) ProtoReflect ¶ added in v0.52.0
func (x *ClientUpdater) ProtoReflect() protoreflect.Message
func (*ClientUpdater) Reset ¶ added in v0.52.0
func (x *ClientUpdater) Reset()
func (*ClientUpdater) String ¶ added in v0.52.0
func (x *ClientUpdater) String() string
func (*ClientUpdater) UnmarshalMsg ¶ added in v0.52.0
func (z *ClientUpdater) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type Config ¶ added in v0.62.0
type Config struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Instances [][]byte `protobuf:"bytes,2,rep,name=instances,proto3" json:"instances,omitempty"`
InitConfig []byte `protobuf:"bytes,3,opt,name=initConfig,proto3" json:"initConfig,omitempty"`
MetricConfig []byte `protobuf:"bytes,4,opt,name=metricConfig,proto3" json:"metricConfig,omitempty"`
LogsConfig []byte `protobuf:"bytes,5,opt,name=logsConfig,proto3" json:"logsConfig,omitempty"`
AdIdentifiers []string `protobuf:"bytes,6,rep,name=adIdentifiers,proto3" json:"adIdentifiers,omitempty"`
AdvancedAdIdentifiers []*AdvancedADIdentifier `protobuf:"bytes,7,rep,name=advancedAdIdentifiers,proto3" json:"advancedAdIdentifiers,omitempty"`
Provider string `protobuf:"bytes,8,opt,name=provider,proto3" json:"provider,omitempty"`
ServiceId string `protobuf:"bytes,9,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
TaggerEntity string `protobuf:"bytes,10,opt,name=taggerEntity,proto3" json:"taggerEntity,omitempty"`
ClusterCheck bool `protobuf:"varint,11,opt,name=clusterCheck,proto3" json:"clusterCheck,omitempty"`
NodeName string `protobuf:"bytes,12,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
Source string `protobuf:"bytes,13,opt,name=source,proto3" json:"source,omitempty"`
IgnoreAutodiscoveryTags bool `protobuf:"varint,14,opt,name=ignoreAutodiscoveryTags,proto3" json:"ignoreAutodiscoveryTags,omitempty"`
MetricsExcluded bool `protobuf:"varint,15,opt,name=metricsExcluded,proto3" json:"metricsExcluded,omitempty"`
LogsExcluded bool `protobuf:"varint,16,opt,name=logsExcluded,proto3" json:"logsExcluded,omitempty"`
EventType ConfigEventType `protobuf:"varint,17,opt,name=eventType,proto3,enum=datadog.autodiscovery.ConfigEventType" json:"eventType,omitempty"`
// contains filtered or unexported fields
}
func (*Config) Descriptor
deprecated
added in
v0.62.0
func (*Config) GetAdIdentifiers ¶ added in v0.62.0
func (*Config) GetAdvancedAdIdentifiers ¶ added in v0.62.0
func (x *Config) GetAdvancedAdIdentifiers() []*AdvancedADIdentifier
func (*Config) GetClusterCheck ¶ added in v0.62.0
func (*Config) GetEventType ¶ added in v0.62.0
func (x *Config) GetEventType() ConfigEventType
func (*Config) GetIgnoreAutodiscoveryTags ¶ added in v0.62.0
func (*Config) GetInitConfig ¶ added in v0.62.0
func (*Config) GetInstances ¶ added in v0.62.0
func (*Config) GetLogsConfig ¶ added in v0.62.0
func (*Config) GetLogsExcluded ¶ added in v0.62.0
func (*Config) GetMetricConfig ¶ added in v0.62.0
func (*Config) GetMetricsExcluded ¶ added in v0.62.0
func (*Config) GetNodeName ¶ added in v0.62.0
func (*Config) GetProvider ¶ added in v0.62.0
func (*Config) GetServiceId ¶ added in v0.62.0
func (*Config) GetTaggerEntity ¶ added in v0.62.0
func (*Config) ProtoMessage ¶ added in v0.62.0
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶ added in v0.62.0
func (x *Config) ProtoReflect() protoreflect.Message
type ConfigEvent ¶ added in v0.70.0
type ConfigEvent struct {
// Types that are valid to be assigned to Event:
//
// *ConfigEvent_Snapshot
// *ConfigEvent_Update
Event isConfigEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*ConfigEvent) Descriptor
deprecated
added in
v0.70.0
func (*ConfigEvent) Descriptor() ([]byte, []int)
Deprecated: Use ConfigEvent.ProtoReflect.Descriptor instead.
func (*ConfigEvent) GetEvent ¶ added in v0.70.0
func (x *ConfigEvent) GetEvent() isConfigEvent_Event
func (*ConfigEvent) GetSnapshot ¶ added in v0.70.0
func (x *ConfigEvent) GetSnapshot() *ConfigSnapshot
func (*ConfigEvent) GetUpdate ¶ added in v0.70.0
func (x *ConfigEvent) GetUpdate() *ConfigUpdate
func (*ConfigEvent) ProtoMessage ¶ added in v0.70.0
func (*ConfigEvent) ProtoMessage()
func (*ConfigEvent) ProtoReflect ¶ added in v0.70.0
func (x *ConfigEvent) ProtoReflect() protoreflect.Message
func (*ConfigEvent) Reset ¶ added in v0.70.0
func (x *ConfigEvent) Reset()
func (*ConfigEvent) String ¶ added in v0.70.0
func (x *ConfigEvent) String() string
type ConfigEventType ¶ added in v0.62.0
type ConfigEventType int32
const ( ConfigEventType_SCHEDULE ConfigEventType = 0 ConfigEventType_UNSCHEDULE ConfigEventType = 1 )
func (ConfigEventType) Descriptor ¶ added in v0.62.0
func (ConfigEventType) Descriptor() protoreflect.EnumDescriptor
func (ConfigEventType) Enum ¶ added in v0.62.0
func (x ConfigEventType) Enum() *ConfigEventType
func (ConfigEventType) EnumDescriptor
deprecated
added in
v0.62.0
func (ConfigEventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigEventType.Descriptor instead.
func (ConfigEventType) Number ¶ added in v0.62.0
func (x ConfigEventType) Number() protoreflect.EnumNumber
func (ConfigEventType) String ¶ added in v0.62.0
func (x ConfigEventType) String() string
func (ConfigEventType) Type ¶ added in v0.62.0
func (ConfigEventType) Type() protoreflect.EnumType
type ConfigEvent_Snapshot ¶ added in v0.70.0
type ConfigEvent_Snapshot struct {
Snapshot *ConfigSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3,oneof"`
}
type ConfigEvent_Update ¶ added in v0.70.0
type ConfigEvent_Update struct {
Update *ConfigUpdate `protobuf:"bytes,2,opt,name=update,proto3,oneof"`
}
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) MarshalMsg ¶
func (z *ConfigMetas) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ConfigMetas) Msgsize ¶
func (z *ConfigMetas) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ConfigMetas) UnmarshalMsg ¶
func (z *ConfigMetas) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSetting ¶ added in v0.70.0
type ConfigSetting struct {
Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigSetting) Descriptor
deprecated
added in
v0.70.0
func (*ConfigSetting) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSetting.ProtoReflect.Descriptor instead.
func (*ConfigSetting) GetKey ¶ added in v0.70.0
func (x *ConfigSetting) GetKey() string
func (*ConfigSetting) GetSource ¶ added in v0.70.0
func (x *ConfigSetting) GetSource() string
func (*ConfigSetting) GetValue ¶ added in v0.70.0
func (x *ConfigSetting) GetValue() *structpb.Value
func (*ConfigSetting) ProtoMessage ¶ added in v0.70.0
func (*ConfigSetting) ProtoMessage()
func (*ConfigSetting) ProtoReflect ¶ added in v0.70.0
func (x *ConfigSetting) ProtoReflect() protoreflect.Message
func (*ConfigSetting) Reset ¶ added in v0.70.0
func (x *ConfigSetting) Reset()
func (*ConfigSetting) String ¶ added in v0.70.0
func (x *ConfigSetting) String() string
type ConfigSnapshot ¶ added in v0.70.0
type ConfigSnapshot struct {
Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
SequenceId int32 `protobuf:"varint,2,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
Settings []*ConfigSetting `protobuf:"bytes,3,rep,name=settings,proto3" json:"settings,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigSnapshot) Descriptor
deprecated
added in
v0.70.0
func (*ConfigSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSnapshot.ProtoReflect.Descriptor instead.
func (*ConfigSnapshot) GetOrigin ¶ added in v0.70.0
func (x *ConfigSnapshot) GetOrigin() string
func (*ConfigSnapshot) GetSequenceId ¶ added in v0.70.0
func (x *ConfigSnapshot) GetSequenceId() int32
func (*ConfigSnapshot) GetSettings ¶ added in v0.70.0
func (x *ConfigSnapshot) GetSettings() []*ConfigSetting
func (*ConfigSnapshot) ProtoMessage ¶ added in v0.70.0
func (*ConfigSnapshot) ProtoMessage()
func (*ConfigSnapshot) ProtoReflect ¶ added in v0.70.0
func (x *ConfigSnapshot) ProtoReflect() protoreflect.Message
func (*ConfigSnapshot) Reset ¶ added in v0.70.0
func (x *ConfigSnapshot) Reset()
func (*ConfigSnapshot) String ¶ added in v0.70.0
func (x *ConfigSnapshot) 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) MarshalMsg ¶
func (z *ConfigState) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ConfigState) Msgsize ¶
func (z *ConfigState) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*ConfigState) UnmarshalMsg ¶
func (z *ConfigState) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigStatus ¶ added in v0.65.0
type ConfigStatus int32
const ( ConfigStatus_CONFIG_STATUS_OK ConfigStatus = 0 ConfigStatus_CONFIG_STATUS_EXPIRED ConfigStatus = 1 )
func (ConfigStatus) Descriptor ¶ added in v0.65.0
func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (ConfigStatus) Enum ¶ added in v0.65.0
func (x ConfigStatus) Enum() *ConfigStatus
func (ConfigStatus) EnumDescriptor
deprecated
added in
v0.65.0
func (ConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigStatus.Descriptor instead.
func (ConfigStatus) MarshalMsg ¶ added in v0.65.0
func (z ConfigStatus) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ConfigStatus) Msgsize ¶ added in v0.65.0
func (z ConfigStatus) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (ConfigStatus) Number ¶ added in v0.65.0
func (x ConfigStatus) Number() protoreflect.EnumNumber
func (ConfigStatus) String ¶ added in v0.65.0
func (x ConfigStatus) String() string
func (ConfigStatus) Type ¶ added in v0.65.0
func (ConfigStatus) Type() protoreflect.EnumType
func (*ConfigStatus) UnmarshalMsg ¶ added in v0.65.0
func (z *ConfigStatus) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigStreamRequest ¶ added in v0.71.0
type ConfigStreamRequest struct {
// The name of the client subscribing to the config stream.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigStreamRequest) Descriptor
deprecated
added in
v0.71.0
func (*ConfigStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigStreamRequest.ProtoReflect.Descriptor instead.
func (*ConfigStreamRequest) GetName ¶ added in v0.71.0
func (x *ConfigStreamRequest) GetName() string
func (*ConfigStreamRequest) ProtoMessage ¶ added in v0.71.0
func (*ConfigStreamRequest) ProtoMessage()
func (*ConfigStreamRequest) ProtoReflect ¶ added in v0.71.0
func (x *ConfigStreamRequest) ProtoReflect() protoreflect.Message
func (*ConfigStreamRequest) Reset ¶ added in v0.71.0
func (x *ConfigStreamRequest) Reset()
func (*ConfigStreamRequest) String ¶ added in v0.71.0
func (x *ConfigStreamRequest) String() string
type ConfigSubscriptionProducts ¶ added in v0.73.0
type ConfigSubscriptionProducts int32
ConfigSubscriptionProducts is used to targets specific products for tracking with a ConfigSubscriptionRequest.
const ( ConfigSubscriptionProducts_INVALID ConfigSubscriptionProducts = 0 // LIVE_DEBUGGING corresponds to the LIVE_DEBUGING and LIVE_DEBUGGING_SYMBOLDB // products. ConfigSubscriptionProducts_LIVE_DEBUGGING ConfigSubscriptionProducts = 1 )
func (ConfigSubscriptionProducts) Descriptor ¶ added in v0.73.0
func (ConfigSubscriptionProducts) Descriptor() protoreflect.EnumDescriptor
func (ConfigSubscriptionProducts) Enum ¶ added in v0.73.0
func (x ConfigSubscriptionProducts) Enum() *ConfigSubscriptionProducts
func (ConfigSubscriptionProducts) EnumDescriptor
deprecated
added in
v0.73.0
func (ConfigSubscriptionProducts) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionProducts.Descriptor instead.
func (ConfigSubscriptionProducts) MarshalMsg ¶ added in v0.73.0
func (z ConfigSubscriptionProducts) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ConfigSubscriptionProducts) Msgsize ¶ added in v0.73.0
func (z ConfigSubscriptionProducts) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (ConfigSubscriptionProducts) Number ¶ added in v0.73.0
func (x ConfigSubscriptionProducts) Number() protoreflect.EnumNumber
func (ConfigSubscriptionProducts) String ¶ added in v0.73.0
func (x ConfigSubscriptionProducts) String() string
func (ConfigSubscriptionProducts) Type ¶ added in v0.73.0
func (ConfigSubscriptionProducts) Type() protoreflect.EnumType
func (*ConfigSubscriptionProducts) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionProducts) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSubscriptionRequest ¶ added in v0.73.0
type ConfigSubscriptionRequest struct {
// RuntimeID of the client to track or untrack.
RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
// Action indicates the action to take for the client with the given
// runtime_id.
Action ConfigSubscriptionRequest_Action `protobuf:"varint,2,opt,name=action,proto3,enum=datadog.config.ConfigSubscriptionRequest_Action" json:"action,omitempty"`
// If action is TRACK, products indicates the set of products for which the
// client is interested in receiving updates.
Products ConfigSubscriptionProducts `protobuf:"varint,3,opt,name=products,proto3,enum=datadog.config.ConfigSubscriptionProducts" json:"products,omitempty"`
// contains filtered or unexported fields
}
ConfigSubscriptionRequest is used to manage the state of the stream created using CreateConfigSubscription.
func (*ConfigSubscriptionRequest) Descriptor
deprecated
added in
v0.73.0
func (*ConfigSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*ConfigSubscriptionRequest) GetAction ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) GetAction() ConfigSubscriptionRequest_Action
func (*ConfigSubscriptionRequest) GetProducts ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) GetProducts() ConfigSubscriptionProducts
func (*ConfigSubscriptionRequest) GetRuntimeId ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) GetRuntimeId() string
func (ConfigSubscriptionRequest) MarshalMsg ¶ added in v0.73.0
func (z ConfigSubscriptionRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ConfigSubscriptionRequest) Msgsize ¶ added in v0.73.0
func (z ConfigSubscriptionRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ConfigSubscriptionRequest) ProtoMessage ¶ added in v0.73.0
func (*ConfigSubscriptionRequest) ProtoMessage()
func (*ConfigSubscriptionRequest) ProtoReflect ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*ConfigSubscriptionRequest) Reset ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) Reset()
func (*ConfigSubscriptionRequest) String ¶ added in v0.73.0
func (x *ConfigSubscriptionRequest) String() string
func (*ConfigSubscriptionRequest) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSubscriptionRequest_Action ¶ added in v0.73.0
type ConfigSubscriptionRequest_Action int32
const ( ConfigSubscriptionRequest_INVALID ConfigSubscriptionRequest_Action = 0 ConfigSubscriptionRequest_TRACK ConfigSubscriptionRequest_Action = 1 ConfigSubscriptionRequest_UNTRACK ConfigSubscriptionRequest_Action = 2 )
func (ConfigSubscriptionRequest_Action) Descriptor ¶ added in v0.73.0
func (ConfigSubscriptionRequest_Action) Descriptor() protoreflect.EnumDescriptor
func (ConfigSubscriptionRequest_Action) Enum ¶ added in v0.73.0
func (x ConfigSubscriptionRequest_Action) Enum() *ConfigSubscriptionRequest_Action
func (ConfigSubscriptionRequest_Action) EnumDescriptor
deprecated
added in
v0.73.0
func (ConfigSubscriptionRequest_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionRequest_Action.Descriptor instead.
func (ConfigSubscriptionRequest_Action) MarshalMsg ¶ added in v0.73.0
func (z ConfigSubscriptionRequest_Action) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ConfigSubscriptionRequest_Action) Msgsize ¶ added in v0.73.0
func (z ConfigSubscriptionRequest_Action) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (ConfigSubscriptionRequest_Action) Number ¶ added in v0.73.0
func (x ConfigSubscriptionRequest_Action) Number() protoreflect.EnumNumber
func (ConfigSubscriptionRequest_Action) String ¶ added in v0.73.0
func (x ConfigSubscriptionRequest_Action) String() string
func (ConfigSubscriptionRequest_Action) Type ¶ added in v0.73.0
func (ConfigSubscriptionRequest_Action) Type() protoreflect.EnumType
func (*ConfigSubscriptionRequest_Action) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionRequest_Action) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSubscriptionResponse ¶ added in v0.73.0
type ConfigSubscriptionResponse struct {
// Client is the client that was tracked or untracked.
Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
// Matched configs are all configs that were matched for the client given
// the subscription request.
//
// If a previously reported config is no longer matched, it will not be
// included in the response.
MatchedConfigs []string `protobuf:"bytes,2,rep,name=matched_configs,json=matchedConfigs,proto3" json:"matched_configs,omitempty"`
// Target files are the target files that needs to be sent to the client.
TargetFiles []*File `protobuf:"bytes,3,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"`
// contains filtered or unexported fields
}
ConfigSubscriptionResponse is streamed from CreateConfigSubscription with updates for matching clients and products.
func (*ConfigSubscriptionResponse) Descriptor
deprecated
added in
v0.73.0
func (*ConfigSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*ConfigSubscriptionResponse) GetClient ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) GetClient() *Client
func (*ConfigSubscriptionResponse) GetMatchedConfigs ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) GetMatchedConfigs() []string
func (*ConfigSubscriptionResponse) GetTargetFiles ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) GetTargetFiles() []*File
func (*ConfigSubscriptionResponse) MarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ConfigSubscriptionResponse) Msgsize ¶ added in v0.73.0
func (z *ConfigSubscriptionResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ConfigSubscriptionResponse) ProtoMessage ¶ added in v0.73.0
func (*ConfigSubscriptionResponse) ProtoMessage()
func (*ConfigSubscriptionResponse) ProtoReflect ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*ConfigSubscriptionResponse) Reset ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) Reset()
func (*ConfigSubscriptionResponse) String ¶ added in v0.73.0
func (x *ConfigSubscriptionResponse) String() string
func (*ConfigSubscriptionResponse) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSubscriptionState ¶ added in v0.73.0
type ConfigSubscriptionState struct {
// SubscriptionID is a process-unique identifier for the subscription.
SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
// TrackedClients is the list of clients that are currently tracked by the
// subscription.
TrackedClients []*ConfigSubscriptionState_TrackedClient `protobuf:"bytes,2,rep,name=tracked_clients,json=trackedClients,proto3" json:"tracked_clients,omitempty"`
// contains filtered or unexported fields
}
ConfigSubscriptionState describes the state of a config subscription.
func (*ConfigSubscriptionState) Descriptor
deprecated
added in
v0.73.0
func (*ConfigSubscriptionState) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionState.ProtoReflect.Descriptor instead.
func (*ConfigSubscriptionState) GetSubscriptionId ¶ added in v0.73.0
func (x *ConfigSubscriptionState) GetSubscriptionId() uint64
func (*ConfigSubscriptionState) GetTrackedClients ¶ added in v0.73.0
func (x *ConfigSubscriptionState) GetTrackedClients() []*ConfigSubscriptionState_TrackedClient
func (*ConfigSubscriptionState) MarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionState) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ConfigSubscriptionState) Msgsize ¶ added in v0.73.0
func (z *ConfigSubscriptionState) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ConfigSubscriptionState) ProtoMessage ¶ added in v0.73.0
func (*ConfigSubscriptionState) ProtoMessage()
func (*ConfigSubscriptionState) ProtoReflect ¶ added in v0.73.0
func (x *ConfigSubscriptionState) ProtoReflect() protoreflect.Message
func (*ConfigSubscriptionState) Reset ¶ added in v0.73.0
func (x *ConfigSubscriptionState) Reset()
func (*ConfigSubscriptionState) String ¶ added in v0.73.0
func (x *ConfigSubscriptionState) String() string
func (*ConfigSubscriptionState) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionState) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigSubscriptionState_TrackedClient ¶ added in v0.73.0
type ConfigSubscriptionState_TrackedClient struct {
RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
SeenAny bool `protobuf:"varint,2,opt,name=seen_any,json=seenAny,proto3" json:"seen_any,omitempty"`
Products ConfigSubscriptionProducts `protobuf:"varint,3,opt,name=products,proto3,enum=datadog.config.ConfigSubscriptionProducts" json:"products,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigSubscriptionState_TrackedClient) Descriptor
deprecated
added in
v0.73.0
func (*ConfigSubscriptionState_TrackedClient) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionState_TrackedClient.ProtoReflect.Descriptor instead.
func (*ConfigSubscriptionState_TrackedClient) GetProducts ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) GetProducts() ConfigSubscriptionProducts
func (*ConfigSubscriptionState_TrackedClient) GetRuntimeId ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) GetRuntimeId() string
func (*ConfigSubscriptionState_TrackedClient) GetSeenAny ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) GetSeenAny() bool
func (ConfigSubscriptionState_TrackedClient) MarshalMsg ¶ added in v0.73.0
func (z ConfigSubscriptionState_TrackedClient) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ConfigSubscriptionState_TrackedClient) Msgsize ¶ added in v0.73.0
func (z ConfigSubscriptionState_TrackedClient) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ConfigSubscriptionState_TrackedClient) ProtoMessage ¶ added in v0.73.0
func (*ConfigSubscriptionState_TrackedClient) ProtoMessage()
func (*ConfigSubscriptionState_TrackedClient) ProtoReflect ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) ProtoReflect() protoreflect.Message
func (*ConfigSubscriptionState_TrackedClient) Reset ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) Reset()
func (*ConfigSubscriptionState_TrackedClient) String ¶ added in v0.73.0
func (x *ConfigSubscriptionState_TrackedClient) String() string
func (*ConfigSubscriptionState_TrackedClient) UnmarshalMsg ¶ added in v0.73.0
func (z *ConfigSubscriptionState_TrackedClient) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ConfigUpdate ¶ added in v0.70.0
type ConfigUpdate struct {
Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
SequenceId int32 `protobuf:"varint,2,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
Setting *ConfigSetting `protobuf:"bytes,3,opt,name=setting,proto3" json:"setting,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigUpdate) Descriptor
deprecated
added in
v0.70.0
func (*ConfigUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ConfigUpdate.ProtoReflect.Descriptor instead.
func (*ConfigUpdate) GetOrigin ¶ added in v0.70.0
func (x *ConfigUpdate) GetOrigin() string
func (*ConfigUpdate) GetSequenceId ¶ added in v0.70.0
func (x *ConfigUpdate) GetSequenceId() int32
func (*ConfigUpdate) GetSetting ¶ added in v0.70.0
func (x *ConfigUpdate) GetSetting() *ConfigSetting
func (*ConfigUpdate) ProtoMessage ¶ added in v0.70.0
func (*ConfigUpdate) ProtoMessage()
func (*ConfigUpdate) ProtoReflect ¶ added in v0.70.0
func (x *ConfigUpdate) ProtoReflect() protoreflect.Message
func (*ConfigUpdate) Reset ¶ added in v0.70.0
func (x *ConfigUpdate) Reset()
func (*ConfigUpdate) String ¶ added in v0.70.0
func (x *ConfigUpdate) 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 `` /* 141-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 `` /* 147-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"`
CgroupPath string `protobuf:"bytes,12,opt,name=cgroupPath,proto3" json:"cgroupPath,omitempty"`
ResolvedAllocatedResources []*ContainerAllocatedResource `protobuf:"bytes,13,rep,name=resolvedAllocatedResources,proto3" json:"resolvedAllocatedResources,omitempty"`
Resources *ContainerResources `protobuf:"bytes,14,opt,name=resources,proto3" json:"resources,omitempty"`
Owner *WorkloadmetaEntityId `protobuf:"bytes,15,opt,name=owner,proto3" json:"owner,omitempty"`
// contains filtered or unexported fields
}
func (*Container) Descriptor
deprecated
func (*Container) GetCgroupPath ¶ added in v0.55.0
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) GetOwner ¶ added in v0.70.0
func (x *Container) GetOwner() *WorkloadmetaEntityId
func (*Container) GetPorts ¶
func (x *Container) GetPorts() []*ContainerPort
func (*Container) GetResolvedAllocatedResources ¶ added in v0.66.1
func (x *Container) GetResolvedAllocatedResources() []*ContainerAllocatedResource
func (*Container) GetResources ¶ added in v0.70.0
func (x *Container) GetResources() *ContainerResources
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 ContainerAllocatedResource ¶ added in v0.64.0
type ContainerAllocatedResource struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID string `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
// contains filtered or unexported fields
}
func (*ContainerAllocatedResource) Descriptor
deprecated
added in
v0.64.0
func (*ContainerAllocatedResource) Descriptor() ([]byte, []int)
Deprecated: Use ContainerAllocatedResource.ProtoReflect.Descriptor instead.
func (*ContainerAllocatedResource) GetID ¶ added in v0.64.0
func (x *ContainerAllocatedResource) GetID() string
func (*ContainerAllocatedResource) GetName ¶ added in v0.64.0
func (x *ContainerAllocatedResource) GetName() string
func (*ContainerAllocatedResource) ProtoMessage ¶ added in v0.64.0
func (*ContainerAllocatedResource) ProtoMessage()
func (*ContainerAllocatedResource) ProtoReflect ¶ added in v0.64.0
func (x *ContainerAllocatedResource) ProtoReflect() protoreflect.Message
func (*ContainerAllocatedResource) Reset ¶ added in v0.64.0
func (x *ContainerAllocatedResource) Reset()
func (*ContainerAllocatedResource) String ¶ added in v0.64.0
func (x *ContainerAllocatedResource) String() string
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"`
RepoDigest string `protobuf:"bytes,6,opt,name=repo_digest,json=repoDigest,proto3" json:"repo_digest,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) GetRepoDigest ¶ added in v0.52.0
func (x *ContainerImage) GetRepoDigest() 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 ContainerResources ¶ added in v0.70.0
type ContainerResources struct {
CpuRequest *float64 `protobuf:"fixed64,1,opt,name=cpuRequest,proto3,oneof" json:"cpuRequest,omitempty"`
CpuLimit *float64 `protobuf:"fixed64,2,opt,name=cpuLimit,proto3,oneof" json:"cpuLimit,omitempty"`
MemoryRequest *uint64 `protobuf:"varint,3,opt,name=memoryRequest,proto3,oneof" json:"memoryRequest,omitempty"`
MemoryLimit *uint64 `protobuf:"varint,4,opt,name=memoryLimit,proto3,oneof" json:"memoryLimit,omitempty"`
// contains filtered or unexported fields
}
func (*ContainerResources) Descriptor
deprecated
added in
v0.70.0
func (*ContainerResources) Descriptor() ([]byte, []int)
Deprecated: Use ContainerResources.ProtoReflect.Descriptor instead.
func (*ContainerResources) GetCpuLimit ¶ added in v0.70.0
func (x *ContainerResources) GetCpuLimit() float64
func (*ContainerResources) GetCpuRequest ¶ added in v0.70.0
func (x *ContainerResources) GetCpuRequest() float64
func (*ContainerResources) GetMemoryLimit ¶ added in v0.70.0
func (x *ContainerResources) GetMemoryLimit() uint64
func (*ContainerResources) GetMemoryRequest ¶ added in v0.70.0
func (x *ContainerResources) GetMemoryRequest() uint64
func (*ContainerResources) ProtoMessage ¶ added in v0.70.0
func (*ContainerResources) ProtoMessage()
func (*ContainerResources) ProtoReflect ¶ added in v0.70.0
func (x *ContainerResources) ProtoReflect() protoreflect.Message
func (*ContainerResources) Reset ¶ added in v0.70.0
func (x *ContainerResources) Reset()
func (*ContainerResources) String ¶ added in v0.70.0
func (x *ContainerResources) 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 int64 `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() int64
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 Crd ¶ added in v0.75.0
type Crd struct {
EnityId *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=enity_id,json=enityId,proto3" json:"enity_id,omitempty"`
EntityMeta *EntityMeta `protobuf:"bytes,2,opt,name=entity_meta,json=entityMeta,proto3" json:"entity_meta,omitempty"`
Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*Crd) Descriptor
deprecated
added in
v0.75.0
func (*Crd) GetEnityId ¶ added in v0.75.0
func (x *Crd) GetEnityId() *WorkloadmetaEntityId
func (*Crd) GetEntityMeta ¶ added in v0.75.0
func (x *Crd) GetEntityMeta() *EntityMeta
func (*Crd) GetVersion ¶ added in v0.75.0
func (*Crd) ProtoMessage ¶ added in v0.75.0
func (*Crd) ProtoMessage()
func (*Crd) ProtoReflect ¶ added in v0.75.0
func (x *Crd) ProtoReflect() protoreflect.Message
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) MarshalMsg ¶
func (z *DelegatedMeta) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*DelegatedMeta) Msgsize ¶
func (z *DelegatedMeta) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*DelegatedMeta) UnmarshalMsg ¶
func (z *DelegatedMeta) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type DeprecatedFilter ¶ added in v0.60.0
type DeprecatedFilter 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 (*DeprecatedFilter) Descriptor
deprecated
added in
v0.60.0
func (*DeprecatedFilter) Descriptor() ([]byte, []int)
Deprecated: Use DeprecatedFilter.ProtoReflect.Descriptor instead.
func (*DeprecatedFilter) GetContainerName ¶ added in v0.60.0
func (x *DeprecatedFilter) GetContainerName() string
func (*DeprecatedFilter) GetImage ¶ added in v0.60.0
func (x *DeprecatedFilter) GetImage() string
func (*DeprecatedFilter) GetKubeNamespace ¶ added in v0.60.0
func (x *DeprecatedFilter) GetKubeNamespace() string
func (*DeprecatedFilter) ProtoMessage ¶ added in v0.60.0
func (*DeprecatedFilter) ProtoMessage()
func (*DeprecatedFilter) ProtoReflect ¶ added in v0.60.0
func (x *DeprecatedFilter) ProtoReflect() protoreflect.Message
func (*DeprecatedFilter) Reset ¶ added in v0.60.0
func (x *DeprecatedFilter) Reset()
func (*DeprecatedFilter) String ¶ added in v0.60.0
func (x *DeprecatedFilter) 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) MarshalMsg ¶
func (z *DirectorMetas) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*DirectorMetas) Msgsize ¶
func (z *DirectorMetas) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*DirectorMetas) UnmarshalMsg ¶
func (z *DirectorMetas) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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 `` /* 135-byte string literal not displayed */
ContainerInstanceTags map[string]string `` /* 169-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"`
AwsAccountID string `protobuf:"bytes,12,opt,name=awsAccountID,proto3" json:"awsAccountID,omitempty"`
// contains filtered or unexported fields
}
func (*ECSTask) Descriptor
deprecated
func (*ECSTask) GetAvailabilityZone ¶
func (*ECSTask) GetAwsAccountID ¶ added in v0.60.0
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 `` /* 149-byte string literal not displayed */
Labels map[string]string `` /* 139-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) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
func (*File) Msgsize ¶
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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) MarshalMsg ¶
func (z FileMetaState) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (FileMetaState) Msgsize ¶
func (z FileMetaState) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*FileMetaState) UnmarshalMsg ¶
func (z *FileMetaState) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type FilterContainer ¶ added in v0.74.0
type FilterContainer 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 *FilterImage `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
// Types that are valid to be assigned to Owner:
//
// *FilterContainer_Pod
// *FilterContainer_EcsTask
Owner isFilterContainer_Owner `protobuf_oneof:"owner"`
// contains filtered or unexported fields
}
func (*FilterContainer) Descriptor
deprecated
added in
v0.74.0
func (*FilterContainer) Descriptor() ([]byte, []int)
Deprecated: Use FilterContainer.ProtoReflect.Descriptor instead.
func (*FilterContainer) GetEcsTask ¶ added in v0.74.0
func (x *FilterContainer) GetEcsTask() *FilterECSTask
func (*FilterContainer) GetId ¶ added in v0.74.0
func (x *FilterContainer) GetId() string
func (*FilterContainer) GetImage ¶ added in v0.74.0
func (x *FilterContainer) GetImage() *FilterImage
func (*FilterContainer) GetName ¶ added in v0.74.0
func (x *FilterContainer) GetName() string
func (*FilterContainer) GetOwner ¶ added in v0.74.0
func (x *FilterContainer) GetOwner() isFilterContainer_Owner
func (*FilterContainer) GetPod ¶ added in v0.74.0
func (x *FilterContainer) GetPod() *FilterPod
func (*FilterContainer) ProtoMessage ¶ added in v0.74.0
func (*FilterContainer) ProtoMessage()
func (*FilterContainer) ProtoReflect ¶ added in v0.74.0
func (x *FilterContainer) ProtoReflect() protoreflect.Message
func (*FilterContainer) Reset ¶ added in v0.74.0
func (x *FilterContainer) Reset()
func (*FilterContainer) String ¶ added in v0.74.0
func (x *FilterContainer) String() string
type FilterContainer_EcsTask ¶ added in v0.74.0
type FilterContainer_EcsTask struct {
EcsTask *FilterECSTask `protobuf:"bytes,5,opt,name=ecs_task,json=ecsTask,proto3,oneof"`
}
type FilterContainer_Pod ¶ added in v0.74.0
type FilterContainer_Pod struct {
Pod *FilterPod `protobuf:"bytes,4,opt,name=pod,proto3,oneof"`
}
type FilterECSTask ¶ added in v0.74.0
type FilterECSTask struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Arn string `protobuf:"bytes,2,opt,name=arn,proto3" json:"arn,omitempty"` // TODO: Explore task fields to add
// contains filtered or unexported fields
}
func (*FilterECSTask) Descriptor
deprecated
added in
v0.74.0
func (*FilterECSTask) Descriptor() ([]byte, []int)
Deprecated: Use FilterECSTask.ProtoReflect.Descriptor instead.
func (*FilterECSTask) GetArn ¶ added in v0.74.0
func (x *FilterECSTask) GetArn() string
func (*FilterECSTask) GetId ¶ added in v0.74.0
func (x *FilterECSTask) GetId() string
func (*FilterECSTask) ProtoMessage ¶ added in v0.74.0
func (*FilterECSTask) ProtoMessage()
func (*FilterECSTask) ProtoReflect ¶ added in v0.74.0
func (x *FilterECSTask) ProtoReflect() protoreflect.Message
func (*FilterECSTask) Reset ¶ added in v0.74.0
func (x *FilterECSTask) Reset()
func (*FilterECSTask) String ¶ added in v0.74.0
func (x *FilterECSTask) String() string
type FilterImage ¶ added in v0.74.0
type FilterImage struct {
Reference string `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
// contains filtered or unexported fields
}
func (*FilterImage) Descriptor
deprecated
added in
v0.74.0
func (*FilterImage) Descriptor() ([]byte, []int)
Deprecated: Use FilterImage.ProtoReflect.Descriptor instead.
func (*FilterImage) GetReference ¶ added in v0.74.0
func (x *FilterImage) GetReference() string
func (*FilterImage) ProtoMessage ¶ added in v0.74.0
func (*FilterImage) ProtoMessage()
func (*FilterImage) ProtoReflect ¶ added in v0.74.0
func (x *FilterImage) ProtoReflect() protoreflect.Message
func (*FilterImage) Reset ¶ added in v0.74.0
func (x *FilterImage) Reset()
func (*FilterImage) String ¶ added in v0.74.0
func (x *FilterImage) String() string
type FilterKubeEndpoint ¶ added in v0.74.0
type FilterKubeEndpoint 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 `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FilterKubeEndpoint) Descriptor
deprecated
added in
v0.74.0
func (*FilterKubeEndpoint) Descriptor() ([]byte, []int)
Deprecated: Use FilterKubeEndpoint.ProtoReflect.Descriptor instead.
func (*FilterKubeEndpoint) GetAnnotations ¶ added in v0.74.0
func (x *FilterKubeEndpoint) GetAnnotations() map[string]string
func (*FilterKubeEndpoint) GetName ¶ added in v0.74.0
func (x *FilterKubeEndpoint) GetName() string
func (*FilterKubeEndpoint) GetNamespace ¶ added in v0.74.0
func (x *FilterKubeEndpoint) GetNamespace() string
func (*FilterKubeEndpoint) ProtoMessage ¶ added in v0.74.0
func (*FilterKubeEndpoint) ProtoMessage()
func (*FilterKubeEndpoint) ProtoReflect ¶ added in v0.74.0
func (x *FilterKubeEndpoint) ProtoReflect() protoreflect.Message
func (*FilterKubeEndpoint) Reset ¶ added in v0.74.0
func (x *FilterKubeEndpoint) Reset()
func (*FilterKubeEndpoint) String ¶ added in v0.74.0
func (x *FilterKubeEndpoint) String() string
type FilterKubeService ¶ added in v0.74.0
type FilterKubeService 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 `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FilterKubeService) Descriptor
deprecated
added in
v0.74.0
func (*FilterKubeService) Descriptor() ([]byte, []int)
Deprecated: Use FilterKubeService.ProtoReflect.Descriptor instead.
func (*FilterKubeService) GetAnnotations ¶ added in v0.74.0
func (x *FilterKubeService) GetAnnotations() map[string]string
func (*FilterKubeService) GetName ¶ added in v0.74.0
func (x *FilterKubeService) GetName() string
func (*FilterKubeService) GetNamespace ¶ added in v0.74.0
func (x *FilterKubeService) GetNamespace() string
func (*FilterKubeService) ProtoMessage ¶ added in v0.74.0
func (*FilterKubeService) ProtoMessage()
func (*FilterKubeService) ProtoReflect ¶ added in v0.74.0
func (x *FilterKubeService) ProtoReflect() protoreflect.Message
func (*FilterKubeService) Reset ¶ added in v0.74.0
func (x *FilterKubeService) Reset()
func (*FilterKubeService) String ¶ added in v0.74.0
func (x *FilterKubeService) String() string
type FilterPod ¶ added in v0.74.0
type FilterPod 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"`
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
Annotations map[string]string `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FilterPod) Descriptor
deprecated
added in
v0.74.0
func (*FilterPod) GetAnnotations ¶ added in v0.74.0
func (*FilterPod) GetNamespace ¶ added in v0.74.0
func (*FilterPod) ProtoMessage ¶ added in v0.74.0
func (*FilterPod) ProtoMessage()
func (*FilterPod) ProtoReflect ¶ added in v0.74.0
func (x *FilterPod) ProtoReflect() protoreflect.Message
type FilterProcess ¶ added in v0.74.0
type FilterProcess struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Cmdline string `protobuf:"bytes,2,opt,name=cmdline,proto3" json:"cmdline,omitempty"`
Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
// log_file is only set when the rules are evaluated by the logs component.
LogFile string `protobuf:"bytes,4,opt,name=log_file,json=logFile,proto3" json:"log_file,omitempty"`
// contains filtered or unexported fields
}
func (*FilterProcess) Descriptor
deprecated
added in
v0.74.0
func (*FilterProcess) Descriptor() ([]byte, []int)
Deprecated: Use FilterProcess.ProtoReflect.Descriptor instead.
func (*FilterProcess) GetArgs ¶ added in v0.74.0
func (x *FilterProcess) GetArgs() []string
func (*FilterProcess) GetCmdline ¶ added in v0.74.0
func (x *FilterProcess) GetCmdline() string
func (*FilterProcess) GetLogFile ¶ added in v0.74.0
func (x *FilterProcess) GetLogFile() string
func (*FilterProcess) GetName ¶ added in v0.74.0
func (x *FilterProcess) GetName() string
func (*FilterProcess) ProtoMessage ¶ added in v0.74.0
func (*FilterProcess) ProtoMessage()
func (*FilterProcess) ProtoReflect ¶ added in v0.74.0
func (x *FilterProcess) ProtoReflect() protoreflect.Message
func (*FilterProcess) Reset ¶ added in v0.74.0
func (x *FilterProcess) Reset()
func (*FilterProcess) String ¶ added in v0.74.0
func (x *FilterProcess) String() string
type FlareProviderClient ¶ added in v0.73.0
type FlareProviderClient interface {
// Gets all relevant flare files of a remote agent.
GetFlareFiles(ctx context.Context, in *GetFlareFilesRequest, opts ...grpc.CallOption) (*GetFlareFilesResponse, error)
}
FlareProviderClient is the client API for FlareProvider service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFlareProviderClient ¶ added in v0.73.0
func NewFlareProviderClient(cc grpc.ClientConnInterface) FlareProviderClient
type FlareProviderServer ¶ added in v0.73.0
type FlareProviderServer interface {
// Gets all relevant flare files of a remote agent.
GetFlareFiles(context.Context, *GetFlareFilesRequest) (*GetFlareFilesResponse, error)
// contains filtered or unexported methods
}
FlareProviderServer is the server API for FlareProvider service. All implementations must embed UnimplementedFlareProviderServer for forward compatibility.
type GenerateContainerIDFromOriginInfoRequest ¶ added in v0.62.0
type GenerateContainerIDFromOriginInfoRequest struct {
LocalData *GenerateContainerIDFromOriginInfoRequest_LocalData `protobuf:"bytes,1,opt,name=localData,proto3,oneof" json:"localData,omitempty"` // Local data for the container, generated by the client.
ExternalData *GenerateContainerIDFromOriginInfoRequest_ExternalData `protobuf:"bytes,2,opt,name=externalData,proto3,oneof" json:"externalData,omitempty"` // External data for the container, generated by the Admission Controller.
// contains filtered or unexported fields
}
func (*GenerateContainerIDFromOriginInfoRequest) Descriptor
deprecated
added in
v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenerateContainerIDFromOriginInfoRequest.ProtoReflect.Descriptor instead.
func (*GenerateContainerIDFromOriginInfoRequest) GetExternalData ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest) GetExternalData() *GenerateContainerIDFromOriginInfoRequest_ExternalData
func (*GenerateContainerIDFromOriginInfoRequest) GetLocalData ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest) GetLocalData() *GenerateContainerIDFromOriginInfoRequest_LocalData
func (*GenerateContainerIDFromOriginInfoRequest) ProtoMessage ¶ added in v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest) ProtoMessage()
func (*GenerateContainerIDFromOriginInfoRequest) ProtoReflect ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest) ProtoReflect() protoreflect.Message
func (*GenerateContainerIDFromOriginInfoRequest) Reset ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest) Reset()
func (*GenerateContainerIDFromOriginInfoRequest) String ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest) String() string
type GenerateContainerIDFromOriginInfoRequest_ExternalData ¶ added in v0.62.0
type GenerateContainerIDFromOriginInfoRequest_ExternalData struct {
Init *bool `protobuf:"varint,1,opt,name=init,proto3,oneof" json:"init,omitempty"` // Init is true if the container is an init container.
ContainerName *string `protobuf:"bytes,2,opt,name=containerName,proto3,oneof" json:"containerName,omitempty"` // Container name in the Kubernetes Pod spec.
PodUID *string `protobuf:"bytes,3,opt,name=podUID,proto3,oneof" json:"podUID,omitempty"` // Pod UID in the Kubernetes Pod spec.
// contains filtered or unexported fields
}
Nested message for the external data
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) Descriptor
deprecated
added in
v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) Descriptor() ([]byte, []int)
Deprecated: Use GenerateContainerIDFromOriginInfoRequest_ExternalData.ProtoReflect.Descriptor instead.
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) GetContainerName ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetContainerName() string
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) GetInit ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetInit() bool
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) GetPodUID ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) GetPodUID() string
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoMessage ¶ added in v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoMessage()
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoReflect ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) ProtoReflect() protoreflect.Message
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) Reset ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) Reset()
func (*GenerateContainerIDFromOriginInfoRequest_ExternalData) String ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_ExternalData) String() string
type GenerateContainerIDFromOriginInfoRequest_LocalData ¶ added in v0.62.0
type GenerateContainerIDFromOriginInfoRequest_LocalData struct {
ProcessID *uint32 `protobuf:"varint,1,opt,name=processID,proto3,oneof" json:"processID,omitempty"` // Process ID of the container process on the host.
ContainerID *string `protobuf:"bytes,2,opt,name=containerID,proto3,oneof" json:"containerID,omitempty"` // Container ID send from the client.
Inode *uint64 `protobuf:"varint,3,opt,name=inode,proto3,oneof" json:"inode,omitempty"` // Cgroup inode of the container.
PodUID *string `protobuf:"bytes,4,opt,name=podUID,proto3,oneof" json:"podUID,omitempty"` // Pod UID send from the client.
// contains filtered or unexported fields
}
Nested message for the local data
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) Descriptor
deprecated
added in
v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) Descriptor() ([]byte, []int)
Deprecated: Use GenerateContainerIDFromOriginInfoRequest_LocalData.ProtoReflect.Descriptor instead.
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) GetContainerID ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetContainerID() string
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) GetInode ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetInode() uint64
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) GetPodUID ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetPodUID() string
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) GetProcessID ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) GetProcessID() uint32
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoMessage ¶ added in v0.62.0
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoMessage()
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoReflect ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) ProtoReflect() protoreflect.Message
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) Reset ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) Reset()
func (*GenerateContainerIDFromOriginInfoRequest_LocalData) String ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoRequest_LocalData) String() string
type GenerateContainerIDFromOriginInfoResponse ¶ added in v0.62.0
type GenerateContainerIDFromOriginInfoResponse struct {
ContainerID string `protobuf:"bytes,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
// contains filtered or unexported fields
}
func (*GenerateContainerIDFromOriginInfoResponse) Descriptor
deprecated
added in
v0.62.0
func (*GenerateContainerIDFromOriginInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenerateContainerIDFromOriginInfoResponse.ProtoReflect.Descriptor instead.
func (*GenerateContainerIDFromOriginInfoResponse) GetContainerID ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoResponse) GetContainerID() string
func (*GenerateContainerIDFromOriginInfoResponse) ProtoMessage ¶ added in v0.62.0
func (*GenerateContainerIDFromOriginInfoResponse) ProtoMessage()
func (*GenerateContainerIDFromOriginInfoResponse) ProtoReflect ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoResponse) ProtoReflect() protoreflect.Message
func (*GenerateContainerIDFromOriginInfoResponse) Reset ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoResponse) Reset()
func (*GenerateContainerIDFromOriginInfoResponse) String ¶ added in v0.62.0
func (x *GenerateContainerIDFromOriginInfoResponse) String() string
type GetFlareFilesRequest ¶ added in v0.61.0
type GetFlareFilesRequest struct {
// contains filtered or unexported fields
}
func (*GetFlareFilesRequest) Descriptor
deprecated
added in
v0.61.0
func (*GetFlareFilesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFlareFilesRequest.ProtoReflect.Descriptor instead.
func (*GetFlareFilesRequest) ProtoMessage ¶ added in v0.61.0
func (*GetFlareFilesRequest) ProtoMessage()
func (*GetFlareFilesRequest) ProtoReflect ¶ added in v0.61.0
func (x *GetFlareFilesRequest) ProtoReflect() protoreflect.Message
func (*GetFlareFilesRequest) Reset ¶ added in v0.61.0
func (x *GetFlareFilesRequest) Reset()
func (*GetFlareFilesRequest) String ¶ added in v0.61.0
func (x *GetFlareFilesRequest) String() string
type GetFlareFilesResponse ¶ added in v0.61.0
type GetFlareFilesResponse struct {
// Set of files to add to the flare.
//
// The key is the name of the file, and the value is the contents of the file.
//
// The key SHOULD be an ASCII string with no path separators (`/`), and will be sanitized as necessary to ensure it can be
// used as a valid filename. The key SHOULD have a file extension that is applicable to the file contents, such as
// `.yaml` for YAML data.
Files map[string][]byte `` /* 137-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetFlareFilesResponse) Descriptor
deprecated
added in
v0.61.0
func (*GetFlareFilesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetFlareFilesResponse.ProtoReflect.Descriptor instead.
func (*GetFlareFilesResponse) GetFiles ¶ added in v0.61.0
func (x *GetFlareFilesResponse) GetFiles() map[string][]byte
func (*GetFlareFilesResponse) ProtoMessage ¶ added in v0.61.0
func (*GetFlareFilesResponse) ProtoMessage()
func (*GetFlareFilesResponse) ProtoReflect ¶ added in v0.61.0
func (x *GetFlareFilesResponse) ProtoReflect() protoreflect.Message
func (*GetFlareFilesResponse) Reset ¶ added in v0.61.0
func (x *GetFlareFilesResponse) Reset()
func (*GetFlareFilesResponse) String ¶ added in v0.61.0
func (x *GetFlareFilesResponse) String() string
type GetStateConfigResponse ¶
type GetStateConfigResponse struct {
ConfigState map[string]*FileMetaState `` /* 168-byte string literal not displayed */
DirectorState map[string]*FileMetaState `` /* 174-byte string literal not displayed */
TargetFilenames map[string]string `` /* 180-byte string literal not displayed */
ActiveClients []*Client `protobuf:"bytes,4,rep,name=active_clients,json=activeClients,proto3" json:"active_clients,omitempty"`
ConfigSubscriptionStates []*ConfigSubscriptionState `` /* 135-byte string literal not displayed */
// 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) GetConfigSubscriptionStates ¶ added in v0.73.0
func (x *GetStateConfigResponse) GetConfigSubscriptionStates() []*ConfigSubscriptionState
func (*GetStateConfigResponse) GetDirectorState ¶
func (x *GetStateConfigResponse) GetDirectorState() map[string]*FileMetaState
func (*GetStateConfigResponse) GetTargetFilenames ¶
func (x *GetStateConfigResponse) GetTargetFilenames() map[string]string
func (*GetStateConfigResponse) MarshalMsg ¶
func (z *GetStateConfigResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*GetStateConfigResponse) Msgsize ¶
func (z *GetStateConfigResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*GetStateConfigResponse) UnmarshalMsg ¶
func (z *GetStateConfigResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type GetStatusDetailsRequest ¶ added in v0.61.0
type GetStatusDetailsRequest struct {
// contains filtered or unexported fields
}
func (*GetStatusDetailsRequest) Descriptor
deprecated
added in
v0.61.0
func (*GetStatusDetailsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusDetailsRequest.ProtoReflect.Descriptor instead.
func (*GetStatusDetailsRequest) ProtoMessage ¶ added in v0.61.0
func (*GetStatusDetailsRequest) ProtoMessage()
func (*GetStatusDetailsRequest) ProtoReflect ¶ added in v0.61.0
func (x *GetStatusDetailsRequest) ProtoReflect() protoreflect.Message
func (*GetStatusDetailsRequest) Reset ¶ added in v0.61.0
func (x *GetStatusDetailsRequest) Reset()
func (*GetStatusDetailsRequest) String ¶ added in v0.61.0
func (x *GetStatusDetailsRequest) String() string
type GetStatusDetailsResponse ¶ added in v0.61.0
type GetStatusDetailsResponse struct {
// Main status detail section.
//
// Generally reserved for high-level details such as version, uptime, configuration flags, etc.
MainSection *StatusSection `protobuf:"bytes,1,opt,name=main_section,json=mainSection,proto3" json:"main_section,omitempty"`
// Named status detail sections.
//
// Generally reserved for specific (sub)component details, such as the status of a specific feature or integration, etc.
NamedSections map[string]*StatusSection `` /* 174-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetStatusDetailsResponse) Descriptor
deprecated
added in
v0.61.0
func (*GetStatusDetailsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusDetailsResponse.ProtoReflect.Descriptor instead.
func (*GetStatusDetailsResponse) GetMainSection ¶ added in v0.61.0
func (x *GetStatusDetailsResponse) GetMainSection() *StatusSection
func (*GetStatusDetailsResponse) GetNamedSections ¶ added in v0.61.0
func (x *GetStatusDetailsResponse) GetNamedSections() map[string]*StatusSection
func (*GetStatusDetailsResponse) ProtoMessage ¶ added in v0.61.0
func (*GetStatusDetailsResponse) ProtoMessage()
func (*GetStatusDetailsResponse) ProtoReflect ¶ added in v0.61.0
func (x *GetStatusDetailsResponse) ProtoReflect() protoreflect.Message
func (*GetStatusDetailsResponse) Reset ¶ added in v0.61.0
func (x *GetStatusDetailsResponse) Reset()
func (*GetStatusDetailsResponse) String ¶ added in v0.61.0
func (x *GetStatusDetailsResponse) String() string
type GetTelemetryRequest ¶ added in v0.66.0
type GetTelemetryRequest struct {
// contains filtered or unexported fields
}
func (*GetTelemetryRequest) Descriptor
deprecated
added in
v0.66.0
func (*GetTelemetryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTelemetryRequest.ProtoReflect.Descriptor instead.
func (*GetTelemetryRequest) ProtoMessage ¶ added in v0.66.0
func (*GetTelemetryRequest) ProtoMessage()
func (*GetTelemetryRequest) ProtoReflect ¶ added in v0.66.0
func (x *GetTelemetryRequest) ProtoReflect() protoreflect.Message
func (*GetTelemetryRequest) Reset ¶ added in v0.66.0
func (x *GetTelemetryRequest) Reset()
func (*GetTelemetryRequest) String ¶ added in v0.66.0
func (x *GetTelemetryRequest) String() string
type GetTelemetryResponse ¶ added in v0.66.0
type GetTelemetryResponse struct {
// Telemetry payload.
//
// Types that are valid to be assigned to Payload:
//
// *GetTelemetryResponse_PromText
Payload isGetTelemetryResponse_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*GetTelemetryResponse) Descriptor
deprecated
added in
v0.66.0
func (*GetTelemetryResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTelemetryResponse.ProtoReflect.Descriptor instead.
func (*GetTelemetryResponse) GetPayload ¶ added in v0.66.0
func (x *GetTelemetryResponse) GetPayload() isGetTelemetryResponse_Payload
func (*GetTelemetryResponse) GetPromText ¶ added in v0.66.0
func (x *GetTelemetryResponse) GetPromText() string
func (*GetTelemetryResponse) ProtoMessage ¶ added in v0.66.0
func (*GetTelemetryResponse) ProtoMessage()
func (*GetTelemetryResponse) ProtoReflect ¶ added in v0.66.0
func (x *GetTelemetryResponse) ProtoReflect() protoreflect.Message
func (*GetTelemetryResponse) Reset ¶ added in v0.66.0
func (x *GetTelemetryResponse) Reset()
func (*GetTelemetryResponse) String ¶ added in v0.66.0
func (x *GetTelemetryResponse) String() string
type GetTelemetryResponse_PromText ¶ added in v0.66.0
type GetTelemetryResponse_PromText struct {
// Prometheus "text" exposition format.
//
// https://prometheus.io/docs/instrumenting/exposition_formats/#text-based-format
PromText string `protobuf:"bytes,1,opt,name=prom_text,json=promText,proto3,oneof"`
}
type HostTagReply ¶ added in v0.63.0
type HostTagReply struct {
System []string `protobuf:"bytes,1,rep,name=system,proto3" json:"system,omitempty"`
GoogleCloudPlatform []string `protobuf:"bytes,2,rep,name=googleCloudPlatform,proto3" json:"googleCloudPlatform,omitempty"`
// contains filtered or unexported fields
}
func (*HostTagReply) Descriptor
deprecated
added in
v0.63.0
func (*HostTagReply) Descriptor() ([]byte, []int)
Deprecated: Use HostTagReply.ProtoReflect.Descriptor instead.
func (*HostTagReply) GetGoogleCloudPlatform ¶ added in v0.63.0
func (x *HostTagReply) GetGoogleCloudPlatform() []string
func (*HostTagReply) GetSystem ¶ added in v0.63.0
func (x *HostTagReply) GetSystem() []string
func (*HostTagReply) ProtoMessage ¶ added in v0.63.0
func (*HostTagReply) ProtoMessage()
func (*HostTagReply) ProtoReflect ¶ added in v0.63.0
func (x *HostTagReply) ProtoReflect() protoreflect.Message
func (*HostTagReply) Reset ¶ added in v0.63.0
func (x *HostTagReply) Reset()
func (*HostTagReply) String ¶ added in v0.63.0
func (x *HostTagReply) String() string
type HostTagRequest ¶ added in v0.63.0
type HostTagRequest struct {
// contains filtered or unexported fields
}
func (*HostTagRequest) Descriptor
deprecated
added in
v0.63.0
func (*HostTagRequest) Descriptor() ([]byte, []int)
Deprecated: Use HostTagRequest.ProtoReflect.Descriptor instead.
func (*HostTagRequest) ProtoMessage ¶ added in v0.63.0
func (*HostTagRequest) ProtoMessage()
func (*HostTagRequest) ProtoReflect ¶ added in v0.63.0
func (x *HostTagRequest) ProtoReflect() protoreflect.Message
func (*HostTagRequest) Reset ¶ added in v0.63.0
func (x *HostTagRequest) Reset()
func (*HostTagRequest) String ¶ added in v0.63.0
func (x *HostTagRequest) 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 InjectionState ¶ added in v0.72.0
type InjectionState int32
const ( InjectionState_INJECTION_UNKNOWN InjectionState = 0 InjectionState_INJECTION_INJECTED InjectionState = 1 InjectionState_INJECTION_NOT_INJECTED InjectionState = 2 )
func (InjectionState) Descriptor ¶ added in v0.72.0
func (InjectionState) Descriptor() protoreflect.EnumDescriptor
func (InjectionState) Enum ¶ added in v0.72.0
func (x InjectionState) Enum() *InjectionState
func (InjectionState) EnumDescriptor
deprecated
added in
v0.72.0
func (InjectionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use InjectionState.Descriptor instead.
func (InjectionState) Number ¶ added in v0.72.0
func (x InjectionState) Number() protoreflect.EnumNumber
func (InjectionState) String ¶ added in v0.72.0
func (x InjectionState) String() string
func (InjectionState) Type ¶ added in v0.72.0
func (InjectionState) Type() protoreflect.EnumType
type KubeEndpointsIdentifier ¶ added in v0.69.0
type KubeEndpointsIdentifier struct {
KubeNamespacedName *KubeNamespacedName `protobuf:"bytes,1,opt,name=kubeNamespacedName,proto3" json:"kubeNamespacedName,omitempty"`
Resolve string `protobuf:"bytes,2,opt,name=resolve,proto3" json:"resolve,omitempty"`
// contains filtered or unexported fields
}
func (*KubeEndpointsIdentifier) Descriptor
deprecated
added in
v0.69.0
func (*KubeEndpointsIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use KubeEndpointsIdentifier.ProtoReflect.Descriptor instead.
func (*KubeEndpointsIdentifier) GetKubeNamespacedName ¶ added in v0.69.0
func (x *KubeEndpointsIdentifier) GetKubeNamespacedName() *KubeNamespacedName
func (*KubeEndpointsIdentifier) GetResolve ¶ added in v0.69.0
func (x *KubeEndpointsIdentifier) GetResolve() string
func (*KubeEndpointsIdentifier) ProtoMessage ¶ added in v0.69.0
func (*KubeEndpointsIdentifier) ProtoMessage()
func (*KubeEndpointsIdentifier) ProtoReflect ¶ added in v0.69.0
func (x *KubeEndpointsIdentifier) ProtoReflect() protoreflect.Message
func (*KubeEndpointsIdentifier) Reset ¶ added in v0.69.0
func (x *KubeEndpointsIdentifier) Reset()
func (*KubeEndpointsIdentifier) String ¶ added in v0.69.0
func (x *KubeEndpointsIdentifier) String() string
type KubeNamespacedName ¶ added in v0.62.0
type KubeNamespacedName 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"`
// contains filtered or unexported fields
}
func (*KubeNamespacedName) Descriptor
deprecated
added in
v0.62.0
func (*KubeNamespacedName) Descriptor() ([]byte, []int)
Deprecated: Use KubeNamespacedName.ProtoReflect.Descriptor instead.
func (*KubeNamespacedName) GetName ¶ added in v0.62.0
func (x *KubeNamespacedName) GetName() string
func (*KubeNamespacedName) GetNamespace ¶ added in v0.62.0
func (x *KubeNamespacedName) GetNamespace() string
func (*KubeNamespacedName) ProtoMessage ¶ added in v0.62.0
func (*KubeNamespacedName) ProtoMessage()
func (*KubeNamespacedName) ProtoReflect ¶ added in v0.62.0
func (x *KubeNamespacedName) ProtoReflect() protoreflect.Message
func (*KubeNamespacedName) Reset ¶ added in v0.62.0
func (x *KubeNamespacedName) Reset()
func (*KubeNamespacedName) String ¶ added in v0.62.0
func (x *KubeNamespacedName) 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 `` /* 158-byte string literal not displayed */
InitContainers []*OrchestratorContainer `protobuf:"bytes,13,rep,name=InitContainers,proto3" json:"InitContainers,omitempty"`
RuntimeClass string `protobuf:"bytes,14,opt,name=runtimeClass,proto3" json:"runtimeClass,omitempty"`
EphemeralContainers []*OrchestratorContainer `protobuf:"bytes,15,rep,name=ephemeralContainers,proto3" json:"ephemeralContainers,omitempty"`
// 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) GetEphemeralContainers ¶ added in v0.69.0
func (x *KubernetesPod) GetEphemeralContainers() []*OrchestratorContainer
func (*KubernetesPod) GetInitContainers ¶ added in v0.49.0
func (x *KubernetesPod) GetInitContainers() []*OrchestratorContainer
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) GetRuntimeClass ¶ added in v0.57.0
func (x *KubernetesPod) GetRuntimeClass() string
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.71.0
type Language 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"`
// contains filtered or unexported fields
}
func (*Language) Descriptor
deprecated
added in
v0.71.0
func (*Language) GetVersion ¶ added in v0.71.0
func (*Language) ProtoMessage ¶ added in v0.71.0
func (*Language) ProtoMessage()
func (*Language) ProtoReflect ¶ added in v0.71.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"`
Tags []string `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
AgentUuid string `protobuf:"bytes,16,opt,name=agent_uuid,json=agentUuid,proto3" json:"agent_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) GetAgentUuid ¶ added in v0.52.0
func (x *LatestConfigsRequest) GetAgentUuid() string
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) GetTags ¶ added in v0.52.0
func (x *LatestConfigsRequest) GetTags() []string
func (*LatestConfigsRequest) GetTraceAgentEnv ¶
func (x *LatestConfigsRequest) GetTraceAgentEnv() string
func (*LatestConfigsRequest) MarshalMsg ¶
func (z *LatestConfigsRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*LatestConfigsRequest) Msgsize ¶
func (z *LatestConfigsRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*LatestConfigsRequest) UnmarshalMsg ¶
func (z *LatestConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z *LatestConfigsResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*LatestConfigsResponse) Msgsize ¶
func (z *LatestConfigsResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*LatestConfigsResponse) UnmarshalMsg ¶
func (z *LatestConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z OrgDataResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (OrgDataResponse) Msgsize ¶
func (z OrgDataResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*OrgDataResponse) UnmarshalMsg ¶
func (z *OrgDataResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type OrgStatusResponse ¶
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
func (*OrgStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use OrgStatusResponse.ProtoReflect.Descriptor instead.
func (*OrgStatusResponse) GetAuthorized ¶
func (x *OrgStatusResponse) GetAuthorized() bool
func (*OrgStatusResponse) GetEnabled ¶
func (x *OrgStatusResponse) GetEnabled() bool
func (OrgStatusResponse) MarshalMsg ¶
func (z OrgStatusResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (OrgStatusResponse) Msgsize ¶
func (z OrgStatusResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*OrgStatusResponse) ProtoMessage ¶
func (*OrgStatusResponse) ProtoMessage()
func (*OrgStatusResponse) ProtoReflect ¶
func (x *OrgStatusResponse) ProtoReflect() protoreflect.Message
func (*OrgStatusResponse) Reset ¶
func (x *OrgStatusResponse) Reset()
func (*OrgStatusResponse) String ¶
func (x *OrgStatusResponse) String() string
func (*OrgStatusResponse) UnmarshalMsg ¶
func (z *OrgStatusResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type PackageState ¶ added in v0.52.0
type PackageState struct {
Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
StableVersion string `protobuf:"bytes,2,opt,name=stable_version,json=stableVersion,proto3" json:"stable_version,omitempty"`
ExperimentVersion string `protobuf:"bytes,3,opt,name=experiment_version,json=experimentVersion,proto3" json:"experiment_version,omitempty"`
Task *PackageStateTask `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"`
StableConfigVersion string `protobuf:"bytes,11,opt,name=stable_config_version,json=stableConfigVersion,proto3" json:"stable_config_version,omitempty"`
ExperimentConfigVersion string `` /* 133-byte string literal not displayed */
RunningVersion string `protobuf:"bytes,13,opt,name=running_version,json=runningVersion,proto3" json:"running_version,omitempty"`
RunningConfigVersion string `protobuf:"bytes,14,opt,name=running_config_version,json=runningConfigVersion,proto3" json:"running_config_version,omitempty"`
// contains filtered or unexported fields
}
func (*PackageState) Descriptor
deprecated
added in
v0.52.0
func (*PackageState) Descriptor() ([]byte, []int)
Deprecated: Use PackageState.ProtoReflect.Descriptor instead.
func (*PackageState) GetExperimentConfigVersion ¶ added in v0.58.0
func (x *PackageState) GetExperimentConfigVersion() string
func (*PackageState) GetExperimentVersion ¶ added in v0.52.0
func (x *PackageState) GetExperimentVersion() string
func (*PackageState) GetPackage ¶ added in v0.52.0
func (x *PackageState) GetPackage() string
func (*PackageState) GetRunningConfigVersion ¶ added in v0.74.0
func (x *PackageState) GetRunningConfigVersion() string
func (*PackageState) GetRunningVersion ¶ added in v0.74.0
func (x *PackageState) GetRunningVersion() string
func (*PackageState) GetStableConfigVersion ¶ added in v0.58.0
func (x *PackageState) GetStableConfigVersion() string
func (*PackageState) GetStableVersion ¶ added in v0.52.0
func (x *PackageState) GetStableVersion() string
func (*PackageState) GetTask ¶ added in v0.53.0
func (x *PackageState) GetTask() *PackageStateTask
func (*PackageState) MarshalMsg ¶ added in v0.52.0
func (z *PackageState) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*PackageState) Msgsize ¶ added in v0.52.0
func (z *PackageState) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*PackageState) ProtoMessage ¶ added in v0.52.0
func (*PackageState) ProtoMessage()
func (*PackageState) ProtoReflect ¶ added in v0.52.0
func (x *PackageState) ProtoReflect() protoreflect.Message
func (*PackageState) Reset ¶ added in v0.52.0
func (x *PackageState) Reset()
func (*PackageState) String ¶ added in v0.52.0
func (x *PackageState) String() string
func (*PackageState) UnmarshalMsg ¶ added in v0.52.0
func (z *PackageState) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type PackageStateTask ¶ added in v0.53.0
type PackageStateTask struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
State TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=datadog.config.TaskState" json:"state,omitempty"`
Error *TaskError `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*PackageStateTask) Descriptor
deprecated
added in
v0.53.0
func (*PackageStateTask) Descriptor() ([]byte, []int)
Deprecated: Use PackageStateTask.ProtoReflect.Descriptor instead.
func (*PackageStateTask) GetError ¶ added in v0.53.0
func (x *PackageStateTask) GetError() *TaskError
func (*PackageStateTask) GetId ¶ added in v0.53.0
func (x *PackageStateTask) GetId() string
func (*PackageStateTask) GetState ¶ added in v0.53.0
func (x *PackageStateTask) GetState() TaskState
func (*PackageStateTask) MarshalMsg ¶ added in v0.53.0
func (z *PackageStateTask) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*PackageStateTask) Msgsize ¶ added in v0.53.0
func (z *PackageStateTask) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*PackageStateTask) ProtoMessage ¶ added in v0.53.0
func (*PackageStateTask) ProtoMessage()
func (*PackageStateTask) ProtoReflect ¶ added in v0.53.0
func (x *PackageStateTask) ProtoReflect() protoreflect.Message
func (*PackageStateTask) Reset ¶ added in v0.53.0
func (x *PackageStateTask) Reset()
func (*PackageStateTask) String ¶ added in v0.53.0
func (x *PackageStateTask) String() string
func (*PackageStateTask) UnmarshalMsg ¶ added in v0.53.0
func (z *PackageStateTask) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type Process ¶ added in v0.71.0
type Process struct {
EntityId *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"`
Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
Nspid int32 `protobuf:"varint,3,opt,name=nspid,proto3" json:"nspid,omitempty"`
Ppid int32 `protobuf:"varint,4,opt,name=ppid,proto3" json:"ppid,omitempty"`
Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
Cwd string `protobuf:"bytes,6,opt,name=cwd,proto3" json:"cwd,omitempty"`
Exe string `protobuf:"bytes,7,opt,name=exe,proto3" json:"exe,omitempty"`
Comm string `protobuf:"bytes,8,opt,name=comm,proto3" json:"comm,omitempty"`
Cmdline []string `protobuf:"bytes,9,rep,name=cmdline,proto3" json:"cmdline,omitempty"`
Uids []int32 `protobuf:"varint,10,rep,packed,name=uids,proto3" json:"uids,omitempty"`
Gids []int32 `protobuf:"varint,11,rep,packed,name=gids,proto3" json:"gids,omitempty"`
ContainerId string `protobuf:"bytes,12,opt,name=containerId,proto3" json:"containerId,omitempty"`
CreationTime int64 `protobuf:"varint,13,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
Language *Language `protobuf:"bytes,14,opt,name=language,proto3" json:"language,omitempty"`
Owner *WorkloadmetaEntityId `protobuf:"bytes,15,opt,name=owner,proto3" json:"owner,omitempty"`
Service *Service `protobuf:"bytes,16,opt,name=service,proto3" json:"service,omitempty"`
InjectionState InjectionState `protobuf:"varint,17,opt,name=injectionState,proto3,enum=datadog.workloadmeta.InjectionState" json:"injectionState,omitempty"`
// contains filtered or unexported fields
}
func (*Process) Descriptor
deprecated
added in
v0.71.0
func (*Process) GetCmdline ¶ added in v0.71.0
func (*Process) GetContainerId ¶ added in v0.71.0
func (*Process) GetCreationTime ¶ added in v0.71.0
func (*Process) GetEntityId ¶ added in v0.71.0
func (x *Process) GetEntityId() *WorkloadmetaEntityId
func (*Process) GetInjectionState ¶ added in v0.72.0
func (x *Process) GetInjectionState() InjectionState
func (*Process) GetLanguage ¶ added in v0.71.0
func (*Process) GetOwner ¶ added in v0.71.0
func (x *Process) GetOwner() *WorkloadmetaEntityId
func (*Process) GetService ¶ added in v0.71.0
func (*Process) ProtoMessage ¶ added in v0.71.0
func (*Process) ProtoMessage()
func (*Process) ProtoReflect ¶ added in v0.71.0
func (x *Process) ProtoReflect() protoreflect.Message
type RefreshRemoteAgentRequest ¶ added in v0.73.0
type RefreshRemoteAgentRequest struct {
// UUID representing the current connection between the remoteAgentRegistry and the remoteAgent.
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
func (*RefreshRemoteAgentRequest) Descriptor
deprecated
added in
v0.73.0
func (*RefreshRemoteAgentRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshRemoteAgentRequest.ProtoReflect.Descriptor instead.
func (*RefreshRemoteAgentRequest) GetSessionId ¶ added in v0.73.0
func (x *RefreshRemoteAgentRequest) GetSessionId() string
func (*RefreshRemoteAgentRequest) ProtoMessage ¶ added in v0.73.0
func (*RefreshRemoteAgentRequest) ProtoMessage()
func (*RefreshRemoteAgentRequest) ProtoReflect ¶ added in v0.73.0
func (x *RefreshRemoteAgentRequest) ProtoReflect() protoreflect.Message
func (*RefreshRemoteAgentRequest) Reset ¶ added in v0.73.0
func (x *RefreshRemoteAgentRequest) Reset()
func (*RefreshRemoteAgentRequest) String ¶ added in v0.73.0
func (x *RefreshRemoteAgentRequest) String() string
type RefreshRemoteAgentResponse ¶ added in v0.73.0
type RefreshRemoteAgentResponse struct {
// contains filtered or unexported fields
}
func (*RefreshRemoteAgentResponse) Descriptor
deprecated
added in
v0.73.0
func (*RefreshRemoteAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshRemoteAgentResponse.ProtoReflect.Descriptor instead.
func (*RefreshRemoteAgentResponse) ProtoMessage ¶ added in v0.73.0
func (*RefreshRemoteAgentResponse) ProtoMessage()
func (*RefreshRemoteAgentResponse) ProtoReflect ¶ added in v0.73.0
func (x *RefreshRemoteAgentResponse) ProtoReflect() protoreflect.Message
func (*RefreshRemoteAgentResponse) Reset ¶ added in v0.73.0
func (x *RefreshRemoteAgentResponse) Reset()
func (*RefreshRemoteAgentResponse) String ¶ added in v0.73.0
func (x *RefreshRemoteAgentResponse) String() string
type RegisterRemoteAgentRequest ¶ added in v0.61.0
type RegisterRemoteAgentRequest struct {
// Process ID of the remote agent.
Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
// Flavor of the remoteAgent
//
// This should be a stable, unique name for the agent instance (e.g., "otel_agent").
Flavor string `protobuf:"bytes,2,opt,name=flavor,proto3" json:"flavor,omitempty"`
// Human-friendly display name of the remote agent.
//
// SHOULD be the common name for the remote agent, such as "OpenTelemetry Collector".
DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// gRPC endpoint address where the remote agent can be reached.
//
// MUST be a valid gRPC endpoint address, such as "localhost:4317".
// MUST expose the `RemoteAgent` service.
// MUST be prefixed by the transport layer if not TCP (e.g., "unix:///opt/datadog-agent/run/trace-agent.sock").
//
// Currently supported transport layers: ["tcp"]
//
// MUST be secured with TLS if using TCP, and SHOULD present a valid certificate where possible.
ApiEndpointUri string `protobuf:"bytes,4,opt,name=api_endpoint_uri,json=apiEndpointUri,proto3" json:"api_endpoint_uri,omitempty"`
// List of services that the remote agent supports.
// service name MUST be the full name of the service, such as "datadog.remoteagent.status.v1.StatusProvider".
Services []string `protobuf:"bytes,5,rep,name=services,proto3" json:"services,omitempty"`
// contains filtered or unexported fields
}
This message contains fields that identify a Remote Agent instance.
func (*RegisterRemoteAgentRequest) Descriptor
deprecated
added in
v0.61.0
func (*RegisterRemoteAgentRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRemoteAgentRequest.ProtoReflect.Descriptor instead.
func (*RegisterRemoteAgentRequest) GetApiEndpointUri ¶ added in v0.73.0
func (x *RegisterRemoteAgentRequest) GetApiEndpointUri() string
func (*RegisterRemoteAgentRequest) GetDisplayName ¶ added in v0.61.0
func (x *RegisterRemoteAgentRequest) GetDisplayName() string
func (*RegisterRemoteAgentRequest) GetFlavor ¶ added in v0.73.0
func (x *RegisterRemoteAgentRequest) GetFlavor() string
func (*RegisterRemoteAgentRequest) GetPid ¶ added in v0.73.0
func (x *RegisterRemoteAgentRequest) GetPid() string
func (*RegisterRemoteAgentRequest) GetServices ¶ added in v0.73.0
func (x *RegisterRemoteAgentRequest) GetServices() []string
func (*RegisterRemoteAgentRequest) ProtoMessage ¶ added in v0.61.0
func (*RegisterRemoteAgentRequest) ProtoMessage()
func (*RegisterRemoteAgentRequest) ProtoReflect ¶ added in v0.61.0
func (x *RegisterRemoteAgentRequest) ProtoReflect() protoreflect.Message
func (*RegisterRemoteAgentRequest) Reset ¶ added in v0.61.0
func (x *RegisterRemoteAgentRequest) Reset()
func (*RegisterRemoteAgentRequest) String ¶ added in v0.61.0
func (x *RegisterRemoteAgentRequest) String() string
type RegisterRemoteAgentResponse ¶ added in v0.61.0
type RegisterRemoteAgentResponse struct {
// UUID representing the current connection between the remoteAgentRegistry and the remoteAgent.
//
// The remoteAgent MUST include its session_id in all the response to the remoteAgentRegistry
// as a metadata named `session_id`.
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// Recommended refresh interval for the remote agent.
//
// This is the interval at which the remote agent should call the RegisterRemoteAgent RPC in order to assert that the
// remote agent is live and healthy.
//
// The remote agent SHOULD refresh its status every `recommended_refresh_interval_secs` seconds.
RecommendedRefreshIntervalSecs uint32 `` /* 156-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*RegisterRemoteAgentResponse) Descriptor
deprecated
added in
v0.61.0
func (*RegisterRemoteAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRemoteAgentResponse.ProtoReflect.Descriptor instead.
func (*RegisterRemoteAgentResponse) GetRecommendedRefreshIntervalSecs ¶ added in v0.61.0
func (x *RegisterRemoteAgentResponse) GetRecommendedRefreshIntervalSecs() uint32
func (*RegisterRemoteAgentResponse) GetSessionId ¶ added in v0.73.0
func (x *RegisterRemoteAgentResponse) GetSessionId() string
func (*RegisterRemoteAgentResponse) ProtoMessage ¶ added in v0.61.0
func (*RegisterRemoteAgentResponse) ProtoMessage()
func (*RegisterRemoteAgentResponse) ProtoReflect ¶ added in v0.61.0
func (x *RegisterRemoteAgentResponse) ProtoReflect() protoreflect.Message
func (*RegisterRemoteAgentResponse) Reset ¶ added in v0.61.0
func (x *RegisterRemoteAgentResponse) Reset()
func (*RegisterRemoteAgentResponse) String ¶ added in v0.61.0
func (x *RegisterRemoteAgentResponse) String() string
type ResetStateConfigResponse ¶ added in v0.70.0
type ResetStateConfigResponse struct {
// contains filtered or unexported fields
}
func (*ResetStateConfigResponse) Descriptor
deprecated
added in
v0.70.0
func (*ResetStateConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResetStateConfigResponse.ProtoReflect.Descriptor instead.
func (ResetStateConfigResponse) MarshalMsg ¶ added in v0.70.0
func (z ResetStateConfigResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ResetStateConfigResponse) Msgsize ¶ added in v0.70.0
func (z ResetStateConfigResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ResetStateConfigResponse) ProtoMessage ¶ added in v0.70.0
func (*ResetStateConfigResponse) ProtoMessage()
func (*ResetStateConfigResponse) ProtoReflect ¶ added in v0.70.0
func (x *ResetStateConfigResponse) ProtoReflect() protoreflect.Message
func (*ResetStateConfigResponse) Reset ¶ added in v0.70.0
func (x *ResetStateConfigResponse) Reset()
func (*ResetStateConfigResponse) String ¶ added in v0.70.0
func (x *ResetStateConfigResponse) String() string
func (*ResetStateConfigResponse) UnmarshalMsg ¶ added in v0.70.0
func (z *ResetStateConfigResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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 Service ¶ added in v0.71.0
type Service struct {
GeneratedName string `protobuf:"bytes,1,opt,name=generatedName,proto3" json:"generatedName,omitempty"`
GeneratedNameSource string `protobuf:"bytes,2,opt,name=generatedNameSource,proto3" json:"generatedNameSource,omitempty"`
AdditionalGeneratedNames []string `protobuf:"bytes,4,rep,name=additionalGeneratedNames,proto3" json:"additionalGeneratedNames,omitempty"`
TracerMetadata []*TracerMetadata `protobuf:"bytes,5,rep,name=tracerMetadata,proto3" json:"tracerMetadata,omitempty"`
TcpPorts []int32 `protobuf:"varint,7,rep,packed,name=tcpPorts,proto3" json:"tcpPorts,omitempty"`
UdpPorts []int32 `protobuf:"varint,8,rep,packed,name=udpPorts,proto3" json:"udpPorts,omitempty"`
ApmInstrumentation bool `protobuf:"varint,9,opt,name=apmInstrumentation,proto3" json:"apmInstrumentation,omitempty"`
Ust *UST `protobuf:"bytes,17,opt,name=ust,proto3" json:"ust,omitempty"`
// contains filtered or unexported fields
}
func (*Service) Descriptor
deprecated
added in
v0.71.0
func (*Service) GetAdditionalGeneratedNames ¶ added in v0.71.0
func (*Service) GetApmInstrumentation ¶ added in v0.71.0
func (*Service) GetGeneratedName ¶ added in v0.71.0
func (*Service) GetGeneratedNameSource ¶ added in v0.71.0
func (*Service) GetTcpPorts ¶ added in v0.71.0
func (*Service) GetTracerMetadata ¶ added in v0.71.0
func (x *Service) GetTracerMetadata() []*TracerMetadata
func (*Service) GetUdpPorts ¶ added in v0.71.0
func (*Service) ProtoMessage ¶ added in v0.71.0
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶ added in v0.71.0
func (x *Service) ProtoReflect() protoreflect.Message
type StatusProviderClient ¶ added in v0.73.0
type StatusProviderClient interface {
// Gets the status details of a remote agent.
GetStatusDetails(ctx context.Context, in *GetStatusDetailsRequest, opts ...grpc.CallOption) (*GetStatusDetailsResponse, error)
}
StatusProviderClient is the client API for StatusProvider service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStatusProviderClient ¶ added in v0.73.0
func NewStatusProviderClient(cc grpc.ClientConnInterface) StatusProviderClient
type StatusProviderServer ¶ added in v0.73.0
type StatusProviderServer interface {
// Gets the status details of a remote agent.
GetStatusDetails(context.Context, *GetStatusDetailsRequest) (*GetStatusDetailsResponse, error)
// contains filtered or unexported methods
}
StatusProviderServer is the server API for StatusProvider service. All implementations must embed UnimplementedStatusProviderServer for forward compatibility.
type StatusSection ¶ added in v0.61.0
type StatusSection struct {
Fields map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*StatusSection) Descriptor
deprecated
added in
v0.61.0
func (*StatusSection) Descriptor() ([]byte, []int)
Deprecated: Use StatusSection.ProtoReflect.Descriptor instead.
func (*StatusSection) GetFields ¶ added in v0.61.0
func (x *StatusSection) GetFields() map[string]string
func (*StatusSection) ProtoMessage ¶ added in v0.61.0
func (*StatusSection) ProtoMessage()
func (*StatusSection) ProtoReflect ¶ added in v0.61.0
func (x *StatusSection) ProtoReflect() protoreflect.Message
func (*StatusSection) Reset ¶ added in v0.61.0
func (x *StatusSection) Reset()
func (*StatusSection) String ¶ added in v0.61.0
func (x *StatusSection) String() string
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 *DeprecatedFilter `protobuf:"bytes,2,opt,name=includeFilter,proto3" json:"includeFilter,omitempty"`
ExcludeFilter *DeprecatedFilter `protobuf:"bytes,3,opt,name=excludeFilter,proto3" json:"excludeFilter,omitempty"`
Prefixes []string `protobuf:"bytes,4,rep,name=prefixes,proto3" json:"prefixes,omitempty"`
StreamingID string `protobuf:"bytes,5,opt,name=streamingID,proto3" json:"streamingID,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() *DeprecatedFilter
func (*StreamTagsRequest) GetIncludeFilter ¶
func (x *StreamTagsRequest) GetIncludeFilter() *DeprecatedFilter
func (*StreamTagsRequest) GetPrefixes ¶ added in v0.60.0
func (x *StreamTagsRequest) GetPrefixes() []string
func (*StreamTagsRequest) GetStreamingID ¶ added in v0.60.0
func (x *StreamTagsRequest) GetStreamingID() string
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 `` /* 137-byte string literal not displayed */
PidMap map[int32]string `` /* 140-byte string literal not displayed */
Duration int64 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
// contains filtered or unexported fields
}
func (*TaggerState) Descriptor
deprecated
func (*TaggerState) Descriptor() ([]byte, []int)
Deprecated: Use TaggerState.ProtoReflect.Descriptor instead.
func (*TaggerState) GetDuration ¶ added in v0.73.0
func (x *TaggerState) GetDuration() int64
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) MarshalMsg ¶
func (z TargetFileHash) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (TargetFileHash) Msgsize ¶
func (z TargetFileHash) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*TargetFileHash) UnmarshalMsg ¶
func (z *TargetFileHash) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z *TargetFileMeta) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*TargetFileMeta) Msgsize ¶
func (z *TargetFileMeta) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*TargetFileMeta) UnmarshalMsg ¶
func (z *TargetFileMeta) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type TaskError ¶ added in v0.53.0
type TaskError struct {
Code uint64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*TaskError) Descriptor
deprecated
added in
v0.53.0
func (*TaskError) GetMessage ¶ added in v0.53.0
func (TaskError) MarshalMsg ¶ added in v0.53.0
MarshalMsg implements msgp.Marshaler
func (TaskError) Msgsize ¶ added in v0.53.0
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*TaskError) ProtoMessage ¶ added in v0.53.0
func (*TaskError) ProtoMessage()
func (*TaskError) ProtoReflect ¶ added in v0.53.0
func (x *TaskError) ProtoReflect() protoreflect.Message
type TaskState ¶ added in v0.53.0
type TaskState int32
func (TaskState) Descriptor ¶ added in v0.53.0
func (TaskState) Descriptor() protoreflect.EnumDescriptor
func (TaskState) EnumDescriptor
deprecated
added in
v0.53.0
func (TaskState) MarshalMsg ¶ added in v0.53.0
MarshalMsg implements msgp.Marshaler
func (TaskState) Msgsize ¶ added in v0.53.0
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (TaskState) Number ¶ added in v0.53.0
func (x TaskState) Number() protoreflect.EnumNumber
func (TaskState) Type ¶ added in v0.53.0
func (TaskState) Type() protoreflect.EnumType
type TelemetryProviderClient ¶ added in v0.73.0
type TelemetryProviderClient interface {
// Gets the telemetry data of a remote agent.
GetTelemetry(ctx context.Context, in *GetTelemetryRequest, opts ...grpc.CallOption) (*GetTelemetryResponse, error)
}
TelemetryProviderClient is the client API for TelemetryProvider service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTelemetryProviderClient ¶ added in v0.73.0
func NewTelemetryProviderClient(cc grpc.ClientConnInterface) TelemetryProviderClient
type TelemetryProviderServer ¶ added in v0.73.0
type TelemetryProviderServer interface {
// Gets the telemetry data of a remote agent.
GetTelemetry(context.Context, *GetTelemetryRequest) (*GetTelemetryResponse, error)
// contains filtered or unexported methods
}
TelemetryProviderServer is the server API for TelemetryProvider service. All implementations must embed UnimplementedTelemetryProviderServer for forward compatibility.
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) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
func (*TopMeta) Msgsize ¶
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*TopMeta) ProtoMessage ¶
func (*TopMeta) ProtoMessage()
func (*TopMeta) ProtoReflect ¶
func (x *TopMeta) ProtoReflect() protoreflect.Message
type TracerMetadata ¶ added in v0.71.0
type TracerMetadata struct {
RuntimeId string `protobuf:"bytes,1,opt,name=runtimeId,proto3" json:"runtimeId,omitempty"`
ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
// contains filtered or unexported fields
}
func (*TracerMetadata) Descriptor
deprecated
added in
v0.71.0
func (*TracerMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TracerMetadata.ProtoReflect.Descriptor instead.
func (*TracerMetadata) GetRuntimeId ¶ added in v0.71.0
func (x *TracerMetadata) GetRuntimeId() string
func (*TracerMetadata) GetServiceName ¶ added in v0.71.0
func (x *TracerMetadata) GetServiceName() string
func (*TracerMetadata) ProtoMessage ¶ added in v0.71.0
func (*TracerMetadata) ProtoMessage()
func (*TracerMetadata) ProtoReflect ¶ added in v0.71.0
func (x *TracerMetadata) ProtoReflect() protoreflect.Message
func (*TracerMetadata) Reset ¶ added in v0.71.0
func (x *TracerMetadata) Reset()
func (*TracerMetadata) String ¶ added in v0.71.0
func (x *TracerMetadata) String() string
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) MarshalMsg ¶
func (z *TracerPredicateV1) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*TracerPredicateV1) Msgsize ¶
func (z *TracerPredicateV1) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*TracerPredicateV1) UnmarshalMsg ¶
func (z *TracerPredicateV1) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
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) MarshalMsg ¶
func (z *TracerPredicates) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*TracerPredicates) Msgsize ¶
func (z *TracerPredicates) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
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
func (*TracerPredicates) UnmarshalMsg ¶
func (z *TracerPredicates) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type UST ¶ added in v0.72.0
type UST struct {
Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
Env string `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*UST) Descriptor
deprecated
added in
v0.72.0
func (*UST) GetService ¶ added in v0.72.0
func (*UST) GetVersion ¶ added in v0.72.0
func (*UST) ProtoMessage ¶ added in v0.72.0
func (*UST) ProtoMessage()
func (*UST) ProtoReflect ¶ added in v0.72.0
func (x *UST) ProtoReflect() protoreflect.Message
type UnimplementedAgentSecureServer ¶
type UnimplementedAgentSecureServer struct{}
UnimplementedAgentSecureServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentSecureServer) AutodiscoveryStreamConfig ¶ added in v0.62.0
func (UnimplementedAgentSecureServer) AutodiscoveryStreamConfig(*emptypb.Empty, grpc.ServerStreamingServer[AutodiscoveryStreamResponse]) error
func (UnimplementedAgentSecureServer) ClientGetConfigs ¶
func (UnimplementedAgentSecureServer) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
func (UnimplementedAgentSecureServer) ClientGetConfigsHA ¶ added in v0.52.0
func (UnimplementedAgentSecureServer) ClientGetConfigsHA(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
func (UnimplementedAgentSecureServer) CreateConfigSubscription ¶ added in v0.73.0
func (UnimplementedAgentSecureServer) CreateConfigSubscription(grpc.BidiStreamingServer[ConfigSubscriptionRequest, ConfigSubscriptionResponse]) 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) GetConfigStateHA ¶ added in v0.52.0
func (UnimplementedAgentSecureServer) GetConfigStateHA(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)
func (UnimplementedAgentSecureServer) GetHostTags ¶ added in v0.63.0
func (UnimplementedAgentSecureServer) GetHostTags(context.Context, *HostTagRequest) (*HostTagReply, error)
func (UnimplementedAgentSecureServer) RefreshRemoteAgent ¶ added in v0.73.0
func (UnimplementedAgentSecureServer) RefreshRemoteAgent(context.Context, *RefreshRemoteAgentRequest) (*RefreshRemoteAgentResponse, error)
func (UnimplementedAgentSecureServer) RegisterRemoteAgent ¶ added in v0.61.0
func (UnimplementedAgentSecureServer) RegisterRemoteAgent(context.Context, *RegisterRemoteAgentRequest) (*RegisterRemoteAgentResponse, error)
func (UnimplementedAgentSecureServer) ResetConfigState ¶ added in v0.70.0
func (UnimplementedAgentSecureServer) ResetConfigState(context.Context, *emptypb.Empty) (*ResetStateConfigResponse, error)
func (UnimplementedAgentSecureServer) StreamConfigEvents ¶ added in v0.71.0
func (UnimplementedAgentSecureServer) StreamConfigEvents(*ConfigStreamRequest, grpc.ServerStreamingServer[ConfigEvent]) error
func (UnimplementedAgentSecureServer) TaggerFetchEntity ¶
func (UnimplementedAgentSecureServer) TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
func (UnimplementedAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo ¶ added in v0.62.0
func (UnimplementedAgentSecureServer) TaggerGenerateContainerIDFromOriginInfo(context.Context, *GenerateContainerIDFromOriginInfoRequest) (*GenerateContainerIDFromOriginInfoResponse, error)
func (UnimplementedAgentSecureServer) TaggerStreamEntities ¶
func (UnimplementedAgentSecureServer) TaggerStreamEntities(*StreamTagsRequest, grpc.ServerStreamingServer[StreamTagsResponse]) error
func (UnimplementedAgentSecureServer) WorkloadFilterEvaluate ¶ added in v0.75.0
func (UnimplementedAgentSecureServer) WorkloadFilterEvaluate(context.Context, *WorkloadFilterEvaluateRequest) (*WorkloadFilterEvaluateResponse, error)
func (UnimplementedAgentSecureServer) WorkloadmetaStreamEntities ¶
func (UnimplementedAgentSecureServer) WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, grpc.ServerStreamingServer[WorkloadmetaStreamResponse]) error
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct{}
UnimplementedAgentServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentServer) GetHostname ¶
func (UnimplementedAgentServer) GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error)
type UnimplementedFlareProviderServer ¶ added in v0.73.0
type UnimplementedFlareProviderServer struct{}
UnimplementedFlareProviderServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedFlareProviderServer) GetFlareFiles ¶ added in v0.73.0
func (UnimplementedFlareProviderServer) GetFlareFiles(context.Context, *GetFlareFilesRequest) (*GetFlareFilesResponse, error)
type UnimplementedStatusProviderServer ¶ added in v0.73.0
type UnimplementedStatusProviderServer struct{}
UnimplementedStatusProviderServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedStatusProviderServer) GetStatusDetails ¶ added in v0.73.0
func (UnimplementedStatusProviderServer) GetStatusDetails(context.Context, *GetStatusDetailsRequest) (*GetStatusDetailsResponse, error)
type UnimplementedTelemetryProviderServer ¶ added in v0.73.0
type UnimplementedTelemetryProviderServer struct{}
UnimplementedTelemetryProviderServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedTelemetryProviderServer) GetTelemetry ¶ added in v0.73.0
func (UnimplementedTelemetryProviderServer) GetTelemetry(context.Context, *GetTelemetryRequest) (*GetTelemetryResponse, 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 UnsafeAgentSecureServer ¶ added in v0.76.0
type UnsafeAgentSecureServer interface {
// contains filtered or unexported methods
}
UnsafeAgentSecureServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentSecureServer will result in compilation errors.
type UnsafeAgentServer ¶ added in v0.76.0
type UnsafeAgentServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.
type UnsafeFlareProviderServer ¶ added in v0.76.0
type UnsafeFlareProviderServer interface {
// contains filtered or unexported methods
}
UnsafeFlareProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlareProviderServer will result in compilation errors.
type UnsafeStatusProviderServer ¶ added in v0.76.0
type UnsafeStatusProviderServer interface {
// contains filtered or unexported methods
}
UnsafeStatusProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatusProviderServer will result in compilation errors.
type UnsafeTelemetryProviderServer ¶ added in v0.76.0
type UnsafeTelemetryProviderServer interface {
// contains filtered or unexported methods
}
UnsafeTelemetryProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TelemetryProviderServer will result in compilation errors.
type WorkloadFilterEvaluateRequest ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest struct {
ProgramName string `protobuf:"bytes,1,opt,name=program_name,json=programName,proto3" json:"program_name,omitempty"`
// Types that are valid to be assigned to Workload:
//
// *WorkloadFilterEvaluateRequest_Container
// *WorkloadFilterEvaluateRequest_Pod
// *WorkloadFilterEvaluateRequest_Process
// *WorkloadFilterEvaluateRequest_KubeService
// *WorkloadFilterEvaluateRequest_KubeEndpoint
Workload isWorkloadFilterEvaluateRequest_Workload `protobuf_oneof:"workload"`
// contains filtered or unexported fields
}
func (*WorkloadFilterEvaluateRequest) Descriptor
deprecated
added in
v0.75.0
func (*WorkloadFilterEvaluateRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadFilterEvaluateRequest.ProtoReflect.Descriptor instead.
func (*WorkloadFilterEvaluateRequest) GetContainer ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetContainer() *FilterContainer
func (*WorkloadFilterEvaluateRequest) GetKubeEndpoint ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetKubeEndpoint() *FilterKubeEndpoint
func (*WorkloadFilterEvaluateRequest) GetKubeService ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetKubeService() *FilterKubeService
func (*WorkloadFilterEvaluateRequest) GetPod ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetPod() *FilterPod
func (*WorkloadFilterEvaluateRequest) GetProcess ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetProcess() *FilterProcess
func (*WorkloadFilterEvaluateRequest) GetProgramName ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetProgramName() string
func (*WorkloadFilterEvaluateRequest) GetWorkload ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) GetWorkload() isWorkloadFilterEvaluateRequest_Workload
func (*WorkloadFilterEvaluateRequest) ProtoMessage ¶ added in v0.75.0
func (*WorkloadFilterEvaluateRequest) ProtoMessage()
func (*WorkloadFilterEvaluateRequest) ProtoReflect ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) ProtoReflect() protoreflect.Message
func (*WorkloadFilterEvaluateRequest) Reset ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) Reset()
func (*WorkloadFilterEvaluateRequest) String ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateRequest) String() string
type WorkloadFilterEvaluateRequest_Container ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest_Container struct {
Container *FilterContainer `protobuf:"bytes,3,opt,name=container,proto3,oneof"`
}
type WorkloadFilterEvaluateRequest_KubeEndpoint ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest_KubeEndpoint struct {
KubeEndpoint *FilterKubeEndpoint `protobuf:"bytes,7,opt,name=kube_endpoint,json=kubeEndpoint,proto3,oneof"`
}
type WorkloadFilterEvaluateRequest_KubeService ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest_KubeService struct {
KubeService *FilterKubeService `protobuf:"bytes,6,opt,name=kube_service,json=kubeService,proto3,oneof"`
}
type WorkloadFilterEvaluateRequest_Pod ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest_Pod struct {
Pod *FilterPod `protobuf:"bytes,4,opt,name=pod,proto3,oneof"`
}
type WorkloadFilterEvaluateRequest_Process ¶ added in v0.75.0
type WorkloadFilterEvaluateRequest_Process struct {
Process *FilterProcess `protobuf:"bytes,5,opt,name=process,proto3,oneof"`
}
type WorkloadFilterEvaluateResponse ¶ added in v0.75.0
type WorkloadFilterEvaluateResponse struct {
Result WorkloadFilterResult `protobuf:"varint,1,opt,name=result,proto3,enum=datadog.workloadfilter.WorkloadFilterResult" json:"result,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*WorkloadFilterEvaluateResponse) Descriptor
deprecated
added in
v0.75.0
func (*WorkloadFilterEvaluateResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadFilterEvaluateResponse.ProtoReflect.Descriptor instead.
func (*WorkloadFilterEvaluateResponse) GetError ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateResponse) GetError() string
func (*WorkloadFilterEvaluateResponse) GetResult ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateResponse) GetResult() WorkloadFilterResult
func (*WorkloadFilterEvaluateResponse) ProtoMessage ¶ added in v0.75.0
func (*WorkloadFilterEvaluateResponse) ProtoMessage()
func (*WorkloadFilterEvaluateResponse) ProtoReflect ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateResponse) ProtoReflect() protoreflect.Message
func (*WorkloadFilterEvaluateResponse) Reset ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateResponse) Reset()
func (*WorkloadFilterEvaluateResponse) String ¶ added in v0.75.0
func (x *WorkloadFilterEvaluateResponse) String() string
type WorkloadFilterResult ¶ added in v0.75.0
type WorkloadFilterResult int32
const ( WorkloadFilterResult_UNKNOWN WorkloadFilterResult = 0 WorkloadFilterResult_INCLUDE WorkloadFilterResult = 1 WorkloadFilterResult_EXCLUDE WorkloadFilterResult = 2 )
func (WorkloadFilterResult) Descriptor ¶ added in v0.75.0
func (WorkloadFilterResult) Descriptor() protoreflect.EnumDescriptor
func (WorkloadFilterResult) Enum ¶ added in v0.75.0
func (x WorkloadFilterResult) Enum() *WorkloadFilterResult
func (WorkloadFilterResult) EnumDescriptor
deprecated
added in
v0.75.0
func (WorkloadFilterResult) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkloadFilterResult.Descriptor instead.
func (WorkloadFilterResult) Number ¶ added in v0.75.0
func (x WorkloadFilterResult) Number() protoreflect.EnumNumber
func (WorkloadFilterResult) String ¶ added in v0.75.0
func (x WorkloadFilterResult) String() string
func (WorkloadFilterResult) Type ¶ added in v0.75.0
func (WorkloadFilterResult) Type() protoreflect.EnumType
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"`
Process *Process `protobuf:"bytes,5,opt,name=process,proto3" json:"process,omitempty"`
Crd *Crd `protobuf:"bytes,6,opt,name=crd,proto3" json:"crd,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) GetCrd ¶ added in v0.75.0
func (x *WorkloadmetaEvent) GetCrd() *Crd
func (*WorkloadmetaEvent) GetEcsTask ¶
func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask
func (*WorkloadmetaEvent) GetKubernetesPod ¶
func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod
func (*WorkloadmetaEvent) GetProcess ¶ added in v0.71.0
func (x *WorkloadmetaEvent) GetProcess() *Process
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 WorkloadmetaKind_PROCESS WorkloadmetaKind = 3 WorkloadmetaKind_CRD WorkloadmetaKind = 4 )
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