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) BlobRead(ctx context.Context, req *spb.BlobReadRequest) (*spb.BlobReadResponse, error)
  • func (s *Server) BlobWrite(ctx context.Context, req *spb.BlobWriteRequest) (*spb.BlobWriteResponse, 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) BlobRead

func (s *Server) BlobRead(ctx context.Context, req *spb.BlobReadRequest) (*spb.BlobReadResponse, error)

BlobRead returns a blob of data.

func (*Server) BlobWrite

func (s *Server) BlobWrite(ctx context.Context, req *spb.BlobWriteRequest) (*spb.BlobWriteResponse, error)

BlobWrite returns the size of blob in the WriteRequest. It does not operate on the blob.

func (*Server) Echo

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

Echo reflects back the incoming message. TODO: return error if EchoMessage is greater than maxMsgSize.

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.