head

Documentation

Index

• Constants
• type Contract
• type NoopSubs
  • func (self *NoopSubs) Err() <-chan error
  • func (self *NoopSubs) Unsubscribe()
• type TrackerHead
  • func New(ctx context.Context, logger log.Logger, client *ethclient.Client, ...) (*TrackerHead, chan *types.Block, error)
  • func (self *TrackerHead) Start() error
  • func (self *TrackerHead) Stop()

Constants

const (
	ComponentName = "trackerHead"
)

Types

type Contract

type Contract interface {
	NetID() int64
	Addr() common.Address
}

type NoopSubs

type NoopSubs struct{}

func (*NoopSubs) Err

func (self *NoopSubs) Err() <-chan error

func (*NoopSubs) Unsubscribe

func (self *NoopSubs) Unsubscribe()

type TrackerHead

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

func New

func New(
	ctx context.Context,
	logger log.Logger,
	client *ethclient.Client,
	reorgWaitPeriod time.Duration,
) (*TrackerHead, chan *types.Block, error)

func (*TrackerHead) Start

func (self *TrackerHead) Start() error

func (*TrackerHead) Stop

func (self *TrackerHead) Stop()