Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ManyMessageTransfer ¶
type ManyMessageTransfer struct {
// contains filtered or unexported fields
}
ManyMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
func NewManyMessageTransfer ¶
func NewManyMessageTransfer(remotingCommand *protocol.RemotingCommand, getMessageResult *stgstorelog.GetMessageResult) *ManyMessageTransfer
NewManyMessageTransfer 初始化 Author rongzhihong Since 2017/9/17
func (*ManyMessageTransfer) Bytes ¶
func (mmt *ManyMessageTransfer) Bytes() []byte
Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17
func (*ManyMessageTransfer) EncodeBody ¶
func (mmt *ManyMessageTransfer) EncodeBody()
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
type OneMessageTransfer ¶
type OneMessageTransfer struct {
// contains filtered or unexported fields
}
OneMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
func NewOneMessageTransfer ¶
func NewOneMessageTransfer(response *protocol.RemotingCommand, selectMapedBufferResult *stgstorelog.SelectMapedBufferResult) *OneMessageTransfer
NewOneMessageTransfer 初始化OneMessageTransfer Author rongzhihong Since 2017/9/17
func (*OneMessageTransfer) Bytes ¶
func (mmt *OneMessageTransfer) Bytes() []byte
Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17
func (*OneMessageTransfer) EncodeBody ¶
func (mmt *OneMessageTransfer) EncodeBody()
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
type QueryMessageTransfer ¶
type QueryMessageTransfer struct {
// contains filtered or unexported fields
}
OneMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
func NewQueryMessageTransfer ¶
func NewQueryMessageTransfer(response *protocol.RemotingCommand, queryMessageResult *stgstorelog.QueryMessageResult) *QueryMessageTransfer
NewOneMessageTransfer 初始化OneMessageTransfer Author rongzhihong Since 2017/9/17
func (*QueryMessageTransfer) Bytes ¶
func (omt *QueryMessageTransfer) Bytes() []byte
Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17
func (*QueryMessageTransfer) EncodeBody ¶
func (omt *QueryMessageTransfer) EncodeBody()
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
Source Files