TrueCloudLab/frostfs-sdk-go
30
0
Fork 21
Code Issues 29 Pull requests 2 Releases Activity Actions

[#182] pool: Fix linter error about deprecated methods
All checks were successful
DCO / DCO (pull_request) Successful in 1m11s
Details
Tests and linters / Lint (pull_request) Successful in 1m30s
Details
Tests and linters / Tests (1.20) (pull_request) Successful in 1m25s
Details
Tests and linters / Tests (1.19) (pull_request) Successful in 1m1s
Details

Browse source 
Signed-off-by: Airat Arifullin <a.arifullin@yadro.com>
This commit is contained in:
Airat Arifullin 2023-10-23 17:37:50 +03:00
parent 5804128ff3
commit 4c1feaf2cb
1 changed files with 11 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
pool/object_put_pool_transformer.go
View file

@ -110,16 +110,11 @@ func (it *internalTarget) WriteObject(ctx context.Context, o *object.Object) err
} }
func (it *internalTarget) putAsStream(ctx context.Context, o *object.Object) error { func (it *internalTarget) putAsStream(ctx context.Context, o *object.Object) error {
var cliPrm sdkClient.PrmObjectPutInit cliPrm := sdkClient.PrmObjectPutInit{
cliPrm.SetCopiesNumberByVectors(it.prm.copiesNumber) CopiesNumber: it.prm.copiesNumber,
if it.prm.stoken != nil { Session: it.prm.stoken,
cliPrm.WithinSession(*it.prm.stoken) Key: it.prm.key,
} BearerToken: it.prm.btoken,
if it.prm.key != nil {
cliPrm.UseKey(*it.prm.key)
}
if it.prm.btoken != nil {
cliPrm.WithBearerToken(*it.prm.btoken)
} }
wrt, err := it.client.ObjectPutInit(ctx, cliPrm) wrt, err := it.client.ObjectPutInit(ctx, cliPrm)
@ -141,16 +136,13 @@ func (it *internalTarget) tryPutSingle(ctx context.Context, o *object.Object) (b
if it.useStream { if it.useStream {
return false, nil return false, nil
} }
var cliPrm sdkClient.PrmObjectPutSingle cliPrm := sdkClient.PrmObjectPutSingle{
cliPrm.SetCopiesNumber(it.prm.copiesNumber) CopiesNumber: it.prm.copiesNumber,
cliPrm.UseKey(it.prm.key) Key: it.prm.key,
if it.prm.stoken != nil { Session: it.prm.stoken,
cliPrm.WithinSession(*it.prm.stoken) BearerToken: it.prm.btoken,
Object: o,
} }
if it.prm.btoken != nil {
cliPrm.WithBearerToken(*it.prm.btoken)
}
cliPrm.SetObject(o.ToV2())
res, err := it.client.ObjectPutSingle(ctx, cliPrm) res, err := it.client.ObjectPutSingle(ctx, cliPrm)
if err != nil && status.Code(err) == codes.Unimplemented { if err != nil && status.Code(err) == codes.Unimplemented {