Zhen Ye 4ba0ed3178

enhance: speed up streaming barrier timetick (#38787) ...

issue: #38399

- use last allocate but not last confirmed id to make barrier. 
- move the barrier logic into the timetick allocator.
- try to sync up local allocator and remote allocator when first barrier
check not pass to speed up.

Signed-off-by: chyezh <chyezh@outlook.com>

2024-12-27 15:08:50 +08:00

..

flusher

enhance: use lazy initializing client for streaming node (#38400)

2024-12-23 11:36:47 +08:00

resource

enhance: speed up streaming barrier timetick (#38787)

2024-12-27 15:08:50 +08:00

service

enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)

2024-11-11 17:24:29 +08:00

wal

enhance: speed up streaming barrier timetick (#38787)

2024-12-27 15:08:50 +08:00

walmanager

enhance: use lazy initializing client for streaming node (#38400)

2024-12-23 11:36:47 +08:00

builder.go

enhance: use lazy initializing client for streaming node (#38400)

2024-12-23 11:36:47 +08:00

server.go

enhance: implement kafka for wal (#38598)

2024-12-25 10:22:50 +08:00