aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_grpc_admin.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-12-29 00:03:30 -0800
committerChris Lu <chris.lu@gmail.com>2018-12-29 00:03:30 -0800
commit0c932d17384f9bfcccf5dd523289165fe3083b45 (patch)
treefbfa1a9444747949cd96764daac86e67f966a580 /weed/server/volume_grpc_admin.go
parent03c7447ad6705c2b0d2e79400f0d55c9b5237668 (diff)
downloadseaweedfs-0c932d17384f9bfcccf5dd523289165fe3083b45.tar.xz
seaweedfs-0c932d17384f9bfcccf5dd523289165fe3083b45.zip
add volume delete grpc API
fix https://github.com/chrislusf/seaweedfs/issues/808
Diffstat (limited to 'weed/server/volume_grpc_admin.go')
-rw-r--r--weed/server/volume_grpc_admin.go16
1 files changed, 16 insertions, 0 deletions
diff --git a/weed/server/volume_grpc_admin.go b/weed/server/volume_grpc_admin.go
index f0b57b35a..429ca9b68 100644
--- a/weed/server/volume_grpc_admin.go
+++ b/weed/server/volume_grpc_admin.go
@@ -78,3 +78,19 @@ func (vs *VolumeServer) VolumeUnmount(ctx context.Context, req *volume_server_pb
return resp, err
}
+
+func (vs *VolumeServer) VolumeDelete(ctx context.Context, req *volume_server_pb.VolumeDeleteRequest) (*volume_server_pb.VolumeDeleteResponse, error) {
+
+ resp := &volume_server_pb.VolumeDeleteResponse{}
+
+ err := vs.store.DeleteVolume(storage.VolumeId(req.VolumdId))
+
+ if err != nil {
+ glog.Errorf("volume delete %v: %v", req, err)
+ } else {
+ glog.V(2).Infof("volume delete %v", req)
+ }
+
+ return resp, err
+
+}