Versions in this module Expand all Collapse all v0 v0.0.1 Jun 20, 2023 Changes in this version + type Manager interface + AddSubscribe func(string, chan interface{}) + Close func(string) + ShutDown func() + TryPublish func(string, interface{}) + TrySendOnce func(ch chan interface{}, data interface{}) + UnSubscribe func(string, chan interface{}) + func GetSubscribeManager() Manager + func InitSubscribeManager() Manager + type ManagerImpl struct + func (c *ManagerImpl) AddSubscribe(key string, ch chan interface{}) + func (c *ManagerImpl) Close(key string) + func (c *ManagerImpl) ShutDown() + func (c *ManagerImpl) TryPublish(key string, data interface{}) + func (c *ManagerImpl) TrySendOnce(ch chan interface{}, data interface{}) + func (c *ManagerImpl) UnSubscribe(key string, ch chan interface{})