JointCloud
/
JCC-CSScheduler
mirror of https://gitlink.org.cn/cloudream/scheduler.git
24
0
Fork 2
Code Issues Packages Projects Releases Wiki Activity

CDS接口调整

This commit is contained in:
Sydonian 2024-03-18 10:12:04 +08:00
parent 88ef6daaf5
commit 0d83a52c0e
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
collector/internal/mq/storage.go
View File

@ -17,7 +17,7 @@ func (svc *Service) PackageGetCachedStgNodes(msg *colmq.PackageGetCachedStgNodes
}
defer schglb.CloudreamStoragePool.Release(stgCli)
resp, err := stgCli.PackageGetCachedNodes(cdssdk.PackageGetCachedNodesReq{
resp, err := stgCli.Package().GetCachedNodes(cdssdk.PackageGetCachedNodesReq{
PackageID: msg.PackageID,
UserID: msg.UserID,
})
@ -37,7 +37,7 @@ func (svc *Service) PackageGetLoadedStgNodes(msg *colmq.PackageGetLoadedStgNodes
}
defer schglb.CloudreamStoragePool.Release(stgCli)
resp, err := stgCli.PackageGetLoadedNodes(cdssdk.PackageGetLoadedNodesReq{
resp, err := stgCli.Package().GetLoadedNodes(cdssdk.PackageGetLoadedNodesReq{
PackageID: msg.PackageID,
UserID: msg.UserID,
})

2
manager/internal/jobmgr/adjusting_handler.go
View File

@ -283,7 +283,7 @@ func (h *AdjustingHandler) doImageScheduling(evt event.Event, job *adjustingJob,
}
defer schglb.CloudreamStoragePool.Release(stgCli)
pkgObjs, err := stgCli.ObjectGetPackageObjects(cdssdk.ObjectGetPackageObjectsReq{UserID: 1, PackageID: *file.PackageID})
pkgObjs, err := stgCli.Object().GetPackageObjects(cdssdk.ObjectGetPackageObjectsReq{UserID: 1, PackageID: *file.PackageID})
if err != nil {
return fmt.Errorf("getting package objects: %w", err)
}

2
manager/internal/jobmgr/prescheduling_handler.go
View File

@ -351,7 +351,7 @@ func (h *PreSchedulingHandler) doImageScheduling(evt event.Event, job *preSchedu
}
defer schglb.CloudreamStoragePool.Release(stgCli)
pkgObjs, err := stgCli.ObjectGetPackageObjects(cdssdk.ObjectGetPackageObjectsReq{UserID: 1, PackageID: *file.PackageID})
pkgObjs, err := stgCli.Object().GetPackageObjects(cdssdk.ObjectGetPackageObjectsReq{UserID: 1, PackageID: *file.PackageID})
if err != nil {
return fmt.Errorf("getting package objects: %w", err)
}