Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrBadConsumersCount = errors.New("max consumers should be greater then zero") ErrBadQueueSize = errors.New("max queue size should be greater then zero") ErrDuplicateConsumer = errors.New("consumer already subscribed") ErrQueueOverflow = errors.New("max queue size reached") ErrTooManyConsumers = errors.New("maximum consumers count reached") )
View Source
var ErrNotificationFailed = errors.New("notification failed")
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
NewConsumer создает нового подписчика.
Click to show internal directories.
Click to hide internal directories.