client

Mar 26, 2020

Changes in this version

+ var PrintMsgExecFunc = func(msg *pb.PubSubResponse)

+ type Client struct

+ func NewClient(opts Opts, dialOpts ...grpc.DialOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) ConnectToPeer(ctx context.Context, multiaddr string) error

+ func (c *Client) Connected(ctx context.Context, peer string) (bool, error)

+ func (c *Client) DisconnectFromPeer(ctx context.Context, id string) error

+ func (c *Client) DownloadFile(ctx context.Context, download *pb.DownloadRequest, printProgress bool, ...) (*bytes.Buffer, error)

+ func (c *Client) GetPeerCount(ctx context.Context) (int, error)

+ func (c *Client) PSGetTopics(ctx context.Context) ([]string, error)

+ func (c *Client) PSListPeers(ctx context.Context, topics ...string) ([]*pb.PubSubPeer, error)

+ func (c *Client) PSPublish(ctx context.Context, topic string, data []byte) error

+ func (c *Client) PSSubscribe(ctx context.Context, topic string, discover bool, ...) error

+ func (c *Client) UploadFile(ctx context.Context, file io.Reader, fileSize int64, opts *pb.UploadOptions, ...) (*pb.PutResponse, error)

+ type Opts struct

+ Insecure bool

+ ListenAddress string