Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 4 additions & 6 deletions deps/rabbitmq_stream/docs/PROTOCOL.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -386,7 +386,7 @@ Deliver => Key Version SubscriptionId OsirisChunk
Key => uint16 // 0x0008
Version => uint16
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
ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot
NumEntries => uint16
Expand All @@ -397,9 +397,8 @@ Deliver => Key Version SubscriptionId OsirisChunk
ChunkCrc => int32
DataLength => 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
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
Message => EntryTypeAndSize
Data => bytes
Expand All @@ -413,7 +412,7 @@ Deliver => Key Version SubscriptionId CommittedOffset OsirisChunk
Version => uint16
SubscriptionId => uint8
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
ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot
NumEntries => uint16
Expand All @@ -424,9 +423,8 @@ Deliver => Key Version SubscriptionId CommittedOffset OsirisChunk
ChunkCrc => int32
DataLength => 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
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
Message => EntryTypeAndSize
Data => bytes
Expand Down