Documentation ¶
Overview ¶
Package meta manages the global topology information.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidCluster = errors.New("invalid cluster")
)
Functions ¶
This section is empty.
Types ¶
type MetaStore ¶
type MetaStore interface { Name() string Start() Stop() // RefreshEvent is fired whenever meta data is refreshed. RefreshEvent() <-chan struct{} ZkCluster(cluster string) *zk.ZkCluster // ClusterNames returns all live cluster names within the current zone. ClusterNames() []string // AssignClusters is director of cluster distribution. AssignClusters() []map[string]string ZkAddrs() []string ZkChroot(cluster string) string // BrokerList returns the live brokers address list. BrokerList(cluster string) []string }
MetaStore is a generic storage that fetches topology meta data.
var Default MetaStore
Click to show internal directories.
Click to hide internal directories.