Versions in this module Expand all Collapse all v1 v1.5.6 Mar 27, 2022 Changes in this version + func ManagerType() interface + func SubscribeRunnableChannel(c Channel) (chan interface{}, error) + func UnsubscribeClosableChannel(c Channel, sub chan interface{}) error + type Channel interface + Publish func(context.Context, interface{}) + Subscribe func() (chan interface{}, error) + Subscribers func() []chan interface{} + Unsubscribe func(chan interface{}) error + func GetOrRegisterChannel(m Manager, name string) (Channel, error) + type Counter interface + Add func(int64) int64 + Set func(int64) int64 + Value func() int64 + func GetOrRegisterCounter(m Manager, name string) (Counter, error) + type Manager interface + GetChannel func(string) Channel + GetCounter func(string) Counter + RegisterChannel func(string) (Channel, error) + RegisterCounter func(string) (Counter, error) + UnregisterChannel func(string) error + UnregisterCounter func(string) error + type NoopManager struct + func (NoopManager) Close() error + func (NoopManager) GetChannel(string) Channel + func (NoopManager) GetCounter(string) Counter + func (NoopManager) RegisterChannel(string) (Channel, error) + func (NoopManager) RegisterCounter(string) (Counter, error) + func (NoopManager) Start() error + func (NoopManager) Type() interface{} + func (NoopManager) UnregisterChannel(string) error + func (NoopManager) UnregisterCounter(string) error
Go to main page