server

Documentation

Index

• func ContextWithPeerInfo(ctx context.Context, c codec.PeerInfo) context.Context
• func PeerInfoFromContext(ctx context.Context) codec.PeerInfo
• type Server
  • func NewServer(r codec.Handler) *Server
  • func (s *Server) ServeCodec(ctx context.Context, remote codec.ReaderWriter) error

Functions

func ContextWithPeerInfo

func ContextWithPeerInfo(ctx context.Context, c codec.PeerInfo) context.Context

func PeerInfoFromContext

func PeerInfoFromContext(ctx context.Context) codec.PeerInfo

PeerInfoFromContext returns information about the client's network connection. Use this with the context passed to RPC method handler functions.

The zero value is returned if no connection info is present in ctx.

Types

type Server

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

Server is an RPC server. it is in charge of calling the handler on the message object, the json encoding of responses, and dealing with batch semantics. a server can be used to listenandserve multiple codecs at a time

func NewServer

func NewServer(r codec.Handler) *Server

NewServer creates a new server instance with no registered handlers.

func (*Server) ServeCodec

func (s *Server) ServeCodec(ctx context.Context, remote codec.ReaderWriter) error

ServeCodec reads incoming requests from codec, calls the appropriate callback and writes the response back using the given codec. It will block until the codec is closed