pagecache

package
v0.0.0-...-ba2213e Latest Latest
Warning

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

Go to latest
Published: Jun 21, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL