rdwr

Documentation

Index

• func ServerMaker() (*server.Server, jrpctest.ClientMaker, func())
• type Client
  • func NewClient(rd io.Reader, wr io.Writer) *Client
  • func (c *Client) Close() error
  • func (c *Client) Closed() <-chan struct{}
  • func (c *Client) Do(ctx context.Context, result any, method string, params any) error
  • func (c *Client) Mount(h jsonrpc.Middleware)
  • func (c *Client) Notify(ctx context.Context, method string, params any) error
  • func (c *Client) SetHandlerPeer(pi jsonrpc.PeerInfo)
  • func (c *Client) SetHeader(key string, value string)
• type Codec
  • func NewCodec(rd io.Reader, wr io.Writer) *Codec
  • func (c *Codec) Close() error
  • func (c *Codec) Closed() <-chan struct{}
  • func (c *Codec) Flush() error
  • func (c *Codec) PeerInfo() jsonrpc.PeerInfo
  • func (c *Codec) ReadBatch(ctx context.Context) ([]*jsonrpc.Message, bool, error)
  • func (c *Codec) RemoteAddr() string
  • func (c *Codec) Write(p []byte) (n int, err error)

Functions

func ServerMaker

func ServerMaker() (*server.Server, jrpctest.ClientMaker, func())

Types

type Client

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

func NewClient

func NewClient(rd io.Reader, wr io.Writer) *Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) Closed

func (c *Client) Closed() <-chan struct{}

func (*Client) Do

func (c *Client) Do(ctx context.Context, result any, method string, params any) error

func (*Client) Mount

func (c *Client) Mount(h jsonrpc.Middleware)

func (*Client) Notify

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

func (*Client) SetHandlerPeer

func (c *Client) SetHandlerPeer(pi jsonrpc.PeerInfo)

func (*Client) SetHeader

func (c *Client) SetHeader(key string, value string)

type Codec

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

func NewCodec

func NewCodec(rd io.Reader, wr io.Writer) *Codec

func (*Codec) Close

func (c *Codec) Close() error

closes the connection

func (*Codec) Closed

func (c *Codec) Closed() <-chan struct{}

Closed returns a channel which is closed when the connection is closed.

func (*Codec) Flush

func (c *Codec) Flush() error

func (*Codec) PeerInfo

func (c *Codec) PeerInfo() jsonrpc.PeerInfo

gets the peer info

func (*Codec) ReadBatch

func (c *Codec) ReadBatch(ctx context.Context) ([]*jsonrpc.Message, bool, error)

func (*Codec) RemoteAddr

func (c *Codec) RemoteAddr() string

RemoteAddr returns the peer address of the connection.

func (*Codec) Write

func (c *Codec) Write(p []byte) (n int, err error)