pbgo

package
v0.0.0-...-7983b3b Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 15 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",
}
View Source 
var EventType_value = map[string]int32{
	"ADDED":    0,
	"MODIFIED": 1,
	"DELETED":  2,
}
View Source 
var Product_name = map[int32]string{
	0: "NO_PRODUCT",
	1: "LIVE_DEBUGGING",
	2: "APPSEC",
	3: "RUNTIME_SECURITY",
	4: "APM_SAMPLING",
	5: "TESTING1",
	6: "TESTING2",
}
View Source 
var Product_value = map[string]int32{
	"NO_PRODUCT":       0,
	"LIVE_DEBUGGING":   1,
	"APPSEC":           2,
	"RUNTIME_SECURITY": 3,
	"APM_SAMPLING":     4,
	"TESTING1":         5,
	"TESTING2":         6,
}
View Source 
var TagCardinality_name = map[int32]string{
	0: "LOW",
	1: "ORCHESTRATOR",
	2: "HIGH",
}
View Source 
var TagCardinality_value = map[string]int32{
	"LOW":          0,
	"ORCHESTRATOR": 1,
	"HIGH":         2,
}

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)

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.ClientConn) 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)
	GetConfigUpdates(ctx context.Context, in *SubscribeConfigRequest, opts ...grpc.CallOption) (AgentSecure_GetConfigUpdatesClient, error)
	// Fetch config of the given product
	GetConfigs(ctx context.Context, in *GetConfigsRequest, opts ...grpc.CallOption) (*GetConfigsResponse, 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.ClientConn) 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)
	GetConfigUpdates(*SubscribeConfigRequest, AgentSecure_GetConfigUpdatesServer) error
	// Fetch config of the given product
	GetConfigs(context.Context, *GetConfigsRequest) (*GetConfigsResponse, error)
}

AgentSecureServer is the server API for AgentSecure service.

type AgentSecure_GetConfigUpdatesClient 

type AgentSecure_GetConfigUpdatesClient interface {
	Recv() (*ConfigResponse, error)
	grpc.ClientStream
}

type AgentSecure_GetConfigUpdatesServer 

type AgentSecure_GetConfigUpdatesServer interface {
	Send(*ConfigResponse) error
	grpc.ServerStream
}

type AgentSecure_TaggerStreamEntitiesClient 

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

type AgentSecure_TaggerStreamEntitiesServer 

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

type 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Dogstatsd capture types

func (*CaptureTriggerRequest) Descriptor 

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

func (*CaptureTriggerRequest) GetCompressed 

func (m *CaptureTriggerRequest) GetCompressed() bool

func (*CaptureTriggerRequest) GetDuration 

func (m *CaptureTriggerRequest) GetDuration() string

func (*CaptureTriggerRequest) GetPath 

func (m *CaptureTriggerRequest) GetPath() string

func (*CaptureTriggerRequest) ProtoMessage 

func (*CaptureTriggerRequest) ProtoMessage()

func (*CaptureTriggerRequest) Reset 

func (m *CaptureTriggerRequest) Reset()

func (*CaptureTriggerRequest) String 

func (m *CaptureTriggerRequest) String() string

func (*CaptureTriggerRequest) XXX_DiscardUnknown 

func (m *CaptureTriggerRequest) XXX_DiscardUnknown()

func (*CaptureTriggerRequest) XXX_Marshal 

func (m *CaptureTriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CaptureTriggerRequest) XXX_Merge 

func (m *CaptureTriggerRequest) XXX_Merge(src proto.Message)

func (*CaptureTriggerRequest) XXX_Size 

func (m *CaptureTriggerRequest) XXX_Size() int

func (*CaptureTriggerRequest) XXX_Unmarshal 

func (m *CaptureTriggerRequest) XXX_Unmarshal(b []byte) error

type CaptureTriggerResponse 

type CaptureTriggerResponse struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CaptureTriggerResponse) Descriptor 

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

func (*CaptureTriggerResponse) GetPath 

func (m *CaptureTriggerResponse) GetPath() string

func (*CaptureTriggerResponse) ProtoMessage 

func (*CaptureTriggerResponse) ProtoMessage()

func (*CaptureTriggerResponse) Reset 

func (m *CaptureTriggerResponse) Reset()

func (*CaptureTriggerResponse) String 

func (m *CaptureTriggerResponse) String() string

func (*CaptureTriggerResponse) XXX_DiscardUnknown 

func (m *CaptureTriggerResponse) XXX_DiscardUnknown()

func (*CaptureTriggerResponse) XXX_Marshal 

func (m *CaptureTriggerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CaptureTriggerResponse) XXX_Merge 

func (m *CaptureTriggerResponse) XXX_Merge(src proto.Message)

func (*CaptureTriggerResponse) XXX_Size 

func (m *CaptureTriggerResponse) XXX_Size() int

func (*CaptureTriggerResponse) XXX_Unmarshal 

