Commit f32f269
authored
enhance: Implement new FlushAllMessage and refactor flush all (milvus-io#45920)
This PR:
1. Define and implement the new FlushAllMessage.
2. Refactor FlushAll to flush the entire cluster.
issue: milvus-io#45919
---------
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>1 parent 8780e12 commit f32f269
52 files changed
Lines changed: 4743 additions & 5224 deletions
File tree
- client
- milvusclient
- internal
- datacoord
- flushcommon
- pipeline
- util
- writebuffer
- mocks
- flushcommon/mock_util
- streamingnode/server/wal/interceptors/shard/mock_shards
- proxy
- streamingcoord/server/broadcaster/registry
- streamingnode/server
- flusher/flusherimpl
- wal/interceptors/shard
- shards
- pkg
- proto
- datapb
- messagespb
- streaming/util/message
- adaptor
- codegen
- tests
- go_client
- integration/flushall
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
9 | | - | |
| 9 | + | |
10 | 10 | | |
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
16 | 15 | | |
17 | | - | |
18 | 16 | | |
19 | 17 | | |
20 | 18 | | |
| |||
94 | 92 | | |
95 | 93 | | |
96 | 94 | | |
| 95 | + | |
97 | 96 | | |
98 | 97 | | |
99 | 98 | | |
| |||
104 | 103 | | |
105 | 104 | | |
106 | 105 | | |
| 106 | + | |
107 | 107 | | |
108 | 108 | | |
109 | 109 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
330 | 330 | | |
331 | 331 | | |
332 | 332 | | |
333 | | - | |
334 | | - | |
| 333 | + | |
| 334 | + | |
335 | 335 | | |
336 | 336 | | |
337 | 337 | | |
| |||
0 commit comments