client

Feb 28, 2024

Changes in this version

type Response

+ func (r *Response) CloseRead()

+ func (r *Response) CloseWrite()

Nov 8, 2023

Changes in this version

type Client

+ func (c *Client) SendToWithTimeout(pid peerCore.ID, cmd string, body command.Body, timeout time.Duration) (cr.Response, error)

+ func (c *Client) SendWithTimeout(cmd string, body command.Body, timeout time.Duration) (cr.Response, error)

type Response

+ func (r *Response) Error() error

Sep 12, 2023

Changes in this version

+ var MaxStreamsPerSend = 16

type Client

+ func (c *Client) New(cmd string, opts ...Option) *Request

+ type Option func(r *Request) error

+ func Body(body command.Body) Option

+ func Threshold(threshold int) Option

+ func Timeout(timeout time.Duration) Option

+ func To(peers ...peerCore.ID) Option

+ type Request struct

+ func (r *Request) Do() (<-chan *Response, error)

+ type Response struct

+ func (r *Response) Close()

+ func (r *Response) PID() peerCore.ID

Jul 18, 2023

Changes in this version

+ var DiscoveryLimit int = 1024

+ var EstablishStreamTimeout time.Duration = 5 * time.Second

+ var NumConnectTries int = 3

+ var NumStreamers int = 3

+ var RecvTimeout time.Duration = 3 * time.Second

+ var SendTimeout time.Duration = 3 * time.Second

+ var SendToPeerTimeout time.Duration = 10 * time.Second

+ type Client struct

+ func New(ctx context.Context, node *peer.Node, peers []string, path string, min int, ...) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Context() context.Context

+ func (c *Client) Send(cmdName string, body command.Body) (cr.Response, error)

+ func (c *Client) SendForPid(cmdName string, body command.Body) (peerCore.ID, cr.Response, error)

+ func (c *Client) SendTo(cid cid.Cid, cmdName string, body command.Body) (cr.Response, error)

+ func (c *Client) TrySend(cmdName string, body command.Body) (cr.Response, error)