func (m *CaptureTriggerResponse) XXX_Unmarshal(b []byte) error

type ClientLatestConfigsRequest 

type ClientLatestConfigsRequest 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                     []Product `protobuf:"varint,4,rep,packed,name=products,proto3,enum=datadog.config.Product" json:"products,omitempty"`
	NewProducts                  []Product `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral         struct{}  `json:"-"`
	XXX_unrecognized             []byte    `json:"-"`
	XXX_sizecache                int32     `json:"-"`
}

func (*ClientLatestConfigsRequest) DecodeMsg 

func (z *ClientLatestConfigsRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*ClientLatestConfigsRequest) Descriptor 

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

func (*ClientLatestConfigsRequest) EncodeMsg 

func (z *ClientLatestConfigsRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*ClientLatestConfigsRequest) GetAgentVersion 

func (m *ClientLatestConfigsRequest) GetAgentVersion() string

func (*ClientLatestConfigsRequest) GetCurrentConfigRootVersion 

func (m *ClientLatestConfigsRequest) GetCurrentConfigRootVersion() uint64

func (*ClientLatestConfigsRequest) GetCurrentConfigSnapshotVersion 

func (m *ClientLatestConfigsRequest) GetCurrentConfigSnapshotVersion() uint64

func (*ClientLatestConfigsRequest) GetCurrentDirectorRootVersion 

func (m *ClientLatestConfigsRequest) GetCurrentDirectorRootVersion() uint64

func (*ClientLatestConfigsRequest) GetHostname 

func (m *ClientLatestConfigsRequest) GetHostname() string

func (*ClientLatestConfigsRequest) GetNewProducts 

func (m *ClientLatestConfigsRequest) GetNewProducts() []Product

func (*ClientLatestConfigsRequest) GetProducts 

func (m *ClientLatestConfigsRequest) GetProducts() []Product

func (*ClientLatestConfigsRequest) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ClientLatestConfigsRequest) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*ClientLatestConfigsRequest) ProtoMessage 

func (*ClientLatestConfigsRequest) ProtoMessage()

func (*ClientLatestConfigsRequest) Reset 

func (m *ClientLatestConfigsRequest) Reset()

func (*ClientLatestConfigsRequest) String 

func (m *ClientLatestConfigsRequest) String() string

func (*ClientLatestConfigsRequest) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientLatestConfigsRequest) XXX_DiscardUnknown 

func (m *ClientLatestConfigsRequest) XXX_DiscardUnknown()

func (*ClientLatestConfigsRequest) XXX_Marshal 

func (m *ClientLatestConfigsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientLatestConfigsRequest) XXX_Merge 

func (m *ClientLatestConfigsRequest) XXX_Merge(src proto.Message)

func (*ClientLatestConfigsRequest) XXX_Size 

func (m *ClientLatestConfigsRequest) XXX_Size() int

func (*ClientLatestConfigsRequest) XXX_Unmarshal 

func (m *ClientLatestConfigsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ConfigMetas) DecodeMsg 

func (z *ConfigMetas) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*ConfigMetas) Descriptor 

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

func (*ConfigMetas) EncodeMsg 

func (z *ConfigMetas) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*ConfigMetas) GetDelegatedTargets 

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

func (*ConfigMetas) GetRoots 

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

func (*ConfigMetas) GetSnapshot 

func (m *ConfigMetas) GetSnapshot() *TopMeta

func (*ConfigMetas) GetTimestamp 

func (m *ConfigMetas) GetTimestamp() *TopMeta

func (*ConfigMetas) GetTopTargets 

func (m *ConfigMetas) GetTopTargets() *TopMeta

func (*ConfigMetas) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ConfigMetas) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*ConfigMetas) ProtoMessage 

func (*ConfigMetas) ProtoMessage()

func (*ConfigMetas) Reset 

func (m *ConfigMetas) Reset()

func (*ConfigMetas) String 

func (m *ConfigMetas) String() string

func (*ConfigMetas) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ConfigMetas) XXX_DiscardUnknown 

func (m *ConfigMetas) XXX_DiscardUnknown()

func (*ConfigMetas) XXX_Marshal 

func (m *ConfigMetas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigMetas) XXX_Merge 

func (m *ConfigMetas) XXX_Merge(src proto.Message)

func (*ConfigMetas) XXX_Size 

func (m *ConfigMetas) XXX_Size() int

func (*ConfigMetas) XXX_Unmarshal 

func (m *ConfigMetas) XXX_Unmarshal(b []byte) error

type ConfigResponse 

type ConfigResponse struct {
	ConfigSnapshotVersion        uint64     `` /* 127-byte string literal not displayed */
	ConfigDelegatedTargetVersion uint64     `` /* 150-byte string literal not displayed */
	DirectoryRoots               []*TopMeta `protobuf:"bytes,3,rep,name=directoryRoots,proto3" json:"directoryRoots,omitempty"`
	DirectoryTargets             *TopMeta   `protobuf:"bytes,4,opt,name=directoryTargets,proto3" json:"directoryTargets,omitempty"`
	TargetFiles                  []*File    `protobuf:"bytes,5,rep,name=target_files,json=targetFiles,proto3" json:"target_files,omitempty"`
	XXX_NoUnkeyedLiteral         struct{}   `json:"-"`
	XXX_unrecognized             []byte     `json:"-"`
	XXX_sizecache                int32      `json:"-"`
}

func (*ConfigResponse) DecodeMsg 

func (z *ConfigResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*ConfigResponse) Descriptor 

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

func (*ConfigResponse) EncodeMsg 

func (z *ConfigResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*ConfigResponse) GetConfigDelegatedTargetVersion 

func (m *ConfigResponse) GetConfigDelegatedTargetVersion() uint64

func (*ConfigResponse) GetConfigSnapshotVersion 

func (m *ConfigResponse) GetConfigSnapshotVersion() uint64

func (*ConfigResponse) GetDirectoryRoots 

func (m *ConfigResponse) GetDirectoryRoots() []*TopMeta

func (*ConfigResponse) GetDirectoryTargets 

func (m *ConfigResponse) GetDirectoryTargets() *TopMeta

func (*ConfigResponse) GetTargetFiles 

func (m *ConfigResponse) GetTargetFiles() []*File

func (*ConfigResponse) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ConfigResponse) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (m *ConfigResponse) String() string

func (*ConfigResponse) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigResponse) XXX_Merge 

func (m *ConfigResponse) XXX_Merge(src proto.Message)

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

func (m *ConfigResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelegatedMeta) DecodeMsg 

func (z *DelegatedMeta) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*DelegatedMeta) Descriptor 

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

func (*DelegatedMeta) EncodeMsg 

func (z *DelegatedMeta) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*DelegatedMeta) GetRaw 

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

func (*DelegatedMeta) GetRole 

func (m *DelegatedMeta) GetRole() string

func (*DelegatedMeta) GetVersion 

func (m *DelegatedMeta) GetVersion() uint64

func (*DelegatedMeta) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*DelegatedMeta) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*DelegatedMeta) ProtoMessage 

func (*DelegatedMeta) ProtoMessage()

func (*DelegatedMeta) Reset 

func (m *DelegatedMeta) Reset()

func (*DelegatedMeta) String 

func (m *DelegatedMeta) String() string

func (*DelegatedMeta) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*DelegatedMeta) XXX_DiscardUnknown 

func (m *DelegatedMeta) XXX_DiscardUnknown()

func (*DelegatedMeta) XXX_Marshal 

func (m *DelegatedMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelegatedMeta) XXX_Merge 

func (m *DelegatedMeta) XXX_Merge(src proto.Message)

func (*DelegatedMeta) XXX_Size 

func (m *DelegatedMeta) XXX_Size() int

func (*DelegatedMeta) XXX_Unmarshal 

func (m *DelegatedMeta) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DirectorMetas) DecodeMsg 

func (z *DirectorMetas) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*DirectorMetas) Descriptor 

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

func (*DirectorMetas) EncodeMsg 

func (z *DirectorMetas) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*DirectorMetas) GetRoots 

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

func (*DirectorMetas) GetSnapshot 

func (m *DirectorMetas) GetSnapshot() *TopMeta

func (*DirectorMetas) GetTargets 

func (m *DirectorMetas) GetTargets() *TopMeta

func (*DirectorMetas) GetTimestamp 

func (m *DirectorMetas) GetTimestamp() *TopMeta

func (*DirectorMetas) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*DirectorMetas) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*DirectorMetas) ProtoMessage 

func (*DirectorMetas) ProtoMessage()

func (*DirectorMetas) Reset 

func (m *DirectorMetas) Reset()

func (*DirectorMetas) String 

func (m *DirectorMetas) String() string

func (*DirectorMetas) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*DirectorMetas) XXX_DiscardUnknown 

func (m *DirectorMetas) XXX_DiscardUnknown()

func (*DirectorMetas) XXX_Marshal 

func (m *DirectorMetas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DirectorMetas) XXX_Merge 

func (m *DirectorMetas) XXX_Merge(src proto.Message)

func (*DirectorMetas) XXX_Size 

func (m *DirectorMetas) XXX_Size() int

func (*DirectorMetas) XXX_Unmarshal 

func (m *DirectorMetas) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral        struct{}  `json:"-"`
	XXX_unrecognized            []byte    `json:"-"`
	XXX_sizecache               int32     `json:"-"`
}

func (*Entity) Descriptor 

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

func (*Entity) GetHash 

func (m *Entity) GetHash() string

func (*Entity) GetHighCardinalityTags 

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

func (*Entity) GetId 

func (m *Entity) GetId() *EntityId

func (*Entity) GetLowCardinalityTags 

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

func (*Entity) GetOrchestratorCardinalityTags 

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

func (*Entity) GetStandardTags 

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

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge 

func (m *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

func (m *Entity) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EntityId) Descriptor 

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

func (*EntityId) GetPrefix 

func (m *EntityId) GetPrefix() string

func (*EntityId) GetUid 

func (m *EntityId) GetUid() string

func (*EntityId) ProtoMessage 

func (*EntityId) ProtoMessage()

func (*EntityId) Reset 

func (m *EntityId) Reset()

func (*EntityId) String 

func (m *EntityId) String() string

func (*EntityId) XXX_DiscardUnknown 

func (m *EntityId) XXX_DiscardUnknown()

func (*EntityId) XXX_Marshal 

func (m *EntityId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EntityId) XXX_Merge 

func (m *EntityId) XXX_Merge(src proto.Message)

func (*EntityId) XXX_Size 

func (m *EntityId) XXX_Size() int

func (*EntityId) XXX_Unmarshal 

func (m *EntityId) XXX_Unmarshal(b []byte) error

type EventType 

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

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*FetchEntityRequest) Descriptor 

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

func (*FetchEntityRequest) GetCardinality 

func (m *FetchEntityRequest) GetCardinality() TagCardinality

func (*FetchEntityRequest) GetId 

func (m *FetchEntityRequest) GetId() *EntityId

func (*FetchEntityRequest) ProtoMessage 

func (*FetchEntityRequest) ProtoMessage()

func (*FetchEntityRequest) Reset 

func (m *FetchEntityRequest) Reset()

func (*FetchEntityRequest) String 

func (m *FetchEntityRequest) String() string

func (*FetchEntityRequest) XXX_DiscardUnknown 

func (m *FetchEntityRequest) XXX_DiscardUnknown()

func (*FetchEntityRequest) XXX_Marshal 

func (m *FetchEntityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchEntityRequest) XXX_Merge 

func (m *FetchEntityRequest) XXX_Merge(src proto.Message)

func (*FetchEntityRequest) XXX_Size 

func (m *FetchEntityRequest) XXX_Size() int

func (*FetchEntityRequest) XXX_Unmarshal 

func (m *FetchEntityRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*FetchEntityResponse) Descriptor 

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

func (*FetchEntityResponse) GetCardinality 

func (m *FetchEntityResponse) GetCardinality() TagCardinality

func (*FetchEntityResponse) GetId 

func (m *FetchEntityResponse) GetId() *EntityId

func (*FetchEntityResponse) GetTags 

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

func (*FetchEntityResponse) ProtoMessage 

func (*FetchEntityResponse) ProtoMessage()

func (*FetchEntityResponse) Reset 

func (m *FetchEntityResponse) Reset()

func (*FetchEntityResponse) String 

func (m *FetchEntityResponse) String() string

func (*FetchEntityResponse) XXX_DiscardUnknown 

func (m *FetchEntityResponse) XXX_DiscardUnknown()

func (*FetchEntityResponse) XXX_Marshal 

func (m *FetchEntityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchEntityResponse) XXX_Merge 

func (m *FetchEntityResponse) XXX_Merge(src proto.Message)

func (*FetchEntityResponse) XXX_Size 

func (m *FetchEntityResponse) XXX_Size() int

func (*FetchEntityResponse) XXX_Unmarshal 

func (m *FetchEntityResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*File) DecodeMsg 

func (z *File) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*File) Descriptor 

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

func (*File) EncodeMsg 

func (z *File) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*File) GetPath 

func (m *File) GetPath() string

func (*File) GetRaw 

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

func (*File) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*File) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) String 

func (m *File) String() string

func (*File) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*File) XXX_DiscardUnknown 

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal 

func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*File) XXX_Merge 

func (m *File) XXX_Merge(src proto.Message)

func (*File) XXX_Size 

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal 

func (m *File) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetContainerName 

func (m *Filter) GetContainerName() string

func (*Filter) GetImage 

func (m *Filter) GetImage() string

func (*Filter) GetKubeNamespace 

func (m *Filter) GetKubeNamespace() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

type GetConfigsRequest 

type GetConfigsRequest struct {
	Product                     Product  `protobuf:"varint,1,opt,name=product,proto3,enum=datadog.config.Product" json:"product,omitempty"`
	CurrentConfigProductVersion uint64   `` /* 147-byte string literal not displayed */
	CurrentDirectorRootVersion  uint64   `` /* 144-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

func (*GetConfigsRequest) DecodeMsg 

func (z *GetConfigsRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*GetConfigsRequest) Descriptor 

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

func (*GetConfigsRequest) EncodeMsg 

func (z *GetConfigsRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*GetConfigsRequest) GetCurrentConfigProductVersion 

func (m *GetConfigsRequest) GetCurrentConfigProductVersion() uint64

func (*GetConfigsRequest) GetCurrentDirectorRootVersion 

func (m *GetConfigsRequest) GetCurrentDirectorRootVersion() uint64

func (*GetConfigsRequest) GetProduct 

func (m *GetConfigsRequest) GetProduct() Product

func (*GetConfigsRequest) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*GetConfigsRequest) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GetConfigsRequest) ProtoMessage 

func (*GetConfigsRequest) ProtoMessage()

func (*GetConfigsRequest) Reset 

func (m *GetConfigsRequest) Reset()

func (*GetConfigsRequest) String 

func (m *GetConfigsRequest) String() string

func (*GetConfigsRequest) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*GetConfigsRequest) XXX_DiscardUnknown 

func (m *GetConfigsRequest) XXX_DiscardUnknown()

func (*GetConfigsRequest) XXX_Marshal 

func (m *GetConfigsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigsRequest) XXX_Merge 

func (m *GetConfigsRequest) XXX_Merge(src proto.Message)

func (*GetConfigsRequest) XXX_Size 

func (m *GetConfigsRequest) XXX_Size() int

func (*GetConfigsRequest) XXX_Unmarshal 

func (m *GetConfigsRequest) XXX_Unmarshal(b []byte) error

type GetConfigsResponse 

type GetConfigsResponse struct {
	ConfigResponses      []*ConfigResponse `protobuf:"bytes,1,rep,name=configResponses,proto3" json:"configResponses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetConfigsResponse) DecodeMsg 

