cmd

Documentation

Index

• type QueueCleanCommand
  • func (cmd QueueCleanCommand) Run(ctx server.Cmd) error
• type QueueCommands
• type QueueCreateCommand
  • func (cmd QueueCreateCommand) Run(ctx server.Cmd) error
• type QueueDeleteCommand
  • func (cmd QueueDeleteCommand) Run(ctx server.Cmd) error
• type QueueGetCommand
  • func (cmd QueueGetCommand) Run(ctx server.Cmd) error
• type QueueListCommand
  • func (cmd QueueListCommand) Run(ctx server.Cmd) error
• type QueueUpdateCommand
  • func (cmd QueueUpdateCommand) Run(ctx server.Cmd) error
• type TaskCommands
• type TaskCreateCommand
  • func (cmd TaskCreateCommand) Run(ctx server.Cmd) error
• type TaskReleaseCommand
  • func (cmd TaskReleaseCommand) Run(ctx server.Cmd) error
• type TaskRetainCommand
  • func (cmd TaskRetainCommand) Run(ctx server.Cmd) error
• type TickerCommands
• type TickerCreateCommand
  • func (cmd TickerCreateCommand) Run(ctx server.Cmd) error
• type TickerDeleteCommand
  • func (cmd TickerDeleteCommand) Run(ctx server.Cmd) error
• type TickerGetCommand
  • func (cmd TickerGetCommand) Run(ctx server.Cmd) error
• type TickerListCommand
  • func (cmd TickerListCommand) Run(ctx server.Cmd) error
• type TickerNextCommand
  • func (cmd TickerNextCommand) Run(ctx server.Cmd) error
• type TickerUpdateCommand
  • func (cmd TickerUpdateCommand) Run(ctx server.Cmd) error

Types

type QueueCleanCommand

type QueueCleanCommand struct {
	QueueGetCommand
}

func (QueueCleanCommand) Run

func (cmd QueueCleanCommand) Run(ctx server.Cmd) error

type QueueCommands

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

type QueueCreateCommand struct {
	schema.QueueMeta
}

func (QueueCreateCommand) Run

func (cmd QueueCreateCommand) Run(ctx server.Cmd) error

type QueueDeleteCommand

type QueueDeleteCommand struct {
	QueueGetCommand
}

func (QueueDeleteCommand) Run

func (cmd QueueDeleteCommand) Run(ctx server.Cmd) error

type QueueGetCommand

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

func (QueueGetCommand) Run

func (cmd QueueGetCommand) Run(ctx server.Cmd) error

type QueueListCommand

type QueueListCommand struct {
	schema.QueueListRequest
}

func (QueueListCommand) Run

func (cmd QueueListCommand) Run(ctx server.Cmd) error

type QueueUpdateCommand

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

func (QueueUpdateCommand) Run

func (cmd QueueUpdateCommand) Run(ctx server.Cmd) error

type TaskCommands

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

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

func (TaskCreateCommand) Run

func (cmd TaskCreateCommand) Run(ctx server.Cmd) error

type TaskReleaseCommand

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

func (TaskReleaseCommand) Run

func (cmd TaskReleaseCommand) Run(ctx server.Cmd) error

type TaskRetainCommand

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

func (TaskRetainCommand) Run

func (cmd TaskRetainCommand) Run(ctx server.Cmd) error

type TickerCommands

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

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

func (TickerCreateCommand) Run

func (cmd TickerCreateCommand) Run(ctx server.Cmd) error

type TickerDeleteCommand

type TickerDeleteCommand struct {
	TickerGetCommand
}

func (TickerDeleteCommand) Run

func (cmd TickerDeleteCommand) Run(ctx server.Cmd) error

type TickerGetCommand

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

func (TickerGetCommand) Run

func (cmd TickerGetCommand) Run(ctx server.Cmd) error

type TickerListCommand

type TickerListCommand struct {
	schema.TickerListRequest
}

func (TickerListCommand) Run

func (cmd TickerListCommand) Run(ctx server.Cmd) error

type TickerNextCommand

type TickerNextCommand struct {
}

func (TickerNextCommand) Run

func (cmd TickerNextCommand) Run(ctx server.Cmd) error

type TickerUpdateCommand

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

func (TickerUpdateCommand) Run

func (cmd TickerUpdateCommand) Run(ctx server.Cmd) error