slicer: Extend slicer.Options with copies number

Signed-off-by: Evgenii Baidakov <[email protected]>

client/object_put.go

@@ -40,7 +40,9 @@ type PrmObjectPutInit struct {
 	copyNum uint32
 }
 
-// SetCopiesNumber sets number of object copies that is enough to consider put successful.
+// SetCopiesNumber sets the minimal number of copies (out of the number specified by container placement policy) for
+// the object PUT operation to succeed. This means that object operation will return with successful status even before
+// container placement policy is completely satisfied.
 func (x *PrmObjectPutInit) SetCopiesNumber(copiesNumber uint32) {
 	x.copyNum = copiesNumber
 }

object/slicer/options.go

@@ -13,6 +13,8 @@ type Options struct {
 
 	withHomoChecksum bool
 
+	copiesNumber uint32
+
 	sessionToken *session.Object
 	bearerToken  *bearer.Token
 }
@@ -45,6 +47,13 @@ func (x *Options) SetBearerToken(bearerToken *bearer.Token) {
 	x.bearerToken = bearerToken
 }
 
+// SetCopiesNumber sets the minimal number of copies (out of the number specified by container placement policy) for
+// the object PUT operation to succeed. This means that object operation will return with successful status even before
+// container placement policy is completely satisfied.
+func (x *Options) SetCopiesNumber(copiesNumber uint32) {
+	x.copiesNumber = copiesNumber
+}
+
 // ObjectPayloadLimit returns required max object size.
 func (x *Options) ObjectPayloadLimit() uint64 {
 	return x.objectPayloadLimit
@@ -69,3 +78,8 @@ func (x *Options) Session() *session.Object {
 func (x *Options) BearerToken() *bearer.Token {
 	return x.bearerToken
 }
+
+// CopiesNumber returns the number of object copies.
+func (x *Options) CopiesNumber() uint32 {
+	return x.copiesNumber
+}

object/slicer/slicer.go

@@ -218,6 +218,7 @@ func initPayloadStream(ctx context.Context, ow ObjectWriter, header object.Objec
 	}
 
 	var prm client.PrmObjectPutInit
+	prm.SetCopiesNumber(opts.copiesNumber)
 
 	if opts.sessionToken != nil {
 		prm.WithinSession(*opts.sessionToken)