head

package
v0.0.0-...-d86056c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 27, 2018 License: Apache-2.0 Imports: 6 Imported by: 7

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.

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.

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.

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.

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.

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.

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.

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.

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

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CMResult 

type CMResult int
const (
	CR_SUCCESS CMResult = iota
	CR_LATER
	CR_ROLLBACK
	CR_COMMIT
	CR_THROW_EXCEPTION
	CR_RETURN_NULL
)

func (CMResult) String 

func (cr CMResult) String() string

type CheckTransactionStateRequestHeader 

type CheckTransactionStateRequestHeader struct {
	MsgId                string
	TransactionId        string
	TranStateTableOffset int64
	CommitLogOffset      int64
}

CheckTransactionStateRequestHeader 检查事务状态的请求头 Author rongzhihong Since 2017/9/11

func (*CheckTransactionStateRequestHeader) CheckFields 

func (header *CheckTransactionStateRequestHeader) CheckFields() error

type CloneGroupOffsetRequestHeader 

type CloneGroupOffsetRequestHeader struct {
	SrcGroup  string `json:"srcGroup"`
	DestGroup string `json:"destGroup"`
	Topic     string `json:"topic"`
	Offline   bool   `json:"offline"`
}

CloneGroupOffsetRequestHeader 克隆cloneGroupOffset的请求头 Author rongzhihong Since 2017/9/19

func NewCloneGroupOffsetRequestHeader 

func NewCloneGroupOffsetRequestHeader(srcGroup, destGroup, topic string, isOffline bool) *CloneGroupOffsetRequestHeader

NewCloneGroupOffsetRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1

func (*CloneGroupOffsetRequestHeader) CheckFields 

func (header *CloneGroupOffsetRequestHeader) CheckFields() error

type ConsumeMessageDirectlyResult 

type ConsumeMessageDirectlyResult struct {
	Order          bool
	AutoCommit     bool
	ConsumeResult  CMResult
	Remark         string
	SpentTimeMills int64
}

func (*ConsumeMessageDirectlyResult) String 

func (r *ConsumeMessageDirectlyResult) String() string

type ConsumeMessageDirectlyResultRequestHeader 

type ConsumeMessageDirectlyResultRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	ClientId      string `json:"clientId"`
	MsgId         string `json:"msgId"`
	BrokerName    string `json:"brokerName"`
}

consumeMessageDirectlyResultRequestHeader consumeMessageDirectlyResult请求头 Author rongzhihong Since 2017/9/19

func (*ConsumeMessageDirectlyResultRequestHeader) CheckFields 

func (header *ConsumeMessageDirectlyResultRequestHeader) CheckFields() error

type ConsumerSendMsgBackRequestHeader 

type ConsumerSendMsgBackRequestHeader struct {
	Offset      int64  `json:"offset"`
	Group       string `json:"group"`
	DelayLevel  int32  `json:"delayLevel"`
	OriginMsgId string `json:"originMsgId"`
	OriginTopic string `json:"originTopic"`
	UnitMode    bool   `json:"unitMode"`
}

ConsumerSendMsgBackRequestHeader: 消费消息头 Author: yintongqiang Since: 2017/8/17

func NewConsumerSendMsgBackRequestHeader 

func NewConsumerSendMsgBackRequestHeader() *ConsumerSendMsgBackRequestHeader

初始化 ConsumerSendMsgBackRequestHeader Author gaoyanlei Since 2017/8/17

func (*ConsumerSendMsgBackRequestHeader) CheckFields 

func (header *ConsumerSendMsgBackRequestHeader) CheckFields() error

type CreateTopicRequestHeader 

type CreateTopicRequestHeader struct {
	Topic           string // 真正的topic名称是位于topicConfig.Topic字段
	DefaultTopic    string // 表示创建topic的key值
	ReadQueueNums   int32
	WriteQueueNums  int32
	Perm            int
	TopicFilterType basis.TopicFilterType
	TopicSysFlag    int
	Order           bool
}

CreateTopicRequestHeader: 创建topic头信息 Author: yintongqiang Since: 2017/8/17

func NewCreateTopicRequestHeader 

func NewCreateTopicRequestHeader(topicWithProjectGroup, defaultTopic string, topicConfig *base.TopicConfig) *CreateTopicRequestHeader

