Versions in this module Expand all Collapse all v0 v0.0.1 Oct 11, 2019 Changes in this version + func Init(worker *machinery.Worker, initOptions Options) error + type DBEntry struct + ID primitive.ObjectID + Points []DataPoint + Queue string + func NewEntry(queue string) DBEntry + func (e *DBEntry) NewEntry(status TaskStatus, ifErrorMsg error) + type DataPoint struct + Errors []string + From int64 + Retries int + Successes int + type MongoDBConnectOptions struct + ConnectionURI string + Database string + type Options struct + Mongodb MongoDBConnectOptions + type TaskStatus uint8 + const StatusError + const StatusOke + const StatusRetry + func (s TaskStatus) IsError() bool + func (s TaskStatus) IsOke() bool + func (s TaskStatus) IsRetry() bool
Go to main page