listing

Documentation

Index

• func Crons() (map[string]*cron.CronType, error)
• func DisabledCrons() (map[string]*cron.CronType, error)
• func Queues(short bool) (queueHash map[string]*QueueInfoType, err error)
• func RunningJobs(fast bool) (jobs []*task.Task, err error)
• func RunningWorkers() (workers []*heartbeat.HeartbeatType, err error)
• type QueueInfoType

Functions

func Crons

func Crons() (map[string]*cron.CronType, error)

func DisabledCrons

func DisabledCrons() (map[string]*cron.CronType, error)

func Queues

func Queues(short bool) (queueHash map[string]*QueueInfoType, err error)

func RunningJobs

func RunningJobs(fast bool) (jobs []*task.Task, err error)

SCAN takes about 0.5s per million total items in redis we skip it by guessing the possible working list names from worker heartbeat data this is much faster, but the prune functions still need the true list to find any zombie working lists

func RunningWorkers

func RunningWorkers() (workers []*heartbeat.HeartbeatType, err error)

Types

type QueueInfoType

type QueueInfoType struct {
	Name    string
	Threads int64
	Pending int64
	Running int64
	Done    int64
	Failed  int64
	Delayed int64
	// contains filtered or unexported fields
}