func (*CreateTopicRequestHeader) CheckFields 

func (header *CreateTopicRequestHeader) CheckFields() error

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 DeleteSubscriptionGroupRequestHeader 

type DeleteSubscriptionGroupRequestHeader struct {
	GroupName string
}

deleteSubscriptionGroup 删除消费分组的请求头 Author rongzhihong Since 2017/9/19

func (*DeleteSubscriptionGroupRequestHeader) CheckFields 

func (header *DeleteSubscriptionGroupRequestHeader) 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 DeleteTopicRequestHeader 

type DeleteTopicRequestHeader struct {
	Topic string `json:"topic"`
}

DeleteTopicRequestHeader 删除Topic Author gaoyanlei Since 2017/8/25

func (*DeleteTopicRequestHeader) CheckFields 

func (header *DeleteTopicRequestHeader) CheckFields() error

type EndTransactionRequestHeader 

type EndTransactionRequestHeader struct {
	ProducerGroup        string `json:"producerGroup"`
	TranStateTableOffset int64  `json:"tranStateTableOffset"`
	CommitLogOffset      int64  `json:"commitLogOffset"`
	CommitOrRollback     int64  `json:"commitOrRollback"`
	FromTransactionCheck bool   `json:"fromTransactionCheck"`
	MsgId                string `json:"msgId"`
	TransactionId        string `json:"transactionId"`
}

EndTransactionRequestHeader 事务请求头 Author rongzhihong Since 2017/9/18

func (*EndTransactionRequestHeader) CheckFields 

func (header *EndTransactionRequestHeader) CheckFields() error

type GetAllTopicConfigResponseHeader 

type GetAllTopicConfigResponseHeader struct {
}

GetAllTopicConfigResponseHeader 获得Topic配置的返回头 Author rongzhihong Since 2017/9/19

func (*GetAllTopicConfigResponseHeader) CheckFields 

func (header *GetAllTopicConfigResponseHeader) CheckFields() error

type GetBrokerConfigResponseHeader 

type GetBrokerConfigResponseHeader struct {
	Version string
}

GetBrokerConfigResponseHeader 获得Broker配置信息的返回头 Author rongzhihong Since 2017/9/19

func (*GetBrokerConfigResponseHeader) CheckFields 

func (header *GetBrokerConfigResponseHeader) CheckFields() error

type GetConsumerConnectionsRequestHeader 

type GetConsumerConnectionsRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
}

GetConsumerConnectionsRequestHeader 获得Toipc统计信息的请求头 Author rongzhihong Since 2017/9/19

func NewGetConsumerConnectionsRequestHeader 

func NewGetConsumerConnectionsRequestHeader(consumerGroup string) *GetConsumerConnectionsRequestHeader

NewGetConsumerConnectionsRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1

func (*GetConsumerConnectionsRequestHeader) CheckFields 

func (header *GetConsumerConnectionsRequestHeader) CheckFields() error

type GetConsumerRunningInfoRequestHeader 

type GetConsumerRunningInfoRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	ClientId      string `json:"clientId"`
	JstackEnable  bool   `json:"jstackEnable"`
}

GetConsumerRunningInfoRequestHeader 获取Consumer内存数据结构的请求头 Author rongzhihong Since 2017/9/19

func NewGetConsumerRunningInfoRequestHeader 

func NewGetConsumerRunningInfoRequestHeader(consumerGroup, clientId string, jstackEnable bool) *GetConsumerRunningInfoRequestHeader

NewGetConsumerRunningInfoRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6

func (*GetConsumerRunningInfoRequestHeader) CheckFields 

func (header *GetConsumerRunningInfoRequestHeader) CheckFields() error

type GetConsumerStatsRequestHeader 

type GetConsumerStatsRequestHeader struct {
	Topic         string `json:"topic"`
	ConsumerGroup string `json:"consumerGroup"`
}

GetConsumerStatsRequestHeader 获得消费者统计信息的请求头 Author rongzhihong Since 2017/9/19

func NewGetConsumerStatsRequestHeader 

func NewGetConsumerStatsRequestHeader(consumerGroup, topic string) *GetConsumerStatsRequestHeader

NewGetConsumerStatsRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1

func (*GetConsumerStatsRequestHeader) CheckFields 

