diff options
| author | zhangsong <songz.qqmail@qq.com> | 2019-11-10 20:11:03 +0800 |
|---|---|---|
| committer | zhangsong <zhangsong@cloudwalk.cn> | 2019-11-10 20:11:03 +0800 |
| commit | 61fa485700f15b537611dfd399890a63e4b61601 (patch) | |
| tree | b571854a02711d5039f0e5a8cf2a0872f77a7afc /weed/operation/assign_file_id.go | |
| parent | c34ffed43f9e6afde139c78a723fc56d843e03d4 (diff) | |
| download | seaweedfs-61fa485700f15b537611dfd399890a63e4b61601.tar.xz seaweedfs-61fa485700f15b537611dfd399890a63e4b61601.zip | |
add volume number param in assign operation
Diffstat (limited to 'weed/operation/assign_file_id.go')
| -rw-r--r-- | weed/operation/assign_file_id.go | 16 |
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 { |