muxserver

Documentation

Index

• type Server
  • func New(handler drpc.Handler) *Server
  • func NewWithOptions(handler drpc.Handler, opts drpcserver.Options) *Server
  • func (s *Server) Serve(ctx context.Context, ln net.Listener) error
  • func (s *Server) ServeOne(ctx context.Context, conn io.ReadWriteCloser) error

Types

type Server

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

Server is a DRPC server that handles multiplexed streams

func New

func New(handler drpc.Handler) *Server

New returns a new multiplexed Server that serves handler

func NewWithOptions

func NewWithOptions(handler drpc.Handler, opts drpcserver.Options) *Server

NewWithOptions is the same as New but passes options to DRPC

func (*Server) Serve

func (s *Server) Serve(ctx context.Context, ln net.Listener) error

Serve listens on the given listener and handles all multiplexed streams.

func (*Server) ServeOne

func (s *Server) ServeOne(ctx context.Context, conn io.ReadWriteCloser) error

ServeOne serves a single set of rpcs on the provided transport.