fanhuadesenlinnn/cloudpods
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/yunionio/cloudpods.git synced 2026-09-20 08:03:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(cloudmon): sync cloudproviders (#21734)

Browse Source
This commit is contained in:
屈轩
2024-12-04 09:42:49 +08:00
committed by GitHub
parent 5ac581e750
commit b0d387e685
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/cloudmon/resources/resources.go
View File

@@ -153,7 +153,9 @@ func (self *SBaseResources) increment(ctx context.Context) error {
"order_by.1": "imported_at",
"order": "asc",
"filter.0": timeFilter,
"filter.1": "external_id.isnotempty()",
}
if self.manager.GetKeyword() != compute.Cloudproviders.GetKeyword() {
query["filter.1"] = "external_id.isnotempty()"
}
if self.manager.GetKeyword() == compute.Hosts.GetKeyword() {
query["cloud_env"] = "private_or_onpremise"
@@ -216,8 +218,11 @@ func (self *SBaseResources) decrement(ctx context.Context) error {
"delete": "all",
"@deleted": "true",
"filter.0": timeFilter,
"filter.1": "external_id.isnotempty()",
}
if self.manager.GetKeyword() != compute.Cloudproviders.GetKeyword() {
query["filter.1"] = "external_id.isnotempty()"
}
if self.manager.GetKeyword() == compute.Hosts.GetKeyword() {
query["cloud_env"] = "private_or_onpremise"
}
@@ -275,8 +280,11 @@ func (self *SBaseResources) update(ctx context.Context) error {
"order": "asc",
"pending_delete": "all",
"filter.0": timeFilter,
"filter.1": "external_id.isnotempty()",
}
if self.manager.GetKeyword() != compute.Cloudproviders.GetKeyword() {
query["filter.1"] = "external_id.isnotempty()"
}
if self.manager.GetKeyword() == compute.Hosts.GetKeyword() {
query["cloud_env"] = "private_or_onpremise"
}