Logo
Explore Help
Register Sign In
admin/milvus
1
0
Fork 0
You've already forked milvus
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity
milvus/internal/distributed/streaming
History
Zhen Ye 1b6edd0b4b
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
issue: #33285

- Modify the proto of consumer of streaming service.
- Make VChannel as a required option for streaming

---------

Signed-off-by: chyezh <chyezh@outlook.com>
2024-11-11 17:24:29 +08:00
..
internal
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
append.go
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
OWNERS
…
streaming_test.go
enhance: using streaming service in insert/upsert/flush/delete/querynode (#35406)
2024-08-29 10:03:08 +08:00
streaming.go
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
test_streaming.go
enhance: Append create partition msg to wal (#35398)
2024-08-13 14:28:20 +08:00
txn.go
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
util.go
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
wal_test.go
enhance: using streaming service in insert/upsert/flush/delete/querynode (#35406)
2024-08-29 10:03:08 +08:00
wal.go
enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564)
2024-11-11 17:24:29 +08:00
Powered by Gitea Version: 1.23.8 Page: 1152ms Template: 17ms
English
Bahasa Indonesia Deutsch English Español Français Gaeilge Italiano Latviešu Magyar nyelv Nederlands Polski Português de Portugal Português do Brasil Suomi Svenska Türkçe Čeština Ελληνικά Български Русский Українська فارسی മലയാളം 日本語 简体中文 繁體中文(台灣) 繁體中文(香港) 한국어
Licenses API