namesrv

Documentation

Index

• type DeleteKVConfigRequestHeader
  • func (header *DeleteKVConfigRequestHeader) CheckFields() error
• type DeleteTopicInNamesrvRequestHeader
  • func (header *DeleteTopicInNamesrvRequestHeader) CheckFields() error
• type GetKVConfigRequestHeader
  • func (header *GetKVConfigRequestHeader) CheckFields() error
• type GetKVConfigResponseHeader
  • func (header *GetKVConfigResponseHeader) CheckFields() error
• type GetKVListByNamespaceRequestHeader
  • func (header *GetKVListByNamespaceRequestHeader) CheckFields() error
• type GetRouteInfoRequestHeader
  • func (header *GetRouteInfoRequestHeader) CheckFields() error
• type GetTopicStatsInfoRequestHeader
  • func (header *GetTopicStatsInfoRequestHeader) CheckFields() error
• type PutKVConfigRequestHeader
  • func (header *PutKVConfigRequestHeader) CheckFields() error
• type RegisterBrokerRequestHeader
  • func NewRegisterBrokerRequestHeader(clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64) *RegisterBrokerRequestHeader
  • func (header *RegisterBrokerRequestHeader) CheckFields() error
• type RegisterBrokerResponseHeader
  • func NewRegisterBrokerResponseHeader(haServerAddr, masterAddr string) *RegisterBrokerResponseHeader
  • func (self *RegisterBrokerResponseHeader) CheckFields() error
• type UnRegisterBrokerRequestHeader
  • func NewUnRegisterBrokerRequestHeader(brokerName, brokerAddr, clusterName string, brokerId int) *UnRegisterBrokerRequestHeader
  • func (header *UnRegisterBrokerRequestHeader) CheckFields() error
• type WipeWritePermOfBrokerRequestHeader
  • func (header *WipeWritePermOfBrokerRequestHeader) CheckFields() error
• type WipeWritePermOfBrokerResponseHeader
  • func (header *WipeWritePermOfBrokerResponseHeader) CheckFields() error

Types

type DeleteKVConfigRequestHeader

type DeleteKVConfigRequestHeader struct {
	Namespace string
	Key       string
}

DeleteKVConfigRequestHeader 删除KV配置项-请求头 Author: tianyuliang Since: 2017/9/4

func (*DeleteKVConfigRequestHeader) CheckFields

func (header *DeleteKVConfigRequestHeader) CheckFields() error

type DeleteTopicInNamesrvRequestHeader

type DeleteTopicInNamesrvRequestHeader struct {
	Topic string
}

DeleteTopicInNamesrvRequestHeader 删除Topic-请求头 Author: tianyuliang Since: 2017/9/4

func (*DeleteTopicInNamesrvRequestHeader) CheckFields

func (header *DeleteTopicInNamesrvRequestHeader) CheckFields() error

type GetKVConfigRequestHeader

type GetKVConfigRequestHeader struct {
	Namespace string `json:"namespace"`
	Key       string `json:"key"`
}

GetKVConfigRequestHeader: 创建头请求信息 Author: yintongqiang Since: 2017/8/23

func (*GetKVConfigRequestHeader) CheckFields

func (header *GetKVConfigRequestHeader) CheckFields() error

type GetKVConfigResponseHeader

type GetKVConfigResponseHeader struct {
	Value string `json:"value"`
}

GetKVConfigResponseHeader: 响应头 Author: yintongqiang Since: 2017/8/23

func (*GetKVConfigResponseHeader) CheckFields

func (header *GetKVConfigResponseHeader) CheckFields() error

type GetKVListByNamespaceRequestHeader

type GetKVListByNamespaceRequestHeader struct {
	Namespace string
}

func (*GetKVListByNamespaceRequestHeader) CheckFields

func (header *GetKVListByNamespaceRequestHeader) CheckFields() error

type GetRouteInfoRequestHeader

type GetRouteInfoRequestHeader struct {
	Topic string
}

