Documentation ¶
Index ¶
- type ClusterConnStore
- type ClusterStore
- type ClusterTopicStore
- func (s *ClusterTopicStore) ClusterTopics() (map[string]uint64, error)
- func (s *ClusterTopicStore) GetTopicConnNum(topic string) (uint64, error)
- func (s *ClusterTopicStore) RemoveTopic(topic string) error
- func (s *ClusterTopicStore) TopicConnAtomicAddBy(topic string, num int64) error
- func (s *ClusterTopicStore) Topics() (map[string]uint64, error)
- type SingleProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterConnStore ¶
func (*ClusterConnStore) ClusterMembers ¶
func (s *ClusterConnStore) ClusterMembers() ([]string, error)
func (*ClusterConnStore) GetAllConnNum ¶
func (s *ClusterConnStore) GetAllConnNum() (uint64, error)
func (*ClusterConnStore) OneClientAtomicAddBy ¶
func (s *ClusterConnStore) OneClientAtomicAddBy(clientIP string, num int64) error
func (*ClusterConnStore) RemoveClient ¶
func (s *ClusterConnStore) RemoveClient(clientIP string) error
type ClusterStore ¶
type ClusterStore struct { }
func (*ClusterStore) ClusterNumber ¶
func (s *ClusterStore) ClusterNumber() (int64, error)
type ClusterTopicStore ¶
func (*ClusterTopicStore) ClusterTopics ¶
func (s *ClusterTopicStore) ClusterTopics() (map[string]uint64, error)
func (*ClusterTopicStore) GetTopicConnNum ¶
func (s *ClusterTopicStore) GetTopicConnNum(topic string) (uint64, error)
func (*ClusterTopicStore) RemoveTopic ¶
func (s *ClusterTopicStore) RemoveTopic(topic string) error
func (*ClusterTopicStore) TopicConnAtomicAddBy ¶
func (s *ClusterTopicStore) TopicConnAtomicAddBy(topic string, num int64) error
type SingleProvider ¶
type SingleProvider struct {
// contains filtered or unexported fields
}
func Provider ¶
func Provider() *SingleProvider
func Setup ¶
func Setup() (*SingleProvider, error)
func (*SingleProvider) ClusterConnStore ¶
func (s *SingleProvider) ClusterConnStore() store.ClusterConnStore
func (*SingleProvider) ClusterStore ¶
func (s *SingleProvider) ClusterStore() store.ClusterStore
func (*SingleProvider) ClusterTopicStore ¶
func (s *SingleProvider) ClusterTopicStore() store.ClusterTopicStore
Click to show internal directories.
Click to hide internal directories.