taskqueue

Documentation

Index

• type AmqpMessage
  • func (m *AmqpMessage) Body() []byte
  • func (m *AmqpMessage) Parse(jsonObj interface{}) error
• type Broker
• type Client
  • func NewAmqpClient(url string, config amqp.Config, routingKeyPrefix string) Client
• type Message

Types

type AmqpMessage

type AmqpMessage struct {
	Delivery amqp.Delivery
}

func (*AmqpMessage) Body

func (m *AmqpMessage) Body() []byte

func (*AmqpMessage) Parse

func (m *AmqpMessage) Parse(jsonObj interface{}) error

type Broker

type Broker interface {
	Publish(body interface{}) error
	Consume(ctx context.Context) (chan Message, error)
	Ack(msg Message) error
	Nack(msg Message, requeue bool) error
}

type Client

type Client interface {
	health.Provider
	Broker(routingKey string) (Broker, error)
	Shutdown() error
}

func NewAmqpClient

func NewAmqpClient(url string, config amqp.Config, routingKeyPrefix string) Client

type Message

type Message interface {
	Body() []byte
	Parse(jsonObj interface{}) error
}