grpc

Documentation

Overview

Package grpc provides a simple gRPC server that acts as a probe target.

Index

• type Server
  • func New(initCtx context.Context, c *configpb.ServerConf, l *logger.Logger) (*Server, error)
  • func (s *Server) Echo(ctx context.Context, req *spb.EchoMessage) (*spb.EchoMessage, error)
  • func (s *Server) ServerStatus(ctx context.Context, req *spb.StatusRequest) (*spb.StatusResponse, error)
  • func (s *Server) Start(ctx context.Context, dataChan chan<- *metrics.EventMetrics) error

Types

type Server

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

Server implements a gRPCServer.

func New

func New(initCtx context.Context, c *configpb.ServerConf, l *logger.Logger) (*Server, error)

New returns a Server.

func (*Server) Echo

func (s *Server) Echo(ctx context.Context, req *spb.EchoMessage) (*spb.EchoMessage, error)

Echo reflects back the incoming message.

func (*Server) ServerStatus

func (s *Server) ServerStatus(ctx context.Context, req *spb.StatusRequest) (*spb.StatusResponse, error)

ServerStatus returns the current server status.

func (*Server) Start

func (s *Server) Start(ctx context.Context, dataChan chan<- *metrics.EventMetrics) error

Start starts the gRPC server and serves requests until the context is canceled or the gRPC server panics.