message

Documentation

Overview

Message queue

Index

• type Iterator
• type Message
• type Queue
  • func NewInMemoryQueue() Queue
• type QueueFactory

Types

type Iterator

type Iterator interface {
	// advances the Iterator. if no more messages or an error occure it returns false.
	Next() bool
	Message() Message
	Error() error
}

type Message

type Message interface {
	Type() string
}

type Queue

type Queue interface {
	Close() error
	Enqueue(msg Message) error
	PendingMessages() bool  // indicates that the queue has pending messages
	DiscardMessages() error // Drop all pending messages in the queue
	Messages() Iterator
}

func NewInMemoryQueue

func NewInMemoryQueue() Queue

inMemoryQueue is concurrency safe for enqueue and dequeue but the returned iterator is not safe for concurrent access.

type QueueFactory

type QueueFactory func() Queue