Versions in this module Expand all Collapse all v0 v0.0.2 Feb 14, 2022 Changes in this version type PubSubManager + func (psm *PubSubManager) PublishWithoutDefault(msg interface{}) + func (psm *PubSubManager) Send(msg interface{}, channels ...string) + func (psm *PubSubManager) SendWithDefault(msg interface{}, channels ...string) v0.0.1 Jun 4, 2021 Changes in this version + var PubSub = NewPubSubManager() + type CloseListenerFunc func() + type PubSubManager struct + func NewPubSubManager() *PubSubManager + func (psm *PubSubManager) AddChannel(channelid string) + func (psm *PubSubManager) ChannelInUse(channelid string) bool + func (psm *PubSubManager) Channels() []string + func (psm *PubSubManager) CloseChannel(channelid string) + func (psm *PubSubManager) CloseNotify(channelid string) (ch <-chan struct{}, ok bool) + func (psm *PubSubManager) Publish(msg interface{}, channels ...string) + func (psm *PubSubManager) PublishWithDefault(msg interface{}, channels ...string) + func (psm *PubSubManager) RegistListener(channelid string, size int) (<-chan interface{}, <-chan struct{}, CloseListenerFunc, error)
Go to main page