core

package
v0.65.0-devel Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2025 License: Apache-2.0 Imports: 20 Imported by: 7

Documentation

Overview

Package core is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ConfigEventType_name = map[int32]string{
		0: "SCHEDULE",
		1: "UNSCHEDULE",
	}
	ConfigEventType_value = map[string]int32{
		"SCHEDULE":   0,
		"UNSCHEDULE": 1,
	}
)

Enum value maps for ConfigEventType.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	WorkloadmetaKind_name = map[int32]string{
		0: "CONTAINER",
		1: "KUBERNETES_POD",
		2: "ECS_TASK",
	}
	WorkloadmetaKind_value = map[string]int32{
		"CONTAINER":      0,
		"KUBERNETES_POD": 1,
		"ECS_TASK":       2,
	}
)

Enum value maps for WorkloadmetaKind.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	ECSLaunchType_name = map[int32]string{
		0: "EC2",
		1: "FARGATE",
	}
	ECSLaunchType_value = map[string]int32{
		"EC2":     0,
		"FARGATE": 1,
	}
)

Enum value maps for ECSLaunchType.

View Source 
var File_datadog_api_v1_api_proto protoreflect.FileDescriptor
View Source 
var File_datadog_autodiscovery_autodiscovery_proto protoreflect.FileDescriptor
View Source 
var File_datadog_model_v1_model_proto protoreflect.FileDescriptor
View Source 
var File_datadog_remoteagent_remoteagent_proto protoreflect.FileDescriptor
View Source 
var File_datadog_remoteconfig_remoteconfig_proto protoreflect.FileDescriptor
View Source 
var File_datadog_workloadmeta_workloadmeta_proto protoreflect.FileDescriptor

Functions

func RegisterAgentHandler 

func RegisterAgentHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAgentHandler registers the http handlers for service Agent to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAgentHandlerClient 

func RegisterAgentHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentClient) error

RegisterAgentHandlerClient registers the http handlers for service Agent to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterAgentHandlerFromEndpoint 

func RegisterAgentHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAgentHandlerFromEndpoint is same as RegisterAgentHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAgentHandlerServer 

func RegisterAgentHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentServer) error

RegisterAgentHandlerServer registers the http handlers for service Agent to "mux". UnaryRPC :call AgentServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAgentHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterAgentSecureHandler 

func RegisterAgentSecureHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAgentSecureHandler registers the http handlers for service AgentSecure to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAgentSecureHandlerClient 

func RegisterAgentSecureHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentSecureClient) error

RegisterAgentSecureHandlerClient registers the http handlers for service AgentSecure to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentSecureClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentSecureClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentSecureClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterAgentSecureHandlerFromEndpoint 

func RegisterAgentSecureHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAgentSecureHandlerFromEndpoint is same as RegisterAgentSecureHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAgentSecureHandlerServer 

func RegisterAgentSecureHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentSecureServer) error

RegisterAgentSecureHandlerServer registers the http handlers for service AgentSecure to "mux". UnaryRPC :call AgentSecureServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAgentSecureHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterAgentSecureServer 

func RegisterAgentSecureServer(s *grpc.Server, srv AgentSecureServer)

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterRemoteAgentServer added in v0.61.0 

func RegisterRemoteAgentServer(s *grpc.Server, srv RemoteAgentServer)

Types

type AdvancedADIdentifier added in v0.62.0 

