add collection.delete

2 files changed, 15 insertions, 0 deletions

diff --git a/weed/storage/erasure_coding/ec_shard.go b/weed/storage/erasure_coding/ec_shard.go
index 037c4ba48..687a582a7 100644
--- a/weed/storage/erasure_coding/ec_shard.go
+++ b/weed/storage/erasure_coding/ec_shard.go
@@ -64,6 +64,10 @@ func (shard *EcVolumeShard) Close() {
 	}
 }
 
+func (shard *EcVolumeShard) Destroy() {
+	os.Remove(shard.FileName() + ToExt(int(shard.ShardId)))
+}
+
 func (shard *EcVolumeShard) ReadAt(buf []byte, offset int64) (int, error) {
 
 	return shard.ecdFile.ReadAt(buf, offset)
diff --git a/weed/storage/erasure_coding/ec_volume.go b/weed/storage/erasure_coding/ec_volume.go
index 32f66260a..28dbd8c7f 100644
--- a/weed/storage/erasure_coding/ec_volume.go
+++ b/weed/storage/erasure_coding/ec_volume.go
@@ -94,6 +94,17 @@ func (ev *EcVolume) Close() {
 	}
 }
 
+func (ev *EcVolume) Destroy() {
+
+	ev.Close()
+
+	baseFileName := EcShardFileName(ev.Collection, ev.dir, int(ev.VolumeId))
+	for _, s := range ev.Shards {
+		s.Destroy()
+	}
+	os.Remove(baseFileName + ".ecx")
+}
+
 func (ev *EcVolume) ToVolumeEcShardInformationMessage() (messages []*master_pb.VolumeEcShardInformationMessage) {
 	prevVolumeId := needle.VolumeId(math.MaxUint32)
 	var m *master_pb.VolumeEcShardInformationMessage