pbgo

package
v0.47.0-rc.8 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package pbgo 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 (
	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_process_process_proto protoreflect.FileDescriptor
View Source 
var File_datadog_process_workloadmeta_process_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.

func RegisterAgentSecureHandler 

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

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

func RegisterAgentSecureHandlerClient 

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

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

func RegisterAgentSecureHandlerFromEndpoint 

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

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

func RegisterAgentSecureHandlerServer 

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

RegisterAgentSecureHandlerServer registers the http handlers for service AgentSecure to "mux". UnaryRPC :call AgentSecureServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterAgentSecureServer 

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

func RegisterAgentServer 

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

func RegisterProcessEntityStreamServer added in v0.47.0 

func RegisterProcessEntityStreamServer(s *grpc.Server, srv ProcessEntityStreamServer)

Types

type AgentClient 

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

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentSecureClient 

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

AgentSecureClient is the client API for AgentSecure service.

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

func NewAgentSecureClient 

func NewAgentSecureClient(cc grpc.ClientConnInterface) AgentSecureClient

type AgentSecureServer 

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

AgentSecureServer is the server API for AgentSecure service.

type AgentSecure_TaggerStreamEntitiesClient 

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

type AgentSecure_TaggerStreamEntitiesServer 

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

type AgentSecure_WorkloadmetaStreamEntitiesClient 

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

type AgentSecure_WorkloadmetaStreamEntitiesServer 

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

type AgentServer 

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

AgentServer is the server API for Agent service.

type CaptureTriggerRequest 

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

Dogstatsd capture types

func (*CaptureTriggerRequest) Descriptor deprecated 

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

Deprecated: Use CaptureTriggerRequest.ProtoReflect.Descriptor instead.

func (*CaptureTriggerRequest) GetCompressed 

func (x *CaptureTriggerRequest) GetCompressed() bool

func (*CaptureTriggerRequest) GetDuration 

func (x *CaptureTriggerRequest) GetDuration() string

func (*CaptureTriggerRequest) GetPath 

func (x *CaptureTriggerRequest) GetPath() string

func (*CaptureTriggerRequest) ProtoMessage 

func (*CaptureTriggerRequest) ProtoMessage()

func (*CaptureTriggerRequest) ProtoReflect 

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

func (*CaptureTriggerRequest) Reset 

func (x *CaptureTriggerRequest) Reset()

func (*CaptureTriggerRequest) String 

func (x *CaptureTriggerRequest) String() string

type CaptureTriggerResponse 

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

func (*CaptureTriggerResponse) Descriptor deprecated 

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

Deprecated: Use CaptureTriggerResponse.ProtoReflect.Descriptor instead.

func (*CaptureTriggerResponse) GetPath 

func (x *CaptureTriggerResponse) GetPath() string

func (*CaptureTriggerResponse) ProtoMessage 

func (*CaptureTriggerResponse) ProtoMessage()

func (*CaptureTriggerResponse) ProtoReflect 

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

func (*CaptureTriggerResponse) Reset 

func (x *CaptureTriggerResponse) Reset()

func (*CaptureTriggerResponse) String 

func (x *CaptureTriggerResponse) String() string

type Client 

type Client struct {
	State        *ClientState  `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Id           string        `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Products     []string      `protobuf:"bytes,3,rep,name=products,proto3" json:"products,omitempty"`
	IsTracer     bool          `protobuf:"varint,6,opt,name=is_tracer,json=isTracer,proto3" json:"is_tracer,omitempty"`
	ClientTracer *ClientTracer `protobuf:"bytes,7,opt,name=client_tracer,json=clientTracer,proto3" json:"client_tracer,omitempty"`
	IsAgent      bool          `protobuf:"varint,8,opt,name=is_agent,json=isAgent,proto3" json:"is_agent,omitempty"`
	ClientAgent  *ClientAgent  `protobuf:"bytes,9,opt,name=client_agent,json=clientAgent,proto3" json:"client_agent,omitempty"`
	LastSeen     uint64        `protobuf:"varint,10,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Capabilities []byte        `protobuf:"bytes,11,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*Client) Descriptor deprecated 

func (*Client) 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) GetId 

func (x *Client) GetId() string

func (*Client) GetIsAgent 

func (x *Client) GetIsAgent() bool

func (*Client) GetIsTracer 

func (x *Client) GetIsTracer() 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) 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

type ClientAgent 

