resource

package

Go to main page

Versions in this module

v0

v0.4.4

Mar 11, 2022

v0.4.3

Mar 11, 2022

v0.4.2

Nov 6, 2021

v0.4.1

Aug 3, 2021

v0.4.0

Jun 15, 2021

Changes in this version

type Error

+ func NewBlockedError(resource, resourceID, reason string) *Error

type JobData

+ DataRaw []byte

type JobListParams

+ NoBlocked bool

+ NoPaused bool

type Queue

+ Blocked bool

+ Paused bool

+ Unpaused bool

v0.3.0

May 17, 2021

Changes in this version

+ func ParseCLIArgs(args []string) ([]interface{}, error)

+ type NullTime struct

+ func (v *NullTime) UnmarshalJSON(data []byte) error

+ func (v NullTime) MarshalJSON() ([]byte, error)

type Status

+ func (s *Status) UnmarshalJSON(data []byte) error

+ func (s Status) MarshalJSON() ([]byte, error)

v0.2.2

Mar 9, 2021

Changes in this version

+ var ErrGenericNotFound = &Error

+ var ErrMethodNotAllowed = &Error

+ func StatusIsDone(status *Status) bool

+ func StatusStrings(statuses ...*Status) []string

+ type Ack struct

+ Data interface{}

+ Error string

+ ID string

+ JobID string

+ Status *Status

+ func (ack *Ack) String() string

+ type Acks struct

+ Acks []*Ack

+ func (as *Acks) JobIDs() []string

+ type Duration time.Duration

+ func (d *Duration) String() string

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ type Error struct

+ IDs []string

+ Invalid []*ValidationError

+ Kind string

+ Message string

+ Orig error

+ Reason string

+ Resource string

+ ResourceID string

+ Status int

+ func NewConflictError(resource, resourceID, reason string) *Error

+ func NewInternalServerError(err error) *Error

+ func NewNotFoundError(resource, resourceID, reason string) *Error

+ func NewUnprocessableEntityError(resource, resourceID, reason string, ids []string) *Error

+ func NewValidationError(resource, resourceID, reason string, verrs []*ValidationError) *Error

+ func (e *Error) Error() string

+ func (e *Error) GetStatus() int

+ func (e *Error) Is(iother error) bool

+ func (e *Error) Unwrap() error

+ type GetByIDOpts struct

+ Includes []string

+ type Job struct

+ Args []interface{}

+ ArgsRaw []byte

+ Attempt int

+ BackoffFactor float32

+ BackoffInitial Duration

+ BackoffMax Duration

+ Checkins []*JobCheckin

+ CompletedAt sql.NullTime

+ Data *JobData

+ DataRaw []byte

+ Duration Duration

+ EnqueuedAt time.Time

+ ID string

+ Name string

+ QueueID int64

+ QueueVersion *Version

+ Results []*JobResult

+ StartedAt sql.NullTime

+ Status *Status

+ Version *Version

+ func (jb *Job) ArgKey() (string, error)

+ func (jb *Job) Copy() *Job

+ func (jb *Job) HasStatus(statuses ...*Status) bool

+ func (jb *Job) IsAttempted() bool

+ func (jb *Job) LastClaimWindow() time.Time

+ func (jb *Job) LastResult() *JobResult

+ func (jb *Job) Populate() error

+ func (jb *Job) String() string

+ type JobCheckin struct

+ CreatedAt time.Time

+ Data interface{}

+ ID string

+ JobID string

+ type JobData struct

+ Claims label.Claims

+ Data interface{}

+ type JobListParams struct

+ Claims label.Claims

+ EnqueuedSince time.Time

+ EnqueuedUntil time.Time

+ Includes []string

+ NoUnclaimed bool

+ Page *Pagination

+ Queues []string

+ Selectors *label.Selectors

+ Statuses []*Status

+ type JobResult struct

+ Attempt int

+ CompletedAt time.Time

+ Data interface{}

+ Error string

+ ID string

+ JobID string

+ StartedAt time.Time

+ Status *Status

+ type Jobs struct

+ Jobs []*Job

+ func (jobs *Jobs) ArgKeys() ([]string, error)

+ func (jobs *Jobs) IDs() []string

+ func (jobs *Jobs) Queues() []string

+ type NullRawMessage struct

+ Valid bool

+ func (n *NullRawMessage) Scan(value interface{}) error

+ func (n NullRawMessage) Value() (driver.Value, error)

+ type Pagination struct

+ LastID string

+ Limit int64

+ type Queue struct

+ BackoffFactor float32

+ BackoffInitial Duration

+ BackoffMax Duration

+ CheckinDuration Duration

+ ClaimDuration Duration

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ Duration Duration

+ ID int64

+ Labels label.Labels

+ Name string

+ Retries int

+ SchemaRaw []byte

+ Unique bool

+ UpdatedAt time.Time

+ Version *Version

+ func (q *Queue) ClaimExpired(job *Job, now time.Time) bool

+ func (q *Queue) Copy() *Queue

+ func (q *Queue) Equal(other *Queue) bool

+ func (q *Queue) EqualAttrs(other *Queue) bool

+ func (q *Queue) String() string

+ type QueueListParams struct

+ Includes []string

+ Names []string

+ Page *Pagination

+ Selectors *label.Selectors

+ type Queues struct

+ Queues []*Queue

+ func (qs *Queues) ToMap() map[string]*Queue

+ type Stats struct

+ Cancelled int64

+ Complete int64

+ Dead int64

+ Failed int64

+ Invalid int64

+ LongestUnstarted int64

+ Queued int64

+ Running int64

+ type Status int

+ const StatusCancelled

+ const StatusComplete

+ const StatusDead

+ const StatusFailed

+ const StatusInvalid

+ const StatusQueued

+ const StatusRunning

+ const StatusUnspecified

+ func NewStatus(s Status) *Status

+ func StatusFromString(s string) *Status

+ func StatusesFromStrings(statuses ...string) []*Status

+ func (s *Status) Scan(value interface{}) error

+ func (s *Status) String() string

+ func (s *Status) Value() (driver.Value, error)

+ type ValidationError struct

+ Message string

+ Path string

+ Value interface{}

+ ValueRaw string

+ type Version struct

+ func NewVersion(v int32) *Version

+ func NewVersionFromString(s string) (*Version, error)

+ func (v *Version) Equals(other *Version) bool

+ func (v *Version) Inc()

+ func (v *Version) MarshalJSON() ([]byte, error)

+ func (v *Version) Raw() int32

+ func (v *Version) Scan(value interface{}) error

+ func (v *Version) Strict() string

+ func (v *Version) String() string

+ func (v *Version) UnmarshalJSON(b []byte) error

+ func (v *Version) Value() (driver.Value, error)

v0.2.1

Mar 8, 2021

v0.2.0

Mar 7, 2021

v0.1.11

Mar 7, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL