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.

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

func (x ContainerHealth) Enum() *ContainerHealth

func (ContainerHealth) EnumDescriptor deprecated

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

Deprecated: Use ContainerHealth.Descriptor instead.

func (ContainerHealth) Number

func (ContainerHealth) String

func (x ContainerHealth) String() string

func (ContainerHealth) Type

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

func (x ContainerStatus) Enum() *ContainerStatus

func (ContainerStatus) EnumDescriptor deprecated

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

Deprecated: Use ContainerStatus.Descriptor instead.

func (ContainerStatus) Number

func (ContainerStatus) String

func (x ContainerStatus) String() string

func (ContainerStatus) Type

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

func (x ECSLaunchType) Enum() *ECSLaunchType

func (ECSLaunchType) EnumDescriptor deprecated

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

Deprecated: Use ECSLaunchType.Descriptor instead.

func (ECSLaunchType) Number

func (ECSLaunchType) String

func (x ECSLaunchType) String() string

func (ECSLaunchType) Type

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

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

func (x TagCardinality) Enum() *TagCardinality

func (TagCardinality) EnumDescriptor deprecated

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

Deprecated: Use TagCardinality.Descriptor instead.

func (TagCardinality) Number

func (TagCardinality) String

func (x TagCardinality) String() string

func (TagCardinality) Type

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) 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) ClientGetConfigsHA added in v0.52.0

func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger

func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState

func (*UnimplementedAgentSecureServer) GetConfigState

func (*UnimplementedAgentSecureServer) GetConfigStateHA added in v0.52.0

func (*UnimplementedAgentSecureServer) TaggerFetchEntity

func (*UnimplementedAgentSecureServer) TaggerStreamEntities

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetHostname

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 (*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 (*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) Enum

func (WorkloadmetaEventType) EnumDescriptor deprecated

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

Deprecated: Use WorkloadmetaEventType.Descriptor instead.

func (WorkloadmetaEventType) Number

func (WorkloadmetaEventType) String

func (x WorkloadmetaEventType) String() string

func (WorkloadmetaEventType) Type

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

func (WorkloadmetaKind) EnumDescriptor deprecated

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

Deprecated: Use WorkloadmetaKind.Descriptor instead.

func (WorkloadmetaKind) Number

func (WorkloadmetaKind) String

func (x WorkloadmetaKind) String() string

func (WorkloadmetaKind) Type

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

func (WorkloadmetaSource) EnumDescriptor deprecated

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

Deprecated: Use WorkloadmetaSource.Descriptor instead.

func (WorkloadmetaSource) Number

func (WorkloadmetaSource) String

func (x WorkloadmetaSource) String() string

func (WorkloadmetaSource) Type

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 (*WorkloadmetaStreamRequest) ProtoMessage

func (*WorkloadmetaStreamRequest) ProtoMessage()

func (*WorkloadmetaStreamRequest) ProtoReflect

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 (*WorkloadmetaStreamResponse) ProtoMessage

func (*WorkloadmetaStreamResponse) ProtoMessage()

func (*WorkloadmetaStreamResponse) ProtoReflect

func (*WorkloadmetaStreamResponse) Reset

func (x *WorkloadmetaStreamResponse) Reset()

func (*WorkloadmetaStreamResponse) String

func (x *WorkloadmetaStreamResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL