mx

Documentation

Index

• Variables
• type Consumer
• type DelayProducer
• type DelayQueue
• type Handler
• type Message
• type Producer
• type Queue

Variables

var (
	ErrClosedQueue = errors.New("closed queue")
)

Types

type Consumer

type Consumer interface {
	Dequeue(handler Handler) error

	Close() error
}

type DelayProducer

type DelayProducer interface {
	Enqueue(data []byte) error

	DeferredEnqueue(delay time.Duration, data []byte) error

	MultiEnqueue(data ...[]byte) error

	Close() error
}

type DelayQueue

type DelayQueue interface {
	Enqueue(data []byte) error

	DeferredEnqueue(delay time.Duration, data []byte) error

	MultiEnqueue(data ...[]byte) error

	Dequeue(group string, handler Handler) error

	Close() error
}

type Handler

type Handler func(m Message) bool

type Message

type Message interface {
	Topic() string

	Value() []byte
}

type Producer

type Producer interface {
	Enqueue(data []byte) error

	MultiEnqueue(data ...[]byte) error

	Close() error
}

type Queue

type Queue interface {
	Enqueue(data []byte) error

	MultiEnqueue(data ...[]byte) error

	Dequeue(group string, handler Handler) error

	Close() error
}