pb

package
v0.0.2-0...-4ce78c8 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

README

gRPC: Protobuf and Gateway code generation

To generate the code for the API you have defined in your .proto files we will need three different grpc-related packages:

  • protobuf - protoc-gen-go: generates the golang protobuf definitions.
  • grpc-gateway - protoc-gen-grpc-gateway: generates the gRPC-REST gateway
  • grpc-gateway - protoc-gen-swagger (optional)

Install

Run the following:

go install github.com/grpc-ecosystem/grpc-gateway/protoc-gen-grpc-gateway github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger github.com/golang/protobuf/protoc-gen-go

This should drop all required binaries in your $GOPATH/bin

Remember to make sure GOPATH/bin is in your PATH, also make sure no other versions of those binaries you may have installed elsewhere take precedence (which is your friend).

Code Generation

Chdir yourself into this directory (cmd/agent/api/pb), and run the following commands:

protoc -I. --go_out=plugins=grpc,paths=source_relative:. api.proto
protoc -I. --grpc-gateway_out=logtostderr=true,paths=source_relative:. api.proto

Those two will generate the protobuf golang definitions and the gRPC gateway code that will allow us to serve the API also as a REST application.

Compiling the Agent

Remember to make sure your gRPC go dependencies are current for the agent by running:

inv -e deps

The grpc deps are defined here and are tracked by gomod.

Note/ToDo

At the time of this writing we had been using the dev branch for all the grpc projects we pull binaries for when we install as we had been experiencing some issues with prior versions (ie. 1.12.2).

This should probably be formally addressed such that the versions of the packages tracked by gomod is the same we pull for the binaries. This should be part of the bootstrapping steps.

Documentation

Overview

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

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

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 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=pb.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=pb.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 StreamTagsEvent 

type StreamTagsEvent struct {
	Type                 EventType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.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=pb.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 UnimplementedAgentSecureServer 

type UnimplementedAgentSecureServer struct {
}

UnimplementedAgentSecureServer can be embedded to have forward compatible implementations.

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)

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks 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.