queue

Documentation

Index

• func AMQPLoadTasks(tasks []t.MIDATask) (int, error)
• func DecodeAMQPMessageToRawTask(delivery amqp.Delivery) (t.MIDATask, error)
• type Consumer
  • func NewAMQPBroadcastConsumer() (*Consumer, <-chan amqp.Delivery, error)
  • func NewAMQPTasksConsumer() (*Consumer, <-chan amqp.Delivery, error)
  • func (c *Consumer) Shutdown() error

Functions

func AMQPLoadTasks

func AMQPLoadTasks(tasks []t.MIDATask) (int, error)

Takes an array of MIDATasks and loads them into a RabbitMQ queue Requires the RabbitMQ URI (along with valid credentials)

func DecodeAMQPMessageToRawTask

func DecodeAMQPMessageToRawTask(delivery amqp.Delivery) (t.MIDATask, error)

Takes an AMQP message (which is expected to be a MIDATask, in JSON format) and converts it into an actual MIDATask struct

Types

type Consumer

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

func NewAMQPBroadcastConsumer

func NewAMQPBroadcastConsumer() (*Consumer, <-chan amqp.Delivery, error)

func NewAMQPTasksConsumer

func NewAMQPTasksConsumer() (*Consumer, <-chan amqp.Delivery, error)

func (*Consumer) Shutdown

func (c *Consumer) Shutdown() error

Graceful shutdown of a connection to AMQP