celery

package

v0.0.0-...-d4cb73b Latest Latest Go to latest Published: Oct 14, 2018 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jianyuan/go-worq

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Binder
- func NewBinder() *Binder
- func (Binder) Bind(ctx worq.Context, v interface{}) error
- func (Binder) Unbind(ctx worq.Context, id string, queue string, sig *worq.Signature) (*worq.Publishing, error)
type Protocol
- func New() *Protocol
- func (Protocol) ID(msg worq.Message) (string, error)
- func (Protocol) Task(msg worq.Message) (string, error)
type TaskArgs
type TaskBody
type TaskEmbed
type TaskKWArgs
type TaskSignature

Constants ¶

View Source

const (
	MIMEApplicationJSON = "application/json"
)

Variables ¶

View Source

var (
	ErrIDMissing              = errors.New("celery: task id missing from header")
	ErrTaskMissing            = errors.New("celery: task missing from header")
	ErrUnsupportedContentType = errors.New("celery: unsupported media type")
	ErrBadJSONBody            = errors.New("celery: bad JSON body")
)

Functions ¶

This section is empty.

Types ¶

type Binder ¶

type Binder struct {
}

func NewBinder ¶

func NewBinder() *Binder

func (Binder) Bind ¶

func (Binder) Bind(ctx worq.Context, v interface{}) error

func (Binder) Unbind ¶

func (Binder) Unbind(ctx worq.Context, id string, queue string, sig *worq.Signature) (*worq.Publishing, error)

type Protocol ¶

type Protocol struct {
}

func New ¶

func New() *Protocol

func (Protocol) ID ¶

func (Protocol) ID(msg worq.Message) (string, error)

func (Protocol) Task ¶

func (Protocol) Task(msg worq.Message) (string, error)

type TaskArgs ¶

type TaskArgs []interface{}

type TaskBody ¶

type TaskBody [3]json.RawMessage

TaskBody is a 3-length array with the shape: [TaskArgs, TaskKWArgs, TaskEmbed]

type TaskEmbed ¶

type TaskEmbed struct {
	Callbacks []*TaskSignature `json:"callbacks"`
	Errbacks  []*TaskSignature `json:"errbacks"`
	Chain     []*TaskSignature `json:"chain"`
	Chord     *TaskSignature   `json:"chord"`
}

type TaskKWArgs ¶

type TaskKWArgs map[string]interface{}

type TaskSignature ¶

type TaskSignature struct {
	Task    string                 `json:"task"`
	Args    []interface{}          `json:"args"`
	KWArgs  map[string]interface{} `json:"kwargs"`
	Options map[string]interface{} `json:"options"`
}

Source Files ¶

View all Source files

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