func (header *GetConsumerStatsRequestHeader) CheckFields() error

type GetConsumerStatusRequestHeader 

type GetConsumerStatusRequestHeader struct {
	Topic      string `json:"topic"`
	Group      string `json:"group"`
	ClientAddr string `json:"clientAddr"`
}

GetConsumerStatusRequestHeader 获得消费者状态的请求头 Author rongzhihong Since 2017/9/19

func NewGetConsumerStatusRequestHeader 

func NewGetConsumerStatusRequestHeader(topic, group, clientAddr string) *GetConsumerStatusRequestHeader

NewGetConsumerStatusRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6

func (*GetConsumerStatusRequestHeader) CheckFields 

func (header *GetConsumerStatusRequestHeader) CheckFields() error

type GetConsumersByGroupRequestHeader 

type GetConsumersByGroupRequestHeader struct {
	ConsumerGroup string
}

GetConsumersByGroupRequestHeader: 获取消费列表 Author: yintongqiang Since: 2017/8/11

func (*GetConsumersByGroupRequestHeader) CheckFields 

func (header *GetConsumersByGroupRequestHeader) CheckFields() error

type GetEarliestMsgStoretimeRequestHeader 

type GetEarliestMsgStoretimeRequestHeader struct {
	Topic   string
	QueueId int32
}

GetEarliestMsgStoretimeRequestHeader 获得早期消息存储时间的请求头 Author rongzhihong Since 2017/9/19

func (*GetEarliestMsgStoretimeRequestHeader) CheckFields 

func (header *GetEarliestMsgStoretimeRequestHeader) CheckFields() error

type GetEarliestMsgStoretimeResponseHeader 

type GetEarliestMsgStoretimeResponseHeader struct {
	Timestamp int64
}

GetEarliestMsgStoretimeResponseHeader 获得早期消息存储时间的返回头 Author rongzhihong Since 2017/9/19

func (*GetEarliestMsgStoretimeResponseHeader) CheckFields 

func (header *GetEarliestMsgStoretimeResponseHeader) 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 GetMaxOffsetRequestHeader 

type GetMaxOffsetRequestHeader struct {
	Topic   string `json:"topic"`
	QueueId int    `json:"queueId"`
}

GetMaxOffsetRequestHeader: 获取队列最大offset Author: yintongqiang Since: 2017/8/23

func NewGetMaxOffsetRequestHeader 

func NewGetMaxOffsetRequestHeader() *GetMaxOffsetRequestHeader

func (*GetMaxOffsetRequestHeader) CheckFields 

func (header *GetMaxOffsetRequestHeader) CheckFields() error

type GetMaxOffsetResponseHeader 

type GetMaxOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

GetMaxOffsetResponseHeader: 最大偏移响应头 Author: yintongqiang Since: 2017/8/23

func (*GetMaxOffsetResponseHeader) CheckFields 

func (header *GetMaxOffsetResponseHeader) CheckFields() error

type GetMinOffsetRequestHeader 

type GetMinOffsetRequestHeader struct {
	Topic   string `json:"topic"`
	QueueId int32  `json:"queueId"`
}

GetMinOffsetRequestHeader 获得最小偏移量的请求头 Author rongzhihong Since 2017/9/19

func (*GetMinOffsetRequestHeader) CheckFields 

func (header *GetMinOffsetRequestHeader) CheckFields() error

type GetMinOffsetResponseHeader 

type GetMinOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

GetMinOffsetResponseHeader 获得最小偏移量的返回头 Author rongzhihong Since 2017/9/19

func (*GetMinOffsetResponseHeader) CheckFields 

func (header *GetMinOffsetResponseHeader) CheckFields() error

type GetProducerConnectionsRequestHeader 

type GetProducerConnectionsRequestHeader struct {
	ProducerGroup string `json:"producerGroup"`
}

GetProducerConnectionsRequestHeader 获得生产者连接信息请求头 Author rongzhihong Since 2017/9/19

func NewGetProducerConnectionsRequestHeader 

func NewGetProducerConnectionsRequestHeader(producerGroup string) *GetProducerConnectionsRequestHeader

NewGetProducerConnectionsRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6

func (*GetProducerConnectionsRequestHeader) CheckFields 

func (header *GetProducerConnectionsRequestHeader) 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 `json:"topic"`
}

GetTopicStatsInfoRequestHeader 获得Topic统计信息的请求头 Author rongzhihong Since 2017/9/19

func NewGetTopicStatsInfoRequestHeader 

func NewGetTopicStatsInfoRequestHeader(topic string) *GetTopicStatsInfoRequestHeader

NewGetTopicStatsInfoRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6

func (*GetTopicStatsInfoRequestHeader) CheckFields 

func (header *GetTopicStatsInfoRequestHeader) CheckFields() error

type GetTopicsByClusterRequestHeader 

type GetTopicsByClusterRequestHeader struct {
	Cluster string `json:"cluster"` // 集群名称
	Extra   bool   `json:"extra"`   // 是否额外查询topic、cluster对应关系
}

func (*GetTopicsByClusterRequestHeader) CheckFields 

func (header *GetTopicsByClusterRequestHeader) CheckFields() error

type NotifyConsumerIdsChangedRequestHeader 

type NotifyConsumerIdsChangedRequestHeader struct {
	ConsumerGroup string
}

NotifyConsumerIdsChangedRequestHeader 通知请求头部 Author: rongzhihong Since: 2017/9/11

func (*NotifyConsumerIdsChangedRequestHeader) CheckFields 

func (notify *NotifyConsumerIdsChangedRequestHeader) CheckFields() error

CheckFields Author: rongzhihong Since: 2017/9/11

type PullMessageRequestHeader 

type PullMessageRequestHeader struct {
	ConsumerGroup        string `json:"consumerGroup"`
	Topic                string `json:"topic"`
	QueueId              int32  `json:"queueId"`
	QueueOffset          int64  `json:"queueOffset"`
	MaxMsgNums           int    `json:"maxMsgNums"`
	SysFlag              int    `json:"sysFlag"`
	CommitOffset         int64  `json:"commitOffset"`
	SuspendTimeoutMillis int    `json:"suspendTimeoutMillis"`
	Subscription         string `json:"subscription"`
	SubVersion           int    `json:"subVersion"`
}

PullMessageRequestHeader: 拉取消息请求头信息 Author: yintongqiang Since: 2017/8/14

func (*PullMessageRequestHeader) CheckFields 

func (header *PullMessageRequestHeader) CheckFields() error

type PullMessageResponseHeader 

type PullMessageResponseHeader struct {
	SuggestWhichBrokerId int64 `json:"suggestWhichBrokerId"`
	NextBeginOffset      int64 `json:"nextBeginOffset"`
	MinOffset            int64 `json:"minOffset"`
	MaxOffset            int64 `json:"maxOffset"`
}

PullMessageResponseHeader: 拉取消息响应头 Author: yintongqiang Since: 2017/8/16

func (*PullMessageResponseHeader) CheckFields 

func (header *PullMessageResponseHeader) 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 QueryConsumerOffsetRequestHeader 

type QueryConsumerOffsetRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int32  `json:"queueId"`
}

QueryConsumerOffsetRequestHeader: 查询消费offset Author: yintongqiang Since: 2017/8/24

func (*QueryConsumerOffsetRequestHeader) CheckFields 

func (header *QueryConsumerOffsetRequestHeader) CheckFields() error

type QueryConsumerOffsetResponseHeader 

type QueryConsumerOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

QueryConsumerOffsetResponseHeader: 查询offset响应头 Author: yintongqiang Since: 2017/8/24

func (*QueryConsumerOffsetResponseHeader) CheckFields 

func (header *QueryConsumerOffsetResponseHeader) CheckFields() error

type QueryConsumerTimeSpanRequestHeader 

type QueryConsumerTimeSpanRequestHeader struct {
	Topic string `json:"topic"`
	Group string `json:"group"`
}

QueryConsumerTimeSpanRequestHeader 根据 topic 和 group 获取消息的时间跨度的请求头 Author rongzhihong Since 2017/9/19

func (*QueryConsumerTimeSpanRequestHeader) CheckFields 

func (header *QueryConsumerTimeSpanRequestHeader) CheckFields() error

type QueryCorrectionOffsetRequestHeader 

type QueryCorrectionOffsetRequestHeader struct {
	FilterGroups string `json:"filterGroups"`
	CompareGroup string `json:"compareGroup"`
	Topic        string `json:"topic"`
}

