core

package
v0.54.0 Latest Latest
Warning

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

 Go to latest Published: May 16, 2024 License: Apache-2.0 Imports: 19 Imported by: 5

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 (
	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",
	}
	Runtime_value = map[string]int32{
		"DOCKER":      0,
		"CONTAINERD":  1,
		"PODMAN":      2,
		"CRIO":        3,
		"GARDEN":      4,
		"ECS_FARGATE": 5,
	}
)

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_model_v1_model_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.

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.

func RegisterAgentSecureHandler 

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

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

func RegisterAgentSecureHandlerClient 

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

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

func RegisterAgentSecureHandlerFromEndpoint 

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

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

func RegisterAgentSecureHandlerServer 

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

RegisterAgentSecureHandlerServer registers the http handlers for service AgentSecure to "mux". UnaryRPC :call AgentSecureServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAgentSecureHandlerFromEndpoint instead.

func RegisterAgentSecureServer 

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

func RegisterAgentServer 

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

Types

type AgentClient 

type AgentClient interface {
	// get the hostname
	GetHostname(ctx context.Context, in *HostnameRequest, opts ...grpc.CallOption) (*HostnameReply, error)
}

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentSecureClient 

type AgentSecureClient interface {
	// subscribes to added, removed, or changed entities in the Tagger
	// and streams them to clients as events.
	// can be called through the HTTP gateway, and events will be streamed as JSON:
	//
	//	  $  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities
	//	  {
	//	   "result": {
	//	       "entity": {
	//	           "id": {
	//	               "prefix": "kubernetes_pod_uid",
	//	               "uid": "4025461f832caf3fceb7fc2a32f879c6"
	//	           },
	//	           "hash": "cad4fc8fc409fcc1",
	//	           "lowCardinalityTags": [
	//	               "kube_namespace:kube-system",
	//	               "pod_phase:running"
	//	           ]
	//	       }
	//	   }
	//	}
	TaggerStreamEntities(ctx context.Context, in *StreamTagsRequest, opts ...grpc.CallOption) (AgentSecure_TaggerStreamEntitiesClient, error)
	// fetches an entity from the Tagger with the desired cardinality tags.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	  $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k -H "Content-Type: application/json" \
	//	     --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \
	//	     https://localhost:5001/v1/grpc/tagger/fetch_entity
	//	  {
	//	   "id": {
	//	       "prefix": "kubernetes_pod_uid",
	//	       "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507"
	//	   },
	//	   "tags": [
	//	       "kube_namespace:kube-system",
	//	       "pod_phase:running",
	//	       "kube_deployment:coredns",
	//	       "kube_service:kube-dns"
	//	   ]
	//	}
	TaggerFetchEntity(ctx context.Context, in *FetchEntityRequest, opts ...grpc.CallOption) (*FetchEntityResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdCaptureTrigger(ctx context.Context, in *CaptureTriggerRequest, opts ...grpc.CallOption) (*CaptureTriggerResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdSetTaggerState(ctx context.Context, in *TaggerState, opts ...grpc.CallOption) (*TaggerStateResponse, error)
	ClientGetConfigs(ctx context.Context, in *ClientGetConfigsRequest, opts ...grpc.CallOption) (*ClientGetConfigsResponse, error)
	GetConfigState(ctx context.Context, in *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)
}

AgentSecureClient is the client API for AgentSecure service.

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

func NewAgentSecureClient 

func NewAgentSecureClient(cc grpc.ClientConnInterface) AgentSecureClient

type AgentSecureServer 

type AgentSecureServer interface {
	// subscribes to added, removed, or changed entities in the Tagger
	// and streams them to clients as events.
	// can be called through the HTTP gateway, and events will be streamed as JSON:
	//
	//	  $  curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k https://localhost:5001/v1/grpc/tagger/stream_entities
	//	  {
	//	   "result": {
	//	       "entity": {
	//	           "id": {
	//	               "prefix": "kubernetes_pod_uid",
	//	               "uid": "4025461f832caf3fceb7fc2a32f879c6"
	//	           },
	//	           "hash": "cad4fc8fc409fcc1",
	//	           "lowCardinalityTags": [
	//	               "kube_namespace:kube-system",
	//	               "pod_phase:running"
	//	           ]
	//	       }
	//	   }
	//	}
	TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error
	// fetches an entity from the Tagger with the desired cardinality tags.
	// can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	  $ curl -H "authorization: Bearer $(cat /etc/datadog-agent/auth_token)" \
	//	     -XPOST -k -H "Content-Type: application/json" \
	//	     --data '{"id":{"prefix":"kubernetes_pod_uid","uid":"d575fb58-82dc-418e-bfb1-aececc9bc507"}}' \
	//	     https://localhost:5001/v1/grpc/tagger/fetch_entity
	//	  {
	//	   "id": {
	//	       "prefix": "kubernetes_pod_uid",
	//	       "uid": "d575fb58-82dc-418e-bfb1-aececc9bc507"
	//	   },
	//	   "tags": [
	//	       "kube_namespace:kube-system",
	//	       "pod_phase:running",
	//	       "kube_deployment:coredns",
	//	       "kube_service:kube-dns"
	//	   ]
	//	}
	TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)
	// Trigger a dogstatsd capture. Only one capture can be triggered at a time.
	// Can be called through the HTTP gateway, and entity will be returned as JSON:
	//
	//	TODO: add the curl code here
	DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)
	ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)
	GetConfigState(context.Context, *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
}

