diff options
| author | Michael Klishin <klishinm@vmware.com> | 2021-11-24 21:48:07 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-11-24 21:48:07 +0300 |
| commit | ce497a5b525b5399ecc08548bf98acb29c41b377 (patch) | |
| tree | 859ec0143b6f69cf2645c1079f80b92d75c31705 | |
| parent | a20a0f14f83d0911ac036ba148184d01fd12b1fa (diff) | |
| parent | 07dc62af7c914c639e55a58be5c52f5813fb50e4 (diff) | |
| download | rabbitmq-server-git-ce497a5b525b5399ecc08548bf98acb29c41b377.tar.gz | |
Merge pull request #3798 from wrobell/rabbitmq-streams-doc-protocol-timestamp
Link to most recent description of Osiris chunk format
| -rw-r--r-- | deps/rabbitmq_stream/docs/PROTOCOL.adoc | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/docs/PROTOCOL.adoc b/deps/rabbitmq_stream/docs/PROTOCOL.adoc index 34786dad30..60a8e48d3e 100644 --- a/deps/rabbitmq_stream/docs/PROTOCOL.adoc +++ b/deps/rabbitmq_stream/docs/PROTOCOL.adoc @@ -322,6 +322,9 @@ Subscribe => Key Version CorrelationId SubscriptionId Stream OffsetSpecification Value => string ``` +NB: Timestamp is https://www.erlang.org/doc/apps/erts/time_correction.html#Erlang_System_Time[Erlang system time], +milliseconds from epoch + === Deliver ``` @@ -334,7 +337,7 @@ Deliver => Key Version SubscriptionId OsirisChunk ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot NumEntries => uint16 NumRecords => uint32 - Timestamp => int64 // in milliseconds, since epoch + Timestamp => int64 // erlang system time in milliseconds, since epoch Epoch => uint64 ChunkFirstOffset => uint64 ChunkCrc => int32 @@ -346,7 +349,7 @@ Deliver => Key Version SubscriptionId OsirisChunk Data => bytes ``` -NB: See the https://github.com/rabbitmq/osiris/blob/348db0528986d6025b823bcf1ae0570aa63f5e25/src/osiris_log.erl#L49-L81[Osiris project] +NB: See the https://github.com/rabbitmq/osiris/blob/f32df7563a036b1687c0208a3cb5f9e8f5cee937/src/osiris_log.erl#L101[Osiris project] for details on the structure of messages. === Credit |