Documentation
¶
Index ¶
- func DeserializeToMQWrapperID(msgID []byte, walName string) (common.MessageID, error)
- func MustGetCommonpbMsgTypeFromMessageType(t message.MessageType) commonpb.MsgType
- func MustGetMQWrapperIDFromMessage(messageID message.MessageID) common.MessageID
- func MustGetMessageIDFromMQWrapperID(commonMessageID common.MessageID) message.MessageID
- func NewFlushMessageBody(msg message.ImmutableMessage) (msgstream.TsMsg, error)
- func NewMsgPackFromMessage(msgs ...message.ImmutableMessage) (*msgstream.MsgPack, error)
- type FlushMessageBody
- func (t FlushMessageBody) ID() msgstream.UniqueID
- func (t FlushMessageBody) Marshal(msgstream.TsMsg) (msgstream.MarshalType, error)
- func (t FlushMessageBody) SetID(id msgstream.UniqueID)
- func (t FlushMessageBody) SetTs(ts uint64)
- func (t FlushMessageBody) Size() int
- func (t FlushMessageBody) SourceID() int64
- func (t FlushMessageBody) Type() commonpb.MsgType
- func (t FlushMessageBody) Unmarshal(msgstream.MarshalType) (msgstream.TsMsg, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeserializeToMQWrapperID ¶
DeserializeToMQWrapperID deserializes messageID bytes to common.MessageID TODO: should be removed in future after common.MessageID is removed
func MustGetCommonpbMsgTypeFromMessageType ¶
func MustGetCommonpbMsgTypeFromMessageType(t message.MessageType) commonpb.MsgType
MustGetCommonpbMsgTypeFromMessageType returns the commonpb.MsgType from message.MessageType.
func MustGetMQWrapperIDFromMessage ¶
MustGetMQWrapperIDFromMessage converts message.MessageID to common.MessageID TODO: should be removed in future after common.MessageID is removed
func MustGetMessageIDFromMQWrapperID ¶
MustGetMessageIDFromMQWrapperID converts common.MessageID to message.MessageID TODO: should be removed in future after common.MessageID is removed
func NewFlushMessageBody ¶
func NewFlushMessageBody(msg message.ImmutableMessage) (msgstream.TsMsg, error)
func NewMsgPackFromMessage ¶
func NewMsgPackFromMessage(msgs ...message.ImmutableMessage) (*msgstream.MsgPack, error)
FromMessageToMsgPack converts message to msgpack. Same TimeTick must be sent with same msgpack. !!! Msgs must be keep same time tick. TODO: remove this function after remove the msgstream implementation.
Types ¶
type FlushMessageBody ¶
type FlushMessageBody struct {
*message.FlushMessageBody
// contains filtered or unexported fields
}
Source Files