AgentSecureServer is the server API for AgentSecure service.

type AgentSecure_TaggerStreamEntitiesClient 

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

type AgentSecure_TaggerStreamEntitiesServer 

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

type AgentSecure_WorkloadmetaStreamEntitiesClient 

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

type AgentSecure_WorkloadmetaStreamEntitiesServer 

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

type AgentServer 

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

AgentServer is the server API for Agent service.

type CaptureTriggerRequest 

type CaptureTriggerRequest struct {
	Duration   string `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Path       string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Compressed bool   `protobuf:"varint,3,opt,name=compressed,proto3" json:"compressed,omitempty"`
	// contains filtered or unexported fields
}

Dogstatsd capture types

func (*CaptureTriggerRequest) Descriptor deprecated 

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

Deprecated: Use CaptureTriggerRequest.ProtoReflect.Descriptor instead.

func (*CaptureTriggerRequest) GetCompressed 

func (x *CaptureTriggerRequest) GetCompressed() bool

func (*CaptureTriggerRequest) GetDuration 

func (x *CaptureTriggerRequest) GetDuration() string

func (*CaptureTriggerRequest) GetPath 

func (x *CaptureTriggerRequest) GetPath() string

func (*CaptureTriggerRequest) ProtoMessage 

func (*CaptureTriggerRequest) ProtoMessage()

func (*CaptureTriggerRequest) ProtoReflect 

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

func (*CaptureTriggerRequest) Reset 

func (x *CaptureTriggerRequest) Reset()

func (*CaptureTriggerRequest) String 

func (x *CaptureTriggerRequest) String() string

type CaptureTriggerResponse 

type CaptureTriggerResponse struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*CaptureTriggerResponse) Descriptor deprecated 

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

Deprecated: Use CaptureTriggerResponse.ProtoReflect.Descriptor instead.

func (*CaptureTriggerResponse) GetPath 

func (x *CaptureTriggerResponse) GetPath() string

func (*CaptureTriggerResponse) ProtoMessage 

func (*CaptureTriggerResponse) ProtoMessage()

func (*CaptureTriggerResponse) ProtoReflect 

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

func (*CaptureTriggerResponse) Reset 

func (x *CaptureTriggerResponse) Reset()

func (*CaptureTriggerResponse) String 

func (x *CaptureTriggerResponse) String() string

type Client 

type Client struct {
	State         *ClientState   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Id            string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Products      []string       `protobuf:"bytes,3,rep,name=products,proto3" json:"products,omitempty"`
	IsTracer      bool           `protobuf:"varint,6,opt,name=is_tracer,json=isTracer,proto3" json:"is_tracer,omitempty"`
	ClientTracer  *ClientTracer  `protobuf:"bytes,7,opt,name=client_tracer,json=clientTracer,proto3" json:"client_tracer,omitempty"`
	IsAgent       bool           `protobuf:"varint,8,opt,name=is_agent,json=isAgent,proto3" json:"is_agent,omitempty"`
	ClientAgent   *ClientAgent   `protobuf:"bytes,9,opt,name=client_agent,json=clientAgent,proto3" json:"client_agent,omitempty"`
	LastSeen      uint64         `protobuf:"varint,10,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Capabilities  []byte         `protobuf:"bytes,11,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	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"`
	// 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) 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 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     `` /* 155-byte string literal not displayed */
	Hostname      string                `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Image         *ContainerImage       `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"`
	NetworkIps    map[string]string     `` /* 161-byte string literal not displayed */
	Pid           int32                 `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"`
	Ports         []*ContainerPort      `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"`
	Runtime       Runtime               `protobuf:"varint,9,opt,name=runtime,proto3,enum=datadog.workloadmeta.Runtime" json:"runtime,omitempty"`
	State         *ContainerState       `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"`
	CollectorTags []string              `protobuf:"bytes,11,rep,name=collectorTags,proto3" json:"collectorTags,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

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

func (*ContainerState) Descriptor deprecated 

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

Deprecated: Use ContainerState.ProtoReflect.Descriptor instead.

func (*ContainerState) GetCreatedAt 

func (x *ContainerState) GetCreatedAt() int64

func (*ContainerState) GetExitCode 

func (x *ContainerState) GetExitCode() uint32

func (*ContainerState) GetFinishedAt 

func (x *ContainerState) GetFinishedAt() int64

func (*ContainerState) GetHealth 

func (x *ContainerState) GetHealth() ContainerHealth

func (*ContainerState) GetRunning 

func (x *ContainerState) GetRunning() bool

func (*ContainerState) GetStartedAt 

func (x *ContainerState) GetStartedAt() int64

func (*ContainerState) GetStatus 

func (x *ContainerState) GetStatus() ContainerStatus

func (*ContainerState) ProtoMessage 

func (*ContainerState) ProtoMessage()

func (*ContainerState) ProtoReflect 

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

func (*ContainerState) Reset 

func (x *ContainerState) Reset()

func (*ContainerState) String 

func (x *ContainerState) String() string

type ContainerStatus 

type ContainerStatus int32
const (
	ContainerStatus_CONTAINER_STATUS_UNKNOWN    ContainerStatus = 0
	ContainerStatus_CONTAINER_STATUS_CREATED    ContainerStatus = 1
	ContainerStatus_CONTAINER_STATUS_RUNNING    ContainerStatus = 2
	ContainerStatus_CONTAINER_STATUS_RESTARTING ContainerStatus = 3
	ContainerStatus_CONTAINER_STATUS_PAUSED     ContainerStatus = 4
	ContainerStatus_CONTAINER_STATUS_STOPPED    ContainerStatus = 5
)

func (ContainerStatus) Descriptor 

func (ContainerStatus) Descriptor() protoreflect.EnumDescriptor

func (ContainerStatus) Enum 

func (x ContainerStatus) Enum() *ContainerStatus

func (ContainerStatus) EnumDescriptor deprecated 

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

Deprecated: Use ContainerStatus.Descriptor instead.

func (ContainerStatus) Number 

func (x ContainerStatus) Number() protoreflect.EnumNumber

func (ContainerStatus) String 

func (x ContainerStatus) String() string

func (ContainerStatus) Type 

func (ContainerStatus) Type() protoreflect.EnumType

type DelegatedMeta 

type DelegatedMeta struct {
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Role    string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	Raw     []byte `protobuf:"bytes,3,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*DelegatedMeta) Descriptor deprecated 

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

Deprecated: Use DelegatedMeta.ProtoReflect.Descriptor instead.

func (*DelegatedMeta) GetRaw 

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

func (*DelegatedMeta) GetRole 

func (x *DelegatedMeta) GetRole() string

func (*DelegatedMeta) GetVersion 

func (x *DelegatedMeta) GetVersion() uint64

func (*DelegatedMeta) 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 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        `` /* 149-byte string literal not displayed */
	ContainerInstanceTags map[string]string        `` /* 183-byte string literal not displayed */
	ClusterName           string                   `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Region                string                   `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	AvailabilityZone      string                   `protobuf:"bytes,7,opt,name=availabilityZone,proto3" json:"availabilityZone,omitempty"`
	Family                string                   `protobuf:"bytes,8,opt,name=family,proto3" json:"family,omitempty"`
	Version               string                   `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	LaunchType            ECSLaunchType            `protobuf:"varint,10,opt,name=launchType,proto3,enum=datadog.workloadmeta.ECSLaunchType" json:"launchType,omitempty"`
	Containers            []*OrchestratorContainer `protobuf:"bytes,11,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*ECSTask) Descriptor deprecated 

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

Deprecated: Use ECSTask.ProtoReflect.Descriptor instead.

func (*ECSTask) GetAvailabilityZone 

func (x *ECSTask) GetAvailabilityZone() string

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 `` /* 163-byte string literal not displayed */
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EntityMeta) Descriptor deprecated 

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

Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

