resource

type Ack struct {
	ID     string  `json:"-" db:"id"`
	JobID  string  `json:"job_id" db:"job_id"`
	Status *Status `json:"status"`
	Data   []byte  `json:"data,omitempty"`
	Error  string  `json:"error,omitempty"`
}

type Acks struct {
	Acks []*Ack `json:"acks"`
}

type Duration time.Duration

type Error struct {
	Status     int                `json:"status,omitempty"`
	Message    string             `json:"message"`
	Kind       string             `json:"kind"`
	Resource   string             `json:"resource,omitempty"`
	ResourceID string             `json:"resource_id,omitempty"`
	Reason     string             `json:"reason,omitempty"`
	Orig       error              `json:"orig,omitempty"`
	Invalid    []*ValidationError `json:"invalid,omitempty"`
	IDs        []string           `json:"ids,omitempty"`
}

type GetByIDOpts struct {
	Includes []string `json:"include,omitempty"`
}

type Job struct {
	ID string `json:"id"`
	// QueueID is the id of the queue that manages this job.
	QueueID        string        `json:"-" db:"queue_id"`
	Version        *Version      `json:"version" db:"v"`
	Name           string        `json:"name"`
	QueueVersion   *Version      `json:"queue_version" db:"queue_v"`
	ArgsRaw        []byte        `json:"args" db:"args"`
	Data           *JobData      `json:"data,omitempty" db:"-"`
	DataRaw        []byte        `json:"-" db:"data"`
	Status         *Status       `json:"status"`
	Attempt        int           `json:"attempt,omitempty"`
	Checkins       []*JobCheckin `json:"checkins,omitempty"`
	Results        []*JobResult  `json:"results,omitempty"`
	EnqueuedAt     time.Time     `json:"enqueued_at,omitempty" db:"enqueued_at"`
	StartedAt      NullTime      `json:"-" db:"started_at"`
	CompletedAt    NullTime      `json:"-" db:"completed_at"`
	BackoffInitial Duration      `json:"-" db:"backoff_initial_duration"`
	BackoffMax     Duration      `json:"-" db:"backoff_max_duration"`
	BackoffFactor  float32       `json:"-" db:"backoff_factor"`
	// Duration lives on queues, but consumers need it for correct timeouts.
	Duration Duration `json:"duration,omitempty" db:"duration"`
}

type JobCheckin struct {
	ID        string    `json:"-"`
	JobID     string    `json:"-" db:"job_id"`
	Data      []byte    `json:"data,omitempty"`
	CreatedAt time.Time `json:"created_at" db:"created_at"`
}

type JobData struct {
	Claims  label.Claims `json:"claims,omitempty"`
	DataRaw []byte       `json:"data,omitempty"`
}

type JobListParams struct {
	Queues        []string         `json:"names,omitempty"`
	Statuses      []*Status        `json:"statuses,omitempty"`
	Selectors     *label.Selectors `json:"selectors,omitempty"`
	Claims        label.Claims     `json:"claims,omitempty"`
	EnqueuedSince time.Time        `json:"enqueued_since,omitempty"`
	EnqueuedUntil time.Time        `json:"enqueued_until,omitempty"`
	NoPaused      bool             `json:"no_paused,omitempty"`
	NoBlocked     bool             `json:"no_blocked,omitempty"`

	// NoUnclaimed will exclude jobs that have outstanding claims.
	NoUnclaimed bool        `json:"no_unclaimed,omitempty"`
	Page        *Pagination `json:"page,omitempty"`
	Includes    []string    `json:"include,omitempty"`
}

type JobResult struct {
	ID          string    `json:"-"`
	JobID       string    `json:"-" db:"job_id"`
	Attempt     int       `json:"attempt"`
	Status      *Status   `json:"status"`
	Data        []byte    `json:"data,omitempty"`
	Error       string    `json:"error,omitempty"`
	StartedAt   time.Time `json:"started_at" db:"started_at"`
	CompletedAt time.Time `json:"completed_at" db:"completed_at"`
}

type Jobs struct {
	Jobs []*Job `json:"jobs"`
}

type NullRawMessage struct {
	json.RawMessage
	Valid bool
}

type NullTime struct {
	sql.NullTime
}

type Pagination struct {
	Limit  int64  `json:"limit,omitempty"`
	LastID string `json:"last_id,omitempty"`
}

type Queue struct {
	ID              string       `json:"-"`
	Name            string       `json:"name"`
	Version         *Version     `json:"version" db:"v"`
	Retries         int          `json:"retries,omitempty"`
	Duration        Duration     `json:"duration,omitempty"`
	CheckinDuration Duration     `json:"checkin_duration,omitempty" db:"checkin_duration"`
	ClaimDuration   Duration     `json:"claim_duration,omitempty" db:"claim_duration"`
	Unique          bool         `json:"unique,omitempty" db:"unique_args"`
	Labels          label.Labels `json:"labels,omitempty"`
	SchemaRaw       []byte       `json:"schema_raw,omitempty" db:"job_schema"`
	BackoffInitial  Duration     `json:"backoff_initial" db:"backoff_initial_duration"`
	BackoffMax      Duration     `json:"backoff_max" db:"backoff_max_duration"`
	BackoffFactor   float32      `json:"backoff_factor" db:"backoff_factor"`
	Paused          bool         `json:"paused"`
	Unpaused        bool         `json:"unpaused"`
	Blocked         bool         `json:"blocked"`
	CreatedAt       time.Time    `json:"created_at" db:"created_at"`
	UpdatedAt       time.Time    `json:"-" db:"updated_at"`
	DeletedAt       NullTime     `json:"deleted_at,omitempty" db:"deleted_at"`
}

type QueueListParams struct {
	Names     []string         `json:"names,omitempty"`
	Selectors *label.Selectors `json:"selectors,omitempty"`
	Page      *Pagination      `json:"page,omitempty"`
	Includes  []string         `json:"include,omitempty"`
}

type Queues struct {
	Queues []*Queue `json:"queues"`
}

type Stats struct {
	Queued           int64 `json:"queued"`
	Running          int64 `json:"running"`
	Complete         int64 `json:"complete"`
	Dead             int64 `json:"dead"`
	Cancelled        int64 `json:"cancelled"`
	Invalid          int64 `json:"invalid"`
	Failed           int64 `json:"failed"`
	LongestUnstarted int64 `json:"longest_unstarted_secs"`
}

type Status int

type ValidationError struct {
	Message  string      `json:"message"`
	Path     string      `json:"path,omitempty"`
	ValueRaw string      `json:"value_raw,omitempty"`
	Value    interface{} `json:"value,omitempty"`
}

type Version struct {
	// contains filtered or unexported fields
}