gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add message batch

Browse Source
This commit is contained in:
chrislu
2022-07-22 01:12:32 -07:00
parent 7576c244c4
commit 06cd491abc
5 changed files with 332 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
weed/pb/message.fbs
View File

@@ -3,13 +3,21 @@ table NameValue {
value:string;
}
table Message {
producer_id:int32 (id:0);
producer_seq:int64 (id:2);
segment_id:int32 (id:1);
segment_seq:int64 (id:3);
event_ts_ns:int64 (id:4);
recv_ts_ns:int64 (id:5);
properties:[NameValue] (id:6);
key:string (id:7); // bytes
data:string (id:8); // bytes
seq_delta:int32 (id:0);
ts_ms_delta:int32 (id:1);
properties:[NameValue] (id:2);
key:string (id:3); // bytes
data:string (id:4); // bytes
}
table MessageBatch {
producer_id:int32 (id:0);
producer_epoch:int32 (id:1);
segment_id:int32 (id:2);
flags: int32 (id:3);
segment_seq_base:int64 (id:4);
segment_seq_max_delta:int32 (id:5);
ts_ms_base:int64 (id:6);
ts_ms_max_delta:int32 (id:7);
messages: [Message] (id:8);
}