Versions in this module Expand all Collapse all v25 v25.1.30 Jan 31, 2025 v25.1.1 Jan 1, 2025 Changes in this version + var File_app_stats_config_proto protoreflect.FileDescriptor + type Channel struct + func NewChannel(config *ChannelConfig) *Channel + func (c *Channel) Close() error + func (c *Channel) Publish(ctx context.Context, msg interface{}) + func (c *Channel) Running() bool + func (c *Channel) Start() error + func (c *Channel) Subscribe() (chan interface{}, error) + func (c *Channel) Subscribers() []chan interface{} + func (c *Channel) Unsubscribe(subscriber chan interface{}) error + type ChannelConfig struct + Blocking bool + BufferSize int32 + SubscriberLimit int32 + func (*ChannelConfig) Descriptor() ([]byte, []int) + func (*ChannelConfig) ProtoMessage() + func (x *ChannelConfig) GetBlocking() bool + func (x *ChannelConfig) GetBufferSize() int32 + func (x *ChannelConfig) GetSubscriberLimit() int32 + func (x *ChannelConfig) ProtoReflect() protoreflect.Message + func (x *ChannelConfig) Reset() + func (x *ChannelConfig) String() string + type Config struct + func (*Config) Descriptor() ([]byte, []int) + func (*Config) ProtoMessage() + func (x *Config) ProtoReflect() protoreflect.Message + func (x *Config) Reset() + func (x *Config) String() string + type Counter struct + func (c *Counter) Add(delta int64) int64 + func (c *Counter) Set(newValue int64) int64 + func (c *Counter) Value() int64 + type Manager struct + func NewManager(ctx context.Context, config *Config) (*Manager, error) + func (*Manager) Type() interface{} + func (m *Manager) Close() error + func (m *Manager) GetChannel(name string) stats.Channel + func (m *Manager) GetCounter(name string) stats.Counter + func (m *Manager) GetOnlineMap(name string) stats.OnlineMap + func (m *Manager) RegisterChannel(name string) (stats.Channel, error) + func (m *Manager) RegisterCounter(name string) (stats.Counter, error) + func (m *Manager) RegisterOnlineMap(name string) (stats.OnlineMap, error) + func (m *Manager) Start() error + func (m *Manager) UnregisterChannel(name string) error + func (m *Manager) UnregisterCounter(name string) error + func (m *Manager) UnregisterOnlineMap(name string) error + func (m *Manager) VisitCounters(visitor func(string, stats.Counter) bool) + type OnlineMap struct + func NewOnlineMap() *OnlineMap + func (c *OnlineMap) AddIP(ip string) + func (c *OnlineMap) Count() int + func (c *OnlineMap) GetKeys() []string + func (c *OnlineMap) List() []string + func (c *OnlineMap) RemoveExpiredIPs(list map[string]time.Time) map[string]time.Time Other modules containing this package github.com/xmplusdev/xray-core github.com/xmplusdev/xray-core/v24
Go to main page