diff --git a/pkgs/mq/coordinator/package.go b/pkgs/mq/coordinator/package.go index d04cfad..faccbe4 100644 --- a/pkgs/mq/coordinator/package.go +++ b/pkgs/mq/coordinator/package.go @@ -19,9 +19,9 @@ type PackageService interface { DeletePackage(msg *DeletePackage) (*DeletePackageResp, *mq.CodeMessage) - GetCacheNodesByPackage(msg *GetCacheNodesByPackage) (*GetCacheNodesByPackageResp, *mq.CodeMessage) + GetPackageCachedNodes(msg *GetPackageCachedNodes) (*GetPackageCachedNodesResp, *mq.CodeMessage) - GetStorageNodesByPackage(msg *GetStorageNodesByPackage) (*GetStorageNodesByPackageResp, *mq.CodeMessage) + GetPackageLoadedNodes(msg *GetPackageLoadedNodes) (*GetPackageLoadedNodesResp, *mq.CodeMessage) } // 获取Package基本信息 @@ -205,61 +205,61 @@ func (client *Client) DeletePackage(msg DeletePackage) (*DeletePackageResp, erro } // 根据PackageID获取object分布情况 -var _ = Register(PackageService.GetCacheNodesByPackage) +var _ = Register(PackageService.GetPackageCachedNodes) -type GetCacheNodesByPackage struct { +type GetPackageCachedNodes struct { UserID int64 `json:"userID"` PackageID int64 `json:"packageID"` } -type GetCacheNodesByPackageResp struct { +type GetPackageCachedNodesResp struct { NodeIDs []int64 `json:"nodeIDs"` RedundancyType string `json:"redundancyType"` } -func NewGetCacheNodesByPackage(userID int64, packageID int64) GetCacheNodesByPackage { - return GetCacheNodesByPackage{ +func NewGetPackageCachedNodes(userID int64, packageID int64) GetPackageCachedNodes { + return GetPackageCachedNodes{ UserID: userID, PackageID: packageID, } } -func NewGetCacheNodesByPackageResp(nodeIDs []int64, redundancyType string) GetCacheNodesByPackageResp { - return GetCacheNodesByPackageResp{ +func NewGetPackageCachedNodesResp(nodeIDs []int64, redundancyType string) GetPackageCachedNodesResp { + return GetPackageCachedNodesResp{ NodeIDs: nodeIDs, RedundancyType: redundancyType, } } -func (client *Client) GetCacheNodesByPackage(msg GetCacheNodesByPackage) (*GetCacheNodesByPackageResp, error) { - return mq.Request[GetCacheNodesByPackageResp](client.rabbitCli, msg) +func (client *Client) GetPackageCachedNodes(msg GetPackageCachedNodes) (*GetPackageCachedNodesResp, error) { + return mq.Request[GetPackageCachedNodesResp](client.rabbitCli, msg) } // 根据PackageID获取storage分布情况 -var _ = Register(PackageService.GetStorageNodesByPackage) +var _ = Register(PackageService.GetPackageLoadedNodes) -type GetStorageNodesByPackage struct { +type GetPackageLoadedNodes struct { UserID int64 `json:"userID"` PackageID int64 `json:"packageID"` } -type GetStorageNodesByPackageResp struct { +type GetPackageLoadedNodesResp struct { NodeIDs []int64 `json:"nodeIDs"` } -func NewGetStorageNodesByPackage(userID int64, packageID int64) GetStorageNodesByPackage { - return GetStorageNodesByPackage{ +func NewGetPackageLoadedNodes(userID int64, packageID int64) GetPackageLoadedNodes { + return GetPackageLoadedNodes{ UserID: userID, PackageID: packageID, } } -func NewGetStorageNodesByPackageResp(nodeIDs []int64) GetStorageNodesByPackageResp { - return GetStorageNodesByPackageResp{ +func NewGetPackageLoadedNodesResp(nodeIDs []int64) GetPackageLoadedNodesResp { + return GetPackageLoadedNodesResp{ NodeIDs: nodeIDs, } } -func (client *Client) GetStorageNodesByPackage(msg GetStorageNodesByPackage) (*GetStorageNodesByPackageResp, error) { - return mq.Request[GetStorageNodesByPackageResp](client.rabbitCli, msg) +func (client *Client) GetPackageLoadedNodes(msg GetPackageLoadedNodes) (*GetPackageLoadedNodesResp, error) { + return mq.Request[GetPackageLoadedNodesResp](client.rabbitCli, msg) }