server

Documentation

Index

• type Server
  • func New(storage storage.Storage, count <-chan int) *Server
  • func (srv Server) CollectorID(ctx context.Context, req *api.CollectorIDRequest) (*api.CollectorIDReply, error)
  • func (srv *Server) Run()

Types

type Server

type Server struct {
	*health.Server
	Storage storage.Storage
	// contains filtered or unexported fields
}

Server represents the gRPC server responsible for handling collector ID requests.

func New

func New(storage storage.Storage, count <-chan int) *Server

New instantiates and returns a Server.

func (Server) CollectorID

func (srv Server) CollectorID(ctx context.Context, req *api.CollectorIDRequest) (*api.CollectorIDReply, error)

CollectorID implements api.CollectorSetControllerServer. It returns the next collector ID to use.

func (*Server) Run

func (srv *Server) Run()

Run starts the gRPC server.