QueryCorrectionOffsetRequestHeader 查找被修正 offset (转发组件）的请求头 Author rongzhihong Since 2017/9/19

func (*QueryCorrectionOffsetRequestHeader) CheckFields 

func (header *QueryCorrectionOffsetRequestHeader) CheckFields() error

type QueryMessageRequestHeader 

type QueryMessageRequestHeader struct {
	Topic          string `json:"topic"`
	Key            string `json:"key"`
	MaxNum         int32  `json:"maxNum"`
	BeginTimestamp int64  `json:"beginTimestamp"`
	EndTimestamp   int64  `json:"endTimestamp"`
}

QueryMessageResponseHeader 查询消息请求头 Author rongzhihong Since 2017/9/18

func (QueryMessageRequestHeader) CheckFields 

func (query QueryMessageRequestHeader) CheckFields() error

type QueryMessageResponseHeader 

type QueryMessageResponseHeader struct {
	IndexLastUpdateTimestamp int64 `json:"indexLastUpdateTimestamp"`
	IndexLastUpdatePhyoffset int64 `json:"indexLastUpdatePhyoffset"`
}

QueryMessageResponseHeader 查询消息返回头 Author rongzhihong Since 2017/9/18

func (QueryMessageResponseHeader) CheckFields 

func (query QueryMessageResponseHeader) CheckFields() error

type QueryTopicConsumeByWhoRequestHeader 

type QueryTopicConsumeByWhoRequestHeader struct {
	Topic string
}

QueryTopicConsumeByWhoRequestHeader 查询Topic被哪些消费者消费的请求头 Author rongzhihong Since 2017/9/19

func (*QueryTopicConsumeByWhoRequestHeader) CheckFields 

func (header *QueryTopicConsumeByWhoRequestHeader) 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主节点地址
}

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

func NewRegisterBrokerResponseHeader 

func NewRegisterBrokerResponseHeader(haServerAddr, masterAddr string) *RegisterBrokerResponseHeader

func (*RegisterBrokerResponseHeader) CheckFields 

func (header *RegisterBrokerResponseHeader) CheckFields() error

type RegisterFilterServerRequestHeader 

type RegisterFilterServerRequestHeader struct {
	FilterServerAddr string `json:"filterServerAddr"`
}

RegisterFilterServerRequestHeader 注册过滤器的请求头 Author rongzhihong Since 2017/9/19

func (*RegisterFilterServerRequestHeader) CheckFields 

func (header *RegisterFilterServerRequestHeader) CheckFields() error

type RegisterFilterServerResponseHeader 

type RegisterFilterServerResponseHeader struct {
	BrokerName string `json:"brokerName"`
	BrokerId   int64  `json:"brokerId"`
}

RegisterFilterServerResponseHeader 注册过滤器的返回头 Author rongzhihong Since 2017/9/19

func (*RegisterFilterServerResponseHeader) CheckFields 

func (header *RegisterFilterServerResponseHeader) CheckFields() error

type ResetOffsetRequestHeader 

type ResetOffsetRequestHeader struct {
	Topic     string
	Group     string
	Timestamp int64
	IsForce   bool
}

ResetOffsetRequestHeader 重置偏移量的请求头 Author rongzhihong Since 2017/9/18

func (*ResetOffsetRequestHeader) CheckFields 

func (req *ResetOffsetRequestHeader) CheckFields() error

type SearchOffsetRequestHeader 

type SearchOffsetRequestHeader struct {
	Topic     string
	QueueId   int32
	Timestamp int64
}

SearchOffsetRequestHeader 查询偏移量的请求头 Author rongzhihong Since 2017/9/19

func (*SearchOffsetRequestHeader) CheckFields 

func (header *SearchOffsetRequestHeader) CheckFields() error

type SearchOffsetResponseHeader 

type SearchOffsetResponseHeader struct {
	Offset int64
}

SearchOffsetResponseHeader 查询偏移量的返回头 Author rongzhihong Since 2017/9/19

func (*SearchOffsetResponseHeader) CheckFields 

func (header *SearchOffsetResponseHeader) CheckFields() error

type SendMessageRequestHeader 

