Changeset 407 in code for trunk/upstream.go

Timestamp:

Aug 20, 2020, 6:05:01 PM (5 years ago)

Author:

contact

Message:

Introduce internal message IDs

For now, these can be used as cursors in the logs. Future patches will
introduce functions that perform log queries with message IDs.

The IDs are state-less tokens containing all the required information to
refer to an on-disk log line: network name, entity name, date and byte
offset. The byte offset doesn't need to point to the first byte of the
line, any byte will do (note, this makes it so message IDs aren't
necessarily unique, we may want to change that in the future).

These internal message IDs are not exposed to clients because we don't
support upstream message IDs yet.

File:

• trunk/upstream.go (modified) (1 diff)

trunk/upstream.go

@@ -1624 +1624 @@
         }
 
-        if err := ml.Append(msg); err != nil {
+        if _, err := ml.Append(msg); err != nil {
                 uc.logger.Printf("failed to log message: %v", err)
         }