jsonrpc

Documentation

Index

• func ReadMessage(r *bufio.Reader) ([]byte, error)
• func WriteMessage(w io.Writer, body []byte) error
• type Client
  • func NewClient(stdin io.WriteCloser, stdout io.Reader, stderr io.Reader, ...) *Client
  • func (c *Client) Call(ctx context.Context, method string, params any) (json.RawMessage, error)
  • func (c *Client) Close()
  • func (c *Client) IsClosed() bool
  • func (c *Client) Notify(method string, params any) error
  • func (c *Client) Start()
• type ResponseError
  • func (e *ResponseError) Error() string

Functions

func ReadMessage

func ReadMessage(r *bufio.Reader) ([]byte, error)

func WriteMessage

func WriteMessage(w io.Writer, body []byte) error

Types

type Client

type Client struct {
	OnNotify func(method string, params json.RawMessage)
	// contains filtered or unexported fields
}

func NewClient

func NewClient(stdin io.WriteCloser, stdout io.Reader, stderr io.Reader, onNotify func(string, json.RawMessage)) *Client

func (*Client) Call

func (c *Client) Call(ctx context.Context, method string, params any) (json.RawMessage, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) IsClosed

func (c *Client) IsClosed() bool

func (*Client) Notify

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

func (*Client) Start

func (c *Client) Start()

type ResponseError

type ResponseError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

func (*ResponseError) Error

func (e *ResponseError) Error() string