grpcutil

Documentation

Index

• func GRPCHandlerFunc(grpcServer *grpc.Server, otherHandler http.Handler) http.Handler
• func IsClosedConnection(err error) bool
• func ListenAndServeGRPC(stopper *stop.Stopper, server *grpc.Server, addr net.Addr, config *tls.Config) (net.Listener, error)
• func NewContextWithStopper(base context.Context, stopper *stop.Stopper) context.Context

Functions

func GRPCHandlerFunc

func GRPCHandlerFunc(grpcServer *grpc.Server, otherHandler http.Handler) http.Handler

GRPCHandlerFunc returns an http.Handler that delegates to grpcServer on incoming gRPC connections or otherHandler otherwise.

func IsClosedConnection

func IsClosedConnection(err error) bool

IsClosedConnection returns true if err is an error produced by gRPC on closed connections.

func ListenAndServeGRPC

func ListenAndServeGRPC(stopper *stop.Stopper, server *grpc.Server, addr net.Addr, config *tls.Config) (net.Listener, error)

ListenAndServeGRPC creates a listener and serves server on it, closing the listener when signalled by the stopper.

func NewContextWithStopper

func NewContextWithStopper(base context.Context, stopper *stop.Stopper) context.Context

NewContextWithStopper returns a context whose Done() channel is closed when base's Done() channel is closed or when stopper's ShouldStop() channel is closed, whichever is first.