broker

Documentation

Index

• type Broker
• type Event
• type Handler
• type Message
• type Publisher

Types

type Broker

type Broker interface {
	Publisher
	Initialize() error
	Consume(group *sync.WaitGroup)
	Disconnect() error
	Subscribe(exchange, routingKey string, handler Handler) error
}

Broker is the interface which defines the client connection(s) to a concrete broker like amqp

type Event

type Event interface {
	Message() *Message
	Ack()
	Nack(retry bool)
	QueueName() string
	RoutingKey() string
	SetContext(ctx context.Context)
}

Event abstraction

type Handler

type Handler func(event Event)

type Message

type Message struct {
	Context context.Context
	Body    []byte
}

Message is the core structure of the broker. It abstract's away the concrete broker message implementations (e.g. amqp.Delivery).

type Publisher

type Publisher interface {
	Publish(exchange, routingKey string, message *Message) error
}

Publisher can publish messages with a routingKey to the message-broker