GetRouteInfoRequestHeader: 获取topic路由信息头 Author: yintongqiang Since: 2017/8/16

func (*GetRouteInfoRequestHeader) CheckFields

func (header *GetRouteInfoRequestHeader) CheckFields() error

type GetTopicStatsInfoRequestHeader

type GetTopicStatsInfoRequestHeader struct {
	Topic string
}

GetTopicStatsInfoRequestHeader 获取topic统计信息头 Author: jerrylou, <gunsluo@gmail.com> Since: 2017-08-25

func (*GetTopicStatsInfoRequestHeader) CheckFields

func (header *GetTopicStatsInfoRequestHeader) CheckFields() error

type PutKVConfigRequestHeader

type PutKVConfigRequestHeader struct {
	Namespace string `json:"namespace"`
	Key       string `json:"key"`
	Value     string `json:"value"`
}

PutKVConfigRequestHeader 向Namesrv追加KV配置-请求头 Author: tianyuliang Since: 2017/9/4

func (*PutKVConfigRequestHeader) CheckFields

func (header *PutKVConfigRequestHeader) CheckFields() error

type RegisterBrokerRequestHeader

type RegisterBrokerRequestHeader struct {
	BrokerName   string // broker名称
	BrokerAddr   string // broker地址(ip:port)
	ClusterName  string // 集群名字
	HaServerAddr string // ha地址
	BrokerId     int64  // brokerId
}

RegisterBrokerRequestHeader 注册Broker-请求头 Author gaoyanlei Since 2017/8/22

func NewRegisterBrokerRequestHeader

func NewRegisterBrokerRequestHeader(clusterName, brokerAddr, brokerName, haServerAddr string, brokerId int64) *RegisterBrokerRequestHeader

func (*RegisterBrokerRequestHeader) CheckFields

func (header *RegisterBrokerRequestHeader) CheckFields() error

type RegisterBrokerResponseHeader

type RegisterBrokerResponseHeader struct {
	HaServerAddr string // broker备节点地址
	MasterAddr   string // broker主节点地址
}

RegisterBrokerRequestHeader 注册Broker-响应头 Author gaoyanlei Since 2017/8/22

func NewRegisterBrokerResponseHeader

func NewRegisterBrokerResponseHeader(haServerAddr, masterAddr string) *RegisterBrokerResponseHeader

func (*RegisterBrokerResponseHeader) CheckFields

func (self *RegisterBrokerResponseHeader) CheckFields() error

type UnRegisterBrokerRequestHeader

type UnRegisterBrokerRequestHeader struct {
	BrokerName  string // broker名字
	BrokerAddr  string // broker地址
	ClusterName string // 集群名字
	BrokerId    int    // brokerId
}

UnRegisterBrokerRequestHeader 注销broker-请求头信息 Author gaoyanlei Since 2017/8/22

func NewUnRegisterBrokerRequestHeader

func NewUnRegisterBrokerRequestHeader(brokerName, brokerAddr, clusterName string, brokerId int) *UnRegisterBrokerRequestHeader

func (*UnRegisterBrokerRequestHeader) CheckFields

func (header *UnRegisterBrokerRequestHeader) CheckFields() error

type WipeWritePermOfBrokerRequestHeader

type WipeWritePermOfBrokerRequestHeader struct {
	BrokerName string // broker名称
}

WipeWritePermOfBrokerRequestHeader 优雅地向Broker写数据-请求头 Author: tianyuliang Since: 2017/9/4

func (*WipeWritePermOfBrokerRequestHeader) CheckFields

func (header *WipeWritePermOfBrokerRequestHeader) CheckFields() error

type WipeWritePermOfBrokerResponseHeader

type WipeWritePermOfBrokerResponseHeader struct {
	WipeTopicCount int
}

WipeWritePermOfBrokerResponseHeader 优雅地向Broker写数据-响应头 Author: tianyuliang Since: 2017/9/4

func (*WipeWritePermOfBrokerResponseHeader) CheckFields

func (header *WipeWritePermOfBrokerResponseHeader) CheckFields() error