client

Documentation

Overview

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• type CallOuterService
  • func NewCallOuterService(remotingClient remoting.RemotingClient) *CallOuterService
  • func (cos *CallOuterService) FetchNameServerAddr() string
  • func (cos *CallOuterService) GetAllConsumerOffset(brokerAddr string) *namesrv.ConsumerOffsetSerializeWrapper
  • func (cos *CallOuterService) GetAllDelayOffset(brokerAddr string) string
  • func (cos *CallOuterService) GetAllSubscriptionGroupConfig(brokerAddr string) *subscription.SubscriptionGroupWrapper
  • func (cos *CallOuterService) GetAllTopicConfig(brokerAddr string) *base.TopicConfigSerializeWrapper
  • func (cos *CallOuterService) RegisterBroker(nameSrvAddr, clusterName, brokerAddr, brokerName, haServerAddr string, ...) (*namesrv.RegisterBrokerResult, error)
  • func (cos *CallOuterService) RegisterBrokerAll(clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64, ...) *namesrv.RegisterBrokerResult
  • func (cos *CallOuterService) Shutdown()
  • func (cos *CallOuterService) Start()
  • func (cos *CallOuterService) UnRegisterBroker(nameSrvAddr, clusterName, brokerAddr, brokerName string, brokerId int) error
  • func (cos *CallOuterService) UnRegisterBrokerAll(clusterName, brokerAddr, brokerName string, brokerId int)
  • func (cos *CallOuterService) UpdateNameServerAddressList(nameSrvAddrs []string)
• type TOPAddr
  • func NewTOPAddr(addr string) *TOPAddr
  • func (taddr *TOPAddr) FetchNSAddr() string

Constants

const (
	WS_DOMAIN_NAME = "env.site.net"
)

Types

type CallOuterService

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

CallOuterService 调用Broker对外的接口封装

func NewCallOuterService

func NewCallOuterService(remotingClient remoting.RemotingClient) *CallOuterService

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

func (*CallOuterService) FetchNameServerAddr

func (cos *CallOuterService) FetchNameServerAddr() string

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

func (*CallOuterService) GetAllConsumerOffset

func (cos *CallOuterService) GetAllConsumerOffset(brokerAddr string) *namesrv.ConsumerOffsetSerializeWrapper

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

func (*CallOuterService) GetAllDelayOffset

func (cos *CallOuterService) GetAllDelayOffset(brokerAddr string) string

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

func (*CallOuterService) GetAllSubscriptionGroupConfig

func (cos *CallOuterService) GetAllSubscriptionGroupConfig(brokerAddr string) *subscription.SubscriptionGroupWrapper

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

func (*CallOuterService) GetAllTopicConfig

func (cos *CallOuterService) GetAllTopicConfig(brokerAddr string) *base.TopicConfigSerializeWrapper

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

func (*CallOuterService) RegisterBroker

func (cos *CallOuterService) RegisterBroker(nameSrvAddr, clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64,
	topicConfigWrapper *base.TopicConfigSerializeWrapper, oneway bool, filterServerList []string) (*namesrv.RegisterBrokerResult, error)

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

func (*CallOuterService) RegisterBrokerAll

func (cos *CallOuterService) RegisterBrokerAll(clusterName, brokerAddr, brokerName,
	haServerAddr string, brokerId int64, topicConfigWrapper *base.TopicConfigSerializeWrapper, oneway bool,
	filterServerList []string) *namesrv.RegisterBrokerResult

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

func (*CallOuterService) Shutdown

func (cos *CallOuterService) Shutdown()

Shutdown 关闭 Author gaoyanlei Since 2017/8/22

func (*CallOuterService) Start

func (cos *CallOuterService) Start()

Start 启动 Author gaoyanlei Since 2017/8/22

func (*CallOuterService) UnRegisterBroker

func (cos *CallOuterService) UnRegisterBroker(nameSrvAddr, clusterName, brokerAddr, brokerName string, brokerId int) error

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

func (*CallOuterService) UnRegisterBrokerAll

func (cos *CallOuterService) UnRegisterBrokerAll(clusterName, brokerAddr, brokerName string, brokerId int)

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

func (*CallOuterService) UpdateNameServerAddressList

func (cos *CallOuterService) UpdateNameServerAddressList(nameSrvAddrs []string)

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

type TOPAddr

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

TOPAddr 寻址服务 Author gaoyanlei Since 2017/8/9

func NewTOPAddr

func NewTOPAddr(addr string) *TOPAddr

NewTOPAddr TOPAddr Author gaoyanlei Since 2017/8/9

func (*TOPAddr) FetchNSAddr

func (taddr *TOPAddr) FetchNSAddr() string