| .. |
|
base
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +08:00 |
|
client
|
refactor(common): auto set the default value of task switch key to cm
|
2024-07-15 11:03:57 +08:00 |
|
balancer_test.go
|
refactor(scheduler): clean up deleted balance tasks if exits in clustermanager
|
2023-03-21 10:32:29 +08:00 |
|
balancer.go
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +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
|
perf(scheduler): update volume cache failed error replace with error code
|
2024-11-12 11:01:05 +08:00 |
|
blob_deleter.go
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +08:00 |
|
client_mock_test.go
|
refactor(common): auto set the default value of task switch key to cm
|
2024-07-15 11:03:57 +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
|
perf(scheduler): update volume cache failed error replace with error code
|
2024-11-12 11:01:05 +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(blobnode): wait all physics chunk file is remove, and then close disk handler
|
2024-04-25 10:27:27 +08:00 |
|
disk_droper_test.go
|
fix(scheduler): fix statics of scheduler incorrect
|
2024-07-15 11:03:57 +08:00 |
|
disk_droper.go
|
chore(common): add new context function of tracer
|
2024-11-12 11:01:05 +08:00 |
|
disk_repairer_test.go
|
feat(scheduler): add disk migrating stats interface
|
2023-03-21 10:30:28 +08:00 |
|
disk_repairer.go
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +08:00 |
|
manual_migrater_test.go
|
style(scheduler): rename taskId to taskID
|
2022-10-12 10:21:39 +08:00 |
|
manual_migrater.go
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +08:00 |
|
migrate_test.go
|
fix(scheduler): update volume unit failed, first get latest volume info to comfirm whether updated
|
2024-07-29 15:13:21 +08:00 |
|
migrate.go
|
fix(scheduler): update volume unit failed, first get latest volume info to comfirm whether updated
|
2024-07-29 15:13:21 +08:00 |
|
scheduler_mock_test.go
|
refactor(scheduler): update process of drop disk for scheduler
|
2024-04-17 16:29:24 +08:00 |
|
scheduler_test.go
|
feat(scheduler): support consumer group
|
2023-06-02 17:03:10 +08:00 |
|
service_test.go
|
fix(scheduler): reclaim from clustermgr with source vuid
|
2024-08-07 10:27:22 +08:00 |
|
service.go
|
fix(scheduler): reclaim from clustermgr with source vuid
|
2024-08-07 10:27:22 +08:00 |
|
shard_repairer_test.go
|
perf(scheduler): update volume cache failed error replace with error code
|
2024-11-12 11:01:05 +08:00 |
|
shard_repairer.go
|
fix(code scan): fix code-scanning problems.
|
2023-11-28 12:32:15 +08:00 |
|
startup_test.go
|
fix(scheduler): kafka offset metric is not accurate,update kafka offset getter
|
2023-11-08 12:37:10 +08:00 |
|
startup.go
|
refactor(scheduler): update process of drop disk for scheduler
|
2024-04-17 16:29:24 +08:00 |
|
volume_inspector_test.go
|
style(scheduler): rename scheduler api structs
|
2022-10-12 10:21:39 +08:00 |
|
volume_inspector.go
|
chore(blobstore): format code with new gofumt
|
2024-07-19 09:42:11 +08:00 |
