package
0.0.0-20211022090819-101e1e6589cc
Repository: https://github.com/jarod2011/toolkit.git
Documentation: pkg.go.dev
# Functions
NewMemoryBroker is build a Broker implement by memory.
WithTimeout is set subscriber receive message timeout.
WithTopic is set message topic or set subscriber only subscribe some topic.
# Variables
ErrBrokerClosed is defined broker close error.
# Structs
MemoryBroker is a Broker implement by Memory use map and channel.
# Interfaces
Broker is defined a message queue broker.