client

Documentation

Overview

Client is used by watchers to stream chain IPLD data from a vulcanizedb ipld-eth-server

Index

• type Client
  • func NewClient(c *rpc.Client) *Client
  • func (c *Client) Stream(payloadChan chan serve.SubscriptionPayload, params eth.SubscriptionSettings) (*rpc.ClientSubscription, error)

Types

type Client

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

Client is used to subscribe to the ipld-eth-server ipld data stream

func NewClient

func NewClient(c *rpc.Client) *Client

NewClient creates a new Client

func (*Client) Stream

func (c *Client) Stream(payloadChan chan serve.SubscriptionPayload, params eth.SubscriptionSettings) (*rpc.ClientSubscription, error)

Stream is the main loop for subscribing to iplds from an ipld-eth-server server