type SendMessageRequestHeader struct {
	ProducerGroup         string `json:"producerGroup"`
	Topic                 string `json:"topic"`
	DefaultTopic          string `json:"defaultTopic"`
	DefaultTopicQueueNums int32  `json:"defaultTopicQueueNums"`
	QueueId               int32  `json:"queueId"`
	SysFlag               int32  `json:"sysFlag"`
	BornTimestamp         int64  `json:"bornTimestamp"`
	Flag                  int32  `json:"flag"`
	Properties            string `json:"properties"`
	ReconsumeTimes        int32  `json:"reconsumeTimes"`
	UnitMode              bool   `json:"unitMode"`
}

SendMessageRequestHeader: 发送消息请求头信息 Author: yintongqiang Since: 2017/8/10

func CreateSendMessageRequestHeaderV1 

func CreateSendMessageRequestHeaderV1(v2 *SendMessageRequestHeaderV2) *SendMessageRequestHeader

CreateSendMessageRequestHeaderV1 v2转v1 Author gaoyanlei Since 2017/8/15

func (*SendMessageRequestHeader) CheckFields 

func (header *SendMessageRequestHeader) CheckFields() error

type SendMessageRequestHeaderV2 

type SendMessageRequestHeaderV2 struct {
	A string `json:"a"`
	B string `json:"b"`
	C string `json:"c"`
	D int32  `json:"d"`
	E int32  `json:"e"`
	F int32  `json:"f"`
	G int64  `json:"g"`
	H int32  `json:"h"`
	I string `json:"i"`
	J int32  `json:"j"`
	K bool   `json:"k"`
}

SendMessageRequestHeaderV2: 为减少网络传输数量准备 Author: yintongqiang Since: 2017/8/10

func CreateSendMessageRequestHeaderV2 

func CreateSendMessageRequestHeaderV2(v1 *SendMessageRequestHeader) *SendMessageRequestHeaderV2

func (*SendMessageRequestHeaderV2) CheckFields 

func (header *SendMessageRequestHeaderV2) CheckFields() error

type SendMessageResponseHeader 

type SendMessageResponseHeader struct {
	MsgId         string `json:"msgId"`
	QueueId       int32  `json:"queueId"`
	QueueOffset   int64  `json:"queueOffset"`
	TransactionId string `json:"transactionId"`
}

SendMessageResponseHeader: 发送消息响应头 Author: yintongqiang Since: 2017/8/16

func (*SendMessageResponseHeader) CheckFields 

func (header *SendMessageResponseHeader) 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 UnRegisterClientRequestHeader 

type UnRegisterClientRequestHeader struct {
	ClientID      string `json:"clientID"`
	ProducerGroup string `json:"producerGroup"`
	ConsumerGroup string `json:"consumerGroup"`
}

UnRegisterClientRequestHeader: 注销客户端 Author: yintongqiang Since: 2017/8/17

func (*UnRegisterClientRequestHeader) CheckFields 

func (header *UnRegisterClientRequestHeader) CheckFields() error

type UpdateConsumerOffsetRequestHeader 

type UpdateConsumerOffsetRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int    `json:"queueId"`
	CommitOffset  int64  `json:"commitOffset"`
}

UpdateConsumerOffsetRequestHeader: 更新消费offset的请求头 Author: yintongqiang Since: 2017/8/11

func (*UpdateConsumerOffsetRequestHeader) CheckFields 

func (header *UpdateConsumerOffsetRequestHeader) CheckFields() error

type ViewBrokerStatsDataRequestHeader 

type ViewBrokerStatsDataRequestHeader struct {
	StatsName string `json:"statsName"`
	StatsKey  string `json:"statsKey"`
}

ViewBrokerStatsDataRequestHeader 查看Broker统计信息的请求头 Author rongzhihong Since 2017/9/19

func (*ViewBrokerStatsDataRequestHeader) CheckFields 

func (header *ViewBrokerStatsDataRequestHeader) CheckFields() error

type ViewMessageRequestHeader 

type ViewMessageRequestHeader struct {
	Offset uint64 `json:"offset"`
}

ViewMessageRequestHeader 根据MsgId查询消息的请求头 Author rongzhihong Since 2017/9/18

func (*ViewMessageRequestHeader) CheckFields 

func (header *ViewMessageRequestHeader) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.