type ClientAgent struct {
	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version      string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	ClusterName  string   `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	ClusterId    string   `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	CwsWorkloads []string `protobuf:"bytes,5,rep,name=cws_workloads,json=cwsWorkloads,proto3" json:"cws_workloads,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientAgent) Descriptor deprecated 

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

Deprecated: Use ClientAgent.ProtoReflect.Descriptor instead.

func (*ClientAgent) GetClusterId 

func (x *ClientAgent) GetClusterId() string

func (*ClientAgent) GetClusterName 

func (x *ClientAgent) GetClusterName() string

func (*ClientAgent) GetCwsWorkloads 

func (x *ClientAgent) GetCwsWorkloads() []string

func (*ClientAgent) GetName 

func (x *ClientAgent) GetName() string

func (*ClientAgent) GetVersion 

func (x *ClientAgent) GetVersion() string

func (*ClientAgent) ProtoMessage 

func (*ClientAgent) ProtoMessage()

func (*ClientAgent) ProtoReflect 

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

func (*ClientAgent) Reset 

func (x *ClientAgent) Reset()

func (*ClientAgent) String 

func (x *ClientAgent) String() string

type ClientGetConfigsRequest 

type ClientGetConfigsRequest struct {
	Client            *Client           `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	CachedTargetFiles []*TargetFileMeta `protobuf:"bytes,2,rep,name=cached_target_files,json=cachedTargetFiles,proto3" json:"cached_target_files,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientGetConfigsRequest) Descriptor deprecated 

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

Deprecated: Use ClientGetConfigsRequest.ProtoReflect.Descriptor instead.

func (*ClientGetConfigsRequest) GetCachedTargetFiles 

func (x *ClientGetConfigsRequest) GetCachedTargetFiles() []*TargetFileMeta

func (*ClientGetConfigsRequest) GetClient 

func (x *ClientGetConfigsRequest) GetClient() *Client

func (*ClientGetConfigsRequest) ProtoMessage 

func (*ClientGetConfigsRequest) ProtoMessage()

func (*ClientGetConfigsRequest) ProtoReflect 

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

func (*ClientGetConfigsRequest) Reset 

func (x *ClientGetConfigsRequest) Reset()

func (*ClientGetConfigsRequest) String 

func (x *ClientGetConfigsRequest) String() string

type ClientGetConfigsResponse 

type ClientGetConfigsResponse struct {
	Roots         [][]byte `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"`
	Targets       []byte   `protobuf:"bytes,2,opt,name=targets,proto3" json:"targets,omitempty"`
	TargetFiles   []*File  `protobuf:"bytes,3,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"`
	ClientConfigs []string `protobuf:"bytes,4,rep,name=client_configs,json=clientConfigs,proto3" json:"client_configs,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientGetConfigsResponse) Descriptor deprecated 

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

Deprecated: Use ClientGetConfigsResponse.ProtoReflect.Descriptor instead.

func (*ClientGetConfigsResponse) GetClientConfigs 

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

func (*ClientGetConfigsResponse) GetRoots 

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

func (*ClientGetConfigsResponse) GetTargetFiles 

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

func (*ClientGetConfigsResponse) GetTargets 

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

func (*ClientGetConfigsResponse) ProtoMessage 

func (*ClientGetConfigsResponse) ProtoMessage()

func (*ClientGetConfigsResponse) ProtoReflect 

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

func (*ClientGetConfigsResponse) Reset 

func (x *ClientGetConfigsResponse) Reset()

func (*ClientGetConfigsResponse) String 

func (x *ClientGetConfigsResponse) String() string

type ClientState 

type ClientState struct {
	RootVersion        uint64         `protobuf:"varint,1,opt,name=root_version,json=rootVersion,proto3" json:"root_version,omitempty"`
	TargetsVersion     uint64         `protobuf:"varint,2,opt,name=targets_version,json=targetsVersion,proto3" json:"targets_version,omitempty"`
	ConfigStates       []*ConfigState `protobuf:"bytes,3,rep,name=config_states,json=configStates,proto3" json:"config_states,omitempty"`
	HasError           bool           `protobuf:"varint,4,opt,name=has_error,json=hasError,proto3" json:"has_error,omitempty"`
	Error              string         `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	BackendClientState []byte         `protobuf:"bytes,6,opt,name=backend_client_state,json=backendClientState,proto3" json:"backend_client_state,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientState) Descriptor deprecated 

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

Deprecated: Use ClientState.ProtoReflect.Descriptor instead.

func (*ClientState) GetBackendClientState 

func (x *ClientState) GetBackendClientState() []byte

func (*ClientState) GetConfigStates 

func (x *ClientState) GetConfigStates() []*ConfigState

func (*ClientState) GetError 

func (x *ClientState) GetError() string

func (*ClientState) GetHasError 

func (x *ClientState) GetHasError() bool

func (*ClientState) GetRootVersion 

func (x *ClientState) GetRootVersion() uint64

func (*ClientState) GetTargetsVersion 

func (x *ClientState) GetTargetsVersion() uint64

func (*ClientState) ProtoMessage 

func (*ClientState) ProtoMessage()

func (*ClientState) ProtoReflect 

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

func (*ClientState) Reset 

func (x *ClientState) Reset()

func (*ClientState) String 

func (x *ClientState) String() string

type ClientTracer 

type ClientTracer struct {
	RuntimeId     string   `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	Language      string   `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	TracerVersion string   `protobuf:"bytes,3,opt,name=tracer_version,json=tracerVersion,proto3" json:"tracer_version,omitempty"`
	Service       string   `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	ExtraServices []string `protobuf:"bytes,8,rep,name=extra_services,json=extraServices,proto3" json:"extra_services,omitempty"`
	Env           string   `protobuf:"bytes,5,opt,name=env,proto3" json:"env,omitempty"`
	AppVersion    string   `protobuf:"bytes,6,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	Tags          []string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientTracer) Descriptor deprecated 

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

Deprecated: Use ClientTracer.ProtoReflect.Descriptor instead.

func (*ClientTracer) GetAppVersion 

func (x *ClientTracer) GetAppVersion() string

func (*ClientTracer) GetEnv 

func (x *ClientTracer) GetEnv() string

func (*ClientTracer) GetExtraServices 

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

func (*ClientTracer) GetLanguage 

func (x *ClientTracer) GetLanguage() string

func (*ClientTracer) GetRuntimeId 

func (x *ClientTracer) GetRuntimeId() string

func (*ClientTracer) GetService 

func (x *ClientTracer) GetService() string

func (*ClientTracer) GetTags 

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

func (*ClientTracer) GetTracerVersion 

func (x *ClientTracer) GetTracerVersion() string

func (*ClientTracer) ProtoMessage 

func (*ClientTracer) ProtoMessage()

func (*ClientTracer) ProtoReflect 

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

func (*ClientTracer) Reset 

func (x *ClientTracer) Reset()

func (*ClientTracer) String 

func (x *ClientTracer) String() string

type ConfigMetas 

type ConfigMetas struct {
	Roots            []*TopMeta       `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"`
	Timestamp        *TopMeta         `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Snapshot         *TopMeta         `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	TopTargets       *TopMeta         `protobuf:"bytes,4,opt,name=topTargets,proto3" json:"topTargets,omitempty"`
	DelegatedTargets []*DelegatedMeta `protobuf:"bytes,5,rep,name=delegatedTargets,proto3" json:"delegatedTargets,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigMetas) Descriptor deprecated 

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

Deprecated: Use ConfigMetas.ProtoReflect.Descriptor instead.

func (*ConfigMetas) GetDelegatedTargets 

func (x *ConfigMetas) GetDelegatedTargets() []*DelegatedMeta

func (*ConfigMetas) GetRoots 

func (x *ConfigMetas) GetRoots() []*TopMeta

func (*ConfigMetas) GetSnapshot 

func (x *ConfigMetas) GetSnapshot() *TopMeta

func (*ConfigMetas) GetTimestamp 

func (x *ConfigMetas) GetTimestamp() *TopMeta

func (*ConfigMetas) GetTopTargets 

func (x *ConfigMetas) GetTopTargets() *TopMeta

func (*ConfigMetas) ProtoMessage 

func (*ConfigMetas) ProtoMessage()

func (*ConfigMetas) ProtoReflect 

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

func (*ConfigMetas) Reset 

func (x *ConfigMetas) Reset()

func (*ConfigMetas) String 

func (x *ConfigMetas) String() string

type ConfigState 

type ConfigState struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version    uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Product    string `protobuf:"bytes,3,opt,name=product,proto3" json:"product,omitempty"`
	ApplyState uint64 `protobuf:"varint,4,opt,name=apply_state,json=applyState,proto3" json:"apply_state,omitempty"`
	ApplyError string `protobuf:"bytes,5,opt,name=apply_error,json=applyError,proto3" json:"apply_error,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigState) Descriptor deprecated 

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

Deprecated: Use ConfigState.ProtoReflect.Descriptor instead.

func (*ConfigState) GetApplyError 

func (x *ConfigState) GetApplyError() string

func (*ConfigState) GetApplyState 

func (x *ConfigState) GetApplyState() uint64

func (*ConfigState) GetId 

func (x *ConfigState) GetId() string

func (*ConfigState) GetProduct 

func (x *ConfigState) GetProduct() string

func (*ConfigState) GetVersion 

func (x *ConfigState) GetVersion() uint64

func (*ConfigState) ProtoMessage 

func (*ConfigState) ProtoMessage()

func (*ConfigState) ProtoReflect 

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

func (*ConfigState) Reset 

func (x *ConfigState) Reset()

func (*ConfigState) String 

func (x *ConfigState) String() string

type Container 

type Container struct {
	EntityId      *WorkloadmetaEntityId `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"`
	EntityMeta    *EntityMeta           `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"`
	EnvVars       map[string]string     `` /* 155-byte string literal not displayed */
	Hostname      string                `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Image         *ContainerImage       `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"`
	NetworkIps    map[string]string     `` /* 161-byte string literal not displayed */
	Pid           int32                 `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"`
	Ports         []*ContainerPort      `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"`
	Runtime       Runtime               `protobuf:"varint,9,opt,name=runtime,proto3,enum=datadog.workloadmeta.Runtime" json:"runtime,omitempty"`
	State         *ContainerState       `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"`
	CollectorTags []string              `protobuf:"bytes,11,rep,name=collectorTags,proto3" json:"collectorTags,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetCollectorTags 

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

func (*Container) GetEntityId 

func (x *Container) GetEntityId() *WorkloadmetaEntityId

func (*Container) GetEntityMeta 

func (x *Container) GetEntityMeta() *EntityMeta

func (*Container) GetEnvVars 

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

func (*Container) GetHostname 

func (x *Container) GetHostname() string

func (*Container) GetImage 

func (x *Container) GetImage() *ContainerImage

func (*Container) GetNetworkIps 

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

func (*Container) GetPid 

func (x *Container) GetPid() int32

func (*Container) GetPorts 

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

func (*Container) GetRuntime 

func (x *Container) GetRuntime() Runtime

func (*Container) GetState 

func (x *Container) GetState() *ContainerState

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

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

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type ContainerHealth 

type ContainerHealth int32
const (
	ContainerHealth_CONTAINER_HEALTH_UNKNOWN   ContainerHealth = 0
	ContainerHealth_CONTAINER_HEALTH_HEALTHY   ContainerHealth = 1
	ContainerHealth_CONTAINER_HEALTH_UNHEALTHY ContainerHealth = 2
)

func (ContainerHealth) Descriptor 

func (ContainerHealth) Descriptor() protoreflect.EnumDescriptor

func (ContainerHealth) Enum 

func (x ContainerHealth) Enum() *ContainerHealth

func (ContainerHealth) EnumDescriptor deprecated 

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

Deprecated: Use ContainerHealth.Descriptor instead.

func (ContainerHealth) Number 

func (x ContainerHealth) Number() protoreflect.EnumNumber

func (ContainerHealth) String 

func (x ContainerHealth) String() string

func (ContainerHealth) Type 

func (ContainerHealth) Type() protoreflect.EnumType

type ContainerImage 

type ContainerImage struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RawName   string `protobuf:"bytes,2,opt,name=rawName,proto3" json:"rawName,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ShortName string `protobuf:"bytes,4,opt,name=shortName,proto3" json:"shortName,omitempty"`
	Tag       string `protobuf:"bytes,5,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerImage) Descriptor deprecated 

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

Deprecated: Use ContainerImage.ProtoReflect.Descriptor instead.

func (*ContainerImage) GetId 

func (x *ContainerImage) GetId() string

func (*ContainerImage) GetName 

func (x *ContainerImage) GetName() string

func (*ContainerImage) GetRawName 

func (x *ContainerImage) GetRawName() string

func (*ContainerImage) GetShortName 

func (x *ContainerImage) GetShortName() string

func (*ContainerImage) GetTag 

func (x *ContainerImage) GetTag() string

func (*ContainerImage) ProtoMessage 

func (*ContainerImage) ProtoMessage()

func (*ContainerImage) ProtoReflect 

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

func (*ContainerImage) Reset 

func (x *ContainerImage) Reset()

func (*ContainerImage) String 

func (x *ContainerImage) String() string

type ContainerPort 

type ContainerPort struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Port     int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerPort) Descriptor deprecated 

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

Deprecated: Use ContainerPort.ProtoReflect.Descriptor instead.

func (*ContainerPort) GetName 

func (x *ContainerPort) GetName() string

func (*ContainerPort) GetPort 

func (x *ContainerPort) GetPort() int32

func (*ContainerPort) GetProtocol 

func (x *ContainerPort) GetProtocol() string

func (*ContainerPort) ProtoMessage 

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) ProtoReflect 

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

func (*ContainerPort) Reset 

func (x *ContainerPort) Reset()

func (*ContainerPort) String 

func (x *ContainerPort) String() string

type ContainerState 

type ContainerState struct {
	Running    bool            `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	Status     ContainerStatus `protobuf:"varint,2,opt,name=status,proto3,enum=datadog.workloadmeta.ContainerStatus" json:"status,omitempty"`
	Health     ContainerHealth `protobuf:"varint,3,opt,name=health,proto3,enum=datadog.workloadmeta.ContainerHealth" json:"health,omitempty"`
	CreatedAt  int64           `protobuf:"varint,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	StartedAt  int64           `protobuf:"varint,5,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	FinishedAt int64           `protobuf:"varint,6,opt,name=finishedAt,proto3" json:"finishedAt,omitempty"`
	ExitCode   uint32          `protobuf:"varint,7,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerState) Descriptor deprecated 

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

Deprecated: Use ContainerState.ProtoReflect.Descriptor instead.

func (*ContainerState) GetCreatedAt 

func (x *ContainerState) GetCreatedAt() int64

func (*ContainerState) GetExitCode 

func (x *ContainerState) GetExitCode() uint32

func (*ContainerState) GetFinishedAt 

func (x *ContainerState) GetFinishedAt() int64

func (*ContainerState) GetHealth 

func (x *ContainerState) GetHealth() ContainerHealth

func (*ContainerState) GetRunning 

func (x *ContainerState) GetRunning() bool

func (*ContainerState) GetStartedAt 

func (x *ContainerState) GetStartedAt() int64

func (*ContainerState) GetStatus 

func (x *ContainerState) GetStatus() ContainerStatus

func (*ContainerState) ProtoMessage 

func (*ContainerState) ProtoMessage()

func (*ContainerState) ProtoReflect 

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

func (*ContainerState) Reset 

func (x *ContainerState) Reset()

func (*ContainerState) String 

func (x *ContainerState) String() string

type ContainerStatus 

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

func (ContainerStatus) Descriptor 

func (ContainerStatus) Descriptor() protoreflect.EnumDescriptor

func (ContainerStatus) Enum 

func (x ContainerStatus) Enum() *ContainerStatus

func (ContainerStatus) EnumDescriptor deprecated 

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

Deprecated: Use ContainerStatus.Descriptor instead.

func (ContainerStatus) Number 

func (x ContainerStatus) Number() protoreflect.EnumNumber

func (ContainerStatus) String 

func (x ContainerStatus) String() string

func (ContainerStatus) Type 

func (ContainerStatus) Type() protoreflect.EnumType

type DelegatedMeta 

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

func (*DelegatedMeta) Descriptor deprecated 

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

Deprecated: Use DelegatedMeta.ProtoReflect.Descriptor instead.

func (*DelegatedMeta) GetRaw 

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

func (*DelegatedMeta) GetRole 

func (x *DelegatedMeta) GetRole() string

func (*DelegatedMeta) GetVersion 

func (x *DelegatedMeta) GetVersion() uint64

func (*DelegatedMeta) ProtoMessage 

func (*DelegatedMeta) ProtoMessage()

func (*DelegatedMeta) ProtoReflect 

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

func (*DelegatedMeta) Reset 

func (x *DelegatedMeta) Reset()

func (*DelegatedMeta) String 

func (x *DelegatedMeta) String() string

type DirectorMetas 

type DirectorMetas struct {
	Roots     []*TopMeta `protobuf:"bytes,1,rep,name=roots,proto3" json:"roots,omitempty"`
	Timestamp *TopMeta   `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Snapshot  *TopMeta   `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	Targets   *TopMeta   `protobuf:"bytes,4,opt,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

func (*DirectorMetas) Descriptor deprecated 

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

Deprecated: Use DirectorMetas.ProtoReflect.Descriptor instead.

func (*DirectorMetas) GetRoots 

func (x *DirectorMetas) GetRoots() []*TopMeta

func (*DirectorMetas) GetSnapshot 

func (x *DirectorMetas) GetSnapshot() *TopMeta

func (*DirectorMetas) GetTargets 

func (x *DirectorMetas) GetTargets() *TopMeta

func (*DirectorMetas) GetTimestamp 

func (x *DirectorMetas) GetTimestamp() *TopMeta

func (*DirectorMetas) ProtoMessage 

func (*DirectorMetas) ProtoMessage()

func (*DirectorMetas) ProtoReflect 

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

func (*DirectorMetas) Reset 

func (x *DirectorMetas) Reset()

func (*DirectorMetas) String 

func (x *DirectorMetas) String() string

type ECSLaunchType 

type ECSLaunchType int32
const (
	ECSLaunchType_EC2     ECSLaunchType = 0
	ECSLaunchType_FARGATE ECSLaunchType = 1
)

func (ECSLaunchType) Descriptor 

func (ECSLaunchType) Descriptor() protoreflect.EnumDescriptor

func (ECSLaunchType) Enum 

func (x ECSLaunchType) Enum() *ECSLaunchType

func (ECSLaunchType) EnumDescriptor deprecated 

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

Deprecated: Use ECSLaunchType.Descriptor instead.

func (ECSLaunchType) Number 

func (x ECSLaunchType) Number() protoreflect.EnumNumber

func (ECSLaunchType) String 

func (x ECSLaunchType) String() string

func (ECSLaunchType) Type 

func (ECSLaunchType) Type() protoreflect.EnumType

type ECSTask 

type ECSTask struct {
	EntityId              *WorkloadmetaEntityId    `protobuf:"bytes,1,opt,name=entityId,proto3" json:"entityId,omitempty"`
	EntityMeta            *EntityMeta              `protobuf:"bytes,2,opt,name=entityMeta,proto3" json:"entityMeta,omitempty"`
	Tags                  map[string]string        `` /* 149-byte string literal not displayed */
	ContainerInstanceTags map[string]string        `` /* 183-byte string literal not displayed */
	ClusterName           string                   `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Region                string                   `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	AvailabilityZone      string                   `protobuf:"bytes,7,opt,name=availabilityZone,proto3" json:"availabilityZone,omitempty"`
	Family                string                   `protobuf:"bytes,8,opt,name=family,proto3" json:"family,omitempty"`
	Version               string                   `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	LaunchType            ECSLaunchType            `protobuf:"varint,10,opt,name=launchType,proto3,enum=datadog.workloadmeta.ECSLaunchType" json:"launchType,omitempty"`
	Containers            []*OrchestratorContainer `protobuf:"bytes,11,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*ECSTask) Descriptor deprecated 

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

Deprecated: Use ECSTask.ProtoReflect.Descriptor instead.

func (*ECSTask) GetAvailabilityZone 

func (x *ECSTask) GetAvailabilityZone() string

func (*ECSTask) GetClusterName 

func (x *ECSTask) GetClusterName() string

func (*ECSTask) GetContainerInstanceTags 

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

func (*ECSTask) GetContainers 

func (x *ECSTask) GetContainers() []*OrchestratorContainer

func (*ECSTask) GetEntityId 

func (x *ECSTask) GetEntityId() *WorkloadmetaEntityId

func (*ECSTask) GetEntityMeta 

func (x *ECSTask) GetEntityMeta() *EntityMeta

func (*ECSTask) GetFamily 

func (x *ECSTask) GetFamily() string

func (*ECSTask) GetLaunchType 

func (x *ECSTask) GetLaunchType() ECSLaunchType

func (*ECSTask) GetRegion 

func (x *ECSTask) GetRegion() string

func (*ECSTask) GetTags 

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

func (*ECSTask) GetVersion 

func (x *ECSTask) GetVersion() string

func (*ECSTask) ProtoMessage 

func (*ECSTask) ProtoMessage()

func (*ECSTask) ProtoReflect 

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

func (*ECSTask) Reset 

func (x *ECSTask) Reset()

func (*ECSTask) String 

func (x *ECSTask) String() string

type Entity 

type Entity struct {
	Id                          *EntityId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hash                        string    `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	HighCardinalityTags         []string  `protobuf:"bytes,3,rep,name=highCardinalityTags,proto3" json:"highCardinalityTags,omitempty"`
	OrchestratorCardinalityTags []string  `protobuf:"bytes,4,rep,name=orchestratorCardinalityTags,proto3" json:"orchestratorCardinalityTags,omitempty"`
	LowCardinalityTags          []string  `protobuf:"bytes,5,rep,name=lowCardinalityTags,proto3" json:"lowCardinalityTags,omitempty"`
	StandardTags                []string  `protobuf:"bytes,6,rep,name=standardTags,proto3" json:"standardTags,omitempty"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetHash 

func (x *Entity) GetHash() string

func (*Entity) GetHighCardinalityTags 

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

func (*Entity) GetId 

func (x *Entity) GetId() *EntityId

func (*Entity) GetLowCardinalityTags 

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

func (*Entity) GetOrchestratorCardinalityTags 

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

func (*Entity) GetStandardTags 

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

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type EntityId 

type EntityId struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Uid    string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityId) Descriptor deprecated 

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

Deprecated: Use EntityId.ProtoReflect.Descriptor instead.

func (*EntityId) GetPrefix 

func (x *EntityId) GetPrefix() string

func (*EntityId) GetUid 

func (x *EntityId) GetUid() string

func (*EntityId) ProtoMessage 

func (*EntityId) ProtoMessage()

func (*EntityId) ProtoReflect 

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

func (*EntityId) Reset 

func (x *EntityId) Reset()

func (*EntityId) String 

func (x *EntityId) String() string

type EntityMeta 

type EntityMeta struct {
	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace   string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EntityMeta) Descriptor deprecated 

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

Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

func (*EntityMeta) GetAnnotations 

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

func (*EntityMeta) GetLabels 

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

func (*EntityMeta) GetName 

func (x *EntityMeta) GetName() string

func (*EntityMeta) GetNamespace 

func (x *EntityMeta) GetNamespace() string

func (*EntityMeta) ProtoMessage 

func (*EntityMeta) ProtoMessage()

func (*EntityMeta) ProtoReflect 

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

func (*EntityMeta) Reset 

func (x *EntityMeta) Reset()

func (*EntityMeta) String 

func (x *EntityMeta) String() string

type EventType 

type EventType int32
const (
	EventType_ADDED    EventType = 0
	EventType_MODIFIED EventType = 1
	EventType_DELETED  EventType = 2
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type FetchEntityRequest 

type FetchEntityRequest struct {
	Id          *EntityId      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Cardinality TagCardinality `protobuf:"varint,2,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchEntityRequest) Descriptor deprecated 

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

Deprecated: Use FetchEntityRequest.ProtoReflect.Descriptor instead.

func (*FetchEntityRequest) GetCardinality 

func (x *FetchEntityRequest) GetCardinality() TagCardinality

func (*FetchEntityRequest) GetId 

func (x *FetchEntityRequest) GetId() *EntityId

func (*FetchEntityRequest) ProtoMessage 

func (*FetchEntityRequest) ProtoMessage()

func (*FetchEntityRequest) ProtoReflect 

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

func (*FetchEntityRequest) Reset 

func (x *FetchEntityRequest) Reset()

func (*FetchEntityRequest) String 

func (x *FetchEntityRequest) String() string

type FetchEntityResponse 

type FetchEntityResponse struct {
	Id          *EntityId      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Cardinality TagCardinality `protobuf:"varint,2,opt,name=cardinality,proto3,enum=datadog.model.v1.TagCardinality" json:"cardinality,omitempty"`
	Tags        []string       `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchEntityResponse) Descriptor deprecated 

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

Deprecated: Use FetchEntityResponse.ProtoReflect.Descriptor instead.

func (*FetchEntityResponse) GetCardinality 

func (x *FetchEntityResponse) GetCardinality() TagCardinality

func (*FetchEntityResponse) GetId 

func (x *FetchEntityResponse) GetId() *EntityId

func (*FetchEntityResponse) GetTags 

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

func (*FetchEntityResponse) ProtoMessage 

func (*FetchEntityResponse) ProtoMessage()

func (*FetchEntityResponse) ProtoReflect 

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

func (*FetchEntityResponse) Reset 

func (x *FetchEntityResponse) Reset()

func (*FetchEntityResponse) String 

func (x *FetchEntityResponse) String() string

type File 

type File struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Raw  []byte `protobuf:"bytes,2,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) GetRaw 

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

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

type FileMetaState 

type FileMetaState struct {
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Hash    string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*FileMetaState) Descriptor deprecated 

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

Deprecated: Use FileMetaState.ProtoReflect.Descriptor instead.

func (*FileMetaState) GetHash 

func (x *FileMetaState) GetHash() string

func (*FileMetaState) GetVersion 

func (x *FileMetaState) GetVersion() uint64

func (*FileMetaState) ProtoMessage 

func (*FileMetaState) ProtoMessage()

func (*FileMetaState) ProtoReflect 

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

func (*FileMetaState) Reset 

func (x *FileMetaState) Reset()

func (*FileMetaState) String 

func (x *FileMetaState) String() string

type Filter 

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

func (*Filter) Descriptor deprecated 

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

func (*GetStateConfigResponse) ProtoMessage()

func (*GetStateConfigResponse) ProtoReflect 

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

func (*GetStateConfigResponse) Reset 

func (x *GetStateConfigResponse) Reset()

func (*GetStateConfigResponse) String 

func (x *GetStateConfigResponse) String() string

type HostnameReply 

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

The response message containing the requested hostname

func (*HostnameReply) Descriptor deprecated 

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

Deprecated: Use HostnameReply.ProtoReflect.Descriptor instead.

func (*HostnameReply) GetHostname 

func (x *HostnameReply) GetHostname() string

func (*HostnameReply) ProtoMessage 

func (*HostnameReply) ProtoMessage()

func (*HostnameReply) ProtoReflect 

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

func (*HostnameReply) Reset 

func (x *HostnameReply) Reset()

func (*HostnameReply) String 

func (x *HostnameReply) String() string

type HostnameRequest 

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

func (*HostnameRequest) Descriptor deprecated 

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

Deprecated: Use HostnameRequest.ProtoReflect.Descriptor instead.

func (*HostnameRequest) ProtoMessage 

func (*HostnameRequest) ProtoMessage()

func (*HostnameRequest) ProtoReflect 

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

func (*HostnameRequest) Reset 

func (x *HostnameRequest) Reset()

func (*HostnameRequest) String 

func (x *HostnameRequest) String() string

type KubernetesPod 

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

func (*KubernetesPod) Descriptor deprecated 

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

Deprecated: Use KubernetesPod.ProtoReflect.Descriptor instead.

func (*KubernetesPod) GetContainers 

func (x *KubernetesPod) GetContainers() []*OrchestratorContainer

func (*KubernetesPod) GetEntityId 

func (x *KubernetesPod) GetEntityId() *WorkloadmetaEntityId

func (*KubernetesPod) GetEntityMeta 

func (x *KubernetesPod) GetEntityMeta() *EntityMeta

func (*KubernetesPod) GetIp 

func (x *KubernetesPod) GetIp() string

func (*KubernetesPod) GetKubeServices 

func (x *KubernetesPod) GetKubeServices() []string

func (*KubernetesPod) GetNamespaceLabels 

func (x *KubernetesPod) GetNamespaceLabels() map[string]string

func (*KubernetesPod) GetOwners 

func (x *KubernetesPod) GetOwners() []*KubernetesPodOwner

func (*KubernetesPod) GetPersistentVolumeClaimNames 

func (x *KubernetesPod) GetPersistentVolumeClaimNames() []string

func (*KubernetesPod) GetPhase 

func (x *KubernetesPod) GetPhase() string

func (*KubernetesPod) GetPriorityClass 

func (x *KubernetesPod) GetPriorityClass() string

func (*KubernetesPod) GetQosClass 

func (x *KubernetesPod) GetQosClass() string

func (*KubernetesPod) GetReady 

func (x *KubernetesPod) GetReady() bool

func (*KubernetesPod) ProtoMessage 

func (*KubernetesPod) ProtoMessage()

func (*KubernetesPod) ProtoReflect 

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

func (*KubernetesPod) Reset 

func (x *KubernetesPod) Reset()

func (*KubernetesPod) String 

func (x *KubernetesPod) String() string

type KubernetesPodOwner 

type KubernetesPodOwner struct {
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Id   string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesPodOwner) Descriptor deprecated 

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

Deprecated: Use KubernetesPodOwner.ProtoReflect.Descriptor instead.

func (*KubernetesPodOwner) GetId 

func (x *KubernetesPodOwner) GetId() string

func (*KubernetesPodOwner) GetKind 

func (x *KubernetesPodOwner) GetKind() string

func (*KubernetesPodOwner) GetName 

func (x *KubernetesPodOwner) GetName() string

func (*KubernetesPodOwner) ProtoMessage 

func (*KubernetesPodOwner) ProtoMessage()

func (*KubernetesPodOwner) ProtoReflect 

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

func (*KubernetesPodOwner) Reset 

func (x *KubernetesPodOwner) Reset()

func (*KubernetesPodOwner) String 

func (x *KubernetesPodOwner) String() string

type Language added in v0.47.0 

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

func (*Language) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use Language.ProtoReflect.Descriptor instead.

func (*Language) GetName added in v0.47.0 

func (x *Language) GetName() string

func (*Language) ProtoMessage added in v0.47.0 

func (*Language) ProtoMessage()

func (*Language) ProtoReflect added in v0.47.0 

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

func (*Language) Reset added in v0.47.0 

func (x *Language) Reset()

func (*Language) String added in v0.47.0 

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

func (*LatestConfigsRequest) Descriptor deprecated 

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

Deprecated: Use LatestConfigsRequest.ProtoReflect.Descriptor instead.

func (*LatestConfigsRequest) GetActiveClients 

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

func (*LatestConfigsRequest) GetAgentVersion 

func (x *LatestConfigsRequest) GetAgentVersion() string

func (*LatestConfigsRequest) GetBackendClientState 

func (x *LatestConfigsRequest) GetBackendClientState() []byte

func (*LatestConfigsRequest) GetCurrentConfigRootVersion 

func (x *LatestConfigsRequest) GetCurrentConfigRootVersion() uint64

func (*LatestConfigsRequest) GetCurrentConfigSnapshotVersion 

func (x *LatestConfigsRequest) GetCurrentConfigSnapshotVersion() uint64

func (*LatestConfigsRequest) GetCurrentDirectorRootVersion 

func (x *LatestConfigsRequest) GetCurrentDirectorRootVersion() uint64

func (*LatestConfigsRequest) GetError 

func (x *LatestConfigsRequest) GetError() string

func (*LatestConfigsRequest) GetHasError 

func (x *LatestConfigsRequest) GetHasError() bool

func (*LatestConfigsRequest) GetHostname 

func (x *LatestConfigsRequest) GetHostname() string

func (*LatestConfigsRequest) GetNewProducts 

func (x *LatestConfigsRequest) GetNewProducts() []string

func (*LatestConfigsRequest) GetOrgUuid 

func (x *LatestConfigsRequest) GetOrgUuid() string

func (*LatestConfigsRequest) GetProducts 

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

func (*LatestConfigsRequest) GetTraceAgentEnv 

func (x *LatestConfigsRequest) GetTraceAgentEnv() string

func (*LatestConfigsRequest) ProtoMessage 

func (*LatestConfigsRequest) ProtoMessage()

func (*LatestConfigsRequest) ProtoReflect 

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

func (*LatestConfigsRequest) Reset 

func (x *LatestConfigsRequest) Reset()

func (*LatestConfigsRequest) String 

func (x *LatestConfigsRequest) String() string

type LatestConfigsResponse 

type LatestConfigsResponse struct {
	ConfigMetas   *ConfigMetas   `protobuf:"bytes,1,opt,name=config_metas,json=configMetas,proto3" json:"config_metas,omitempty"`
	DirectorMetas *DirectorMetas `protobuf:"bytes,2,opt,name=director_metas,json=directorMetas,proto3" json:"director_metas,omitempty"`
	TargetFiles   []*File        `protobuf:"bytes,3,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"`
	// contains filtered or unexported fields
}

func (*LatestConfigsResponse) Descriptor deprecated 

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

Deprecated: Use LatestConfigsResponse.ProtoReflect.Descriptor instead.

func (*LatestConfigsResponse) GetConfigMetas 

func (x *LatestConfigsResponse) GetConfigMetas() *ConfigMetas

func (*LatestConfigsResponse) GetDirectorMetas 

func (x *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas

func (*LatestConfigsResponse) GetTargetFiles 

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

func (*LatestConfigsResponse) ProtoMessage 

func (*LatestConfigsResponse) ProtoMessage()

func (*LatestConfigsResponse) ProtoReflect 

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

func (*LatestConfigsResponse) Reset 

func (x *LatestConfigsResponse) Reset()

func (*LatestConfigsResponse) String 

func (x *LatestConfigsResponse) String() string

type OrchestratorContainer 

type OrchestratorContainer struct {
	Id    string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name  string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image *ContainerImage `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorContainer) Descriptor deprecated 

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

Deprecated: Use OrchestratorContainer.ProtoReflect.Descriptor instead.

func (*OrchestratorContainer) GetId 

func (x *OrchestratorContainer) GetId() string

func (*OrchestratorContainer) GetImage 

func (x *OrchestratorContainer) GetImage() *ContainerImage

func (*OrchestratorContainer) GetName 

func (x *OrchestratorContainer) GetName() string

func (*OrchestratorContainer) ProtoMessage 

func (*OrchestratorContainer) ProtoMessage()

func (*OrchestratorContainer) ProtoReflect 

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

func (*OrchestratorContainer) Reset 

func (x *OrchestratorContainer) Reset()

func (*OrchestratorContainer) String 

func (x *OrchestratorContainer) String() string

type OrgDataResponse 

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

func (*OrgDataResponse) Descriptor deprecated 

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

Deprecated: Use OrgDataResponse.ProtoReflect.Descriptor instead.

func (*OrgDataResponse) GetUuid 

func (x *OrgDataResponse) GetUuid() string

func (*OrgDataResponse) ProtoMessage 

func (*OrgDataResponse) ProtoMessage()

func (*OrgDataResponse) ProtoReflect 

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

func (*OrgDataResponse) Reset 

func (x *OrgDataResponse) Reset()

func (*OrgDataResponse) String 

func (x *OrgDataResponse) String() string

type OrgStatusResponse added in v0.47.0 

type OrgStatusResponse struct {
	Enabled    bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Authorized bool `protobuf:"varint,2,opt,name=authorized,proto3" json:"authorized,omitempty"`
	// contains filtered or unexported fields
}

func (*OrgStatusResponse) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use OrgStatusResponse.ProtoReflect.Descriptor instead.

func (*OrgStatusResponse) GetAuthorized added in v0.47.0 

func (x *OrgStatusResponse) GetAuthorized() bool

func (*OrgStatusResponse) GetEnabled added in v0.47.0 

func (x *OrgStatusResponse) GetEnabled() bool

func (*OrgStatusResponse) ProtoMessage added in v0.47.0 

func (*OrgStatusResponse) ProtoMessage()

func (*OrgStatusResponse) ProtoReflect added in v0.47.0 

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

func (*OrgStatusResponse) Reset added in v0.47.0 

func (x *OrgStatusResponse) Reset()

func (*OrgStatusResponse) String added in v0.47.0 

func (x *OrgStatusResponse) String() string

type ProcessEntityStreamClient added in v0.47.0 

type ProcessEntityStreamClient interface {
	StreamEntities(ctx context.Context, in *ProcessStreamEntitiesRequest, opts ...grpc.CallOption) (ProcessEntityStream_StreamEntitiesClient, error)
}

ProcessEntityStreamClient is the client API for ProcessEntityStream service.

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

func NewProcessEntityStreamClient added in v0.47.0 

func NewProcessEntityStreamClient(cc grpc.ClientConnInterface) ProcessEntityStreamClient

type ProcessEntityStreamServer added in v0.47.0 

type ProcessEntityStreamServer interface {
	StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error
}

ProcessEntityStreamServer is the server API for ProcessEntityStream service.

type ProcessEntityStream_StreamEntitiesClient added in v0.47.0 

type ProcessEntityStream_StreamEntitiesClient interface {
	Recv() (*ProcessStreamResponse, error)
	grpc.ClientStream
}

type ProcessEntityStream_StreamEntitiesServer added in v0.47.0 

type ProcessEntityStream_StreamEntitiesServer interface {
	Send(*ProcessStreamResponse) error
	grpc.ServerStream
}

type ProcessEventSet added in v0.47.0 

type ProcessEventSet struct {
	Pid          int32     `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Nspid        int32     `protobuf:"varint,2,opt,name=nspid,proto3" json:"nspid,omitempty"`
	ContainerId  string    `protobuf:"bytes,3,opt,name=containerId,proto3" json:"containerId,omitempty"`
	CreationTime int64     `protobuf:"varint,4,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	Language     *Language `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessEventSet) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use ProcessEventSet.ProtoReflect.Descriptor instead.

func (*ProcessEventSet) GetContainerId added in v0.47.0 

func (x *ProcessEventSet) GetContainerId() string

func (*ProcessEventSet) GetCreationTime added in v0.47.0 

func (x *ProcessEventSet) GetCreationTime() int64

func (*ProcessEventSet) GetLanguage added in v0.47.0 

func (x *ProcessEventSet) GetLanguage() *Language

func (*ProcessEventSet) GetNspid added in v0.47.0 

func (x *ProcessEventSet) GetNspid() int32

func (*ProcessEventSet) GetPid added in v0.47.0 

func (x *ProcessEventSet) GetPid() int32

func (*ProcessEventSet) ProtoMessage added in v0.47.0 

func (*ProcessEventSet) ProtoMessage()

func (*ProcessEventSet) ProtoReflect added in v0.47.0 

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

func (*ProcessEventSet) Reset added in v0.47.0 

func (x *ProcessEventSet) Reset()

func (*ProcessEventSet) String added in v0.47.0 

func (x *ProcessEventSet) String() string

type ProcessEventUnset added in v0.47.0 

type ProcessEventUnset struct {
	Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessEventUnset) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use ProcessEventUnset.ProtoReflect.Descriptor instead.

func (*ProcessEventUnset) GetPid added in v0.47.0 

func (x *ProcessEventUnset) GetPid() int32

func (*ProcessEventUnset) ProtoMessage added in v0.47.0 

func (*ProcessEventUnset) ProtoMessage()

func (*ProcessEventUnset) ProtoReflect added in v0.47.0 

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

func (*ProcessEventUnset) Reset added in v0.47.0 

func (x *ProcessEventUnset) Reset()

func (*ProcessEventUnset) String added in v0.47.0 

func (x *ProcessEventUnset) String() string

type ProcessStatRequest 

type ProcessStatRequest struct {
	Pids []int32 `protobuf:"varint,1,rep,packed,name=pids,proto3" json:"pids,omitempty"`
	// contains filtered or unexported fields
}

ProcessStatRequest is the request to get process stats.

func (*ProcessStatRequest) Descriptor deprecated 

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

Deprecated: Use ProcessStatRequest.ProtoReflect.Descriptor instead.

func (*ProcessStatRequest) GetPids 

func (x *ProcessStatRequest) GetPids() []int32

func (*ProcessStatRequest) ProtoMessage 

func (*ProcessStatRequest) ProtoMessage()

func (*ProcessStatRequest) ProtoReflect 

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

func (*ProcessStatRequest) Reset 

func (x *ProcessStatRequest) Reset()

func (*ProcessStatRequest) String 

func (x *ProcessStatRequest) String() string

type ProcessStreamEntitiesRequest added in v0.47.0 

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

func (*ProcessStreamEntitiesRequest) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use ProcessStreamEntitiesRequest.ProtoReflect.Descriptor instead.

func (*ProcessStreamEntitiesRequest) ProtoMessage added in v0.47.0 

func (*ProcessStreamEntitiesRequest) ProtoMessage()

func (*ProcessStreamEntitiesRequest) ProtoReflect added in v0.47.0 

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

func (*ProcessStreamEntitiesRequest) Reset added in v0.47.0 

func (x *ProcessStreamEntitiesRequest) Reset()

func (*ProcessStreamEntitiesRequest) String added in v0.47.0 

func (x *ProcessStreamEntitiesRequest) String() string

type ProcessStreamResponse added in v0.47.0 

type ProcessStreamResponse struct {
	EventID     int32                `protobuf:"varint,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	SetEvents   []*ProcessEventSet   `protobuf:"bytes,2,rep,name=setEvents,proto3" json:"setEvents,omitempty"`
	UnsetEvents []*ProcessEventUnset `protobuf:"bytes,3,rep,name=unsetEvents,proto3" json:"unsetEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessStreamResponse) Descriptor deprecated added in v0.47.0 

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

Deprecated: Use ProcessStreamResponse.ProtoReflect.Descriptor instead.

func (*ProcessStreamResponse) GetEventID added in v0.47.0 

func (x *ProcessStreamResponse) GetEventID() int32

func (*ProcessStreamResponse) GetSetEvents added in v0.47.0 

func (x *ProcessStreamResponse) GetSetEvents() []*ProcessEventSet

func (*ProcessStreamResponse) GetUnsetEvents added in v0.47.0 

func (x *ProcessStreamResponse) GetUnsetEvents() []*ProcessEventUnset

func (*ProcessStreamResponse) ProtoMessage added in v0.47.0 

func (*ProcessStreamResponse) ProtoMessage()

func (*ProcessStreamResponse) ProtoReflect added in v0.47.0 

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

func (*ProcessStreamResponse) Reset added in v0.47.0 

func (x *ProcessStreamResponse) Reset()

func (*ProcessStreamResponse) String added in v0.47.0 

func (x *ProcessStreamResponse) String() string

type Runtime 

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

func (Runtime) Descriptor 

func (Runtime) Descriptor() protoreflect.EnumDescriptor

func (Runtime) Enum 

func (x Runtime) Enum() *Runtime

func (Runtime) EnumDescriptor deprecated 

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

Deprecated: Use Runtime.Descriptor instead.

func (Runtime) Number 

func (x Runtime) Number() protoreflect.EnumNumber

func (Runtime) String 

func (x Runtime) String() string

func (Runtime) Type 

func (Runtime) Type() protoreflect.EnumType

type StreamTagsEvent 

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

func (*StreamTagsEvent) Descriptor deprecated 

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

Deprecated: Use StreamTagsEvent.ProtoReflect.Descriptor instead.

func (*StreamTagsEvent) GetEntity 

func (x *StreamTagsEvent) GetEntity() *Entity

func (*StreamTagsEvent) GetType 

func (x *StreamTagsEvent) GetType() EventType

func (*StreamTagsEvent) ProtoMessage 

func (*StreamTagsEvent) ProtoMessage()

func (*StreamTagsEvent) ProtoReflect 

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

func (*StreamTagsEvent) Reset 

func (x *StreamTagsEvent) Reset()

func (*StreamTagsEvent) String 

func (x *StreamTagsEvent) String() string

type StreamTagsRequest 

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

func (*StreamTagsRequest) Descriptor deprecated 

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

Deprecated: Use StreamTagsRequest.ProtoReflect.Descriptor instead.

func (*StreamTagsRequest) GetCardinality 

func (x *StreamTagsRequest) GetCardinality() TagCardinality

func (*StreamTagsRequest) GetExcludeFilter 

func (x *StreamTagsRequest) GetExcludeFilter() *Filter

func (*StreamTagsRequest) GetIncludeFilter 

func (x *StreamTagsRequest) GetIncludeFilter() *Filter

func (*StreamTagsRequest) ProtoMessage 

func (*StreamTagsRequest) ProtoMessage()

func (*StreamTagsRequest) ProtoReflect 

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

func (*StreamTagsRequest) Reset 

func (x *StreamTagsRequest) Reset()

func (*StreamTagsRequest) String 

func (x *StreamTagsRequest) String() string

type StreamTagsResponse 

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

func (*StreamTagsResponse) Descriptor deprecated 

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

Deprecated: Use StreamTagsResponse.ProtoReflect.Descriptor instead.

func (*StreamTagsResponse) GetEvents 

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

func (*StreamTagsResponse) ProtoMessage 

func (*StreamTagsResponse) ProtoMessage()

func (*StreamTagsResponse) ProtoReflect 

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

func (*StreamTagsResponse) Reset 

func (x *StreamTagsResponse) Reset()

func (*StreamTagsResponse) String 

func (x *StreamTagsResponse) String() string

type TagCardinality 

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

func (TagCardinality) Descriptor 

func (TagCardinality) Descriptor() protoreflect.EnumDescriptor

func (TagCardinality) Enum 

func (x TagCardinality) Enum() *TagCardinality

func (TagCardinality) EnumDescriptor deprecated 

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

Deprecated: Use TagCardinality.Descriptor instead.

func (TagCardinality) Number 

func (x TagCardinality) Number() protoreflect.EnumNumber

func (TagCardinality) String 

func (x TagCardinality) String() string

func (TagCardinality) Type 

func (TagCardinality) Type() protoreflect.EnumType

type TaggerState 

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

func (*TaggerState) Descriptor deprecated 

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

Deprecated: Use TaggerState.ProtoReflect.Descriptor instead.

func (*TaggerState) GetPidMap 

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

func (*TaggerState) GetState 

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

func (*TaggerState) ProtoMessage 

func (*TaggerState) ProtoMessage()

func (*TaggerState) ProtoReflect 

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

func (*TaggerState) Reset 

func (x *TaggerState) Reset()

func (*TaggerState) String 

func (x *TaggerState) String() string

type TaggerStateResponse 

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

func (*TaggerStateResponse) Descriptor deprecated 

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

Deprecated: Use TaggerStateResponse.ProtoReflect.Descriptor instead.

func (*TaggerStateResponse) GetLoaded 

func (x *TaggerStateResponse) GetLoaded() bool

func (*TaggerStateResponse) ProtoMessage 

func (*TaggerStateResponse) ProtoMessage()

func (*TaggerStateResponse) ProtoReflect 

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

func (*TaggerStateResponse) Reset 

func (x *TaggerStateResponse) Reset()

func (*TaggerStateResponse) String 

func (x *TaggerStateResponse) String() string

type TargetFileHash 

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

func (*TargetFileHash) Descriptor deprecated 

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

Deprecated: Use TargetFileHash.ProtoReflect.Descriptor instead.

func (*TargetFileHash) GetAlgorithm 

func (x *TargetFileHash) GetAlgorithm() string

func (*TargetFileHash) GetHash 

func (x *TargetFileHash) GetHash() string

func (*TargetFileHash) ProtoMessage 

func (*TargetFileHash) ProtoMessage()

func (*TargetFileHash) ProtoReflect 

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

func (*TargetFileHash) Reset 

func (x *TargetFileHash) Reset()

func (*TargetFileHash) String 

func (x *TargetFileHash) String() string

type TargetFileMeta 

type TargetFileMeta struct {
	Path   string            `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Length int64             `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	Hashes []*TargetFileHash `protobuf:"bytes,3,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// contains filtered or unexported fields
}

func (*TargetFileMeta) Descriptor deprecated 

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

Deprecated: Use TargetFileMeta.ProtoReflect.Descriptor instead.

func (*TargetFileMeta) GetHashes 

func (x *TargetFileMeta) GetHashes() []*TargetFileHash

func (*TargetFileMeta) GetLength 

func (x *TargetFileMeta) GetLength() int64

func (*TargetFileMeta) GetPath 

func (x *TargetFileMeta) GetPath() string

func (*TargetFileMeta) ProtoMessage 

func (*TargetFileMeta) ProtoMessage()

func (*TargetFileMeta) ProtoReflect 

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

func (*TargetFileMeta) Reset 

func (x *TargetFileMeta) Reset()

func (*TargetFileMeta) String 

func (x *TargetFileMeta) String() string

type TopMeta 

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

func (*TopMeta) Descriptor deprecated 

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

type TracerPredicateV1 

type TracerPredicateV1 struct {
	ClientID      string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Service       string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Environment   string `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"`
	AppVersion    string `protobuf:"bytes,4,opt,name=appVersion,proto3" json:"appVersion,omitempty"`
	TracerVersion string `protobuf:"bytes,5,opt,name=tracerVersion,proto3" json:"tracerVersion,omitempty"`
	Language      string `protobuf:"bytes,6,opt,name=language,proto3" json:"language,omitempty"`
	RuntimeID     string `protobuf:"bytes,7,opt,name=runtimeID,proto3" json:"runtimeID,omitempty"`
	// contains filtered or unexported fields
}

func (*TracerPredicateV1) Descriptor deprecated 

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

Deprecated: Use TracerPredicateV1.ProtoReflect.Descriptor instead.

func (*TracerPredicateV1) GetAppVersion 

func (x *TracerPredicateV1) GetAppVersion() string

func (*TracerPredicateV1) GetClientID 

func (x *TracerPredicateV1) GetClientID() string

func (*TracerPredicateV1) GetEnvironment 

func (x *TracerPredicateV1) GetEnvironment() string

func (*TracerPredicateV1) GetLanguage 

func (x *TracerPredicateV1) GetLanguage() string

func (*TracerPredicateV1) GetRuntimeID 

func (x *TracerPredicateV1) GetRuntimeID() string

func (*TracerPredicateV1) GetService 

func (x *TracerPredicateV1) GetService() string

func (*TracerPredicateV1) GetTracerVersion 

func (x *TracerPredicateV1) GetTracerVersion() string

func (*TracerPredicateV1) ProtoMessage 

func (*TracerPredicateV1) ProtoMessage()

func (*TracerPredicateV1) ProtoReflect 

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

func (*TracerPredicateV1) Reset 

func (x *TracerPredicateV1) Reset()

func (*TracerPredicateV1) String 

func (x *TracerPredicateV1) String() string

type TracerPredicates 

type TracerPredicates struct {
	TracerPredicatesV1 []*TracerPredicateV1 `protobuf:"bytes,1,rep,name=tracer_predicates_v1,json=tracerPredicatesV1,proto3" json:"tracer_predicates_v1,omitempty"`
	// contains filtered or unexported fields
}

func (*TracerPredicates) Descriptor deprecated 

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

Deprecated: Use TracerPredicates.ProtoReflect.Descriptor instead.

func (*TracerPredicates) GetTracerPredicatesV1 

func (x *TracerPredicates) GetTracerPredicatesV1() []*TracerPredicateV1

func (*TracerPredicates) ProtoMessage 

func (*TracerPredicates) ProtoMessage()

func (*TracerPredicates) ProtoReflect 

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

func (*TracerPredicates) Reset 

func (x *TracerPredicates) Reset()

func (*TracerPredicates) String 

func (x *TracerPredicates) String() string

type UnimplementedAgentSecureServer 

type UnimplementedAgentSecureServer struct {
}

UnimplementedAgentSecureServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentSecureServer) ClientGetConfigs 

func (*UnimplementedAgentSecureServer) ClientGetConfigs(context.Context, *ClientGetConfigsRequest) (*ClientGetConfigsResponse, error)

func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger 

func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error)

func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState 

func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState(context.Context, *TaggerState) (*TaggerStateResponse, error)

func (*UnimplementedAgentSecureServer) GetConfigState 

func (*UnimplementedAgentSecureServer) GetConfigState(context.Context, *emptypb.Empty) (*GetStateConfigResponse, error)

func (*UnimplementedAgentSecureServer) TaggerFetchEntity 

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

func (*UnimplementedAgentSecureServer) TaggerStreamEntities 

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

func (*UnimplementedAgentSecureServer) WorkloadmetaStreamEntities 

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

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetHostname 

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

type UnimplementedProcessEntityStreamServer added in v0.47.0 

type UnimplementedProcessEntityStreamServer struct {
}

UnimplementedProcessEntityStreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessEntityStreamServer) StreamEntities added in v0.47.0 

func (*UnimplementedProcessEntityStreamServer) StreamEntities(*ProcessStreamEntitiesRequest, ProcessEntityStream_StreamEntitiesServer) error

type UnixDogstatsdMsg 

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

UDS Capture The message contains the payload and the ancillary info

func (*UnixDogstatsdMsg) Descriptor deprecated 

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

Deprecated: Use UnixDogstatsdMsg.ProtoReflect.Descriptor instead.

func (*UnixDogstatsdMsg) GetAncillary 

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

func (*UnixDogstatsdMsg) GetAncillarySize 

func (x *UnixDogstatsdMsg) GetAncillarySize() int32

func (*UnixDogstatsdMsg) GetPayload 

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

func (*UnixDogstatsdMsg) GetPayloadSize 

func (x *UnixDogstatsdMsg) GetPayloadSize() int32

func (*UnixDogstatsdMsg) GetPid 

func (x *UnixDogstatsdMsg) GetPid() int32

func (*UnixDogstatsdMsg) GetTimestamp 

func (x *UnixDogstatsdMsg) GetTimestamp() int64

func (*UnixDogstatsdMsg) ProtoMessage 

func (*UnixDogstatsdMsg) ProtoMessage()

func (*UnixDogstatsdMsg) ProtoReflect 

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

func (*UnixDogstatsdMsg) Reset 

func (x *UnixDogstatsdMsg) Reset()

func (*UnixDogstatsdMsg) String 

func (x *UnixDogstatsdMsg) String() string

type WorkloadmetaEntityId 

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

func (*WorkloadmetaEntityId) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaEntityId.ProtoReflect.Descriptor instead.

func (*WorkloadmetaEntityId) GetId 

func (x *WorkloadmetaEntityId) GetId() string

func (*WorkloadmetaEntityId) GetKind 

func (x *WorkloadmetaEntityId) GetKind() WorkloadmetaKind

func (*WorkloadmetaEntityId) ProtoMessage 

func (*WorkloadmetaEntityId) ProtoMessage()

func (*WorkloadmetaEntityId) ProtoReflect 

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

func (*WorkloadmetaEntityId) Reset 

func (x *WorkloadmetaEntityId) Reset()

func (*WorkloadmetaEntityId) String 

func (x *WorkloadmetaEntityId) String() string

type WorkloadmetaEvent 

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

func (*WorkloadmetaEvent) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaEvent.ProtoReflect.Descriptor instead.

func (*WorkloadmetaEvent) GetContainer 

func (x *WorkloadmetaEvent) GetContainer() *Container

func (*WorkloadmetaEvent) GetEcsTask 

func (x *WorkloadmetaEvent) GetEcsTask() *ECSTask

func (*WorkloadmetaEvent) GetKubernetesPod 

func (x *WorkloadmetaEvent) GetKubernetesPod() *KubernetesPod

func (*WorkloadmetaEvent) GetType 

func (x *WorkloadmetaEvent) GetType() WorkloadmetaEventType

func (*WorkloadmetaEvent) ProtoMessage 

func (*WorkloadmetaEvent) ProtoMessage()

func (*WorkloadmetaEvent) ProtoReflect 

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

func (*WorkloadmetaEvent) Reset 

func (x *WorkloadmetaEvent) Reset()

func (*WorkloadmetaEvent) String 

func (x *WorkloadmetaEvent) String() string

type WorkloadmetaEventType 

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

func (WorkloadmetaEventType) Descriptor 

func (WorkloadmetaEventType) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaEventType) Enum 

func (x WorkloadmetaEventType) Enum() *WorkloadmetaEventType

func (WorkloadmetaEventType) EnumDescriptor deprecated 

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

Deprecated: Use WorkloadmetaEventType.Descriptor instead.

func (WorkloadmetaEventType) Number 

func (x WorkloadmetaEventType) Number() protoreflect.EnumNumber

func (WorkloadmetaEventType) String 

func (x WorkloadmetaEventType) String() string

func (WorkloadmetaEventType) Type 

func (WorkloadmetaEventType) Type() protoreflect.EnumType

type WorkloadmetaFilter 

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

func (*WorkloadmetaFilter) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaFilter.ProtoReflect.Descriptor instead.

func (*WorkloadmetaFilter) GetEventType 

func (x *WorkloadmetaFilter) GetEventType() WorkloadmetaEventType

func (*WorkloadmetaFilter) GetKinds 

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

func (*WorkloadmetaFilter) GetSource 

func (x *WorkloadmetaFilter) GetSource() WorkloadmetaSource

func (*WorkloadmetaFilter) ProtoMessage 

func (*WorkloadmetaFilter) ProtoMessage()

func (*WorkloadmetaFilter) ProtoReflect 

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

func (*WorkloadmetaFilter) Reset 

func (x *WorkloadmetaFilter) Reset()

func (*WorkloadmetaFilter) String 

func (x *WorkloadmetaFilter) String() string

type WorkloadmetaKind 

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

func (WorkloadmetaKind) Descriptor 

func (WorkloadmetaKind) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaKind) Enum 

