From cde707dd8b88c7d1bd730271518542eceb5ed069 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Mon, 26 Jan 2026 12:17:22 -0800 Subject: [PATCH] credential/grpc: refactor configuration calls to return error --- weed/credential/grpc/grpc_identity.go | 19 +++---------------- 1 file changed, 3 insertions(+), 16 deletions(-) diff --git a/weed/credential/grpc/grpc_identity.go b/weed/credential/grpc/grpc_identity.go index af0e5249e..391277823 100644 --- a/weed/credential/grpc/grpc_identity.go +++ b/weed/credential/grpc/grpc_identity.go @@ -2,30 +2,17 @@ package grpc import ( "context" + "fmt" "github.com/seaweedfs/seaweedfs/weed/pb/iam_pb" ) func (store *IamGrpcStore) LoadConfiguration(ctx context.Context) (*iam_pb.S3ApiConfiguration, error) { - var config *iam_pb.S3ApiConfiguration - err := store.withIamClient(func(client iam_pb.SeaweedIdentityAccessManagementClient) error { - resp, err := client.GetConfiguration(ctx, &iam_pb.GetConfigurationRequest{}) - if err != nil { - return err - } - config = resp.Configuration - return nil - }) - return config, err + return nil, fmt.Errorf("LoadConfiguration is not supported in gRPC credential store") } func (store *IamGrpcStore) SaveConfiguration(ctx context.Context, config *iam_pb.S3ApiConfiguration) error { - return store.withIamClient(func(client iam_pb.SeaweedIdentityAccessManagementClient) error { - _, err := client.PutConfiguration(ctx, &iam_pb.PutConfigurationRequest{ - Configuration: config, - }) - return err - }) + return fmt.Errorf("SaveConfiguration is not supported in gRPC credential store") } func (store *IamGrpcStore) CreateUser(ctx context.Context, identity *iam_pb.Identity) error {