diff options
| author | Chris Lu <chris.lu@uber.com> | 2019-03-19 05:19:37 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@uber.com> | 2019-03-19 05:19:37 -0700 |
| commit | eb4a54d9fe865eafb4de12db96b3e668b333fd1a (patch) | |
| tree | 1b98cca002c99c2e74abc5cc46a51e61b982df89 /weed/server/filer_grpc_server.go | |
| parent | ece9d133122fd15faa4efd1b4cec34974e3b37d0 (diff) | |
| download | seaweedfs-eb4a54d9fe865eafb4de12db96b3e668b333fd1a.tar.xz seaweedfs-eb4a54d9fe865eafb4de12db96b3e668b333fd1a.zip | |
refactoring
Diffstat (limited to 'weed/server/filer_grpc_server.go')
| -rw-r--r-- | weed/server/filer_grpc_server.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go index 13c66543b..6f7cf1ad6 100644 --- a/weed/server/filer_grpc_server.go +++ b/weed/server/filer_grpc_server.go @@ -238,7 +238,12 @@ func (fs *FilerServer) AssignVolume(ctx context.Context, req *filer_pb.AssignVol func (fs *FilerServer) DeleteCollection(ctx context.Context, req *filer_pb.DeleteCollectionRequest) (resp *filer_pb.DeleteCollectionResponse, err error) { - err = fs.filer.MasterClient.CollectionDelete(ctx, req.GetCollection()) + err = fs.filer.MasterClient.WithClient(ctx, func(ctx context.Context, client master_pb.SeaweedClient) error { + _, err := client.CollectionDelete(ctx, &master_pb.CollectionDeleteRequest{ + Name: req.GetCollection(), + }) + return err + }) return &filer_pb.DeleteCollectionResponse{}, err } |