func (x WorkloadmetaKind) Enum() *WorkloadmetaKind

func (WorkloadmetaKind) EnumDescriptor deprecated 

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

Deprecated: Use WorkloadmetaKind.Descriptor instead.

func (WorkloadmetaKind) Number 

func (x WorkloadmetaKind) Number() protoreflect.EnumNumber

func (WorkloadmetaKind) String 

func (x WorkloadmetaKind) String() string

func (WorkloadmetaKind) Type 

func (WorkloadmetaKind) Type() protoreflect.EnumType

type WorkloadmetaSource 

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

func (WorkloadmetaSource) Descriptor 

func (WorkloadmetaSource) Descriptor() protoreflect.EnumDescriptor

func (WorkloadmetaSource) Enum 

func (x WorkloadmetaSource) Enum() *WorkloadmetaSource

func (WorkloadmetaSource) EnumDescriptor deprecated 

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

Deprecated: Use WorkloadmetaSource.Descriptor instead.

func (WorkloadmetaSource) Number 

func (x WorkloadmetaSource) Number() protoreflect.EnumNumber

func (WorkloadmetaSource) String 

func (x WorkloadmetaSource) String() string

func (WorkloadmetaSource) Type 

func (WorkloadmetaSource) Type() protoreflect.EnumType

type WorkloadmetaStreamRequest 

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

