Versions in this module Expand all Collapse all v1 v1.0.1 Aug 11, 2020 v1.0.0 Aug 7, 2019 Changes in this version + var JobQueue chan Job + var MAX_QUEUE = 1000 + var MaxLength int64 = 5000 + var MaxQueue = os.Getenv("MAX_QUEUE") + var MaxWorker = os.Getenv("MAX_WORKERS") + var Queue chan Payload + func StartProcessor() + type Dispatcher struct + WorkerPool chan chan Job + func NewDispatcher(maxWorkers int) *Dispatcher + func (d *Dispatcher) Run() + func (d *Dispatcher) Stop() + type Job struct + Payload Payload + type Payload struct + AllocRes func() error + func (p *Payload) UploadToS3() error + type PayloadCollection struct + Payloads []Payload + Token string + Version string + type Worker struct + JobChannel chan Job + WorkerPool chan chan Job + func NewWorker(workerPool chan chan Job) Worker + func (w Worker) Start() + func (w Worker) Stop()