aboutsummaryrefslogtreecommitdiff
path: root/weed/operation
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-12-16 09:14:05 -0800
committerChris Lu <chris.lu@gmail.com>2020-12-16 09:14:05 -0800
commit1bf22c0b5b1ecd99cb1631800e5a6818e8d8d1b1 (patch)
treeeaa221a960e59b1b73b6b76035787a603dd1892c /weed/operation
parent1d88865869b554d72be8fe2629080bcd97cb8767 (diff)
downloadseaweedfs-1bf22c0b5b1ecd99cb1631800e5a6818e8d8d1b1.tar.xz
seaweedfs-1bf22c0b5b1ecd99cb1631800e5a6818e8d8d1b1.zip
go fmt
Diffstat (limited to 'weed/operation')
-rw-r--r--weed/operation/assign_file_id.go10
-rw-r--r--weed/operation/submit.go8
2 files changed, 9 insertions, 9 deletions
diff --git a/weed/operation/assign_file_id.go b/weed/operation/assign_file_id.go
index bb0b8e6df..b2fcf0c96 100644
--- a/weed/operation/assign_file_id.go
+++ b/weed/operation/assign_file_id.go
@@ -18,7 +18,7 @@ type VolumeAssignRequest struct {
Replication string
Collection string
Ttl string
- DiskType string
+ DiskType string
DataCenter string
Rack string
DataNode string
@@ -55,7 +55,7 @@ func Assign(server string, grpcDialOption grpc.DialOption, primaryRequest *Volum
Replication: request.Replication,
Collection: request.Collection,
Ttl: request.Ttl,
- DiskType: request.DiskType,
+ DiskType: request.DiskType,
DataCenter: request.DataCenter,
Rack: request.Rack,
DataNode: request.DataNode,
@@ -107,7 +107,7 @@ func LookupJwt(master string, fileId string) security.EncodedJwt {
type StorageOption struct {
Replication string
- DiskType string
+ DiskType string
Collection string
DataCenter string
Rack string
@@ -126,7 +126,7 @@ func (so *StorageOption) ToAssignRequests(count int) (ar *VolumeAssignRequest, a
Replication: so.Replication,
Collection: so.Collection,
Ttl: so.TtlString(),
- DiskType: so.DiskType,
+ DiskType: so.DiskType,
DataCenter: so.DataCenter,
Rack: so.Rack,
WritableVolumeCount: so.VolumeGrowthCount,
@@ -137,7 +137,7 @@ func (so *StorageOption) ToAssignRequests(count int) (ar *VolumeAssignRequest, a
Replication: so.Replication,
Collection: so.Collection,
Ttl: so.TtlString(),
- DiskType: so.DiskType,
+ DiskType: so.DiskType,
DataCenter: "",
Rack: "",
WritableVolumeCount: so.VolumeGrowthCount,
diff --git a/weed/operation/submit.go b/weed/operation/submit.go
index bcdf9ddce..907825311 100644
--- a/weed/operation/submit.go
+++ b/weed/operation/submit.go
@@ -25,7 +25,7 @@ type FilePart struct {
Collection string
DataCenter string
Ttl string
- DiskType string
+ DiskType string
Server string //this comes from assign result
Fid string //this comes from assign result, but customizable
Fsync bool
@@ -50,7 +50,7 @@ func SubmitFiles(master string, grpcDialOption grpc.DialOption, files []FilePart
Collection: collection,
DataCenter: dataCenter,
Ttl: ttl,
- DiskType: diskType,
+ DiskType: diskType,
}
ret, err := Assign(master, grpcDialOption, ar)
if err != nil {
@@ -146,7 +146,7 @@ func (fi FilePart) Upload(maxMB int, master string, usePublicUrl bool, jwt secur
Replication: fi.Replication,
Collection: fi.Collection,
Ttl: fi.Ttl,
- DiskType: fi.DiskType,
+ DiskType: fi.DiskType,
}
ret, err = Assign(master, grpcDialOption, ar)
if err != nil {
@@ -160,7 +160,7 @@ func (fi FilePart) Upload(maxMB int, master string, usePublicUrl bool, jwt secur
Replication: fi.Replication,
Collection: fi.Collection,
Ttl: fi.Ttl,
- DiskType: fi.DiskType,
+ DiskType: fi.DiskType,
}
ret, err = Assign(master, grpcDialOption, ar)
if err != nil {