queue

Documentation

Index

• func NewInMemory(logger *zap.Logger) *memoryQueue
• func NewNoop() *noopQueue
• type Message
• type Queue

Functions

func NewInMemory

func NewInMemory(logger *zap.Logger) *memoryQueue

func NewNoop

func NewNoop() *noopQueue

Types

type Message

type Message interface {
	// As unmarshals message into the given interface.
	As(interface{}) error
	// Ack marks the message as acknowleged.
	Ack() error
}

type Queue

type Queue interface {
	// Publish publishes a message to the queue.
	Publish(context.Context, names.IncompleteQueueName, interface{}) error
	// Subscribe returns a channel that will receive messages from the queue.
	Subscribe(context.Context, names.IncompleteQueueName, chan<- Message) error
}