From 3ee0e068e978c74fd4dfd0938be7d0936026b3b9 Mon Sep 17 00:00:00 2001 From: Sydonian <794346190@qq.com> Date: Sat, 16 Mar 2024 11:05:39 +0800 Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E6=88=B7ID=E4=BB=8E1=E5=BC=80?= =?UTF-8?q?=E5=A7=8B=EF=BC=8C0=E4=B8=BA=E6=97=A0=E6=95=88ID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- client/internal/cmdline/bucket.go | 6 +++--- client/internal/cmdline/cache.go | 2 +- client/internal/cmdline/storage.go | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/client/internal/cmdline/bucket.go b/client/internal/cmdline/bucket.go index a35dd56..208a449 100644 --- a/client/internal/cmdline/bucket.go +++ b/client/internal/cmdline/bucket.go @@ -8,7 +8,7 @@ import ( ) func BucketListUserBuckets(ctx CommandContext) error { - userID := cdssdk.UserID(0) + userID := cdssdk.UserID(1) buckets, err := ctx.Cmdline.Svc.BucketSvc().GetUserBuckets(userID) if err != nil { @@ -29,7 +29,7 @@ func BucketListUserBuckets(ctx CommandContext) error { } func BucketCreateBucket(ctx CommandContext, bucketName string) error { - userID := cdssdk.UserID(0) + userID := cdssdk.UserID(1) bucketID, err := ctx.Cmdline.Svc.BucketSvc().CreateBucket(userID, bucketName) if err != nil { @@ -41,7 +41,7 @@ func BucketCreateBucket(ctx CommandContext, bucketName string) error { } func BucketDeleteBucket(ctx CommandContext, bucketID cdssdk.BucketID) error { - userID := cdssdk.UserID(0) + userID := cdssdk.UserID(1) err := ctx.Cmdline.Svc.BucketSvc().DeleteBucket(userID, bucketID) if err != nil { diff --git a/client/internal/cmdline/cache.go b/client/internal/cmdline/cache.go index a94859e..08ab896 100644 --- a/client/internal/cmdline/cache.go +++ b/client/internal/cmdline/cache.go @@ -8,7 +8,7 @@ import ( ) func CacheMovePackage(ctx CommandContext, packageID cdssdk.PackageID, nodeID cdssdk.NodeID) error { - taskID, err := ctx.Cmdline.Svc.CacheSvc().StartCacheMovePackage(0, packageID, nodeID) + taskID, err := ctx.Cmdline.Svc.CacheSvc().StartCacheMovePackage(1, packageID, nodeID) if err != nil { return fmt.Errorf("start cache moving package: %w", err) } diff --git a/client/internal/cmdline/storage.go b/client/internal/cmdline/storage.go index 355e85c..e47665c 100644 --- a/client/internal/cmdline/storage.go +++ b/client/internal/cmdline/storage.go @@ -8,7 +8,7 @@ import ( ) func StorageLoadPackage(ctx CommandContext, packageID cdssdk.PackageID, storageID cdssdk.StorageID) error { - nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageLoadPackage(0, packageID, storageID) + nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageLoadPackage(1, packageID, storageID) if err != nil { return fmt.Errorf("start loading package to storage: %w", err) } @@ -31,7 +31,7 @@ func StorageLoadPackage(ctx CommandContext, packageID cdssdk.PackageID, storageI } func StorageCreatePackage(ctx CommandContext, bucketID cdssdk.BucketID, name string, storageID cdssdk.StorageID, path string) error { - nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageCreatePackage(0, bucketID, name, storageID, path, nil) + nodeID, taskID, err := ctx.Cmdline.Svc.StorageSvc().StartStorageCreatePackage(1, bucketID, name, storageID, path, nil) if err != nil { return fmt.Errorf("start storage uploading package: %w", err) }