func (z *GetConfigsResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*GetConfigsResponse) Descriptor 

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

func (*GetConfigsResponse) EncodeMsg 

func (z *GetConfigsResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*GetConfigsResponse) GetConfigResponses 

func (m *GetConfigsResponse) GetConfigResponses() []*ConfigResponse

func (*GetConfigsResponse) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*GetConfigsResponse) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GetConfigsResponse) ProtoMessage 

func (*GetConfigsResponse) ProtoMessage()

func (*GetConfigsResponse) Reset 

func (m *GetConfigsResponse) Reset()

func (*GetConfigsResponse) String 

func (m *GetConfigsResponse) String() string

func (*GetConfigsResponse) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*GetConfigsResponse) XXX_DiscardUnknown 

func (m *GetConfigsResponse) XXX_DiscardUnknown()

func (*GetConfigsResponse) XXX_Marshal 

func (m *GetConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigsResponse) XXX_Merge 

func (m *GetConfigsResponse) XXX_Merge(src proto.Message)

func (*GetConfigsResponse) XXX_Size 

func (m *GetConfigsResponse) XXX_Size() int

func (*GetConfigsResponse) XXX_Unmarshal 

func (m *GetConfigsResponse) XXX_Unmarshal(b []byte) error

type HostnameReply 

