cmd

type QueueCleanCommand struct {
	QueueGetCommand
}

type QueueCommands struct {
	Queues      QueueListCommand   `cmd:"" group:"QUEUE" help:"List queues"`
	Queue       QueueGetCommand    `cmd:"list" group:"QUEUE" help:"Get queue by name"`
	CreateQueue QueueCreateCommand `cmd:"create" group:"QUEUE" help:"Create a new queue"`
	UpdateQueue QueueUpdateCommand `cmd:"update" group:"QUEUE" help:"Update queue"`
	DeleteQueue QueueDeleteCommand `cmd:"delete" group:"QUEUE" help:"Delete queue"`
	CleanQueue  QueueCleanCommand  `cmd:"clean" group:"QUEUE" help:"Clean queue"`
}

type QueueCreateCommand struct {
	schema.QueueMeta
}

type QueueDeleteCommand struct {
	QueueGetCommand
}

type QueueGetCommand struct {
	Queue string `arg:"" help:"Queue name"`
}

type QueueListCommand struct {
	schema.QueueListRequest
}

type QueueUpdateCommand struct {
	Name string `help:"New Queue name"`
	schema.QueueMeta
}

type TaskCommands struct {
	CreateTask  TaskCreateCommand  `cmd:"" group:"QUEUE" help:"Create a new task"`
	RetainTask  TaskRetainCommand  `cmd:"retain" group:"QUEUE" help:"Retain a task"`
	ReleaseTask TaskReleaseCommand `cmd:"release" group:"QUEUE" help:"Release a task"`
}

type TaskCreateCommand struct {
	Queue   string         `arg:"" help:"Queue name"`
	Payload *string        `help:"JSON Task payload"`
	Delay   *time.Duration `help:"Delay before task is executed"`
}

type TaskReleaseCommand struct {
	Task  uint64  `arg:"" help:"Task ID"`
	Error *string `help:"Error message"`
}

type TaskRetainCommand struct {
	Worker *string `help:"Worker name"`
}

type TickerCommands struct {
	Tickers      TickerListCommand   `cmd:"" group:"QUEUE" help:"List tickers"`
	NextTicker   TickerNextCommand   `cmd:"next" group:"QUEUE" help:"Receive ticker events"`
	Ticker       TickerGetCommand    `cmd:"list" group:"QUEUE" help:"Get ticker by name"`
	CreateTicker TickerCreateCommand `cmd:"create" group:"QUEUE" help:"Create a new ticker"`
	UpdateTicker TickerUpdateCommand `cmd:"update" group:"QUEUE" help:"Update ticker"`
	DeleteTicker TickerDeleteCommand `cmd:"delete" group:"QUEUE" help:"Delete ticker"`
}

type TickerCreateCommand struct {
	Ticker   string         `arg:"" help:"Ticker name"`
	Payload  *string        `help:"JSON Ticker payload"`
	Interval *time.Duration `help:"Interval (default 1 minute)"`
}

type TickerDeleteCommand struct {
	TickerGetCommand
}

type TickerGetCommand struct {
	Ticker string `arg:"" help:"Ticker name"`
}

type TickerListCommand struct {
	schema.TickerListRequest
}

type TickerNextCommand struct {
}

type TickerUpdateCommand struct {
	Ticker string `help:"New ticker name"`
	TickerCreateCommand
}