rpc

type API ¶

type API struct {
	// namespace of service
	Namespace string
	// api version
	Version string
	// the service methods holder
	Service interface{}
	// indication if the methods must be considered safe for public use
	Public bool
}

API is a collection of methods for the RPC interface.

type BatchArg ¶

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

BatchArg is a param for internal RPC JSONRPC2.Batch.

type Client ¶

type Client struct {
	*rpc.Client
	// contains filtered or unexported fields
}

Client represents a JSON RPC 2.0 Client. There may be multiple outstanding Calls associated with a single Client, and a Client may be used by multiple goroutines simultaneously.

It also provides all methods of net/rpc Client.

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

func NewClient(conn io.ReadWriteCloser) *Client

func NewClientWithCodec(codec rpc.ClientCodec) *Client

func (c Client) Notify(serviceMethod string, args interface{}) error

type Error ¶

type Error struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

Error represent JSON-RPC 2.0 "Error object".

func NewError(code int, message string) *Error

func ServerError(rpcerr error) *Error

func (e *Error) Error() string

type HTTPServer ¶

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

HTTPServer represents a HTTP RPC server

func NewHTTPServer(whitehosts []string, corsList []string) (*HTTPServer, *hostFilter)

func (server *HTTPServer) GetRPCServer() *rpc.Server

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

type JSONRPC2 ¶

type JSONRPC2 struct{}

JSONRPC2 is an internal RPC service used to process batch requests.

func (JSONRPC2) Batch(arg BatchArg, replies *[]*json.RawMessage) (err error)

type Server ¶

type Server struct {
	rpc.Server
}

Server represents a RPC server

func NewServer() *Server

type WebsocketServerConn ¶

type WebsocketServerConn struct {
	Ws *websocket.Conn
	// contains filtered or unexported fields
}

WebsocketServerConn represents a websocket server connection

func (wc *WebsocketServerConn) Close() (err error)

func (wc *WebsocketServerConn) Read(p []byte) (n int, err error)

func (wc *WebsocketServerConn) Write(p []byte) (n int, err error)

type WsRPCServer ¶

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

WsRPCServer represents a Websocket RPC server

func NewWsRPCServer() *WsRPCServer

func (server *WsRPCServer) GetWsRPCServer() *rpc.Server

func (server *WsRPCServer) ServeWS(w http.ResponseWriter, r *http.Request)