diff --git a/pkg/services/object/put/service.go b/pkg/services/object/put/service.go index 74b89b794..bc8b6945b 100644 --- a/pkg/services/object/put/service.go +++ b/pkg/services/object/put/service.go @@ -40,6 +40,8 @@ type cfg struct { fmtValidator *object.FormatValidator fmtValidatorOpts []object.FormatValidatorOption + + networkState netmap.State } func defaultCfg() *cfg { @@ -116,3 +118,9 @@ func WithFormatValidatorOpts(v ...object.FormatValidatorOption) Option { c.fmtValidatorOpts = v } } + +func WithNetworkState(v netmap.State) Option { + return func(c *cfg) { + c.networkState = v + } +} diff --git a/pkg/services/object/put/streamer.go b/pkg/services/object/put/streamer.go index 3fe7c946a..7b7986422 100644 --- a/pkg/services/object/put/streamer.go +++ b/pkg/services/object/put/streamer.go @@ -73,6 +73,7 @@ func (p *Streamer) initTarget(prm *PutInitPrm) error { Key: sessionKey, NextTarget: p.newCommonTarget(prm), SessionToken: sToken, + NetworkState: p.networkState, }) }, )