aboutsummaryrefslogtreecommitdiff
path: root/weed/operation/assign_file_id.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-11-11 21:30:14 -0800
committerChris Lu <chris.lu@gmail.com>2019-11-11 21:30:14 -0800
commitee90236a972acea8722dccfa1b04926d551fc82d (patch)
tree7890d2482177caad2fa72b741435bcefff140cf3 /weed/operation/assign_file_id.go
parent85f8649320033a46e71b20a588930013c00b3fdf (diff)
parentd7852ebb3b8900baeff3d806f8fe2404c511aa5d (diff)
downloadseaweedfs-ee90236a972acea8722dccfa1b04926d551fc82d.tar.xz
seaweedfs-ee90236a972acea8722dccfa1b04926d551fc82d.zip
Merge branch 'master' into refactoring_dat_backend
Diffstat (limited to 'weed/operation/assign_file_id.go')
-rw-r--r--weed/operation/assign_file_id.go16
1 files changed, 9 insertions, 7 deletions
diff --git a/weed/operation/assign_file_id.go b/weed/operation/assign_file_id.go
index 4c50eaa26..2971cddbb 100644
--- a/weed/operation/assign_file_id.go
+++ b/weed/operation/assign_file_id.go
@@ -11,13 +11,14 @@ import (
)
type VolumeAssignRequest struct {
- Count uint64
- Replication string
- Collection string
- Ttl string
- DataCenter string
- Rack string
- DataNode string
+ Count uint64
+ Replication string
+ Collection string
+ Ttl string
+ DataCenter string
+ Rack string
+ DataNode string
+ WritableVolumeCount uint32
}
type AssignResult struct {
@@ -53,6 +54,7 @@ func Assign(server string, grpcDialOption grpc.DialOption, primaryRequest *Volum
DataCenter: primaryRequest.DataCenter,
Rack: primaryRequest.Rack,
DataNode: primaryRequest.DataNode,
+ WritableVolumeCount: primaryRequest.WritableVolumeCount,
}
resp, grpcErr := masterClient.Assign(context.Background(), req)
if grpcErr != nil {