celery

type AMQP struct{}

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

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

type Binding struct {
	Name     string
	Queue    *Queue
	Exchange *Exchange
}

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

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

type Deliveries chan *Task

type Driver interface {
	Connect() error
	DeclareExchange(*Exchange) error
	DeclareQueue(*Queue) error
	Bind(*Binding) error
	GetMessages(*Queue, int) (<-chan *Message, error)
	Publish(*Publishing) error
	IsConnected() bool
}

type Exchange struct {
	Name               string
	Type               string
	Durable            bool
	DeleteWhenComplete bool
}

type Message struct {
	ContentType string
	Body        []byte
	Receipt     Receipt
}

type Publishing struct {
	Key      string
	Exchange *Exchange
	Body     []byte
}

type Queue struct {
	Name             string
	Durable          bool
	DeleteWhenUnused bool
	Ttl              int
}

type Receipt interface {
	Reply(string, interface{})
	Ack()
	Requeue()
	Reject()
}

type Result struct {
	Status    ResultStatus `json:"status"`
	Traceback []string     `json:"traceback"`
	Result    interface{}  `json:"result"`
	Id        string       `json:"task_id"`
	Children  []string     `json:"children"`
}

type ResultStatus string

type Task struct {
	Task    string                 `json:"task"`
	Id      string                 `json:"id"`
	Args    []interface{}          `json:"args"`
	Kwargs  map[string]interface{} `json:"kwargs"`
	Retries int                    `json:"retries"`
	Eta     celeryTime             `json:"eta"`
	Expires celeryTime             `json:"expires"`
	Receipt Receipt                `json:"-"`
}

type Transport interface {
	Open(string) Driver
}

type Worker interface {
	Exec(*Task) (interface{}, error)
}