taskqueue

type Dst struct {
	db.WithDatabase
	Address    string   `help:"Redis URL for task queue" default:"redis://localhost:6379"`
	Stream     string   `arg:"" help:"Redis stream name" default:"balancer"`
	Attributes []string `help:"Node attributes to display" default:"tag:server_group,tag:host,tag:service"`
}

type Keys struct {
	Address string `help:"Redis URL for task queue" default:"redis://localhost:6379"`
}

type Src struct {
	db.WithDatabase
	Address    string   `help:"Redis URL for task queue" default:"redis://localhost:6379"`
	Stream     string   `arg:"" help:"Redis stream name" default:"balancer"`
	Attributes []string `help:"Node attributes to display" default:"tag:server_group,tag:host,tag:service"`
}

type Stat struct {
	Address  string `help:"redis URL for task queue" default:"redis://localhost:6379"`
	StreamID string `help:"Redis stream name" default:"balancer"`
}

type TaskQueue struct {
	Keys Keys `cmd:"" help:"List all stream keys and their sizes."`
	Stat Stat `cmd:"" help:"Show summary statistics of the task queue."`
	Src  Src  `cmd:"" help:"Show histogram of source nodes in the task queue."`
	Dst  Dst  `cmd:"" help:"Show histogram of destination nodes in the task queue."`
}