type AdvancedADIdentifier struct {
	KubeService   *KubeNamespacedName `protobuf:"bytes,1,opt,name=kubeService,proto3" json:"kubeService,omitempty"`
	KubeEndpoints *KubeNamespacedName `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() *KubeNamespacedName

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentSecureClient 

type AgentSecureClient interface {
	// subscribes to added, removed, or changed entities in the Tagger
	// and streams them to clients as events.
	// can be called through the HTTP gateway, and events will be streamed as JSON:
	//
	//	  $  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities
	//	  {
	//	   "result": {
	//	       "entity": {
	//	           "id": {
	//	               "prefix": "kubernetes_pod_uid",
	//	               "uid": "4025461f832caf3fceb7fc2a32f879c6"
	//	           },
	//	           "hash": "cad4fc8fc409fcc1",
	//	           "lowCardinalityTags": [
	//	               "kube_namespace:kube-system",
	//	               "pod_phase:running"
	//	           ]
	//	       }
	//	   }
	//	}
	TaggerStreamEntities(ctx context.Context, in *StreamTagsRequest, opts ...grpc.CallOption) (AgentSecure_TaggerStreamEntitiesClient, error)
	// Generates a container ID from Origin Info.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	$ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"externalData": {"init": false,"containerName": "dd-trace-py","podUID": "c4b45c6a-b296-4bd5-88df-7c2d6bcaabef"}}' \
	//	   https://localhost:5001/v1/grpc/tagger/generate_container_id_from_origin_info
	//	{
	//	  "containerID":"c9fd60251b5237467462dad48999815eb0025f367c6e1abe91e0bd787d5915fc"
	//	}
	TaggerGenerateContainerIDFromOriginInfo(ctx context.Context, in *GenerateContainerIDFromOriginInfoRequest, opts ...grpc.CallOption) (*GenerateContainerIDFromOriginInfoResponse, error)
	// fetches an entity from the Tagger with the desired cardinality tags.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	  $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k -H "Content-Type: application/json" \
	//	     --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \
	//	     https://localhost:5001/v1/grpc/tagger/fetch_entity
	//	  {
	//	   "id": {
	//	       "prefix": "kubernetes_pod_uid",
	//	       "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507"
	//	   },
	//	   "tags": [
	//	       "kube_namespace:kube-system",
	//	       "pod_phase:running",
	//	       "kube_deployment:coredns",
	//	       "kube_service:kube-dns"
	//	   ]
	//	}
	TaggerFetchEntity(ctx context.Context, in *FetchEntityRequest, opts ...grpc.CallOption) (*FetchEntityResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdCaptureTrigger(ctx context.Context, in *CaptureTriggerRequest, opts ...grpc.CallOption) (*CaptureTriggerResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdSetTaggerState(ctx context.Context, in *TaggerState, opts ...grpc.CallOption) (*TaggerStateResponse, error)
	ClientGetConfigs(ctx context.Context, in *ClientGetConfigsRequest, opts ...grpc.CallOption) (*ClientGetConfigsResponse, error)
	GetConfigState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetStateConfigResponse, error)
	ClientGetConfigsHA(ctx context.Context, in *ClientGetConfigsRequest, opts ...grpc.CallOption) (*ClientGetConfigsResponse, error)
	GetConfigStateHA(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetStateConfigResponse, error)
	// Subscribes to added, removed, or changed entities in the Workloadmeta and
	// streams them to clients as events.
	// Can be called through the HTTP gateway, and events will be streamed as JSON.
	// Example call that receives all the events:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	//
	// Example call that receives only unset events:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"filter":{"eventType":2}}' \
	//	   https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	//
	// Example call that receives only from the cluster orchestrator:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"filter":{"source":3}}' \
	//	   https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	WorkloadmetaStreamEntities(ctx context.Context, in *WorkloadmetaStreamRequest, opts ...grpc.CallOption) (AgentSecure_WorkloadmetaStreamEntitiesClient, error)
	// Registers a remote agent.
	RegisterRemoteAgent(ctx context.Context, in *RegisterRemoteAgentRequest, opts ...grpc.CallOption) (*RegisterRemoteAgentResponse, error)
	// Subscribes to autodiscovery config updates
	AutodiscoveryStreamConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (AgentSecure_AutodiscoveryStreamConfigClient, error)
	// Get the host tags
	GetHostTags(ctx context.Context, in *HostTagRequest, opts ...grpc.CallOption) (*HostTagReply, error)
}

AgentSecureClient is the client API for AgentSecure service.

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

func NewAgentSecureClient 

func NewAgentSecureClient(cc grpc.ClientConnInterface) AgentSecureClient

type AgentSecureServer 

type AgentSecureServer interface {
	// subscribes to added, removed, or changed entities in the Tagger
	// and streams them to clients as events.
	// can be called through the HTTP gateway, and events will be streamed as JSON:
	//
	//	  $  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities
	//	  {
	//	   "result": {
	//	       "entity": {
	//	           "id": {
	//	               "prefix": "kubernetes_pod_uid",
	//	               "uid": "4025461f832caf3fceb7fc2a32f879c6"
	//	           },
	//	           "hash": "cad4fc8fc409fcc1",
	//	           "lowCardinalityTags": [
	//	               "kube_namespace:kube-system",
	//	               "pod_phase:running"
	//	           ]
	//	       }
	//	   }
	//	}
	TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error
	// Generates a container ID from Origin Info.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	$ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"externalData": {"init": false,"containerName": "dd-trace-py","podUID": "c4b45c6a-b296-4bd5-88df-7c2d6bcaabef"}}' \
	//	   https://localhost:5001/v1/grpc/tagger/generate_container_id_from_origin_info
	//	{
	//	  "containerID":"c9fd60251b5237467462dad48999815eb0025f367c6e1abe91e0bd787d5915fc"
	//	}
	TaggerGenerateContainerIDFromOriginInfo(context.Context, *GenerateContainerIDFromOriginInfoRequest) (*GenerateContainerIDFromOriginInfoResponse, error)
	// fetches an entity from the Tagger with the desired cardinality tags.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	  $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k -H "Content-Type: application/json" \
	//	     --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \
	//	     https://localhost:5001/v1/grpc/tagger/fetch_entity
	//	  {
	//	   "id": {
	//	       "prefix": "kubernetes_pod_uid",
	//	       "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507"
	//	   },
	//	   "tags": [
	//	       "kube_namespace:kube-system",
	//	       "pod_phase:running",
	//	       "kube_deployment:coredns",
	//	       "kube_service:kube-dns"
	//	   ]
	//	}
	TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)
	ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
	GetConfigState(context.Context, *empty.Empty) (*GetStateConfigResponse, error)
	ClientGetConfigsHA(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
	GetConfigStateHA(context.Context, *empty.Empty) (*GetStateConfigResponse, error)
	// Subscribes to added, removed, or changed entities in the Workloadmeta and
	// streams them to clients as events.
	// Can be called through the HTTP gateway, and events will be streamed as JSON.
	// Example call that receives all the events:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	//
	// Example call that receives only unset events:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"filter":{"eventType":2}}' \
	//	   https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	//
	// Example call that receives only from the cluster orchestrator:
	//
	//	$  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	   -XPOST -k -H "Content-Type: application/json" \
	//	   --data '{"filter":{"source":3}}' \
	//	   https://localhost:5001/v1/grpc/workloadmeta/stream_entities
	WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, AgentSecure_WorkloadmetaStreamEntitiesServer) error
	// Registers a remote agent.
	RegisterRemoteAgent(context.Context, *RegisterRemoteAgentRequest) (*RegisterRemoteAgentResponse, error)
	// Subscribes to autodiscovery config updates
	AutodiscoveryStreamConfig(*empty.Empty, AgentSecure_AutodiscoveryStreamConfigServer) error
	// Get the host tags
	GetHostTags(context.Context, *HostTagRequest) (*HostTagReply, error)
}

AgentSecureServer is the server API for AgentSecure service.

type AgentSecure_AutodiscoveryStreamConfigClient added in v0.62.0 

type AgentSecure_AutodiscoveryStreamConfigClient interface {
	Recv() (*AutodiscoveryStreamResponse, error)
	grpc.ClientStream
}

type AgentSecure_AutodiscoveryStreamConfigServer added in v0.62.0 

type AgentSecure_AutodiscoveryStreamConfigServer interface {
	Send(*AutodiscoveryStreamResponse) error
	grpc.ServerStream
}

type AgentSecure_TaggerStreamEntitiesClient 

type AgentSecure_TaggerStreamEntitiesClient interface {
	Recv() (*StreamTagsResponse, error)
	grpc.ClientStream
}

type AgentSecure_TaggerStreamEntitiesServer 

type AgentSecure_TaggerStreamEntitiesServer interface {
	Send(*StreamTagsResponse) error
	grpc.ServerStream
}

type AgentSecure_WorkloadmetaStreamEntitiesClient 

type AgentSecure_WorkloadmetaStreamEntitiesClient interface {
	Recv() (*WorkloadmetaStreamResponse, error)
	grpc.ClientStream
}

type AgentSecure_WorkloadmetaStreamEntitiesServer 

type AgentSecure_WorkloadmetaStreamEntitiesServer interface {
	Send(*WorkloadmetaStreamResponse) error
	grpc.ServerStream
}

type AgentServer 

type AgentServer interface {
	// get the hostname
	GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error)
}

AgentServer is the server API for Agent service.

type 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) Descriptor() ([]byte, []int)

Deprecated: Use Client.ProtoReflect.Descriptor instead.

func (*Client) GetCapabilities 

func (x *Client) GetCapabilities() []byte

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) GetId 

func (x *Client) GetId() string

func (*Client) GetIsAgent 

func (x *Client) GetIsAgent() bool

func (*Client) GetIsTracer 

func (x *Client) GetIsTracer() bool

func (*Client) GetIsUpdater added in v0.52.0 

func (x *Client) GetIsUpdater() bool

func (*Client) GetLastSeen 

func (x *Client) GetLastSeen() uint64

func (*Client) GetProducts 

func (x *Client) GetProducts() []string

func (*Client) GetState 

func (x *Client) GetState() *ClientState

func (*Client) MarshalMsg 

func (z *Client) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Client) Msgsize 

func (z *Client) Msgsize() (s int)

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

func (*Client) Reset 

func (x *Client) Reset()

func (*Client) String 

func (x *Client) String() string

func (*Client) UnmarshalMsg 

func (z *Client) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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"`
	// contains filtered or unexported fields
}

