Documentation
¶
Index ¶
- func NewInvokeCmd(ctx context.Context, asyncClient async.Client) *cobra.Command
- func NewQueuesCmd(_ context.Context, asyncInspector Inspector) *cobra.Command
- func NewRootCmd(ctx context.Context) *cobra.Command
- func NewStatsCmd(ctx context.Context, asyncInspector Inspector) *cobra.Command
- type Inspector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Inspector ¶
type Inspector interface {
Queues() ([]string, error)
GetQueueInfo(queue string) (*asynq.QueueInfo, error)
History(queue string, days int) ([]*asynq.DailyStats, error)
ListPendingTasks(queue string, opts ...asynq.ListOption) ([]*asynq.TaskInfo, error)
ListActiveTasks(queue string, opts ...asynq.ListOption) ([]*asynq.TaskInfo, error)
ListCompletedTasks(queue string, opts ...asynq.ListOption) ([]*asynq.TaskInfo, error)
ListArchivedTasks(queue string, opts ...asynq.ListOption) ([]*asynq.TaskInfo, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.