cprpc

Apr 11, 2021

Changes in this version

type Options

+ CodecFunc func(io.ReadWriteCloser) ClientCodec

Nov 21, 2019

Changes in this version

type Server — darwin/amd64, js/wasm

+ func (server *Server) Serve(lis net.Listener) error

Nov 21, 2019

Changes in this version

+ const DefaultDebugPath

+ const DefaultRPCPath

+ var DefaultServer = NewServer()

+ var ErrServerClosed = errors.New("cprpc: Server closed")

+ var ErrShutdown = errors.New("connection is shut down")

+ func HandleHTTP()

+ func Serve(lis net.Listener) error

+ func ServeCodec(codec ServerCodec)

+ func ServeConn(conn io.ReadWriteCloser)

+ func ServeRequest(codec ServerCodec) error

+ func Shutdown(ctx context.Context) error

+ type API interface

+ Serve func(*Context)

+ type Call struct

+ Args interface{}

+ Done chan *Call

+ Error error

+ Path string

+ Reply interface{}

+ type Client struct

+ func Dial(network, address string) (*Client, error)

+ func DialHTTP(network, address string) (*Client, error)

+ func DialHTTPPath(network, address, path string) (*Client, error)

+ func NewClient(conn io.ReadWriteCloser) *Client

+ func NewClientWithCodec(codec ClientCodec) *Client

+ func (client *Client) Call(path string, args interface{}, reply interface{}) error

+ func (client *Client) Close() error

+ func (client *Client) Go(path string, args interface{}, reply interface{}, done chan *Call) *Call

+ type ClientCodec interface

+ Close func() error

+ ReadResponseBody func(interface{}) error

+ ReadResponseHeader func(*Response) error

+ WriteRequest func(*Request, interface{}) error

+ type Codec struct

+ Closer io.ReadWriteCloser

+ Decoder *gob.Decoder

+ EncBuf *bufio.Writer

+ Encoder *gob.Encoder

+ Timeout time.Duration

+ func (c *Codec) Close() error

+ func (c *Codec) ReadResponseBody(body interface{}) error

+ func (c *Codec) ReadResponseHeader(r *Response) error

+ func (c *Codec) WriteRequest(r *Request, body interface{}) (err error)

+ type Context struct

+ func (ctx *Context) ReplyOk(ret interface{})

+ type Options struct

+ DialTimeout time.Duration

+ IdleTimeout time.Duration

+ InitCap int

+ InitTargets []string

+ MaxCap int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func NewOptions() *Options

+ func (o *Options) Input() chan<- *[]string

+ type RPCPool struct

+ IdleTimeout time.Duration

+ Mu sync.Mutex

+ func NewRPCPool(o *Options) (*RPCPool, error)

+ func (c *RPCPool) Call(path string, args interface{}, reply interface{}) error

+ func (c *RPCPool) Close()

+ func (c *RPCPool) Go(path string, args interface{}, reply interface{}, done chan *Call) (*Call, error)

+ type Request struct

+ Path string

+ Seq uint64

+ type Response struct

+ Error string

+ Path string

+ Seq uint64

+ type Server struct

+ func NewServer() *Server

+ func (server *Server) Close() error

+ func (server *Server) HandleHTTP(rpcPath, debugPath string)

+ func (server *Server) RegisterAPI(path string, api API)

+ func (server *Server) Serve(lis net.Listener) error

+ func (server *Server) ServeCodec(codec ServerCodec)

+ func (server *Server) ServeConn(conn io.ReadWriteCloser)

+ func (server *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (server *Server) ServeRequest(codec ServerCodec) error

+ func (server *Server) Shutdown(ctx context.Context) error

+ type ServerCodec interface

+ Close func() error

+ GetRwc func() io.ReadWriteCloser

+ ReadRequestBody func(interface{}) error

+ ReadRequestHeader func(*Request) error

+ WriteResponse func(*Response, interface{}) error

+ type ServerError string

+ func (e ServerError) Error() string