Versions in this module Expand all Collapse all v1 v1.0.1 Jan 18, 2024 v1.0.0 Jan 10, 2024 Changes in this version + func Count() int + func Decode(channelDescriptor string) (string, int) + func Start() error + func Stop() error + type Channel interface + Publish func(msg interface{}) + PublishNoWait func(msg interface{}) bool + RegisterCallback func(callback OnMessage) error + func Get(name string) Channel + func New(name string, bufferSize int) (Channel, error) + type OnMessage func(msg interface{})