1 files changed, 32 insertions, 0 deletions
diff --git a/src/weed/operation/allocate_volume.go b/src/weed/operation/allocate_volume.go
new file mode 100644
index 000000000..1e016abf7
--- /dev/null
+++ b/src/weed/operation/allocate_volume.go
@@ -0,0 +1,32 @@
+package operation
+
+import (
+	"encoding/json"
+	"errors"
+	"net/url"
+	"weed/storage"
+	"weed/topology"
+	"weed/util"
+)
+
+type AllocateVolumeResult struct {
+	Error string
+}
+
+func AllocateVolume(dn *topology.DataNode, vid storage.VolumeId, repType storage.ReplicationType) error {
+	values := make(url.Values)
+	values.Add("volume", vid.String())
+	values.Add("replicationType", repType.String())
+	jsonBlob, err := util.Post("http://"+dn.Url()+"/admin/assign_volume", values)
+	if err != nil {
+		return err
+	}
+	var ret AllocateVolumeResult
+	if err := json.Unmarshal(jsonBlob, &ret); err != nil {
+		return err
+	}
+	if ret.Error != "" {
+		return errors.New(ret.Error)
+	}
+	return nil
+}