client

Documentation

Index

• type Client
  • func New(self plan.PeerID, useUnixSock bool) *Client
  • func (c *Client) GetEgressRates(addrs []plan.NetAddr) []float64
  • func (c *Client) Ping(target plan.PeerID) (time.Duration, error)
  • func (c *Client) ResetConnections(keeps plan.PeerList, token uint32)
  • func (c *Client) Send(a plan.Addr, buf []byte, t connection.ConnType, flags uint32) error
  • func (c *Client) Wait(ctx context.Context, target plan.PeerID) (int, bool)

Types

type Client

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

func New

func New(self plan.PeerID, useUnixSock bool) *Client

func (*Client) GetEgressRates

func (c *Client) GetEgressRates(addrs []plan.NetAddr) []float64

func (*Client) Ping

func (c *Client) Ping(target plan.PeerID) (time.Duration, error)

func (*Client) ResetConnections

func (c *Client) ResetConnections(keeps plan.PeerList, token uint32)

func (*Client) Send

func (c *Client) Send(a plan.Addr, buf []byte, t connection.ConnType, flags uint32) error

Send sends data in buf to given Addr

func (*Client) Wait

func (c *Client) Wait(ctx context.Context, target plan.PeerID) (int, bool)

Wait waits a peer until it's accessible