Documentation ¶
Index ¶
- Constants
- func DecodeAMQPMessageToRawTask(delivery amqp.Delivery) (b.RawTask, error)
- func LoadSummaryPost(summary b.TaskSummary, params ConnParams, queue string, priority uint8) error
- func LoadTasks(tasks b.TaskSet, params ConnParams, queue string, priority uint8, shuffle bool) (int, error)
- type ConnParams
- type Consumer
Constants ¶
View Source
const ( DefaultTls = false // Whether to use TLS connection by default DefaultPort = 5672 DefaultPriority = 5 // Default priority of tasks loaded into queue DefaultTaskQueue = "mida-tasks" DefaultBroadcastExchange = "mida-broadcast" DefaultPostQueue = "mida-complete" )
Variables ¶
This section is empty.
Functions ¶
func DecodeAMQPMessageToRawTask ¶
Takes an AMQP message (which is expected to be a MIDATask, in JSON format) and converts it into an actual MIDATask struct
func LoadSummaryPost ¶
func LoadSummaryPost(summary b.TaskSummary, params ConnParams, queue string, priority uint8) error
LoadSummaryPost loads task summary data into AMQP queue. Creates and tears down a new connections each time.
Types ¶
type ConnParams ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewAMQPBroadcastConsumer ¶
func NewAMQPBroadcastConsumer(params ConnParams, queue string) (*Consumer, <-chan amqp.Delivery, error)
NewAMQPControlConsumer connects to a AMQP which will be used for control messages rather than tasks
func NewAMQPTasksConsumer ¶
Click to show internal directories.
Click to hide internal directories.