server

Documentation

Overview

Package server implements a gRPC server that streams Tagger entities.

Index

• type Server
  • func NewServer(t tagger.Component) *Server
  • func (s *Server) TaggerFetchEntity(ctx context.Context, in *pb.FetchEntityRequest) (*pb.FetchEntityResponse, error)
  • func (s *Server) TaggerStreamEntities(in *pb.StreamTagsRequest, out pb.AgentSecure_TaggerStreamEntitiesServer) error

Types

type Server

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

Server is a grpc server that streams tagger entities

func NewServer

func NewServer(t tagger.Component) *Server

NewServer returns a new Server

func (*Server) TaggerFetchEntity

func (s *Server) TaggerFetchEntity(ctx context.Context, in *pb.FetchEntityRequest) (*pb.FetchEntityResponse, error)

TaggerFetchEntity fetches an entity from the Tagger with the desired cardinality tags.

func (*Server) TaggerStreamEntities

func (s *Server) TaggerStreamEntities(in *pb.StreamTagsRequest, out pb.AgentSecure_TaggerStreamEntitiesServer) error

TaggerStreamEntities subscribes to added, removed, or changed entities in the Tagger and streams them to clients as pb.StreamTagsResponse events. Filtering is as of yet not implemented.