grpc

Documentation

Index

• Constants
• type Option
  • func WithGracePeriod(t time.Duration) Option
  • func WithListen(s string) Option
  • func WithNetwork(s string) Option
  • func WithTLSConfig(cfg *tls.Config) Option
• type ReadWriteStoreServer
• type Server
  • func New(logger log.Logger, reg prometheus.Registerer, tracer opentracing.Tracer, ...) *Server
  • func NewReadWrite(logger log.Logger, reg prometheus.Registerer, tracer opentracing.Tracer, ...) *Server
  • func (s *Server) ListenAndServe() error
  • func (s *Server) Shutdown(err error)

Constants

const UnixSocket = "/tmp/test.sock"

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option overrides behavior of Server.

func WithGracePeriod

func WithGracePeriod(t time.Duration) Option

WithGracePeriod sets shutdown grace period for gRPC server. Server waits connections to drain for specified amount of time.

func WithListen

func WithListen(s string) Option

WithListen sets address to listen for gRPC server. Server accepts incoming connections on given address.

func WithNetwork

func WithNetwork(s string) Option

WithNetwork sets network to listen for gRPC server e.g tcp, udp or unix.

func WithTLSConfig

func WithTLSConfig(cfg *tls.Config) Option

WithTLSConfig sets TLS configuration for gRPC server.

type ReadWriteStoreServer

type ReadWriteStoreServer interface {
	storepb.StoreServer
	storepb.WriteableStoreServer
}

ReadWriteStoreServer is a StoreServer and a WriteableStoreServer.

type Server

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

A Server defines parameters to serve RPC requests, a wrapper around grpc.Server.

func New

func New(logger log.Logger, reg prometheus.Registerer, tracer opentracing.Tracer, comp component.Component, probe *prober.GRPCProbe, storeSrv storepb.StoreServer, opts ...Option) *Server

New creates a new Server.

func NewReadWrite

func NewReadWrite(logger log.Logger, reg prometheus.Registerer, tracer opentracing.Tracer, comp component.Component, probe *prober.GRPCProbe, storeSrv ReadWriteStoreServer, opts ...Option) *Server

NewReadWrite creates a new server that can be written to.

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

ListenAndServe listens on the TCP network address and handles requests on incoming connections.

func (*Server) Shutdown

func (s *Server) Shutdown(err error)

Shutdown gracefully shuts down the server by waiting, for specified amount of time (by gracePeriod) for connections to return to idle and then shut down.