netutil

Documentation

Index

• func FatalIfUnexpected(err error)
• func IsClosedConnection(err error) bool
• func ListenAndServeGRPC(stopper *stop.Stopper, server *grpc.Server, addr net.Addr) (net.Listener, error)
• type Server
  • func MakeServer(stopper *stop.Stopper, tlsConfig *tls.Config, handler http.Handler) Server
  • func (s *Server) ServeWith(ctx context.Context, stopper *stop.Stopper, l net.Listener, ...) error

Functions

func FatalIfUnexpected

func FatalIfUnexpected(err error)

FatalIfUnexpected calls Log.Fatal(err) unless err is nil, cmux.ErrListenerClosed, or the net package's errClosed.

func IsClosedConnection

func IsClosedConnection(err error) bool

IsClosedConnection returns true if err is cmux.ErrListenerClosed, grpc.ErrServerStopped, io.EOF, or the net package's errClosed.

func ListenAndServeGRPC

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

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

Types

type Server

type Server struct {
	*http.Server
}

Server is a thin wrapper around http.Server. See MakeServer for more detail.

func MakeServer

func MakeServer(stopper *stop.Stopper, tlsConfig *tls.Config, handler http.Handler) Server

MakeServer constructs a Server that tracks active connections, closing them when signalled by stopper.

func (*Server) ServeWith

func (s *Server) ServeWith(
	ctx context.Context, stopper *stop.Stopper, l net.Listener, serveConn func(net.Conn),
) error

ServeWith accepts connections on ln and serves them using serveConn.