| .. |
|
base
|
fix(scheduler): follower also should load normal disk
|
2026-04-21 09:23:09 +08:00 |
|
client
|
feat(scheduler): balance task access new alloc interface of cm
|
2026-04-21 09:23:09 +08:00 |
|
balancer_test.go
|
perf(scheduler): optimize volume lock and disk limiting conflicts
|
2026-04-21 09:23:09 +08:00 |
|
balancer.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
base_mock_test.go
|
feature(scheduler): batch consume kafka msg, kafka server manages offset
|
2023-11-08 12:37:10 +08:00 |
|
blob_deleter_test.go
|
feat(scheduler): support ip change for delete and shard repair process
|
2026-04-21 09:23:09 +08:00 |
|
blob_deleter.go
|
feat(scheduler): support ip change for delete and shard repair process
|
2026-04-21 09:23:09 +08:00 |
|
client_mock_test.go
|
feat(scheduler): balance task access new alloc interface of cm
|
2026-04-21 09:23:09 +08:00 |
|
cluster_topology_test.go
|
perf(scheduler): update volume cache failed error replace with error code
|
2024-11-12 11:01:05 +08:00 |
|
cluster_topology.go
|
fix(scheduler): follower also should load normal disk
|
2026-04-21 09:23:09 +08:00 |
|
config_test.go
|
refactor(scheduler): config kafka consumer version on support consumer group feature
|
2023-11-08 12:37:10 +08:00 |
|
config.go
|
fix(scheduler): init clusterID for shard disk repair mgr
|
2025-10-13 15:29:34 +08:00 |
|
disk_droper_test.go
|
perf(scheduler): optimize volume lock and disk limiting conflicts
|
2026-04-21 09:23:09 +08:00 |
|
disk_droper.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
disk_repairer_test.go
|
fix(scheduler): fixup repair task lock failed
|
2026-05-07 16:23:59 +08:00 |
|
disk_repairer.go
|
fix(scheduler): fixup repair task lock failed
|
2026-05-07 16:23:59 +08:00 |
|
manual_migrater_test.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
manual_migrater.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
migrate_test.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
migrate.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
scheduler_mock_test.go
|
feat(scheduler): support ip change for blobnode
|
2026-04-21 09:23:09 +08:00 |
|
scheduler_test.go
|
feat(cli): erase proxy cache by filter
|
2025-10-13 15:29:34 +08:00 |
|
service_test.go
|
feat(blobnode): access the client of clustermgr and shardnode
|
2025-07-08 11:30:14 +08:00 |
|
service.go
|
fix(scheduler): fix stats interface for not response delete
|
2025-10-13 15:29:35 +08:00 |
|
shard_disk_repairer_test.go
|
refactor(blobnode): some changes for code style
|
2025-07-08 11:30:14 +08:00 |
|
shard_disk_repairer.go
|
refactor(blobnode): some changes for code style
|
2025-07-08 11:30:14 +08:00 |
|
shard_migrate_test.go
|
fix(blobnode): remove bad unit which update id failed with cm
|
2025-07-08 11:30:16 +08:00 |
|
shard_migrate.go
|
fix(blobnode): remove bad unit which update id failed with cm
|
2025-07-08 11:30:16 +08:00 |
|
shard_repairer_test.go
|
feat(scheduler): support ip change for delete and shard repair process
|
2026-04-21 09:23:09 +08:00 |
|
shard_repairer.go
|
feat(scheduler): support ip change for delete and shard repair process
|
2026-04-21 09:23:09 +08:00 |
|
startup_test.go
|
feat(scheduler): report chunk miss migrate
|
2025-10-13 15:29:34 +08:00 |
|
startup.go
|
fix(scheduler): manual migrate task also should fresh disk info
|
2026-04-21 09:23:09 +08:00 |
|
volume_inspector_test.go
|
fix(scheduler): update disk info for inspect task
|
2026-04-21 09:23:09 +08:00 |
|
volume_inspector.go
|
fix(scheduler): update disk info for inspect task
|
2026-04-21 09:23:09 +08:00 |
