jobq

type Inspect struct {
	Server    string `required:"true"`
	Identity  string `required:"true"`
	Placement int    `required:"true"`
	StreamID  string `arg:""`
}

type Jobq struct {
	Stat    Stat    `cmd:"" help:"Show job queue statistics."`
	Peek    Peek    `cmd:"" help:"Peek into the job queue, showing the next jobs without removing them."`
	Trim    Trim    `cmd:"" help:"Trim the job queue, removing jobs up to a specified placement constraint."`
	Inspect Inspect `cmd:"" help:"Inspect jobs in the job queue, showing detailed information about each job."`
	Submit  Submit  `cmd:"" help:"Submit a new job to the job queue."`
}

type Peek struct {
	Server        string `required:"true"`
	Identity      string `required:"true"`
	WithHistogram bool
	Placement     *int
	Number        int `help:"number of jobs to peek" alias:"n" default:"10"`
}

type Stat struct {
	Server        string `help:"jobq server address"`
	Identity      string `help:"identity of the jobq cliet"`
	WithHistogram bool   `help:"Include raw histogram data in the output (all records)."`
	Histogram     string `help:"Include histogram data in the output (healthy,retrievable,oop)."`
	Placement     *int
	Retry         bool
}

type Submit struct {
	Server                   string  `required:"true"`
	Identity                 string  `required:"true"`
	StreamID                 string  `required:"true" help:"Stream ID (UUID format)"`
	Position                 uint64  `default:"0" help:"Segment position"`
	Placement                uint16  `default:"0" help:"Placement constraint"`
	Health                   float64 `default:"0.5" help:"Segment health (0.0-1.0)"`
	NumNormalizedHealthy     int16   `default:"0" help:"Number of normalized healthy pieces"`
	NumNormalizedRetrievable int16   `default:"0" help:"Number of normalized retrievable pieces"`
	NumOutOfPlacement        int16   `default:"0" help:"Number of out-of-placement pieces"`
}

type Trim struct {
	Server    string `required:"true"`
	Identity  string `required:"true"`
	Placement *int   `required:"true"`
}