func (*ClientGetConfigsResponse) Descriptor deprecated 

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

Deprecated: Use ClientGetConfigsResponse.ProtoReflect.Descriptor instead.

func (*ClientGetConfigsResponse) GetClientConfigs 

func (x *ClientGetConfigsResponse) GetClientConfigs() []string

func (*ClientGetConfigsResponse) GetRoots 

func (x *ClientGetConfigsResponse) GetRoots() [][]byte

func (*ClientGetConfigsResponse) GetTargetFiles 

func (x *ClientGetConfigsResponse) GetTargetFiles() []*File

func (*ClientGetConfigsResponse) GetTargets 

func (x *ClientGetConfigsResponse) GetTargets() []byte

func (*ClientGetConfigsResponse) 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"`
	// contains filtered or unexported fields
}

func (*ClientTracer) Descriptor deprecated 

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

Deprecated: Use ClientTracer.ProtoReflect.Descriptor instead.

func (*ClientTracer) GetAppVersion 

func (x *ClientTracer) GetAppVersion() string

func (*ClientTracer) GetEnv 

func (x *ClientTracer) GetEnv() string

func (*ClientTracer) GetExtraServices 

func (x *ClientTracer) GetExtraServices() []string

func (*ClientTracer) GetLanguage 

func (x *ClientTracer) GetLanguage() string

func (*ClientTracer) GetRuntimeId 

func (x *ClientTracer) GetRuntimeId() string

func (*ClientTracer) GetService 

func (x *ClientTracer) GetService() string

func (*ClientTracer) GetTags 

func (x *ClientTracer) GetTags() []string

func (*ClientTracer) GetTracerVersion 

func (x *ClientTracer) GetTracerVersion() string

func (*ClientTracer) 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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAdIdentifiers added in v0.62.0 

func (x *Config) GetAdIdentifiers() []string

func (*Config) GetAdvancedAdIdentifiers added in v0.62.0 

func (x *Config) GetAdvancedAdIdentifiers() []*AdvancedADIdentifier

func (*Config) GetClusterCheck added in v0.62.0 

func (x *Config) GetClusterCheck() bool

func (*Config) GetEventType added in v0.62.0 

func (x *Config) GetEventType() ConfigEventType

func (*Config) GetIgnoreAutodiscoveryTags added in v0.62.0 

func (x *Config) GetIgnoreAutodiscoveryTags() bool

func (*Config) GetInitConfig added in v0.62.0 

func (x *Config) GetInitConfig() []byte

func (*Config) GetInstances added in v0.62.0 

func (x *Config) GetInstances() [][]byte

func (*Config) GetLogsConfig added in v0.62.0 

func (x *Config) GetLogsConfig() []byte

func (*Config) GetLogsExcluded added in v0.62.0 

func (x *Config) GetLogsExcluded() bool

func (*Config) GetMetricConfig added in v0.62.0 

