taskmanager

Documentation

Index

• type Config
• type Manager
  • func New(tracker *bestblock.Tracker, lag int64, metrics *metrics.Provider, ...) (*Manager, error)
  • func (m *Manager) Close() error
  • func (m *Manager) FeedToChan(c chan int64)
  • func (m *Manager) IsPaused() bool
  • func (m *Manager) Pause()
  • func (m *Manager) Reset() error
  • func (m *Manager) Resume()
  • func (m *Manager) Todo(block int64) error

Types

type Config

type Config struct {
	RedisServer     string
	RedisPassword   string
	TodoList        string
	BackfillEnabled bool
}

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) Close

func (m *Manager) Close() error

func (*Manager) FeedToChan

func (m *Manager) FeedToChan(c chan int64)

FeedToChan continuously executes blocking pops from the redis queue and sends the resulting task on the provided channel Highest blocks have priority

func (*Manager) IsPaused

func (m *Manager) IsPaused() bool

func (*Manager) Pause

func (m *Manager) Pause()

func (*Manager) Reset

func (m *Manager) Reset() error

func (*Manager) Resume

func (m *Manager) Resume()

func (*Manager) Todo

func (m *Manager) Todo(block int64) error

Todo inserts a block into the redis sorted set used for queue management using a ZADD command