headtracker

Jan 25, 2022

Changes in this version

type HeadSaver

+ func (ht *HeadSaver) LatestChain() *eth.Head

+ func (ht *HeadSaver) LoadFromDB(ctx context.Context) (chain *eth.Head, err error)

type HeadTracker

+ func (ht *HeadTracker) LatestChain() *eth.Head

+ func (ht *HeadTracker) SetLogLevel(lvl zapcore.Level)

type NullTracker

+ func (*NullTracker) SetLogLevel(zapcore.Level)

type ORM

+ func (orm *ORM) LatestHead(ctx context.Context) (head *eth.Head, err error)

+ func (orm *ORM) LatestHeads(ctx context.Context, limit int) (heads []*eth.Head, err error)

Oct 19, 2021

Changes in this version

+ const HeadsBufferSize

type Config

+ EvmFinalityDepth func() uint

+ EvmHeadTrackerHistoryDepth func() uint

+ EvmHeadTrackerMaxBufferSize func() uint

+ EvmHeadTrackerSamplingInterval func() time.Duration

Aug 9, 2021

Changes in this version

type Config

+ BlockEmissionIdleWarningThreshold func() time.Duration

+ EnableLegacyJobPipeline func() bool

type HeadTracker

+ func (ht *HeadTracker) Healthy() error

type NullTracker

+ func (*NullTracker) Healthy() error

+ func (*NullTracker) Ready() error

Jul 26, 2021

Changes in this version

type Config

+ EthFinalityDepth func() uint

+ EthHeadTrackerHistoryDepth func() uint

+ EthHeadTrackerSamplingInterval func() time.Duration

type HeadSaver

+ func (ht *HeadSaver) HeadByHash(ctx context.Context, hash common.Hash) (*models.Head, error)

+ type ORM struct

+ func NewORM(db *gorm.DB) *ORM

+ func (orm *ORM) Chain(ctx context.Context, hash common.Hash, lookback uint) (models.Head, error)

+ func (orm *ORM) HeadByHash(ctx context.Context, hash common.Hash) (*models.Head, error)

+ func (orm *ORM) IdempotentInsertHead(ctx context.Context, h models.Head) error

+ func (orm *ORM) LastHead(ctx context.Context) (*models.Head, error)

+ func (orm *ORM) TrimOldHeads(ctx context.Context, n uint) (err error)

Jun 21, 2021

Changes in this version

+ func NewHeadBroadcaster() httypes.HeadBroadcaster

+ type Config interface

+ ChainID func() *big.Int

+ EthHeadTrackerMaxBufferSize func() uint

+ EthereumURL func() string

+ type HeadListener struct

+ func NewHeadListener(l *logger.Logger, ethClient eth.Client, config Config, chStop chan struct{}, ...) *HeadListener

+ func (hl *HeadListener) Connected() bool

+ func (hl *HeadListener) ListenForNewHeads(handleNewHead func(ctx context.Context, header models.Head) error, ...)

+ func (hl *HeadListener) SetLogger(logger *logger.Logger)

+ type HeadSaver struct

+ func NewHeadSaver(store *strpkg.Store) *HeadSaver

+ func (ht *HeadSaver) Chain(ctx context.Context, hash common.Hash, depth uint) (models.Head, error)

+ func (ht *HeadSaver) HighestSeenHead() *models.Head

+ func (ht *HeadSaver) HighestSeenHeadFromDB() (*models.Head, error)

+ func (ht *HeadSaver) IdempotentInsertHead(ctx context.Context, head models.Head) error

+ func (ht *HeadSaver) Save(ctx context.Context, h models.Head) error

+ func (ht *HeadSaver) SetHighestSeenHeadFromDB() (*models.Head, error)

+ type HeadTracker struct

+ func NewHeadTracker(l *logger.Logger, store *strpkg.Store, headBroadcaster httypes.HeadBroadcaster, ...) *HeadTracker

+ func (ht *HeadTracker) Backfill(ctx context.Context, headWithChain models.Head, depth uint) (err error)

+ func (ht *HeadTracker) Chain(ctx context.Context, hash common.Hash, depth uint) (models.Head, error)

+ func (ht *HeadTracker) Connected() bool

+ func (ht *HeadTracker) HighestSeenHead() *models.Head

+ func (ht *HeadTracker) HighestSeenHeadFromDB() (*models.Head, error)

+ func (ht *HeadTracker) Save(ctx context.Context, h models.Head) error

+ func (ht *HeadTracker) SetLogger(logger *logger.Logger)

+ func (ht *HeadTracker) Start() error

+ func (ht *HeadTracker) Stop() error

+ type NullBroadcaster struct

+ func (*NullBroadcaster) Close() error

+ func (*NullBroadcaster) Connect(head *models.Head) error

+ func (*NullBroadcaster) OnNewLongestChain(ctx context.Context, head models.Head)

+ func (*NullBroadcaster) Start() error

+ func (*NullBroadcaster) Subscribe(callback httypes.HeadTrackable) (unsubscribe func())

+ func (n *NullBroadcaster) Healthy() error

+ func (n *NullBroadcaster) Ready() error

+ type NullTracker struct

+ func (*NullTracker) SetLogger(*logger.Logger)

+ func (*NullTracker) Start() error

+ func (*NullTracker) Stop() error

+ func (n *NullTracker) HighestSeenHeadFromDB() (*models.Head, error)