func (*WorkloadmetaStreamRequest) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaStreamRequest.ProtoReflect.Descriptor instead.

func (*WorkloadmetaStreamRequest) GetFilter 

func (x *WorkloadmetaStreamRequest) GetFilter() *WorkloadmetaFilter

func (*WorkloadmetaStreamRequest) ProtoMessage 

func (*WorkloadmetaStreamRequest) ProtoMessage()

func (*WorkloadmetaStreamRequest) ProtoReflect 

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

func (*WorkloadmetaStreamRequest) Reset 

func (x *WorkloadmetaStreamRequest) Reset()

func (*WorkloadmetaStreamRequest) String 

func (x *WorkloadmetaStreamRequest) String() string

type WorkloadmetaStreamResponse 

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

func (*WorkloadmetaStreamResponse) Descriptor deprecated 

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

Deprecated: Use WorkloadmetaStreamResponse.ProtoReflect.Descriptor instead.

func (*WorkloadmetaStreamResponse) GetEvents 

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

func (*WorkloadmetaStreamResponse) ProtoMessage 

func (*WorkloadmetaStreamResponse) ProtoMessage()

func (*WorkloadmetaStreamResponse) ProtoReflect 

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

func (*WorkloadmetaStreamResponse) Reset 

func (x *WorkloadmetaStreamResponse) Reset()

func (*WorkloadmetaStreamResponse) String 

func (x *WorkloadmetaStreamResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package mock_pbgo is a generated GoMock package.
 Package mock_pbgo is a generated GoMock package.

Jump to

Keyboard shortcuts

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