diff options
Diffstat (limited to 'weed/pb/mq_schema.proto')
| -rw-r--r-- | weed/pb/mq_schema.proto | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/pb/mq_schema.proto b/weed/pb/mq_schema.proto index 2deeadb55..81b523bcd 100644 --- a/weed/pb/mq_schema.proto +++ b/weed/pb/mq_schema.proto @@ -30,11 +30,15 @@ enum OffsetType { EXACT_TS_NS = 10; RESET_TO_LATEST = 15; RESUME_OR_LATEST = 20; + // Offset-based positioning + EXACT_OFFSET = 25; + RESET_TO_OFFSET = 30; } message PartitionOffset { Partition partition = 1; int64 start_ts_ns = 2; + int64 start_offset = 3; // For offset-based positioning } /////////////////////////// |