Versions in this module Expand all Collapse all v4 v4.41.0 Jun 24, 2021 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) RegisterChannel(name string) (stats.Channel, error) + func (m *Manager) RegisterCounter(name string) (stats.Counter, error) + func (m *Manager) Start() error + func (m *Manager) UnregisterChannel(name string) error + func (m *Manager) UnregisterCounter(name string) error + func (m *Manager) VisitCounters(visitor func(string, stats.Counter) bool)
Go to main page