celery

Documentation

Index

• func QueueTask(rc redis.Conn, queueName string, taskName string, args interface{}) error
• type Task
• type TaskDeliveryInfo
• type TaskProperties

Functions

func QueueTask

func QueueTask(rc redis.Conn, queueName string, taskName string, args interface{}) error

QueueTask queues a new empty task with the passed in task name for the passed in queue

Types

type Task

type Task struct {
	Body            string                 `json:"body"`
	Headers         map[string]interface{} `json:"headers"`
	ContentType     string                 `json:"content-type"`
	Properties      TaskProperties         `json:"properties"`
	ContentEncoding string                 `json:"content-encoding"`
}

Task is the outer struct for a celery task

type TaskDeliveryInfo

type TaskDeliveryInfo struct {
	RoutingKey string `json:"routing_key"`
	Exchange   string `json:"exchange"`
}

TaskDeliveryInfo is the struct for a task's delivery information

type TaskProperties

type TaskProperties struct {
	BodyEncoding  string           `json:"body_encoding"`
	CorrelationID string           `json:"correlation_id"`
	ReplyTo       string           `json:"reply_to"`
	DeliveryInfo  TaskDeliveryInfo `json:"delivery_info"`
	DeliveryMode  int              `json:"delivery_mode"`
	DeliveryTag   string           `json:"delivery_tag"`
	Priority      int              `json:"priority"`
}

TaskProperties is the struct for a task's properties