broker

Documentation

Index

• type Broker
  • func NewBroker(mq *rabbitmq.RabbitMQ, logger logging.Logger, tracer trace.Tracer) *Broker
  • func (b *Broker) Consume(ctx context.Context, queue string, eventType event.EventType) (_ <-chan event.Event, err error)
  • func (b *Broker) Publish(ctx context.Context, e event.Event) (err error)
  • func (b *Broker) ResilientPublish(e event.Event) error

Types

type Broker

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

Broker is a wrapper for rabbitmq.RabbitMQ.

func NewBroker

func NewBroker(mq *rabbitmq.RabbitMQ, logger logging.Logger, tracer trace.Tracer) *Broker

func (*Broker) Consume

func (b *Broker) Consume(ctx context.Context, queue string, eventType event.EventType) (_ <-chan event.Event, err error)

func (*Broker) Publish

func (b *Broker) Publish(ctx context.Context, e event.Event) (err error)

func (*Broker) ResilientPublish

func (b *Broker) ResilientPublish(e event.Event) error

ResilientPublish returns an error only if the queue is full or if it failed to serialize the event.