type HostnameReply struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the requested hostname

func (*HostnameReply) Descriptor 

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

func (*HostnameReply) GetHostname 

func (m *HostnameReply) GetHostname() string

func (*HostnameReply) ProtoMessage 

func (*HostnameReply) ProtoMessage()

func (*HostnameReply) Reset 

func (m *HostnameReply) Reset()

func (*HostnameReply) String 

func (m *HostnameReply) String() string

func (*HostnameReply) XXX_DiscardUnknown 

func (m *HostnameReply) XXX_DiscardUnknown()

func (*HostnameReply) XXX_Marshal 

func (m *HostnameReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostnameReply) XXX_Merge 

func (m *HostnameReply) XXX_Merge(src proto.Message)

func (*HostnameReply) XXX_Size 

func (m *HostnameReply) XXX_Size() int

func (*HostnameReply) XXX_Unmarshal 

func (m *HostnameReply) XXX_Unmarshal(b []byte) error

type HostnameRequest 

type HostnameRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HostnameRequest) Descriptor 

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

func (*HostnameRequest) ProtoMessage 

func (*HostnameRequest) ProtoMessage()

func (*HostnameRequest) Reset 

func (m *HostnameRequest) Reset()

func (*HostnameRequest) String 

func (m *HostnameRequest) String() string

