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.
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 *store.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, bufferResult store.BufferResult) *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 *store.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