registry

Documentation

Index

• func NewBrokerHousekeepingService(controller *DefaultNamesrvController) netm.ContextListener
• func NewDefaultRequestProcessor(controller *DefaultNamesrvController) remoting.RequestProcessor
• type BrokerHousekeepingService
  • func (self *BrokerHousekeepingService) OnContextClose(ctx netm.Context)
  • func (self *BrokerHousekeepingService) OnContextConnect(ctx netm.Context)
  • func (self *BrokerHousekeepingService) OnContextError(ctx netm.Context)
  • func (self *BrokerHousekeepingService) OnContextIdle(ctx netm.Context)
• type DefaultNamesrvController
  • func CreateNamesrvController(registryPort int) *DefaultNamesrvController
  • func NewNamesrvController(namesrvConfig *namesrv.NamesrvConfig, ...) *DefaultNamesrvController
  • func Startup(stopChannel chan bool, registryPort int) *DefaultNamesrvController
• type DefaultRequestProcessor
  • func (self *DefaultRequestProcessor) ProcessRequest(ctx netm.Context, request *protocol.RemotingCommand) (*protocol.RemotingCommand, error)
• type KVConfigManager
  • func NewKVConfigManager(controller *DefaultNamesrvController) *KVConfigManager
• type KVConfigSerializeWrapper
  • func NewKVConfigSerializeWrapper(configTable map[string]map[string]string) *KVConfigSerializeWrapper
• type NamesrvControllerTask
  • func NewNamesrvControllerTask(controller *DefaultNamesrvController) *NamesrvControllerTask
• type RouteInfoManager
  • func NewRouteInfoManager() *RouteInfoManager

Functions

func NewBrokerHousekeepingService

func NewBrokerHousekeepingService(controller *DefaultNamesrvController) netm.ContextListener

NewBrokerHousekeepingService 初始化Broker活动检测服务 Author: tianyuliang Since: 2017/9/6

func NewDefaultRequestProcessor

func NewDefaultRequestProcessor(controller *DefaultNamesrvController) remoting.RequestProcessor

NewDefaultRequestProcessor 初始化NameServer网络请求处理 Author: tianyuliang Since: 2017/9/6

Types

type BrokerHousekeepingService

type BrokerHousekeepingService struct {
	NamesrvController *DefaultNamesrvController
}

BrokerHousekeepingServices Broker活动检测服务

(1)ContextListener是smartnet模块封装接口 (2)NameSrv监测Broker的死亡：当Broker和NameSrv之间的长连接断掉之后，回调ContextListener对应的函数，从而触发NameServer的路由信息更新

Author: tianyuliang Since: 2017/9/6

func (*BrokerHousekeepingService) OnContextClose

func (self *BrokerHousekeepingService) OnContextClose(ctx netm.Context)

OnContextClose 关闭Channel,通知Topic路由管理器，清除无效Broker Author: tianyuliang Since: 2017/9/6

func (*BrokerHousekeepingService) OnContextConnect

func (self *BrokerHousekeepingService) OnContextConnect(ctx netm.Context)

OnContextConnect 创建Channel连接 Author: tianyuliang Since: 2017/9/6

func (*BrokerHousekeepingService) OnContextError

func (self *BrokerHousekeepingService) OnContextError(ctx netm.Context)

OnContextError Channel出现异常,通知Topic路由管理器，清除无效Broker Author: tianyuliang Since: 2017/9/6

func (*BrokerHousekeepingService) OnContextIdle

func (self *BrokerHousekeepingService) OnContextIdle(ctx netm.Context)

OnContextIdle Channe的Idle时间超时,通知Topic路由管理器，清除无效Brokers Author: tianyuliang Since: 2017/9/6

type 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       // 默认请求处理器
}

DefaultNamesrvController 注意循环引用 Author: tianyuliang Since: 2017/9/6

func CreateNamesrvController

func CreateNamesrvController(registryPort int) *DefaultNamesrvController

CreateNamesrvController 创建默认Namesrv控制器 Author: tianyuliang Since: 2017/9/15

func NewNamesrvController

func NewNamesrvController(namesrvConfig *namesrv.NamesrvConfig, remotingServer *remoting.DefalutRemotingServer) *DefaultNamesrvController

NewNamesrvController 初始化默认的NamesrvController Author: tianyuliang Since: 2017/9/12

func Startup

func Startup(stopChannel chan bool, registryPort int) *DefaultNamesrvController

Startup 启动Namesrv控制器 Author: tianyuliang Since: 2017/9/14

type DefaultRequestProcessor

type DefaultRequestProcessor struct {
	NamesrvController *DefaultNamesrvController
}

DefaultRequestProcessor NameServer网络请求处理结构体 Author: tianyuliang Since: 2017/9/6

func (*DefaultRequestProcessor) ProcessRequest

func (self *DefaultRequestProcessor) ProcessRequest(ctx netm.Context, request *protocol.RemotingCommand) (*protocol.RemotingCommand, error)

ProcessRequest 默认请求处理器 Author: tianyuliang Since: 2017/9/6

type KVConfigManager

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

KVConfigManager KV配置管理器 Author: tianyuliang Since: 2017/9/8

func NewKVConfigManager

func NewKVConfigManager(controller *DefaultNamesrvController) *KVConfigManager

NewKVConfigManager 初始化KV配置管理器 // NamesrvController *stgregistry.DefaultNamesrvController Author: tianyuliang Since: 2017/9/6

type KVConfigSerializeWrapper

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

KVConfigSerializeWrapper KV配置的json序列化结构 Author: tianyuliang Since: 2017/9/4

func NewKVConfigSerializeWrapper

func NewKVConfigSerializeWrapper(configTable map[string]map[string]string) *KVConfigSerializeWrapper

NewKVConfigSerializeWrapper 初始化KV配置 Author: tianyuliang Since: 2017/9/4

type NamesrvControllerTask

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

func NewNamesrvControllerTask

func NewNamesrvControllerTask(controller *DefaultNamesrvController) *NamesrvControllerTask

type RouteInfoManager

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
}

RouteInfoManager Topic路由管理器 Author: tianyuliang Since: 2017/9/6

func NewRouteInfoManager

func NewRouteInfoManager() *RouteInfoManager

NewRouteInfoManager 初始化Topic路由管理器 Author: tianyuliang Since: 2017/9/6