func (x *Config) GetMetricConfig() []byte

func (*Config) GetMetricsExcluded added in v0.62.0 

func (x *Config) GetMetricsExcluded() bool

func (*Config) GetName added in v0.62.0 

func (x *Config) GetName() string

func (*Config) GetNodeName added in v0.62.0 

func (x *Config) GetNodeName() string

func (*Config) GetProvider added in v0.62.0 

func (x *Config) GetProvider() string

func (*Config) GetServiceId added in v0.62.0 

func (x *Config) GetServiceId() string

func (*Config) GetSource added in v0.62.0 

func (x *Config) GetSource() string

func (*Config) GetTaggerEntity added in v0.62.0 

func (x *Config) GetTaggerEntity() string

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

func (*Config) Reset added in v0.62.0 

func (x *Config) Reset()

func (*Config) String added in v0.62.0 

func (x *Config) 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 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 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 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"`
	AllocatedResources []*ContainerAllocatedResource `protobuf:"bytes,13,rep,name=allocatedResources,proto3" json:"allocatedResources,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetAllocatedResources 

func (x *Container) GetAllocatedResources() []*ContainerAllocatedResource

func (*Container) GetCgroupPath added in v0.55.0 

func (x *Container) GetCgroupPath() string

func (*Container) GetCollectorTags 

func (x *Container) GetCollectorTags() []string

func (*Container) GetEntityId 

func (x *Container) GetEntityId() *WorkloadmetaEntityId

func (*Container) GetEntityMeta 

func (x *Container) GetEntityMeta() *EntityMeta

func (*Container) GetEnvVars 

func (x *Container) GetEnvVars() map[string]string

func (*Container) GetHostname 

func (x *Container) GetHostname() string

func (*Container) GetImage 

func (x *Container) GetImage() *ContainerImage

func (*Container) GetNetworkIps 

func (x *Container) GetNetworkIps() map[string]string

func (*Container) GetPid 

func (x *Container) GetPid() int32

func (*Container) GetPorts 

func (x *Container) GetPorts() []*ContainerPort

func (*Container) GetRuntime 

func (x *Container) GetRuntime() Runtime

func (*Container) GetState 

func (x *Container) GetState() *ContainerState

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

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

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type ContainerAllocatedResource 

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 

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

Deprecated: Use ContainerAllocatedResource.ProtoReflect.Descriptor instead.

func (*ContainerAllocatedResource) GetID 

func (x *ContainerAllocatedResource) GetID() string

func (*ContainerAllocatedResource) GetName 

func (x *ContainerAllocatedResource) GetName() string

func (*ContainerAllocatedResource) ProtoMessage 

func (*ContainerAllocatedResource) ProtoMessage()

func (*ContainerAllocatedResource) ProtoReflect 

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

func (*ContainerAllocatedResource) Reset 

func (x *ContainerAllocatedResource) Reset()

func (*ContainerAllocatedResource) String 

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 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 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          int64                    `protobuf:"varint,12,opt,name=awsAccountID,proto3" json:"awsAccountID,omitempty"`
	// contains filtered or unexported fields
}

func (*ECSTask) Descriptor deprecated 

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

Deprecated: Use ECSTask.ProtoReflect.Descriptor instead.

func (*ECSTask) GetAvailabilityZone 

func (x *ECSTask) GetAvailabilityZone() string

func (*ECSTask) GetAwsAccountID added in v0.60.0 

func (x *ECSTask) GetAwsAccountID() int64

func (*ECSTask) GetClusterName 

func (x *ECSTask) GetClusterName() string

func (*ECSTask) GetContainerInstanceTags 

func (x *ECSTask) GetContainerInstanceTags() map[string]string

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) GetFamily 

func (x *ECSTask) GetFamily() string

func (*ECSTask) GetLaunchType 

func (x *ECSTask) GetLaunchType() ECSLaunchType

func (*ECSTask) GetRegion 

func (x *ECSTask) GetRegion() string

func (*ECSTask) GetTags 

func (x *ECSTask) GetTags() map[string]string

func (*ECSTask) GetVersion 

func (x *ECSTask) GetVersion() string

func (*ECSTask) ProtoMessage 

func (*ECSTask) ProtoMessage()

func (*ECSTask) ProtoReflect 

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

func (*ECSTask) Reset 

func (x *ECSTask) Reset()

func (*ECSTask) String 

func (x *ECSTask) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetHash 

func (x *Entity) GetHash() string

func (*Entity) GetHighCardinalityTags 

func (x *Entity) GetHighCardinalityTags() []string

func (*Entity) GetId 

func (x *Entity) GetId() *EntityId

func (*Entity) GetLowCardinalityTags 

func (x *Entity) GetLowCardinalityTags() []string

func (*Entity) GetOrchestratorCardinalityTags 

func (x *Entity) GetOrchestratorCardinalityTags() []string

func (*Entity) GetStandardTags 

func (x *Entity) GetStandardTags() []string

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use EntityId.ProtoReflect.Descriptor instead.

func (*EntityId) GetPrefix 

func (x *EntityId) GetPrefix() string

func (*EntityId) GetUid 

func (x *EntityId) GetUid() string

func (*EntityId) ProtoMessage 

func (*EntityId) ProtoMessage()

func (*EntityId) ProtoReflect 

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

func (*EntityId) Reset 

func (x *EntityId) Reset()

func (*EntityId) String 

func (x *EntityId) String() string

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
const (
	EventType_ADDED    EventType = 0
	EventType_MODIFIED EventType = 1
	EventType_DELETED  EventType = 2
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) GetRaw 

func (x *File) GetRaw() []byte

func (*File) MarshalMsg 

func (z *File) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*File) Msgsize 

func (z *File) Msgsize() (s int)

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

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

func (*File) UnmarshalMsg 

func (z *File) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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 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"`
	// contains filtered or unexported fields
}

