rpcwrap

package
v2.0.0-alpha3+incompat... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 3, 2015 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Overview

Package rpcwrap provides wrappers for rpcplus package

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis
Package bsonrpc provides codecs for bsonrpc communication
Package bsonrpc provides codecs for bsonrpc communication
Package jsonrpc provides wrappers for json rpc communication
Package jsonrpc provides wrappers for json rpc communication
Package proto provides protocol functions
Package proto provides protocol functions

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL