pbgo

package
v0.0.0-...-551a65d Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2021 License: Apache-2.0 Imports: 14 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 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)
}

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

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

func (*CaptureTriggerRequest) Descriptor 

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

func (*CaptureTriggerRequest) GetDuration 

func (m *CaptureTriggerRequest) GetDuration() 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 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 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 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 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 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 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 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) 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.