func (*GetStateConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetStateConfigResponse.ProtoReflect.Descriptor instead.

func (*GetStateConfigResponse) GetActiveClients 

func (x *GetStateConfigResponse) GetActiveClients() []*Client

func (*GetStateConfigResponse) GetConfigState 

func (x *GetStateConfigResponse) GetConfigState() map[string]*FileMetaState

func (*GetStateConfigResponse) GetDirectorState 

func (x *GetStateConfigResponse) GetDirectorState() map[string]*FileMetaState

func (*GetStateConfigResponse) GetTargetFilenames 

func (x *GetStateConfigResponse) GetTargetFilenames() map[string]string

func (*GetStateConfigResponse) 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 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 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"`
	// 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) 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 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 */
	// 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) 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 RegisterRemoteAgentRequest added in v0.61.0 

type RegisterRemoteAgentRequest struct {

	// Unique ID of the remote agent.
	//
	// SHOULD be semi-human-readable, with a unique component, such as the process name followed by a UUID:
	// otel-agent-0192de13-3d66-7cbc-9b4f-1b74f7b8a467.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Human-friendly display name of the remote agent.
	//
	// SHOULD be the common name for the remote agent, such as OpenTelemetry Collector Agent.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// gRPC endpoint address to reach the remote agent at.
	//
	// MUST be a valid gRPC endpoint address, such as "localhost:4317"
	// MUST be exposing the `RemoteAgent` service.
	// MUST be secured with TLS, and SHOULD present a valid certificate where possible.
	ApiEndpoint string `protobuf:"bytes,3,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
	// Authentication token to be used when connecting to the remote agent's gRPC endpoint.
	//
	// The remote agent's gRPC endpoint MUST check that this authentication token was provided as a bearer token in all
	// requests made to the endpoint. If the token is not provided, the remote agent SHOULD reject the request.
	//
	// SHOULD be a unique string value that is generated randomly before a remote agent registers itself for the first time.
	AuthToken string `protobuf:"bytes,4,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRemoteAgentRequest) Descriptor deprecated added in v0.61.0 

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

Deprecated: Use RegisterRemoteAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterRemoteAgentRequest) GetApiEndpoint added in v0.61.0 

func (x *RegisterRemoteAgentRequest) GetApiEndpoint() string

func (*RegisterRemoteAgentRequest) GetAuthToken added in v0.61.0 

func (x *RegisterRemoteAgentRequest) GetAuthToken() string

func (*RegisterRemoteAgentRequest) GetDisplayName added in v0.61.0 

func (x *RegisterRemoteAgentRequest) GetDisplayName() string

func (*RegisterRemoteAgentRequest) GetId added in v0.61.0 

func (x *RegisterRemoteAgentRequest) GetId() 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 {

	// 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) 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 RemoteAgentClient added in v0.61.0 

type RemoteAgentClient interface {
	// Gets the status details of a remote agent.
	GetStatusDetails(ctx context.Context, in *GetStatusDetailsRequest, opts ...grpc.CallOption) (*GetStatusDetailsResponse, error)
	// Gets all relevant flare files of a remote agent.
	GetFlareFiles(ctx context.Context, in *GetFlareFilesRequest, opts ...grpc.CallOption) (*GetFlareFilesResponse, error)
}

RemoteAgentClient is the client API for RemoteAgent service.

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

func NewRemoteAgentClient added in v0.61.0 

func NewRemoteAgentClient(cc grpc.ClientConnInterface) RemoteAgentClient

type RemoteAgentServer added in v0.61.0 

type RemoteAgentServer interface {
	// Gets the status details of a remote agent.
	GetStatusDetails(context.Context, *GetStatusDetailsRequest) (*GetStatusDetailsResponse, error)
	// Gets all relevant flare files of a remote agent.
	GetFlareFiles(context.Context, *GetFlareFilesRequest) (*GetFlareFilesResponse, error)
}

RemoteAgentServer is the server API for RemoteAgent service.

type Runtime 

type Runtime int32
const (
	Runtime_DOCKER      Runtime = 0
	Runtime_CONTAINERD  Runtime = 1
	Runtime_PODMAN      Runtime = 2
	Runtime_CRIO        Runtime = 3
	Runtime_GARDEN      Runtime = 4
	Runtime_ECS_FARGATE Runtime = 5
	Runtime_UNKNOWN     Runtime = 6
)

func (Runtime) Descriptor 

func (Runtime) Descriptor() protoreflect.EnumDescriptor

func (Runtime) Enum 

func (x Runtime) Enum() *Runtime

func (Runtime) EnumDescriptor deprecated 

func (Runtime) EnumDescriptor() ([]byte, []int)

Deprecated: Use Runtime.Descriptor instead.

func (Runtime) Number 

func (x Runtime) Number() protoreflect.EnumNumber

func (Runtime) String 

func (x Runtime) String() string

func (Runtime) Type 

func (Runtime) Type() protoreflect.EnumType

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 */
	// contains filtered or unexported fields
}

func (*TaggerState) Descriptor deprecated 

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

Deprecated: Use TaggerState.ProtoReflect.Descriptor instead.

func (*TaggerState) GetPidMap 

func (x *TaggerState) GetPidMap() map[int32]string

func (*TaggerState) GetState 

func (x *TaggerState) GetState() map[string]*Entity

func (*TaggerState) ProtoMessage 

func (*TaggerState) ProtoMessage()

func (*TaggerState) ProtoReflect 

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

func (*TaggerState) Reset 

func (x *TaggerState) Reset()

func (*TaggerState) String 

func (x *TaggerState) String() string

type TaggerStateResponse 

type TaggerStateResponse struct {
	Loaded bool `protobuf:"varint,1,opt,name=loaded,proto3" json:"loaded,omitempty"`
	// contains filtered or unexported fields
}

func (*TaggerStateResponse) Descriptor deprecated 

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

Deprecated: Use TaggerStateResponse.ProtoReflect.Descriptor instead.

func (*TaggerStateResponse) GetLoaded 

func (x *TaggerStateResponse) GetLoaded() bool

func (*TaggerStateResponse) ProtoMessage 

func (*TaggerStateResponse) ProtoMessage()

func (*TaggerStateResponse) ProtoReflect 

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

func (*TaggerStateResponse) Reset 

func (x *TaggerStateResponse) Reset()

func (*TaggerStateResponse) String 

func (x *TaggerStateResponse) String() string

type TargetFileHash 

type TargetFileHash struct {
	Algorithm string `protobuf:"bytes,1,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	Hash      string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*TargetFileHash) Descriptor deprecated 

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

Deprecated: Use TargetFileHash.ProtoReflect.Descriptor instead.

func (*TargetFileHash) GetAlgorithm 

func (x *TargetFileHash) GetAlgorithm() string

func (*TargetFileHash) GetHash 

func (x *TargetFileHash) GetHash() string

func (TargetFileHash) 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) Descriptor() ([]byte, []int)

Deprecated: Use TaskError.ProtoReflect.Descriptor instead.

func (*TaskError) GetCode added in v0.53.0 

func (x *TaskError) GetCode() uint64

func (*TaskError) GetMessage added in v0.53.0 

func (x *TaskError) GetMessage() string

func (TaskError) MarshalMsg added in v0.53.0 

func (z TaskError) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (TaskError) Msgsize added in v0.53.0 

func (z TaskError) Msgsize() (s int)

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

func (*TaskError) Reset added in v0.53.0 

func (x *TaskError) Reset()

func (*TaskError) String added in v0.53.0 

func (x *TaskError) String() string

func (*TaskError) UnmarshalMsg added in v0.53.0 

func (z *TaskError) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type TaskState added in v0.53.0 

type TaskState int32
const (
	TaskState_IDLE          TaskState = 0
	TaskState_RUNNING       TaskState = 1
	TaskState_DONE          TaskState = 2
	TaskState_INVALID_STATE TaskState = 3
	TaskState_ERROR         TaskState = 4
)

func (TaskState) Descriptor added in v0.53.0 

func (TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskState) Enum added in v0.53.0 

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor deprecated added in v0.53.0 

func (TaskState) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskState.Descriptor instead.

func (TaskState) MarshalMsg added in v0.53.0 

func (z TaskState) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (TaskState) Msgsize added in v0.53.0 

func (z TaskState) Msgsize() (s int)

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) String added in v0.53.0 

func (x TaskState) String() string

func (TaskState) Type added in v0.53.0 

func (TaskState) Type() protoreflect.EnumType

func (*TaskState) UnmarshalMsg added in v0.53.0 

func (z *TaskState) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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) Descriptor() ([]byte, []int)

Deprecated: Use TopMeta.ProtoReflect.Descriptor instead.

func (*TopMeta) GetRaw 

func (x *TopMeta) GetRaw() []byte

func (*TopMeta) GetVersion 

func (x *TopMeta) GetVersion() uint64

func (*TopMeta) MarshalMsg 

func (z *TopMeta) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*TopMeta) Msgsize 

func (z *TopMeta) Msgsize() (s int)

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

func (*TopMeta) Reset 

func (x *TopMeta) Reset()

func (*TopMeta) String 

func (x *TopMeta) String() string

func (*TopMeta) UnmarshalMsg 

func (z *TopMeta) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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 UnimplementedAgentSecureServer 

type UnimplementedAgentSecureServer struct {
}

UnimplementedAgentSecureServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentSecureServer) AutodiscoveryStreamConfig added in v0.62.0 

func (*UnimplementedAgentSecureServer) AutodiscoveryStreamConfig(*empty.Empty, AgentSecure_AutodiscoveryStreamConfigServer) 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) 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, *empty.Empty) (*GetStateConfigResponse, error)

func (*UnimplementedAgentSecureServer) GetConfigStateHA added in v0.52.0 

func (*UnimplementedAgentSecureServer) GetConfigStateHA(context.Context, *empty.Empty) (*GetStateConfigResponse, error)

func (*UnimplementedAgentSecureServer) GetHostTags added in v0.63.0 

func (*UnimplementedAgentSecureServer) GetHostTags(context.Context, *HostTagRequest) (*HostTagReply, error)

func (*UnimplementedAgentSecureServer) RegisterRemoteAgent added in v0.61.0 

func (*UnimplementedAgentSecureServer) RegisterRemoteAgent(context.Context, *RegisterRemoteAgentRequest) (*RegisterRemoteAgentResponse, 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, AgentSecure_TaggerStreamEntitiesServer) error

func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities 

func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities(*WorkloadmetaStreamRequest, AgentSecure_WorkloadmetaStreamEntitiesServer) error

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetHostname 

func (*UnimplementedAgentServer) GetHostname(context.Context, *HostnameRequest) (*HostnameReply, error)

type UnimplementedRemoteAgentServer added in v0.61.0 

type UnimplementedRemoteAgentServer struct {
}

UnimplementedRemoteAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedRemoteAgentServer) GetFlareFiles added in v0.61.0 

func (*UnimplementedRemoteAgentServer) GetFlareFiles(context.Context, *GetFlareFilesRequest) (*GetFlareFilesResponse, error)

func (*UnimplementedRemoteAgentServer) GetStatusDetails added in v0.61.0 

func (*UnimplementedRemoteAgentServer) GetStatusDetails(context.Context, *GetStatusDetailsRequest) (*GetStatusDetailsResponse, error)

type UnixDogstatsdMsg 

type UnixDogstatsdMsg struct {
	Timestamp     int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	PayloadSize   int32  `protobuf:"varint,2,opt,name=payloadSize,proto3" json:"payloadSize,omitempty"`
	Payload       []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Pid           int32  `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	AncillarySize int32  `protobuf:"varint,5,opt,name=ancillarySize,proto3" json:"ancillarySize,omitempty"`
	Ancillary     []byte `protobuf:"bytes,6,opt,name=ancillary,proto3" json:"ancillary,omitempty"`
	// contains filtered or unexported fields
}

UDS Capture The message contains the payload and the ancillary info

func (*UnixDogstatsdMsg) Descriptor deprecated 

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

Deprecated: Use UnixDogstatsdMsg.ProtoReflect.Descriptor instead.

func (*UnixDogstatsdMsg) GetAncillary 

func (x *UnixDogstatsdMsg) GetAncillary() []byte

func (*UnixDogstatsdMsg) GetAncillarySize 

func (x *UnixDogstatsdMsg) GetAncillarySize() int32

func (*UnixDogstatsdMsg) GetPayload 

func (x *UnixDogstatsdMsg) GetPayload() []byte

func (*UnixDogstatsdMsg) GetPayloadSize 

func (x *UnixDogstatsdMsg) GetPayloadSize() int32

func (*UnixDogstatsdMsg) GetPid 

func (x *UnixDogstatsdMsg) GetPid() int32

func (*UnixDogstatsdMsg) GetTimestamp 

func (x *UnixDogstatsdMsg) GetTimestamp() int64

func (*UnixDogstatsdMsg) ProtoMessage 

func (*UnixDogstatsdMsg) ProtoMessage()

func (*UnixDogstatsdMsg) ProtoReflect 

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

func (*UnixDogstatsdMsg) Reset 

func (x *UnixDogstatsdMsg) Reset()

func (*UnixDogstatsdMsg) String 

func (x *UnixDogstatsdMsg) String() string

type WorkloadmetaEntityId 

type WorkloadmetaEntityId struct {
	Kind WorkloadmetaKind `protobuf:"varint,1,opt,name=kind,proto3,enum=datadog.workloadmeta.WorkloadmetaKind" json:"kind,omitempty"`
	Id   string           `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadmetaEntityId) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaEntityId.ProtoReflect.Descriptor instead.

func (*WorkloadmetaEntityId) GetId 

func (x *WorkloadmetaEntityId) GetId() string

func (*WorkloadmetaEntityId) GetKind 

func (x *WorkloadmetaEntityId) GetKind() WorkloadmetaKind

func (*WorkloadmetaEntityId) ProtoMessage 

func (*WorkloadmetaEntityId) ProtoMessage()

func (*WorkloadmetaEntityId) ProtoReflect 

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

func (*WorkloadmetaEntityId) Reset 

func (x *WorkloadmetaEntityId) Reset()

func (*WorkloadmetaEntityId) String 

func (x *WorkloadmetaEntityId) String() string

type WorkloadmetaEvent 

type WorkloadmetaEvent struct {
	Type          WorkloadmetaEventType `protobuf:"varint,1,opt,name=type,proto3,enum=datadog.workloadmeta.WorkloadmetaEventType" json:"type,omitempty"`
	Container     *Container            `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	KubernetesPod *KubernetesPod        `protobuf:"bytes,3,opt,name=kubernetesPod,proto3" json:"kubernetesPod,omitempty"`
	EcsTask       *ECSTask              `protobuf:"bytes,4,opt,name=ecsTask,proto3" json:"ecsTask,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadmetaEvent) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaEvent.ProtoReflect.Descriptor instead.

func (*WorkloadmetaEvent) GetContainer 

func (x *WorkloadmetaEvent) GetContainer() *Container

func (*WorkloadmetaEvent) GetEcsTask 

func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask

func (*WorkloadmetaEvent) GetKubernetesPod 

func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod

func (*WorkloadmetaEvent) GetType 

func (x *WorkloadmetaEvent) GetType() WorkloadmetaEventType

func (*WorkloadmetaEvent) ProtoMessage 

func (*WorkloadmetaEvent) ProtoMessage()

func (*WorkloadmetaEvent) ProtoReflect 

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

func (*WorkloadmetaEvent) Reset 

func (x *WorkloadmetaEvent) Reset()

func (*WorkloadmetaEvent) String 

func (x *WorkloadmetaEvent) String() string

type WorkloadmetaEventType 

type WorkloadmetaEventType int32
const (
	WorkloadmetaEventType_EVENT_TYPE_ALL   WorkloadmetaEventType = 0
	WorkloadmetaEventType_EVENT_TYPE_SET   WorkloadmetaEventType = 1
	WorkloadmetaEventType_EVENT_TYPE_UNSET WorkloadmetaEventType = 2
)

func (WorkloadmetaEventType) Descriptor 

func (WorkloadmetaEventType) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaEventType) Enum 

func (x WorkloadmetaEventType) Enum() *WorkloadmetaEventType

func (WorkloadmetaEventType) EnumDescriptor deprecated 

func (WorkloadmetaEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkloadmetaEventType.Descriptor instead.

func (WorkloadmetaEventType) Number 

func (x WorkloadmetaEventType) Number() protoreflect.EnumNumber

func (WorkloadmetaEventType) String 

func (x WorkloadmetaEventType) String() string

func (WorkloadmetaEventType) Type 

func (WorkloadmetaEventType) Type() protoreflect.EnumType

type WorkloadmetaFilter 

type WorkloadmetaFilter struct {
	Kinds     []WorkloadmetaKind    `protobuf:"varint,1,rep,packed,name=kinds,proto3,enum=datadog.workloadmeta.WorkloadmetaKind" json:"kinds,omitempty"`
	Source    WorkloadmetaSource    `protobuf:"varint,2,opt,name=source,proto3,enum=datadog.workloadmeta.WorkloadmetaSource" json:"source,omitempty"`
	EventType WorkloadmetaEventType `protobuf:"varint,3,opt,name=eventType,proto3,enum=datadog.workloadmeta.WorkloadmetaEventType" json:"eventType,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadmetaFilter) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaFilter.ProtoReflect.Descriptor instead.

func (*WorkloadmetaFilter) GetEventType 

func (x *WorkloadmetaFilter) GetEventType() WorkloadmetaEventType

func (*WorkloadmetaFilter) GetKinds 

func (x *WorkloadmetaFilter) GetKinds() []WorkloadmetaKind

func (*WorkloadmetaFilter) GetSource 

func (x *WorkloadmetaFilter) GetSource() WorkloadmetaSource

func (*WorkloadmetaFilter) ProtoMessage 

func (*WorkloadmetaFilter) ProtoMessage()

func (*WorkloadmetaFilter) ProtoReflect 

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

func (*WorkloadmetaFilter) Reset 

func (x *WorkloadmetaFilter) Reset()

func (*WorkloadmetaFilter) String 

func (x *WorkloadmetaFilter) String() string

type WorkloadmetaKind 

type WorkloadmetaKind int32
const (
	WorkloadmetaKind_CONTAINER      WorkloadmetaKind = 0
	WorkloadmetaKind_KUBERNETES_POD WorkloadmetaKind = 1
	WorkloadmetaKind_ECS_TASK       WorkloadmetaKind = 2
)

func (WorkloadmetaKind) Descriptor 

func (WorkloadmetaKind) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaKind) Enum 

func (x WorkloadmetaKind) Enum() *WorkloadmetaKind

func (WorkloadmetaKind) EnumDescriptor deprecated 

func (WorkloadmetaKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkloadmetaKind.Descriptor instead.

func (WorkloadmetaKind) Number 

func (x WorkloadmetaKind) Number() protoreflect.EnumNumber

func (WorkloadmetaKind) String 

func (x WorkloadmetaKind) String() string

func (WorkloadmetaKind) Type 

func (WorkloadmetaKind) Type() protoreflect.EnumType

type WorkloadmetaSource 

type WorkloadmetaSource int32
const (
	WorkloadmetaSource_ALL                  WorkloadmetaSource = 0
	WorkloadmetaSource_RUNTIME              WorkloadmetaSource = 1
	WorkloadmetaSource_NODE_ORCHESTRATOR    WorkloadmetaSource = 2
	WorkloadmetaSource_CLUSTER_ORCHESTRATOR WorkloadmetaSource = 3
)

func (WorkloadmetaSource) Descriptor 

func (WorkloadmetaSource) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaSource) Enum 

func (x WorkloadmetaSource) Enum() *WorkloadmetaSource

func (WorkloadmetaSource) EnumDescriptor deprecated 

func (WorkloadmetaSource) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkloadmetaSource.Descriptor instead.

func (WorkloadmetaSource) Number 

func (x WorkloadmetaSource) Number() protoreflect.EnumNumber

func (WorkloadmetaSource) String 

func (x WorkloadmetaSource) String() string

func (WorkloadmetaSource) Type 

func (WorkloadmetaSource) Type() protoreflect.EnumType

type WorkloadmetaStreamRequest 

type WorkloadmetaStreamRequest struct {
	Filter *WorkloadmetaFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadmetaStreamRequest) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaStreamRequest.ProtoReflect.Descriptor instead.

func (*WorkloadmetaStreamRequest) GetFilter 

func (x *WorkloadmetaStreamRequest) GetFilter() *WorkloadmetaFilter

func (*WorkloadmetaStreamRequest) ProtoMessage 

func (*WorkloadmetaStreamRequest) ProtoMessage()

func (*WorkloadmetaStreamRequest) ProtoReflect 

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

func (*WorkloadmetaStreamRequest) Reset 

func (x *WorkloadmetaStreamRequest) Reset()

func (*WorkloadmetaStreamRequest) String 

func (x *WorkloadmetaStreamRequest) String() string

type WorkloadmetaStreamResponse 

type WorkloadmetaStreamResponse struct {
	Events []*WorkloadmetaEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadmetaStreamResponse) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaStreamResponse.ProtoReflect.Descriptor instead.

func (*WorkloadmetaStreamResponse) GetEvents 

func (x *WorkloadmetaStreamResponse) GetEvents() []*WorkloadmetaEvent

func (*WorkloadmetaStreamResponse) ProtoMessage 

func (*WorkloadmetaStreamResponse) ProtoMessage()

func (*WorkloadmetaStreamResponse) ProtoReflect 

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

func (*WorkloadmetaStreamResponse) Reset 

func (x *WorkloadmetaStreamResponse) Reset()

func (*WorkloadmetaStreamResponse) String 

func (x *WorkloadmetaStreamResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.