com.taobao.metamorphosis.network
类 SyncCommand
java.lang.Object
com.taobao.metamorphosis.network.AbstractRequestCommand
com.taobao.metamorphosis.network.PutCommand
com.taobao.metamorphosis.network.SyncCommand
- 所有已实现的接口:
- com.taobao.gecko.core.command.Command, com.taobao.gecko.core.command.CommandHeader, com.taobao.gecko.core.command.RequestCommand, MetaEncodeCommand
public class SyncCommand
- extends PutCommand
同步复制,master/slave复制消息的协议,协议格式如下: sync topic partition value-length flag
msgId checksum opaque\r\ndata
- 作者:
- boyan(boyan@taobao.com)
从接口 com.taobao.metamorphosis.network.MetaEncodeCommand 继承的字段 |
CRLF, GET_CMD, OFFSET_CMD, PUT_CMD, QUIT_CMD, RESULT_CMD, SPACE, STATS_CMD, SYNC_CMD, TRANS_CMD, VALUE_CMD, VERSION_CMD |
SyncCommand
public SyncCommand(String topic,
int partition,
byte[] data,
int flag,
long msgId,
int checksum,
Integer opaque)
getMsgId
public long getMsgId()
encode
public com.taobao.gecko.core.buffer.IoBuffer encode()
- 从接口
MetaEncodeCommand
复制的描述
- 编码协议
- 指定者:
- 接口
MetaEncodeCommand
中的 encode
- 覆盖:
- 类
PutCommand
中的 encode
- 返回:
- 编码后的buffer
hashCode
public int hashCode()
- 覆盖:
- 类
PutCommand
中的 hashCode
equals
public boolean equals(Object obj)
- 覆盖:
- 类
PutCommand
中的 equals
toString
public String toString()
- 覆盖:
- 类
Object
中的 toString
Copyright © 2010–2013. All rights reserved.