func (*HostnameRequest) XXX_DiscardUnknown 

func (m *HostnameRequest) XXX_DiscardUnknown()

func (*HostnameRequest) XXX_Marshal 

func (m *HostnameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostnameRequest) XXX_Merge 

func (m *HostnameRequest) XXX_Merge(src proto.Message)

func (*HostnameRequest) XXX_Size 

func (m *HostnameRequest) XXX_Size() int

func (*HostnameRequest) XXX_Unmarshal 

func (m *HostnameRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*LatestConfigsResponse) DecodeMsg 

func (z *LatestConfigsResponse) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*LatestConfigsResponse) Descriptor 

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

func (*LatestConfigsResponse) EncodeMsg 

func (z *LatestConfigsResponse) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*LatestConfigsResponse) GetConfigMetas 

func (m *LatestConfigsResponse) GetConfigMetas() *ConfigMetas

func (*LatestConfigsResponse) GetDirectorMetas 

func (m *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas

func (*LatestConfigsResponse) GetTargetFiles 

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

func (*LatestConfigsResponse) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*LatestConfigsResponse) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*LatestConfigsResponse) ProtoMessage 

func (*LatestConfigsResponse) ProtoMessage()

func (*LatestConfigsResponse) Reset 

func (m *LatestConfigsResponse) Reset()

