WorkQueue

type DispatcherConfig struct {
	RetryTimeout time.Duration
}

type IQueuedWorker interface {
	Start()
	DoWork(Job)
}

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

type Job struct {
	JobId  int64
	Params interface{}
}

type JobDispatcher struct {
	EmptyQueueChan chan bool // channel to communicate that queue was consumed
	// contains filtered or unexported fields
}

type PoolConfig struct {
	StartHeight int64
	EndHeight   int64
}

type QueuedWorker struct {
	Worker IQueuedWorker
}

type WorkQueue struct {
	ID          string
	WorkersChan chan chan Job // used to communicate between dispatcher and workers
	JobsChan    chan Job
	End         chan bool
}

type WorkerConstructor func(string, chan chan Job) QueuedWorker