grpcsrv

Documentation

Index

• type T
  • func New(addr string, proxySet *proxy.Set) (*T, error)
  • func (s *T) Consume(ctx context.Context, req *pb.ConsReq) (*pb.ConsRes, error)
  • func (s *T) ErrorCh() <-chan error
  • func (s *T) Produce(ctx context.Context, req *pb.ProdReq) (*pb.ProdRes, error)
  • func (s *T) Start()
  • func (s *T) Stop()

Types

type T

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

func New

func New(addr string, proxySet *proxy.Set) (*T, error)

New creates a gRPC server instance.

func (*T) Consume

func (s *T) Consume(ctx context.Context, req *pb.ConsReq) (*pb.ConsRes, error)

Consume implements pb.KafkaPixyServer

func (*T) ErrorCh

func (s *T) ErrorCh() <-chan error

ErrorCh returns an output channel that HTTP server running in another goroutine will use if it stops with error if one occurs. The channel will be closed when the server is fully stopped due to an error or otherwise..

func (*T) Produce

func (s *T) Produce(ctx context.Context, req *pb.ProdReq) (*pb.ProdRes, error)

Produce implements pb.KafkaPixyServer

func (*T) Start

func (s *T) Start()

Starts triggers asynchronous gRPC server start. If it fails then the error will be sent down to `ErrorCh()`.

func (*T) Stop

func (s *T) Stop()

Stop gracefully stops the gRPC server. It stops listening on the socket for incoming requests first, and then blocks waiting for pending requests to complete.