func (*LatestConfigsResponse) String 

func (m *LatestConfigsResponse) String() string

func (*LatestConfigsResponse) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*LatestConfigsResponse) XXX_DiscardUnknown 

func (m *LatestConfigsResponse) XXX_DiscardUnknown()

func (*LatestConfigsResponse) XXX_Marshal 

func (m *LatestConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LatestConfigsResponse) XXX_Merge 

func (m *LatestConfigsResponse) XXX_Merge(src proto.Message)

func (*LatestConfigsResponse) XXX_Size 

func (m *LatestConfigsResponse) XXX_Size() int

func (*LatestConfigsResponse) XXX_Unmarshal 

func (m *LatestConfigsResponse) XXX_Unmarshal(b []byte) error

type ProcessStatRequest 

type ProcessStatRequest struct {
	Pids                 []int32  `protobuf:"varint,1,rep,packed,name=pids,proto3" json:"pids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProcessStatRequest is the request to get process stats.

func (*ProcessStatRequest) Descriptor 

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

func (*ProcessStatRequest) GetPids 

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

func (*ProcessStatRequest) ProtoMessage 

func (*ProcessStatRequest) ProtoMessage()

func (*ProcessStatRequest) Reset 

func (m *ProcessStatRequest) Reset()

func (*ProcessStatRequest) String 

func (m *ProcessStatRequest) String() string

func (*ProcessStatRequest) XXX_DiscardUnknown 

func (m *ProcessStatRequest) XXX_DiscardUnknown()

func (*ProcessStatRequest) XXX_Marshal 

func (m *ProcessStatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessStatRequest) XXX_Merge 

func (m *ProcessStatRequest) XXX_Merge(src proto.Message)

func (*ProcessStatRequest) XXX_Size 

func (m *ProcessStatRequest) XXX_Size() int

func (*ProcessStatRequest) XXX_Unmarshal 

func (m *ProcessStatRequest) XXX_Unmarshal(b []byte) error

type Product 

type Product int32
const (
	Product_NO_PRODUCT       Product = 0
	Product_LIVE_DEBUGGING   Product = 1
	Product_APPSEC           Product = 2
	Product_RUNTIME_SECURITY Product = 3
	Product_APM_SAMPLING     Product = 4
	Product_TESTING1         Product = 5
	Product_TESTING2         Product = 6
)

func (*Product) DecodeMsg 

func (z *Product) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (Product) EncodeMsg 

func (z Product) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (Product) EnumDescriptor 

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

func (Product) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (Product) Msgsize 

func (z Product) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (Product) String 

func (x Product) String() string

func (*Product) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StreamTagsEvent) Descriptor 

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

func (*StreamTagsEvent) GetEntity 

func (m *StreamTagsEvent) GetEntity() *Entity

func (*StreamTagsEvent) GetType 

func (m *StreamTagsEvent) GetType() EventType

func (*StreamTagsEvent) ProtoMessage 

func (*StreamTagsEvent) ProtoMessage()

func (*StreamTagsEvent) Reset 

func (m *StreamTagsEvent) Reset()

func (*StreamTagsEvent) String 

func (m *StreamTagsEvent) String() string

func (*StreamTagsEvent) XXX_DiscardUnknown 

func (m *StreamTagsEvent) XXX_DiscardUnknown()

func (*StreamTagsEvent) XXX_Marshal 

func (m *StreamTagsEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTagsEvent) XXX_Merge 

func (m *StreamTagsEvent) XXX_Merge(src proto.Message)

func (*StreamTagsEvent) XXX_Size 

func (m *StreamTagsEvent) XXX_Size() int

func (*StreamTagsEvent) XXX_Unmarshal 

func (m *StreamTagsEvent) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StreamTagsRequest) Descriptor 

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

func (*StreamTagsRequest) GetCardinality 

func (m *StreamTagsRequest) GetCardinality() TagCardinality

func (*StreamTagsRequest) GetExcludeFilter 

func (m *StreamTagsRequest) GetExcludeFilter() *Filter

func (*StreamTagsRequest) GetIncludeFilter 

func (m *StreamTagsRequest) GetIncludeFilter() *Filter

func (*StreamTagsRequest) ProtoMessage 

func (*StreamTagsRequest) ProtoMessage()

func (*StreamTagsRequest) Reset 

func (m *StreamTagsRequest) Reset()

func (*StreamTagsRequest) String 

func (m *StreamTagsRequest) String() string

func (*StreamTagsRequest) XXX_DiscardUnknown 

func (m *StreamTagsRequest) XXX_DiscardUnknown()

func (*StreamTagsRequest) XXX_Marshal 

func (m *StreamTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTagsRequest) XXX_Merge 

func (m *StreamTagsRequest) XXX_Merge(src proto.Message)

func (*StreamTagsRequest) XXX_Size 

func (m *StreamTagsRequest) XXX_Size() int

func (*StreamTagsRequest) XXX_Unmarshal 

func (m *StreamTagsRequest) XXX_Unmarshal(b []byte) error

type StreamTagsResponse 

type StreamTagsResponse struct {
	Events               []*StreamTagsEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*StreamTagsResponse) Descriptor 

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

func (*StreamTagsResponse) GetEvents 

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

func (*StreamTagsResponse) ProtoMessage 

func (*StreamTagsResponse) ProtoMessage()

func (*StreamTagsResponse) Reset 

func (m *StreamTagsResponse) Reset()

func (*StreamTagsResponse) String 

func (m *StreamTagsResponse) String() string

func (*StreamTagsResponse) XXX_DiscardUnknown 

func (m *StreamTagsResponse) XXX_DiscardUnknown()

func (*StreamTagsResponse) XXX_Marshal 

func (m *StreamTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTagsResponse) XXX_Merge 

func (m *StreamTagsResponse) XXX_Merge(src proto.Message)

func (*StreamTagsResponse) XXX_Size 

func (m *StreamTagsResponse) XXX_Size() int

func (*StreamTagsResponse) XXX_Unmarshal 

func (m *StreamTagsResponse) XXX_Unmarshal(b []byte) error

type SubscribeConfigRequest 

type SubscribeConfigRequest struct {
	CurrentConfigSnapshotVersion uint64   `` /* 150-byte string literal not displayed */
	Product                      Product  `protobuf:"varint,2,opt,name=product,proto3,enum=datadog.config.Product" json:"product,omitempty"`
	XXX_NoUnkeyedLiteral         struct{} `json:"-"`
	XXX_unrecognized             []byte   `json:"-"`
	XXX_sizecache                int32    `json:"-"`
}

func (*SubscribeConfigRequest) DecodeMsg 

func (z *SubscribeConfigRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*SubscribeConfigRequest) Descriptor 

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

func (*SubscribeConfigRequest) EncodeMsg 

func (z *SubscribeConfigRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*SubscribeConfigRequest) GetCurrentConfigSnapshotVersion 

func (m *SubscribeConfigRequest) GetCurrentConfigSnapshotVersion() uint64

func (*SubscribeConfigRequest) GetProduct 

func (m *SubscribeConfigRequest) GetProduct() Product

func (*SubscribeConfigRequest) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*SubscribeConfigRequest) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SubscribeConfigRequest) ProtoMessage 

func (*SubscribeConfigRequest) ProtoMessage()

func (*SubscribeConfigRequest) Reset 

func (m *SubscribeConfigRequest) Reset()

func (*SubscribeConfigRequest) String 

func (m *SubscribeConfigRequest) String() string

func (*SubscribeConfigRequest) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*SubscribeConfigRequest) XXX_DiscardUnknown 

func (m *SubscribeConfigRequest) XXX_DiscardUnknown()

func (*SubscribeConfigRequest) XXX_Marshal 

func (m *SubscribeConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeConfigRequest) XXX_Merge 

func (m *SubscribeConfigRequest) XXX_Merge(src proto.Message)

func (*SubscribeConfigRequest) XXX_Size 

func (m *SubscribeConfigRequest) XXX_Size() int

func (*SubscribeConfigRequest) XXX_Unmarshal 

func (m *SubscribeConfigRequest) XXX_Unmarshal(b []byte) error

type TagCardinality 

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

func (TagCardinality) EnumDescriptor 

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

func (TagCardinality) String 

func (x TagCardinality) String() string

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 */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TaggerState) Descriptor 

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

func (*TaggerState) GetPidMap 

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

func (*TaggerState) GetState 

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

func (*TaggerState) ProtoMessage 

func (*TaggerState) ProtoMessage()

func (*TaggerState) Reset 

func (m *TaggerState) Reset()

func (*TaggerState) String 

func (m *TaggerState) String() string

func (*TaggerState) XXX_DiscardUnknown 

func (m *TaggerState) XXX_DiscardUnknown()

func (*TaggerState) XXX_Marshal 

func (m *TaggerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaggerState) XXX_Merge 

func (m *TaggerState) XXX_Merge(src proto.Message)

func (*TaggerState) XXX_Size 

func (m *TaggerState) XXX_Size() int

func (*TaggerState) XXX_Unmarshal 

func (m *TaggerState) XXX_Unmarshal(b []byte) error

type TaggerStateResponse 

type TaggerStateResponse struct {
	Loaded               bool     `protobuf:"varint,1,opt,name=loaded,proto3" json:"loaded,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaggerStateResponse) Descriptor 

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

func (*TaggerStateResponse) GetLoaded 

func (m *TaggerStateResponse) GetLoaded() bool

func (*TaggerStateResponse) ProtoMessage 

func (*TaggerStateResponse) ProtoMessage()

func (*TaggerStateResponse) Reset 

func (m *TaggerStateResponse) Reset()

func (*TaggerStateResponse) String 

func (m *TaggerStateResponse) String() string

func (*TaggerStateResponse) XXX_DiscardUnknown 

func (m *TaggerStateResponse) XXX_DiscardUnknown()

func (*TaggerStateResponse) XXX_Marshal 

func (m *TaggerStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaggerStateResponse) XXX_Merge 

func (m *TaggerStateResponse) XXX_Merge(src proto.Message)

func (*TaggerStateResponse) XXX_Size 

func (m *TaggerStateResponse) XXX_Size() int

func (*TaggerStateResponse) XXX_Unmarshal 

func (m *TaggerStateResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopMeta) DecodeMsg 

func (z *TopMeta) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*TopMeta) Descriptor 

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

