types

Documentation

Index

• Variables
• type HTTPError
• type Handler
• type Tags
  • func (tags Tags) Get(key string) string
  • func (tags *Tags) Scan(value interface{}) error
  • func (tags *Tags) Set(key, value string)
  • func (tags Tags) Value() (driver.Value, error)
• type Task
  • func (t Task) Checksum() string
  • func (t *Task) FromHTTP(r *http.Request) error
  • func (t *Task) Marshal(source interface{}) (err error)
  • func (t *Task) Sign(secret string) error
  • func (t Task) Unmarshal(res interface{}) (err error)
  • func (task Task) VerifySignature(secret string) error

Variables

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")

Types

type HTTPError

type HTTPError struct {
	Status int
	Error  error
}

type Handler

type Handler interface {
	Handle(Task) (bool, error)
}

type Tags

type Tags map[string]string

func (Tags) Get

func (tags Tags) Get(key string) string

func (*Tags) Scan

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

func (*Tags) Set

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

func (Tags) Value

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

type Task

type Task struct {
	ID           string        `json:"id"`
	Body         string        `json:"body"`
	Delay        time.Duration `json:"delay"` // Delay overrides RunAt
	RunAt        time.Time     `json:"run_at"`
	NoExpBackoff bool          `json:"no_exp_backoff"`
	Attempts     int           `json:"attempts"`
	Tags         Tags          `json:"tags"`
	QueueName    string        `json:"queue_name"`
	Token        string        `json:"token"`
	Timeout      time.Duration `json:"timeout"`
}

func (Task) Checksum

func (t Task) Checksum() string

func (*Task) FromHTTP

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

func (*Task) Marshal

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

func (*Task) Sign

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

func (Task) Unmarshal

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

func (Task) VerifySignature

func (task Task) VerifySignature(secret string) error