client

Feb 2, 2023

Changes in this version

+ type AsyncClient struct

+ Conn AsyncConnection

+ OnParseMessageError func(err error) error

+ OnUnknownResponse func(*pjrpc.Response) error

+ Results *AsyncResults

+ func NewAsyncClient(conn AsyncConnection) *AsyncClient

+ func (c *AsyncClient) Close() error

+ func (c *AsyncClient) Invoke(ctx context.Context, id, method string, params, result interface{}, ...) error

+ func (c *AsyncClient) Listen() error

+ type AsyncConnection interface

+ Close func() error

+ Read func(b []byte) (n int, err error)

+ Write func(b []byte) (n int, err error)

+ type AsyncResult chan *pjrpc.Response

+ type AsyncResults struct

+ func NewAsyncResults() *AsyncResults

+ func (r *AsyncResults) CreateResult(id string) AsyncResult

+ func (r *AsyncResults) DeleteResult(id string)

+ func (r *AsyncResults) SendResult(id string, resp *pjrpc.Response) bool

Jun 5, 2022

Changes in this version

+ type Client struct

+ HTTPClient HTTPDoer

+ Logger *log.Logger

+ Mods []Mod

+ URL string

+ func New(endpoint string, mods ...Mod) (*Client, error)

+ func (c *Client) Invoke(ctx context.Context, id, method string, params, result interface{}, ...) error

+ func (c *Client) SetLogger(w io.Writer)

+ type HTTPDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type Invoker interface

+ Invoke func(ctx context.Context, id, method string, params, result interface{}, ...) error

+ type Mod func(req *http.Request)

+ func ModWithBasicAuth(username, password string) Mod

+ func ModWithHeader(header, value string) Mod