client

Documentation

Index

• type Client
  • func NewClient(target string, opts ...grpc.DialOption) (*Client, error)
  • func (c *Client) AddRecord(ctx context.Context, id thread.ID, lid peer.ID, rec core.Record, ...) error
  • func (c *Client) AddReplicator(ctx context.Context, id thread.ID, paddr ma.Multiaddr, ...) (pid peer.ID, err error)
  • func (c *Client) AddThread(ctx context.Context, addr ma.Multiaddr, opts ...core.NewThreadOption) (info thread.Info, err error)
  • func (c *Client) Close() error
  • func (c *Client) CreateRecord(ctx context.Context, id thread.ID, body format.Node, opts ...core.ThreadOption) (core.ThreadRecord, error)
  • func (c *Client) CreateThread(ctx context.Context, id thread.ID, opts ...core.NewThreadOption) (info thread.Info, err error)
  • func (c *Client) DeleteThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) error
  • func (c *Client) GetHostID(ctx context.Context) (peer.ID, error)
  • func (c *Client) GetRecord(ctx context.Context, id thread.ID, rid cid.Cid, opts ...core.ThreadOption) (core.Record, error)
  • func (c *Client) GetThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) (info thread.Info, err error)
  • func (c *Client) GetToken(ctx context.Context, identity thread.Identity) (tok thread.Token, err error)
  • func (c *Client) PullThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) error
  • func (c *Client) Subscribe(ctx context.Context, opts ...core.SubOption) (<-chan core.ThreadRecord, error)

Types

type Client

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

Client provides the client api.

func NewClient

func NewClient(target string, opts ...grpc.DialOption) (*Client, error)

NewClient starts the client.

func (*Client) AddRecord

func (c *Client) AddRecord(ctx context.Context, id thread.ID, lid peer.ID, rec core.Record, opts ...core.ThreadOption) error

func (*Client) AddReplicator

func (c *Client) AddReplicator(ctx context.Context, id thread.ID, paddr ma.Multiaddr, opts ...core.ThreadOption) (pid peer.ID, err error)

func (*Client) AddThread

func (c *Client) AddThread(ctx context.Context, addr ma.Multiaddr, opts ...core.NewThreadOption) (info thread.Info, err error)

func (*Client) Close

func (c *Client) Close() error

Close closes the client's grpc connection and cancels any active requests.

func (*Client) CreateRecord

func (c *Client) CreateRecord(ctx context.Context, id thread.ID, body format.Node, opts ...core.ThreadOption) (core.ThreadRecord, error)

func (*Client) CreateThread

func (c *Client) CreateThread(ctx context.Context, id thread.ID, opts ...core.NewThreadOption) (info thread.Info, err error)

func (*Client) DeleteThread

func (c *Client) DeleteThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) error

func (*Client) GetHostID

func (c *Client) GetHostID(ctx context.Context) (peer.ID, error)

func (*Client) GetRecord

func (c *Client) GetRecord(ctx context.Context, id thread.ID, rid cid.Cid, opts ...core.ThreadOption) (core.Record, error)

func (*Client) GetThread

func (c *Client) GetThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) (info thread.Info, err error)

func (*Client) GetToken

func (c *Client) GetToken(ctx context.Context, identity thread.Identity) (tok thread.Token, err error)

func (*Client) PullThread

func (c *Client) PullThread(ctx context.Context, id thread.ID, opts ...core.ThreadOption) error

func (*Client) Subscribe

func (c *Client) Subscribe(ctx context.Context, opts ...core.SubOption) (<-chan core.ThreadRecord, error)