func (*TopMeta) EncodeMsg 

func (z *TopMeta) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*TopMeta) GetRaw 

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

func (*TopMeta) GetVersion 

func (m *TopMeta) GetVersion() uint64

func (*TopMeta) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*TopMeta) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*TopMeta) ProtoMessage 

func (*TopMeta) ProtoMessage()

func (*TopMeta) Reset 

func (m *TopMeta) Reset()

func (*TopMeta) String 

func (m *TopMeta) String() string

func (*TopMeta) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*TopMeta) XXX_DiscardUnknown 

func (m *TopMeta) XXX_DiscardUnknown()

func (*TopMeta) XXX_Marshal 

func (m *TopMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopMeta) XXX_Merge 

func (m *TopMeta) XXX_Merge(src proto.Message)

func (*TopMeta) XXX_Size 

func (m *TopMeta) XXX_Size() int

func (*TopMeta) XXX_Unmarshal 

func (m *TopMeta) XXX_Unmarshal(b []byte) error

type UnimplementedAgentSecureServer 

type UnimplementedAgentSecureServer struct {
}

UnimplementedAgentSecureServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger 

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

func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState 

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

func (*UnimplementedAgentSecureServer) GetConfigUpdates 

func (*UnimplementedAgentSecureServer) GetConfigUpdates(req *SubscribeConfigRequest, srv AgentSecure_GetConfigUpdatesServer) error

