rpcwrap

Documentation

Overview

Package rpcwrap provides wrappers for rpcplus package

Index

• func DialHTTP(network, address, codecName string, cFactory ClientCodecFactory, ...) (*rpc.Client, error)
• func GetRpcPath(codecName string) string
• func ServeCustomRPC(handler *http.ServeMux, server *rpc.Server, codecName string, ...)
• func ServeHTTPRPC(handler *http.ServeMux, server *rpc.Server, codecName string, ...)
• func ServeRPC(codecName string, cFactory ServerCodecFactory)
• type BufferedConnection
  • func NewBufferedConnection(conn io.ReadWriteCloser) *BufferedConnection
  • func (bc *BufferedConnection) Close() error
• type ClientCodecFactory
• type ServerCodecFactory

Functions

func DialHTTP

func DialHTTP(network, address, codecName string, cFactory ClientCodecFactory, connectTimeout time.Duration) (*rpc.Client, error)

DialHTTP connects to a go HTTP RPC server using the specified codec. use 0 as connectTimeout for no timeout

func GetRpcPath

func GetRpcPath(codecName string) string

GetRpcPath returns the toplevel path used for serving RPCs over HTTP

func ServeCustomRPC

func ServeCustomRPC(handler *http.ServeMux, server *rpc.Server, codecName string, cFactory ServerCodecFactory)

ServeCustomRPC serves the given rpc requests with the provided ServeMux

func ServeHTTPRPC

func ServeHTTPRPC(
	handler *http.ServeMux,
	server *rpc.Server,
	codecName string,
	cFactory ServerCodecFactory,
	contextCreator func(*http.Request) context.Context)

ServeHTTPRPC serves the given http rpc requests with the provided ServeMux

func ServeRPC

func ServeRPC(codecName string, cFactory ServerCodecFactory)

ServeRPC handles rpc requests using the hijack scheme of rpc

Types

type BufferedConnection

type BufferedConnection struct {
	*bufio.Reader
	io.WriteCloser
	// contains filtered or unexported fields
}

BufferedConnection holds connection data for codecs

func NewBufferedConnection

func NewBufferedConnection(conn io.ReadWriteCloser) *BufferedConnection

NewBufferedConnection creates a new Buffered Connection

func (*BufferedConnection) Close

func (bc *BufferedConnection) Close() error

Close closes the buffered connection FIXME(sougou/szopa): Find a better way to track connection count.

type ClientCodecFactory

type ClientCodecFactory func(conn io.ReadWriteCloser) rpc.ClientCodec

ClientCodecFactory holds pattern for other client codec factories

type ServerCodecFactory

type ServerCodecFactory func(conn io.ReadWriteCloser) rpc.ServerCodec

ServerCodecFactory holds pattern for other server codec factories