root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Remove Bloom filter data section for message delivery command 

Also update OsirisChunk entry to reflect current state.
This commit is contained in:
wrobell 2024-06-22 13:34:37 +01:00
parent 7335aaaf1b
commit 75278ddf21
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
deps/rabbitmq_stream/docs/PROTOCOL.adoc vendored
View File

@ -386,7 +386,7 @@ Deliver => Key Version SubscriptionId OsirisChunk
Key => uint16 // 0x0008 Key => uint16 // 0x0008
Version => uint16 Version => uint16
SubscriptionId => uint8 SubscriptionId => uint8
OsirisChunk => MagicVersion NumEntries NumRecords Epoch ChunkFirstOffset ChunkCrc DataLength Messages OsirisChunk => MagicVersion ChunkType NumEntries NumRecords Timestamp Epoch ChunkFirstOffset ChunkCrc DataLength TrailerLength BloomSize Reserved Messages
MagicVersion => int8 MagicVersion => int8
ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot
NumEntries => uint16 NumEntries => uint16
@ -397,9 +397,8 @@ Deliver => Key Version SubscriptionId OsirisChunk
ChunkCrc => int32 ChunkCrc => int32
DataLength => uint32 DataLength => uint32
TrailerLength => uint32 TrailerLength => uint32
BloomSize => uint8 // size of bloom filter data BloomSize => uint8 // size of bloom filter data, ignored at the moment
Reserved => uint24 // 24 bits reserved for future use Reserved => uint24 // 24 bits reserved for future use
BloomFilterData => [uint8] // bloom filter data, the size of the array is defined by BloomSize
Messages => [Message] // a continous collection of messages, the size of the array is defined by NumEntries Messages => [Message] // a continous collection of messages, the size of the array is defined by NumEntries
Message => EntryTypeAndSize Message => EntryTypeAndSize
Data => bytes Data => bytes
@ -413,7 +412,7 @@ Deliver => Key Version SubscriptionId CommittedOffset OsirisChunk
Version => uint16 Version => uint16
SubscriptionId => uint8 SubscriptionId => uint8
CommittedChunkId => uint64 CommittedChunkId => uint64
OsirisChunk => MagicVersion NumEntries NumRecords Epoch ChunkFirstOffset ChunkCrc DataLength Messages OsirisChunk => MagicVersion ChunkType NumEntries NumRecords Timestamp Epoch ChunkFirstOffset ChunkCrc DataLength TrailerLength BloomSize Reserved Messages
MagicVersion => int8 MagicVersion => int8
ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot
NumEntries => uint16 NumEntries => uint16
@ -424,9 +423,8 @@ Deliver => Key Version SubscriptionId CommittedOffset OsirisChunk
ChunkCrc => int32 ChunkCrc => int32
DataLength => uint32 DataLength => uint32
TrailerLength => uint32 TrailerLength => uint32
BloomSize => uint8 // size of bloom filter data BloomSize => uint8 // size of bloom filter data, ignored at the moment
Reserved => uint24 // 24 bits reserved for future use Reserved => uint24 // 24 bits reserved for future use
BloomFilterData => [uint8] // bloom filter data, the size of the array is defined by BloomSize
Messages => [Message] // a continous collection of messages, the size of the array is defined by NumEntries Messages => [Message] // a continous collection of messages, the size of the array is defined by NumEntries
Message => EntryTypeAndSize Message => EntryTypeAndSize
Data => bytes Data => bytes