func (*UnimplementedAgentSecureServer) GetConfigs 

func (*UnimplementedAgentSecureServer) GetConfigs(ctx context.Context, req *GetConfigsRequest) (*GetConfigsResponse, error)

func (*UnimplementedAgentSecureServer) TaggerFetchEntity 

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

func (*UnimplementedAgentSecureServer) TaggerStreamEntities 

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

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetHostname 

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

type UnixDogstatsdMsg 

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

UDS Capture The message contains the payload and the ancillary info

func (*UnixDogstatsdMsg) Descriptor 

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

func (*UnixDogstatsdMsg) GetAncillary 

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

func (*UnixDogstatsdMsg) GetAncillarySize 

func (m *UnixDogstatsdMsg) GetAncillarySize() int32

func (*UnixDogstatsdMsg) GetPayload 

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

func (*UnixDogstatsdMsg) GetPayloadSize 

func (m *UnixDogstatsdMsg) GetPayloadSize() int32

func (*UnixDogstatsdMsg) GetPid 

func (m *UnixDogstatsdMsg) GetPid() int32

func (*UnixDogstatsdMsg) GetTimestamp 

func (m *UnixDogstatsdMsg) GetTimestamp() int64

func (*UnixDogstatsdMsg) ProtoMessage 

func (*UnixDogstatsdMsg) ProtoMessage()

func (*UnixDogstatsdMsg) Reset 

func (m *UnixDogstatsdMsg) Reset()

func (*UnixDogstatsdMsg) String 

func (m *UnixDogstatsdMsg) String() string

func (*UnixDogstatsdMsg) XXX_DiscardUnknown 

func (m *UnixDogstatsdMsg) XXX_DiscardUnknown()

func (*UnixDogstatsdMsg) XXX_Marshal 

func (m *UnixDogstatsdMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnixDogstatsdMsg) XXX_Merge 

func (m *UnixDogstatsdMsg) XXX_Merge(src proto.Message)

func (*UnixDogstatsdMsg) XXX_Size 

func (m *UnixDogstatsdMsg) XXX_Size() int

func (*UnixDogstatsdMsg) XXX_Unmarshal 

func (m *UnixDogstatsdMsg) XXX_Unmarshal(b []byte) error

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.