schema

type Partition struct {
	PartitionMeta
	Count uint64 `json:"count" db:"count"`
}

type PartitionList struct {
	Body []Partition `json:"body,omitempty"`
}

type PartitionListRequest struct{}

type PartitionMeta struct {
	Partition string `json:"partition" db:"partition"`
	Start     uint64 `json:"start" db:"start"`
	End       uint64 `json:"end" db:"end"`
}

type PartitionName string

type PartitionSeq uint64

type PartitionSeqRequest struct{}

type Queue struct {
	Queue string `json:"queue,omitempty" arg:"" help:"Queue name"`
	QueueMeta
}

type QueueCleanRequest struct {
	Queue string `json:"queue,omitempty" arg:"" help:"Queue name"`
}

type QueueCleanResponse struct {
	QueueCleanRequest
	Body []Task `json:"body,omitempty"`
}

type QueueList struct {
	QueueListRequest
	Count uint64  `json:"count"`
	Body  []Queue `json:"body,omitempty"`
}

type QueueListRequest struct {
	pg.OffsetLimit
}

type QueueMeta struct {
	TTL         *time.Duration `json:"ttl,omitempty" help:"Time-to-live for queue messages"`
	Retries     *uint64        `json:"retries" help:"Number of retries before failing"`
	RetryDelay  *time.Duration `json:"retry_delay" help:"Backoff delay"`
	Concurrency *uint64        `json:"concurrency" help:"Number of concurrent workers"`
}

type QueueName string

type QueueStatus struct {
	Queue  string `json:"queue"`
	Status string `json:"status"`
	Count  uint64 `json:"count"`
}

type QueueStatusRequest struct{}

type QueueStatusResponse struct {
	QueueStatusRequest
	Body []QueueStatus `json:"body,omitempty"`
}

type Task struct {
	Id     uint64          `json:"id,omitempty"`
	Queue  string          `json:"queue,omitempty"`
	Worker *string         `json:"worker,omitempty"`
	Result json.RawMessage `json:"result,omitempty"`
	TaskMeta
	CreatedAt  *time.Time `json:"created_at,omitempty"`
	StartedAt  *time.Time `json:"started_at,omitempty"`
	FinishedAt *time.Time `json:"finished_at,omitempty"`
	DiesAt     *time.Time `json:"dies_at,omitempty"`
	Retries    *uint64    `json:"retries,omitempty"`
}

type TaskFunc func(context.Context, json.RawMessage) (any, error)

type TaskId uint64

type TaskList struct {
	TaskListRequest
	Count uint64           `json:"count"`
	Body  []TaskWithStatus `json:"body,omitempty"`
}

type TaskListRequest struct {
	pg.OffsetLimit
	Status string `json:"status,omitempty"`
}

type TaskMeta struct {
	Payload   json.RawMessage `json:"payload,omitempty"`
	DelayedAt *time.Time      `json:"delayed_at,omitempty"`
}

type TaskRelease struct {
	Id     uint64          `json:"id,omitempty"`
	Fail   bool            `json:"fail,omitempty"`
	Result json.RawMessage `json:"result,omitempty"`
}

type TaskRetain struct {
	Queues []string `json:"queues,omitempty"`
	Worker string   `json:"worker,omitempty"`
}

type TaskWithStatus struct {
	Task
	Status string `json:"status,omitempty"`
}

type Ticker struct {
	Ticker string `json:"ticker" arg:"" help:"Ticker name"`
	TickerMeta
	LastAt *time.Time `json:"last_at,omitempty"`
}

type TickerList struct {
	TickerListRequest
	Count uint64   `json:"count"`
	Body  []Ticker `json:"body,omitempty"`
}

type TickerListRequest struct {
	pg.OffsetLimit
}

type TickerMeta struct {
	Payload  json.RawMessage `json:"payload,omitempty"`
	Interval *time.Duration  `json:"interval,omitempty" help:"Interval (default 1 minute)"`
}

type TickerName string

type TickerNext struct{}