Method SetBucketReplication

api-bucket-replication.go:55–67

SetBucketReplication sets the replication configuration on an existing bucket. If the provided configuration is empty, this method removes the existing replication configuration. Parameters: - ctx: Context for request cancellation and timeout - bucketName: Name of the bucket - cfg: Replication conf

(ctx context.Context, bucketName string, cfg replication.Config)

//
// Returns an error if the operation fails.
func (c *Client) SetBucketReplication(ctx context.Context, bucketName string, cfg replication.Config) error {
	// Input validation.
	if err := s3utils.CheckValidBucketName(bucketName); err != nil {
		return err
	}

	// If replication is empty then delete it.
	if cfg.Empty() {
		return c.removeBucketReplication(ctx, bucketName)
	}
	// Save the updated replication.
	return c.putBucketReplication(ctx, bucketName, cfg)
}

// Saves a new bucket replication.
func (c *Client) putBucketReplication(ctx context.Context, bucketName string, cfg replication.Config) error {