registry

type BrokerHousekeepingService struct {
	NamesrvController *DefaultNamesrvController
}

type DefaultNamesrvController struct {
	NamesrvConfig             *namesrv.NamesrvConfig          // namesrv配置项
	RemotingServer            *remoting.DefalutRemotingServer // 远程请求server端
	RouteInfoManager          *RouteInfoManager               // topic路由管理器
	KvConfigManager           *KVConfigManager                // kv管理器
	BrokerHousekeepingService netm.ContextListener            // 扫描不活跃broker
	ScheduledExecutorService  *NamesrvControllerTask          // Namesrv定时器服务
	RequestProcessor          remoting.RequestProcessor       // 默认请求处理器
}

type DefaultRequestProcessor struct {
	NamesrvController *DefaultNamesrvController
}

type KVConfigManager struct {
	ConfigTable       map[string]map[string]string // 数据格式：Namespace[Key[Value]]
	ReadWriteLock     *sync.RWMutex
	NamesrvController *DefaultNamesrvController
}

type KVConfigSerializeWrapper struct {
	ConfigTable map[string]map[string]string `json:"configTable"` // 数据格式：Namespace[Key[Value]]
	*protocol.RemotingSerializable
}

type NamesrvControllerTask struct {
	NamesrvController *DefaultNamesrvController
	// contains filtered or unexported fields
}

type RouteInfoManager struct {
	TopicQueueTable   map[string][]*route.QueueData        // topic[list<QueueData>]
	BrokerAddrTable   map[string]*route.BrokerData         // brokerName[BrokerData]
	ClusterAddrTable  map[string]set.Set                   // clusterName[set<brokerName>]
	BrokerLiveTable   map[string]*routeinfo.BrokerLiveInfo // brokerAddr[brokerLiveTable]
	FilterServerTable map[string][]string                  // brokerAddr[FilterServer]
	ReadWriteLock     *sync.RWMutex                        // read & write lock
}