import "github.com/squioc/chronos"
The chronos package provides a job scheduler implementation
The documentation is available at https://godoc.org/github.com/squioc/chronos, thanks to GoDoc
func NewChronos(provider axis.Provider, queue Queue) *ChronosCreates a new Scheduler with an axis.Provider and a chronos.Queue.
func (c *Chronos) Run(pushChan, workerChan chan Entry, stopChan chan bool)Starts the scheduler (we recommend to use it in a goroutine).
Parameters:
pushChanis the input channel, which delivers jobs to schedule.workerChanis the output channel, which receives jobs whose the position was reached.stopChanallow to stop gracefully the scheduler.
type Entry interface {
Position() axis.Position
}Entry is the interface that wraps elements to send in the scheduler
type Queue interface {
heap.Interface
Peek() interface{}
}Queue is the interface that holds elements as an ordered collection