pubsub

Documentation

Index

• type Consumer
• type HandlerFunc
• type Message
• type Producer

Types

type Consumer

type Consumer interface {
	Consume(context.Context, HandlerFunc) error
}

Consumer of messages from a message queue

type HandlerFunc

type HandlerFunc func(ctx context.Context, msg Message) error

HandlerFunc for the consumer

type Message

type Message interface {
	// Ack nowledges and accepts a message
	Ack()
	// Nack (not acklowdges) a message and requeue it
	Nack()
	// Data returns the byte data of a message
	Data() []byte
}

Message of an event. The message has to be abstracted to be used in an business environment, so that a possible switch to a different message queue is possible in the future.

type Producer

type Producer interface {
	Produce(ctx context.Context, data []byte) error
}

Producer interface for message queue implementation