single

package
v0.4.1-alpha.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2023 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterConnStore

type ClusterConnStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

type ClusterTopicStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

func (*ClusterTopicStore) Topics

func (s *ClusterTopicStore) Topics() (map[string]uint64, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL