rpc

package

v0.0.0-...-4cbcc9d Latest Latest Go to latest Published: Apr 15, 2024 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func StartServer(addr string, codec jsonrpc2.ObjectCodec, h jsonrpc2.Handler) error

type Client struct {
	*jsonrpc2.Conn
}

func (c *Client) Call(method string, payload any, result any) error

func (c *Client) Handle(ctx context.Context, conn *jsonrpc2.Conn, req *jsonrpc2.Request)

func (c *Client) Notify(method string, payload any) error

type CustomStream struct {
	io.ReadCloser
	io.WriteCloser
}

func (conn *CustomStream) Close() error

func (conn *CustomStream) Read(p []byte) (n int, err error)

func (conn *CustomStream) Write(p []byte) (n int, err error)

type HandlerFunc func(context.Context, *jsonrpc2.Conn, *jsonrpc2.Request)

func (h HandlerFunc) Handle(ctx context.Context, c *jsonrpc2.Conn, r *jsonrpc2.Request)