diff options
| author | Chris Lu <chris.lu@gmail.com> | 2014-03-09 23:54:07 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2014-03-09 23:54:07 -0700 |
| commit | a121453188f14ac3580bf61b47268bf029d61390 (patch) | |
| tree | 8c72b2455111bd8e85c2d027a253bc42c6fde7bc /go/operation/assign_file_id.go | |
| parent | eac9c4d86b7c7c9683504566e680bfb6531bfbff (diff) | |
| download | seaweedfs-a121453188f14ac3580bf61b47268bf029d61390.tar.xz seaweedfs-a121453188f14ac3580bf61b47268bf029d61390.zip | |
benchmarking writing data to a specific collection
Diffstat (limited to 'go/operation/assign_file_id.go')
| -rw-r--r-- | go/operation/assign_file_id.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/go/operation/assign_file_id.go b/go/operation/assign_file_id.go index a6680cbb8..4941d3c86 100644 --- a/go/operation/assign_file_id.go +++ b/go/operation/assign_file_id.go @@ -17,12 +17,15 @@ type AssignResult struct { Error string `json:"error"` } -func Assign(server string, count int, replication string) (*AssignResult, error) { +func Assign(server string, count int, replication string, collection string) (*AssignResult, error) { values := make(url.Values) values.Add("count", strconv.Itoa(count)) if replication != "" { values.Add("replication", replication) } + if collection != "" { + values.Add("collection", collection) + } jsonBlob, err := util.Post("http://"+server+"/dir/assign", values) glog.V(2).Info("assign result :", string(jsonBlob)) if err != nil { |