client

Documentation

Index

• Variables
• type Client
  • 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)

Variables

var (
	NumConnectTries        int           = 3
	NumStreamers           int           = 3
	DiscoveryLimit         int           = 1024
	SendTimeout            time.Duration = 3 * time.Second
	RecvTimeout            time.Duration = 3 * time.Second
	EstablishStreamTimeout time.Duration = 5 * time.Second
	SendToPeerTimeout      time.Duration = 10 * time.Second
)

Types

type Client

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

func New

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

func (*Client) Close

func (c *Client) Close()

func (*Client) Context

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

func (*Client) Send

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

func (*Client) SendForPid

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

func (*Client) SendTo

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

func (*Client) TrySend

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

this command will only fail with a timeout error or out of peers