Versions in this module Expand all Collapse all v0 v0.0.1 Jul 30, 2020 Changes in this version + type Client struct + func NewClient(net Network) *Client + func (c *Client) HandleProviderResponse(msg []byte) + func (c *Client) HandleProviderStream(s network.Stream) + func (c *Client) Start() error + func (c *Client) Stop() error + func (c *Client) SubmitQuery(ctx context.Context, params shared.Params) error + func (c *Client) SubscribeToQueryResponses(subscriber ClientSubscriber, params shared.Params) Unsubscribe + type ClientSubscriber func(resp shared.QueryResponse) + type Network interface + MultiAddrs func() []string + Publish func(ctx context.Context, msg []byte) error + RegisterStreamHandler func(id core.ProtocolID, handler network.StreamHandler) + Start func() error + Stop func() error + type Unsubscribe func()