Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func New ¶
func New(tracker *bestblock.Tracker, lag int64, metrics *metrics.Provider, config Config) (*Manager, error)
New instantiates a new task manager and also takes care of the redis connection management it subscribes to the best block tracker for new blocks which it'll add to the redis queue automatically
func (*Manager) FeedToChan ¶
FeedToChan continuously executes blocking pops from the redis queue and sends the resulting task on the provided channel Highest blocks have priority
Click to show internal directories.
Click to hide internal directories.