func (*EntityMeta) GetAnnotations 

func (x *EntityMeta) GetAnnotations() map[string]string

func (*EntityMeta) GetLabels 

func (x *EntityMeta) GetLabels() map[string]string

func (*EntityMeta) GetName 

func (x *EntityMeta) GetName() string

func (*EntityMeta) GetNamespace 

func (x *EntityMeta) GetNamespace() string

func (*EntityMeta) ProtoMessage 

func (*EntityMeta) ProtoMessage()

func (*EntityMeta) ProtoReflect 

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

func (*EntityMeta) Reset 

func (x *EntityMeta) Reset()

func (*EntityMeta) String 

func (x *EntityMeta) String() string

type EventType 

type EventType int32
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 Filter 

type Filter struct {
	KubeNamespace string `protobuf:"bytes,1,opt,name=kubeNamespace,proto3" json:"kubeNamespace,omitempty"`
	Image         string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	ContainerName string `protobuf:"bytes,3,opt,name=containerName,proto3" json:"containerName,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetContainerName 

func (x *Filter) GetContainerName() string

func (*Filter) GetImage 

func (x *Filter) GetImage() string

func (*Filter) GetKubeNamespace 

func (x *Filter) GetKubeNamespace() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type GetStateConfigResponse 

type GetStateConfigResponse struct {
	ConfigState     map[string]*FileMetaState `` /* 182-byte string literal not displayed */
	DirectorState   map[string]*FileMetaState `` /* 188-byte string literal not displayed */
	TargetFilenames map[string]string         `` /* 194-byte string literal not displayed */
	ActiveClients   []*Client                 `protobuf:"bytes,4,rep,name=active_clients,json=activeClients,proto3" json:"active_clients,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetStateConfigResponse.ProtoReflect.Descriptor instead.

func (*GetStateConfigResponse) GetActiveClients 

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

func (*GetStateConfigResponse) GetConfigState 

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

func (*GetStateConfigResponse) GetDirectorState 

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

func (*GetStateConfigResponse) GetTargetFilenames 

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

func (*GetStateConfigResponse) 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 HostnameReply 

type HostnameReply struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the requested hostname

func (*HostnameReply) Descriptor deprecated 

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

Deprecated: Use HostnameReply.ProtoReflect.Descriptor instead.

func (*HostnameReply) GetHostname 

func (x *HostnameReply) GetHostname() string

func (*HostnameReply) ProtoMessage 

func (*HostnameReply) ProtoMessage()

func (*HostnameReply) ProtoReflect 

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

func (*HostnameReply) Reset 

func (x *HostnameReply) Reset()

func (*HostnameReply) String 

func (x *HostnameReply) String() string

type HostnameRequest 

type HostnameRequest struct {
	// contains filtered or unexported fields
}

func (*HostnameRequest) Descriptor deprecated 

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

Deprecated: Use HostnameRequest.ProtoReflect.Descriptor instead.

func (*HostnameRequest) ProtoMessage 

func (*HostnameRequest) ProtoMessage()

func (*HostnameRequest) ProtoReflect 

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

func (*HostnameRequest) Reset 

func (x *HostnameRequest) Reset()

func (*HostnameRequest) String 

func (x *HostnameRequest) String() string

type KubernetesPod 

type KubernetesPod struct {
	EntityId                   *WorkloadmetaEntityId    `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"`
	EntityMeta                 *EntityMeta              `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"`
	Owners                     []*KubernetesPodOwner    `protobuf:"bytes,3,rep,name=owners,proto3" json:"owners,omitempty"`
	PersistentVolumeClaimNames []string                 `protobuf:"bytes,4,rep,name=persistentVolumeClaimNames,proto3" json:"persistentVolumeClaimNames,omitempty"`
	Containers                 []*OrchestratorContainer `protobuf:"bytes,5,rep,name=containers,proto3" json:"containers,omitempty"`
	Ready                      bool                     `protobuf:"varint,6,opt,name=ready,proto3" json:"ready,omitempty"`
	Phase                      string                   `protobuf:"bytes,7,opt,name=phase,proto3" json:"phase,omitempty"`
	Ip                         string                   `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"`
	PriorityClass              string                   `protobuf:"bytes,9,opt,name=priorityClass,proto3" json:"priorityClass,omitempty"`
	QosClass                   string                   `protobuf:"bytes,10,opt,name=qosClass,proto3" json:"qosClass,omitempty"`
	KubeServices               []string                 `protobuf:"bytes,11,rep,name=kubeServices,proto3" json:"kubeServices,omitempty"`
	NamespaceLabels            map[string]string        `` /* 172-byte string literal not displayed */
	InitContainers             []*OrchestratorContainer `protobuf:"bytes,13,rep,name=InitContainers,proto3" json:"InitContainers,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) 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"`
	// 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) 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) 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 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
)

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 StreamTagsEvent 

type StreamTagsEvent struct {
	Type   EventType `protobuf:"varint,1,opt,name=type,proto3,enum=datadog.model.v1.EventType" json:"type,omitempty"`
	Entity *Entity   `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTagsEvent) Descriptor deprecated 

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

Deprecated: Use StreamTagsEvent.ProtoReflect.Descriptor instead.

func (*StreamTagsEvent) GetEntity 

func (x *StreamTagsEvent) GetEntity() *Entity

func (*StreamTagsEvent) GetType 

func (x *StreamTagsEvent) GetType() EventType

func (*StreamTagsEvent) ProtoMessage 

func (*StreamTagsEvent) ProtoMessage()

func (*StreamTagsEvent) ProtoReflect 

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

func (*StreamTagsEvent) Reset 

func (x *StreamTagsEvent) Reset()

func (*StreamTagsEvent) String 

func (x *StreamTagsEvent) String() string

type StreamTagsRequest 

type StreamTagsRequest struct {
	Cardinality   TagCardinality `protobuf:"varint,1,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"`
	IncludeFilter *Filter        `protobuf:"bytes,2,opt,name=includeFilter,proto3" json:"includeFilter,omitempty"`
	ExcludeFilter *Filter        `protobuf:"bytes,3,opt,name=excludeFilter,proto3" json:"excludeFilter,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTagsRequest) Descriptor deprecated 

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

Deprecated: Use StreamTagsRequest.ProtoReflect.Descriptor instead.

func (*StreamTagsRequest) GetCardinality 

func (x *StreamTagsRequest) GetCardinality() TagCardinality

func (*StreamTagsRequest) GetExcludeFilter 

func (x *StreamTagsRequest) GetExcludeFilter() *Filter

func (*StreamTagsRequest) GetIncludeFilter 

func (x *StreamTagsRequest) GetIncludeFilter() *Filter

func (*StreamTagsRequest) ProtoMessage 

func (*StreamTagsRequest) ProtoMessage()

func (*StreamTagsRequest) ProtoReflect 

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

func (*StreamTagsRequest) Reset 

func (x *StreamTagsRequest) Reset()

func (*StreamTagsRequest) String 

func (x *StreamTagsRequest) String() string

type StreamTagsResponse 

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

func (*StreamTagsResponse) Descriptor deprecated 

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

Deprecated: Use StreamTagsResponse.ProtoReflect.Descriptor instead.

func (*StreamTagsResponse) GetEvents 

func (x *StreamTagsResponse) GetEvents() []*StreamTagsEvent

func (*StreamTagsResponse) ProtoMessage 

func (*StreamTagsResponse) ProtoMessage()

func (*StreamTagsResponse) ProtoReflect 

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

func (*StreamTagsResponse) Reset 

func (x *StreamTagsResponse) Reset()

func (*StreamTagsResponse) String 

func (x *StreamTagsResponse) String() string

type TagCardinality 

type TagCardinality int32
const (
	TagCardinality_LOW          TagCardinality = 0
	TagCardinality_ORCHESTRATOR TagCardinality = 1
	TagCardinality_HIGH         TagCardinality = 2
)

func (TagCardinality) Descriptor 

func (TagCardinality) Descriptor() protoreflect.EnumDescriptor

func (TagCardinality) Enum 

func (x TagCardinality) Enum() *TagCardinality

func (TagCardinality) EnumDescriptor deprecated 

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

Deprecated: Use TagCardinality.Descriptor instead.

func (TagCardinality) Number 

func (x TagCardinality) Number() protoreflect.EnumNumber

func (TagCardinality) String 

func (x TagCardinality) String() string

func (TagCardinality) Type 

func (TagCardinality) Type() protoreflect.EnumType

type TaggerState 

type TaggerState struct {
	State  map[string]*Entity `` /* 151-byte string literal not displayed */
	PidMap map[int32]string   `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaggerState) Descriptor deprecated 

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

Deprecated: Use TaggerState.ProtoReflect.Descriptor instead.

func (*TaggerState) GetPidMap 

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

func (*TaggerState) GetState 

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

func (*TaggerState) ProtoMessage 

func (*TaggerState) ProtoMessage()

func (*TaggerState) ProtoReflect 

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

func (*TaggerState) Reset 

func (x *TaggerState) Reset()

func (*TaggerState) String 

func (x *TaggerState) String() string

type TaggerStateResponse 

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

func (*TaggerStateResponse) Descriptor deprecated 

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

Deprecated: Use TaggerStateResponse.ProtoReflect.Descriptor instead.

func (*TaggerStateResponse) GetLoaded 

func (x *TaggerStateResponse) GetLoaded() bool

func (*TaggerStateResponse) ProtoMessage 

func (*TaggerStateResponse) ProtoMessage()

func (*TaggerStateResponse) ProtoReflect 

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

func (*TaggerStateResponse) Reset 

func (x *TaggerStateResponse) Reset()

func (*TaggerStateResponse) String 

func (x *TaggerStateResponse) String() string

type TargetFileHash 

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

func (*TargetFileHash) Descriptor deprecated 

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

Deprecated: Use TargetFileHash.ProtoReflect.Descriptor instead.

func (*TargetFileHash) GetAlgorithm 

func (x *TargetFileHash) GetAlgorithm() string

func (*TargetFileHash) GetHash 

func (x *TargetFileHash) GetHash() string

func (TargetFileHash) 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) 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) TaggerFetchEntity 

func (*UnimplementedAgentSecureServer) TaggerFetchEntity(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error)

func (*UnimplementedAgentSecureServer) TaggerStreamEntities 

func (*UnimplementedAgentSecureServer) TaggerStreamEntities(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error

func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities 

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

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetHostname 

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

type 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.