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.

# Constants

the timeout key name in options.
the topic key name in options.

# 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.

# Type aliases

Option is callback function to edit Options.
Options is used to extend for subscribe method.