store

Documentation

Index

• type ClusterConnStore
• type ClusterStore
• type ClusterTopicStore

Types

type ClusterConnStore

type ClusterConnStore interface {
	OneClientAtomicAddBy(clientIP string, num int64) error
	GetAllConnNum() (int64, error)
	RemoveClient(clientIP string) error
}

type ClusterStore

type ClusterStore interface {
	ClusterNumber() (int64, error)
}

type ClusterTopicStore

type ClusterTopicStore interface {
	TopicConnAtomicAddBy(topic string, num int64) error
	GetTopicConnNum(topic string) (int64, error)
	RemoveTopic(topic string) error
	Topics() ([]string, error)
}