out

Documentation

Index

• type BrokerOuterAPI
  • func NewBrokerOuterAPI(defaultRemotingClient *remoting.DefalutRemotingClient) *BrokerOuterAPI
  • func (self *BrokerOuterAPI) FetchNameServerAddr() string
  • func (self *BrokerOuterAPI) GetAllConsumerOffset(brokerAddr string) *body.ConsumerOffsetSerializeWrapper
  • func (self *BrokerOuterAPI) GetAllDelayOffset(brokerAddr string) string
  • func (self *BrokerOuterAPI) GetAllSubscriptionGroupConfig(brokerAddr string) *body.SubscriptionGroupWrapper
  • func (self *BrokerOuterAPI) GetAllTopicConfig(brokerAddr string) *body.TopicConfigSerializeWrapper
  • func (self *BrokerOuterAPI) RegisterBroker(namesrvAddr, clusterName, brokerAddr, brokerName, haServerAddr string, ...) (*namesrv.RegisterBrokerResult, error)
  • func (self *BrokerOuterAPI) RegisterBrokerAll(clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64, ...) *namesrv.RegisterBrokerResult
  • func (self *BrokerOuterAPI) Shutdown()
  • func (self *BrokerOuterAPI) Start()
  • func (self *BrokerOuterAPI) UnRegisterBroker(namesrvAddr, clusterName, brokerAddr, brokerName string, brokerId int)
  • func (self *BrokerOuterAPI) UnRegisterBrokerAll(clusterName, brokerAddr, brokerName string, brokerId int)
  • func (self *BrokerOuterAPI) UpdateNameServerAddressList(namesrvAddrs string)

Types

type BrokerOuterAPI

type BrokerOuterAPI struct {
	// contains filtered or unexported fields
}

BrokerOuterAPI Broker对外调用的API封装 Author gaoyanlei Since 2017/8/22

func NewBrokerOuterAPI

func NewBrokerOuterAPI(defaultRemotingClient *remoting.DefalutRemotingClient) *BrokerOuterAPI

NewBrokerOuterAPI 初始化 Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) FetchNameServerAddr

func (self *BrokerOuterAPI) FetchNameServerAddr() string

FetchNameServerAddr 获取NameServerAddr Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) GetAllConsumerOffset

func (self *BrokerOuterAPI) GetAllConsumerOffset(brokerAddr string) *body.ConsumerOffsetSerializeWrapper

GetAllConsumerOffset 获取所有Consumer Offset Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) GetAllDelayOffset

func (self *BrokerOuterAPI) GetAllDelayOffset(brokerAddr string) string

GetAllDelayOffset 获取所有DelayOffset Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) GetAllSubscriptionGroupConfig

func (self *BrokerOuterAPI) GetAllSubscriptionGroupConfig(brokerAddr string) *body.SubscriptionGroupWrapper

GetAllSubscriptionGroupConfig 获取订阅组配置 Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) GetAllTopicConfig

func (self *BrokerOuterAPI) GetAllTopicConfig(brokerAddr string) *body.TopicConfigSerializeWrapper

GetAllTopicConfig 获取全部topic信息 Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) RegisterBroker

func (self *BrokerOuterAPI) RegisterBroker(namesrvAddr, clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64,
	topicConfigWrapper *body.TopicConfigSerializeWrapper, oneway bool, filterServerList []string) (*namesrv.RegisterBrokerResult, error)

RegisterBroker 向nameService注册broker Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) RegisterBrokerAll

func (self *BrokerOuterAPI) RegisterBrokerAll(clusterName, brokerAddr, brokerName,
	haServerAddr string, brokerId int64, topicConfigWrapper *body.TopicConfigSerializeWrapper, oneway bool,
	filterServerList []string) *namesrv.RegisterBrokerResult

RegisterBrokerAll 向nameservice注册所有broker Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) Shutdown

func (self *BrokerOuterAPI) Shutdown()

Shutdown 关闭 Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) Start

func (self *BrokerOuterAPI) Start()

Start 启动 Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) UnRegisterBroker

func (self *BrokerOuterAPI) UnRegisterBroker(namesrvAddr, clusterName, brokerAddr, brokerName string, brokerId int)

UnRegisterBroker 注销单个broker Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) UnRegisterBrokerAll

func (self *BrokerOuterAPI) UnRegisterBrokerAll(clusterName, brokerAddr, brokerName string, brokerId int)

UnRegisterBrokerAll 注销全部Broker Author gaoyanlei Since 2017/8/22

func (*BrokerOuterAPI) UpdateNameServerAddressList

func (self *BrokerOuterAPI) UpdateNameServerAddressList(namesrvAddrs string)

UpdateNameServerAddressList 更新nameService地址 Author gaoyanlei Since 2017/8/22