Versions in this module Expand all Collapse all v0 v0.0.2 Feb 18, 2019 v0.0.1 Feb 15, 2019 Changes in this version + var ISO8601 = "2006-01-02T15:04:05" + func GetRealValue(val *reflect.Value) interface + func NewAMQPConnection(host string) (*amqp.Connection, *amqp.Channel) + func NewRedisPool(host string, port int, db int, pass string) *redis.Pool + type AMQPCeleryBackend struct + func NewAMQPCeleryBackend(host string) *AMQPCeleryBackend + func (b *AMQPCeleryBackend) GetResult(taskID string) (*ResultMessage, error) + func (b *AMQPCeleryBackend) Reconnect() + func (b *AMQPCeleryBackend) SetResult(taskID string, result *ResultMessage) error + type AMQPCeleryBroker struct + func NewAMQPCeleryBroker(host string) *AMQPCeleryBroker + func (b *AMQPCeleryBroker) CreateExchange() error + func (b *AMQPCeleryBroker) CreateQueue() error + func (b *AMQPCeleryBroker) GetTask() (*CeleryTask, error) + func (b *AMQPCeleryBroker) SendCeleryMessage(message *CeleryMessage) error + func (b *AMQPCeleryBroker) StartConsumingChannel() error + type AMQPExchange struct + AutoDelete bool + Durable bool + Name string + Type string + func NewAMQPExchange(name string) *AMQPExchange + type AMQPQueue struct + AutoDelete bool + Durable bool + Name string + func NewAMQPQueue(name string) *AMQPQueue + type AsyncResult struct + func (ar *AsyncResult) AsyncGet() (interface{}, error) + func (ar *AsyncResult) Get(timeout time.Duration) (interface{}, error) + func (ar *AsyncResult) GetTaskId() string + func (ar *AsyncResult) Ready() (bool, error) + type BrokerOptions struct + func BrokerQueueName(queueName string) BrokerOptions + type CeleryBackend interface + GetResult func(string) (*ResultMessage, error) + SetResult func(taskID string, result *ResultMessage) error + type CeleryBroker interface + GetTask func() (*CeleryTask, error) + SendCeleryMessage func(*CeleryMessage) error + type CeleryClient struct + func NewCeleryClient(broker CeleryBroker, backend CeleryBackend) (*CeleryClient, error) + func (cc *CeleryClient) ApplyAsync(task string, args []interface{}, kwargs map[string]interface{}, ...) (*AsyncResult, error) + func (cc *CeleryClient) Delay(task string, args ...interface{}) (*AsyncResult, error) + func (cc *CeleryClient) DelayKwargs(task string, args map[string]interface{}) (*AsyncResult, error) + type CeleryDeliveryInfo struct + Exchange string + RoutingKey string + func NewCeleryDeliveryInfo(routingKey string, exchange string) *CeleryDeliveryInfo + type CeleryMessage struct + Body string + ContentEncoding string + ContentType string + Headers ST_Headers + Properties ST_Properties + func Task2Msg(task *CeleryTask) *CeleryMessage + type CeleryServer struct + func NewCeleryServer(broker CeleryBroker, backend CeleryBackend, numWorkers int) (*CeleryServer, error) + func (cc *CeleryServer) Register(name string, task interface{}) + func (cc *CeleryServer) StartWorker() + func (cc *CeleryServer) StopWorker() + type CeleryTask struct + Args []interface{} + ETA time.Time + Embed map[string]interface{} + Expires time.Time + Id string + Kwargs map[string]interface{} + Priority int + Retries int + Task string + func Msg2Task(msg *CeleryMessage) *CeleryTask + func (tm *CeleryTask) EncodeBody() string + type CeleryWorker struct + func NewCeleryWorker(broker CeleryBroker, backend CeleryBackend, numWorkers int) *CeleryWorker + func (w *CeleryWorker) GetNumWorkers() int + func (w *CeleryWorker) GetTask(name string) interface{} + func (w *CeleryWorker) Register(name string, task interface{}) + func (w *CeleryWorker) RunTask(message *CeleryTask) (*ResultMessage, error) + func (w *CeleryWorker) StartWorker() + func (w *CeleryWorker) StopWorker() + type Itf_CeleryTask interface + ParseKwargs func(map[string]interface{}) error + RunTask func() (interface{}, error) + type PythonBody struct + Args []interface{} + Embed map[string]interface{} + Kwargs map[string]interface{} + func DecodeBody(encodedBody string) *PythonBody + func (body *PythonBody) UnmarshalJSON(buf []byte) error + type RedisCeleryBackend struct + func NewRedisCeleryBackend(host string, port int, db int, pass string) *RedisCeleryBackend + func (cb *RedisCeleryBackend) GetResult(taskID string) (*ResultMessage, error) + func (cb *RedisCeleryBackend) SetResult(taskID string, result *ResultMessage) error + type RedisCeleryBroker struct + QueueName string + func NewRedisCeleryBroker(host string, port int, db int, pass string, options ...BrokerOptions) *RedisCeleryBroker + func (cb *RedisCeleryBroker) GetCeleryMessage() (*CeleryMessage, error) + func (cb *RedisCeleryBroker) GetTask() (*CeleryTask, error) + func (cb *RedisCeleryBroker) SendCeleryMessage(message *CeleryMessage) error + type ResultMessage struct + Children []interface{} + ID string + Result interface{} + Status string + Traceback interface{} + type ST_Headers struct + ArgsRepr string + ETA time.Time + Expires time.Time + Group string + KwargsRepr string + Lang string + Origin string + ParentId string + Retries int + RootId string + Shadow string + Task string + TaskId string + TimeLimit [2]string + type ST_Properties struct + BodyEncoding string + CorrelationID string + CorrelationId string + DeliveryInfo CeleryDeliveryInfo + DeliveryMode int + DeliveryTag string + Priority int + ReplyTo string