types

type HeadBroadcaster interface {
	service.Service
	HeadTrackable
	Subscribe(callback HeadTrackable) (currentLongestChain *eth.Head, unsubscribe func())
}

type HeadBroadcasterRegistry interface {
	Subscribe(callback HeadTrackable) (currentLongestChain *eth.Head, unsubscribe func())
}

type HeadTrackable interface {
	OnNewLongestChain(ctx context.Context, head eth.Head)
}

type SubscribeFunc func(callback HeadTrackable) (unsubscribe func())

type Tracker interface {
	HighestSeenHeadFromDB(context.Context) (*eth.Head, error)
	Start() error
	Stop() error
	SetLogLevel(lvl zapcore.Level)
	Ready() error
	Healthy() error
}