TrueCloudLab/frostfs-node
18
1
Fork 27
Code Issues 93 Pull requests 3 Projects Releases 1 Activity Actions

[#1392] object: Fix target initialization within put streamer
All checks were successful
DCO action / DCO (pull_request) Successful in 2m2s
Details
Tests and linters / Run gofumpt (pull_request) Successful in 2m14s
Details
Vulncheck / Vulncheck (pull_request) Successful in 2m50s
Details
Tests and linters / Tests (pull_request) Successful in 3m5s
Details
Tests and linters / Staticcheck (pull_request) Successful in 3m39s
Details
Pre-commit hooks / Pre-commit (pull_request) Successful in 3m50s
Details
Build / Build Components (pull_request) Successful in 3m54s
Details
Tests and linters / gopls check (pull_request) Successful in 4m19s
Details
Tests and linters / Lint (pull_request) Successful in 5m4s
Details
Tests and linters / Tests with -race (pull_request) Successful in 7m24s
Details

Browse source 
* Remove `relay` field from put streamer as it's no longer used;
* Fix initialization of `Relay` object writer parameter.

Signed-off-by: Airat Arifullin <a.arifullin@yadro.com>
This commit is contained in:
Airat Arifullin 2024-09-24 11:46:15 +03:00
parent d4bec24c9f
commit 7c56564b81
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
pkg/services/object/put/streamer.go
View file

@ -5,7 +5,6 @@ import (
"errors"
"fmt"
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/core/client"
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/services/object/common/target"
objectwriter "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/services/object/common/writer"
"git.frostfs.info/TrueCloudLab/frostfs-sdk-go/object/transformer"
@ -15,8 +14,6 @@ type Streamer struct {
*objectwriter.Config
target transformer.ChunkedObjectWriter
relay func(context.Context, client.NodeInfo, client.MultiAddressClient) error
}
var errNotInit = errors.New("stream not initialized")
@ -35,7 +32,7 @@ func (p *Streamer) Init(ctx context.Context, prm *PutInitPrm) error {
Header: prm.hdr,
Container: prm.cnr,
TraverseOpts: prm.traverseOpts,
Relay: p.relay,
Relay: prm.relay,
}
var err error