| .. |
|
allocator_test.go
|
|
|
|
allocator.go
|
|
|
|
channel_checker_test.go
|
Make VChannelInfo read compatible with 2.0.2 (#17995)
|
2022-07-07 21:58:22 +08:00 |
|
channel_checker.go
|
Make VChannelInfo read compatible with 2.0.2 (#17995)
|
2022-07-07 21:58:22 +08:00 |
|
channel_manager_factory.go
|
|
|
|
channel_manager_test.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
channel_manager.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
channel_store_test.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
channel_store.go
|
Make VChannelInfo read compatible with 2.0.2 (#17995)
|
2022-07-07 21:58:22 +08:00 |
|
cluster_test.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
cluster.go
|
Fix an issue with bulk load with multiple DataNodes (#17324)
|
2022-06-02 18:54:04 +08:00 |
|
compaction_test.go
|
Fix test compact logic and data race (#18932)
|
2022-08-31 12:10:57 +08:00 |
|
compaction_trigger_test.go
|
fix GetCompactionState hang (#18829)
|
2022-08-26 14:22:55 +08:00 |
|
compaction_trigger.go
|
fix GetCompactionState hang (#18829)
|
2022-08-26 14:22:55 +08:00 |
|
compaction.go
|
fix GetCompactionState hang (#18829)
|
2022-08-26 14:22:55 +08:00 |
|
const.go
|
Add distributed lock for segment refgerence (#16782)
|
2022-05-31 16:36:03 +08:00 |
|
errors_test.go
|
|
|
|
errors.go
|
|
|
|
garbage_collector_test.go
|
Fix ParseSegmentIDBinlog panicks with bad input (#18413)
|
2022-07-26 19:32:30 +08:00 |
|
garbage_collector.go
|
Fix Parse binlog path failure (#18583)
|
2022-08-10 17:04:37 +08:00 |
|
handler.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
meta_test.go
|
Refactor for IndexCoord to support cloud (#18643)
|
2022-08-25 15:48:54 +08:00 |
|
meta_util.go
|
Make VChannelInfo read compatible with 2.0.2 (#17995)
|
2022-07-07 21:58:22 +08:00 |
|
meta.go
|
Refine save dropped segments into kv metastore (#18779)
|
2022-08-25 16:48:53 +08:00 |
|
metrics_info_test.go
|
|
|
|
metrics_info.go
|
Add ShowConfigurations for all remaining session (#18594)
|
2022-08-12 13:20:39 +08:00 |
|
mock_test.go
|
Refactor for IndexCoord to support cloud (#18643)
|
2022-08-25 15:48:54 +08:00 |
|
OWNERS
|
|
|
|
policy_test.go
|
Watch channels with start positions (#18744)
|
2022-08-22 14:42:52 +08:00 |
|
policy.go
|
Make VChannelInfo read compatible with 2.0.2 (#17995)
|
2022-07-07 21:58:22 +08:00 |
|
README.md
|
|
|
|
segment_allocation_policy_test.go
|
|
|
|
segment_allocation_policy.go
|
|
|
|
segment_info.go
|
Fix # of rows of recovering segment (#18736)
|
2022-08-19 19:50:50 +08:00 |
|
segment_manager_test.go
|
Unified catalog interface for segment (#18289) (#18290)
|
2022-08-20 10:24:51 +08:00 |
|
segment_manager.go
|
Move bulk load segment lock happen early (#17612)
|
2022-06-27 13:56:17 +08:00 |
|
segment_reference_manager_test.go
|
Acquiring the segment reference lock on task level (#17544)
|
2022-06-15 21:38:10 +08:00 |
|
segment_reference_manager.go
|
Fix DN flowgraph delete buffer logs (#18657)
|
2022-08-15 16:28:48 +08:00 |
|
server_test.go
|
Refactor for IndexCoord to support cloud (#18643)
|
2022-08-25 15:48:54 +08:00 |
|
server.go
|
Refactor for IndexCoord to support cloud (#18643)
|
2022-08-25 15:48:54 +08:00 |
|
services.go
|
fix GetCompactionState hang (#18829)
|
2022-08-26 14:22:55 +08:00 |
|
session_manager.go
|
refactor compaction concurency logic (#18660)
|
2022-08-23 15:50:52 +08:00 |
|
session.go
|
|
|
|
util_test.go
|
Refine compaction selection poliy (#17486)
|
2022-06-15 23:14:10 +08:00 |
|
util.go
|
Make DataNode not panic if stale segment is not found during flush (#18322)
|
2022-07-20 15:06:30 +08:00 |
43c14055f6