types

Oct 9, 2023

Changes in this version

type Task

+ Timeout time.Duration

Mar 25, 2021

Changes in this version

+ type HTTPError struct

+ Error error

+ Status int

type Tags

+ func (tags *Tags) Set(key, value string)

+ func (tags Tags) Get(key string) string

type Task

+ QueueName string

+ Token string

+ func (t *Task) FromHTTP(r *http.Request) error

+ func (t *Task) Sign(secret string) error

+ func (t Task) Checksum() string

+ func (task Task) VerifySignature(secret string) error

Jun 1, 2020

Changes in this version

+ var ConnectionClosed = errors.New("The connection to the backend is closed")

+ var NotImplemented = errors.New("This method is not implemented on this backend")

+ var QueueNotFound = errors.New("I don't know any queue by that name")

+ var SubscriptionCancelled = errors.New("This subscription has been cancelled")

+ var UnknownBackend = errors.New("I have never heard of that backend")

+ type Handler interface

+ Handle func(Task) (bool, error)

+ type Tags map[string]string

+ func (tags *Tags) Scan(value interface{}) error

+ func (tags Tags) Value() (driver.Value, error)

+ type Task struct

+ Attempts int

+ Body string

+ Delay time.Duration

+ ID string

+ NoExpBackoff bool

+ RunAt time.Time

+ Tags Tags

+ func (t *Task) Marshal(source interface{}) (err error)

+ func (t Task) Unmarshal(res interface{}) (err error)