milvus/pkg/streaming/walimpls
chyezh 3563136c2a
enhance: timetick interceptor implementation (#34238)
issue: #33285

- optimize the message package
- add interceptor package to achieve append operation intercepting.
- add timetick interceptor to attach timetick properties for message.
- add timetick background task to send timetick message.

Signed-off-by: chyezh <chyezh@outlook.com>
2024-07-02 14:42:08 +08:00
..
helper enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00
impls enhance: timetick interceptor implementation (#34238) 2024-07-02 14:42:08 +08:00
registry enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00
builder.go enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00
opener.go enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00
scanner.go enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00
test_framework.go enhance: timetick interceptor implementation (#34238) 2024-07-02 14:42:08 +08:00
wal.go enhance: implement rmq and pulsar as wal (#34046) 2024-06-27 15:11:05 +08:00