server

package
v2.0.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2020 License: MPL-2.0 Imports: 11 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL