Documentation ¶
Index ¶
Constants ¶
View Source
const LastEnqueueTimeFormat = "2006-01-02 15:04:05 -0700"
Variables ¶
This section is empty.
Functions ¶
func CronEntryFromMap ¶
func NewCronEntry ¶
func NewCronEntry(name, desc, cron string, status EntryStatus, queuePrefix, queueDelimiter string, args []interface{}, job Job) (*cronEntry, error)
Types ¶
type Cron ¶
type Cron struct {
// contains filtered or unexported fields
}
func NewCron ¶
NewCron creates a new instance of the cron manager. You can use the Cron object to add and remove cron entries and to start polling. NewCron expects a valid sidekiq manager which it will use to interact with redis, and to enqueue jobs with. log can optionally be set, and will delegate logging to the passed in object if it is not nil.
func (*Cron) AddCron ¶
AddCron adds a cron entry to sidekiq. If the cron entry already exists, its state will be updated.
func (*Cron) CronEntries ¶
CronEntries returns all of the entries associated with the sidekiq instance.
type EntryStatus ¶
type EntryStatus string
const ( Enabled EntryStatus = "enabled" Disabled EntryStatus = "disabled" )
Click to show internal directories.
Click to hide internal directories.