taskqueue

Documentation

Index

• type Consumer
  • func NewConsumer(consumer rabbitmq.Consumer, queueName, routingKey string) *Consumer
  • func (c *Consumer) StartConsuming(handler func(taskID uuid.UUID) error) error
• type Producer
  • func NewProducer(publisher *rabbitmq.Publisher, exchangeName string, routingKey string) *Producer
  • func (p *Producer) Produce(task Task) error
• type Task

Types

type Consumer

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

func NewConsumer

func NewConsumer(consumer rabbitmq.Consumer, queueName, routingKey string) *Consumer

func (*Consumer) StartConsuming

func (c *Consumer) StartConsuming(handler func(taskID uuid.UUID) error) error

StartConsuming consumes tasks and calls handler for each of them. If a message cannot be unmarshalled, it's discarded. If handler fails, the message is requeued. Otherwise, the message is acked.

type Producer

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

func NewProducer

func NewProducer(publisher *rabbitmq.Publisher, exchangeName string, routingKey string) *Producer

func (*Producer) Produce

func (p *Producer) Produce(task Task) error

type Task

type Task struct {
	ID uuid.UUID `json:"id"`
}