Function NewClient

ethstorage/eth/polling_client.go:70–106

NewClient creates a client that uses the given RPC client.

(
	ctx context.Context,
	c *ethclient.Client,
	isHTTP bool,
	esContract common.Address,
	pollRate uint64,
	qh func() (*types.Header, error),
	lg log.Logger,
)

// NewClient creates a client that uses the given RPC client.
func NewClient(
	ctx context.Context,
	c *ethclient.Client,
	isHTTP bool,
	esContract common.Address,
	pollRate uint64,
	qh func() (*types.Header, error),
	lg log.Logger,
) *PollingClient {
	ctx, cancel := context.WithCancel(ctx)
	networkID, err := c.NetworkID(ctx)
	if err != nil {
		lg.Crit("Failed to get network id", "err", err)
	}
	res := &PollingClient{
		Client:     c,
		isHTTP:     isHTTP,
		lg:         lg,
		pollRate:   time.Duration(pollRate) * time.Second,
		ctx:        ctx,
		cancel:     cancel,
		esContract: esContract,
		pollReqCh:  make(chan struct{}, 1),
		subs:       make(map[int]chan *types.Header),
		closedCh:   make(chan struct{}),
		NetworkID:  networkID,
	}
	if qh == nil {
		res.queryHeader = res.getLatestHeader
	} else {
		res.queryHeader = qh
	}
	if isHTTP {
		go res.pollHeads()
	}
	return res
}

// Close closes the PollingClient and the underlying RPC client it talks to.
func (w *PollingClient) Close() {