Versions in this module Expand all Collapse all v24 v24.12.6 Dec 6, 2024 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 + GetOnlineMap func(string) OnlineMap + RegisterChannel func(string) (Channel, error) + RegisterCounter func(string) (Counter, error) + RegisterOnlineMap func(string) (OnlineMap, error) + UnregisterChannel func(string) error + UnregisterCounter func(string) error + UnregisterOnlineMap func(string) error + type NoopManager struct + func (NoopManager) Close() error + func (NoopManager) GetChannel(string) Channel + func (NoopManager) GetCounter(string) Counter + func (NoopManager) GetOnlineMap(string) OnlineMap + func (NoopManager) RegisterChannel(string) (Channel, error) + func (NoopManager) RegisterCounter(string) (Counter, error) + func (NoopManager) RegisterOnlineMap(string) (OnlineMap, error) + func (NoopManager) Start() error + func (NoopManager) Type() interface{} + func (NoopManager) UnregisterChannel(string) error + func (NoopManager) UnregisterCounter(string) error + func (NoopManager) UnregisterOnlineMap(string) error + type OnlineMap interface + AddIP func(string) + Count func() int + List func() []string + func GetOrRegisterOnlineMap(m Manager, name string) (OnlineMap, error) Other modules containing this package github.com/morooi/xray-core
Go to main page