schema

type Queue struct {
	QueueMeta
	Namespace string `json:"namespace,omitempty" help:"Namespace"`
}

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

type QueueCleanResponse struct {
	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 {
	Queue      string         `json:"queue,omitempty" arg:"" help:"Queue name"`
	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"`
}

type QueueName string

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

type QueueStatusRequest struct{}

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

type Task struct {
	Id uint64 `json:"id,omitempty"`
	TaskMeta
	Worker     *string    `json:"worker,omitempty"`
	Namespace  string     `json:"namespace,omitempty"`
	Queue      string     `json:"queue,omitempty"`
	Result     any        `json:"result,omitempty"`
	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 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   any        `json:"payload,omitempty"`
	DelayedAt *time.Time `json:"delayed_at,omitempty"`
}

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

type TaskRetain struct {
	Worker string `json:"worker,omitempty"`
}

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

type Ticker struct {
	TickerMeta
	Namespace string     `json:"namespace,omitempty" help:"Namespace"`
	Ts        *time.Time `json:"timestamp,omitempty"`
}

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

type TickerListRequest struct {
	pg.OffsetLimit
}

type TickerMeta struct {
	Ticker   string         `json:"ticker" arg:"" help:"Ticker name"`
	Payload  any            `json:"payload,omitempty"`
	Interval *time.Duration `json:"interval,omitempty" help:"Interval (default 1 minute)"`
}

type TickerName string

type TickerNext struct{}