- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for getReplicationConfig (0.16 sec)
-
cmd/bucket-replication-handlers.go
if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } config, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } configData, err := xml.Marshal(config) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} return nil, time.Time{}, err } return meta.quotaConfig, meta.QuotaConfigUpdatedAt, nil } // GetReplicationConfig returns configured bucket replication config // The returned object may not be modified. func (sys *BucketMetadataSys) GetReplicationConfig(ctx context.Context, bucket string) (*replication.Config, time.Time, error) { meta, reloaded, err := sys.GetConfig(ctx, bucket) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
return } rawDataFn(bytes.NewReader(configData), cfgPath, len(configData)) case bucketReplicationConfig: config, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket) if err != nil { if errors.Is(err, BucketReplicationConfigNotFound{Bucket: bucket}) { continue } writeErrorResponse(ctx, w, exportError(ctx, err, cfgFile, bucket), r.URL)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 33.3K bytes - Viewed (0) -
cmd/global-heal.go
} // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue } rcfg, err = getReplicationConfig(ctx, bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue } } if serverDebugLog {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 04 13:49:12 UTC 2025 - 16.2K bytes - Viewed (0) -
cmd/bucket-targets.go
if err != nil { return BucketRemoteArnInvalid{Bucket: bucket} } if arn.Type == madmin.ReplicationService { // reject removal of remote target if replication configuration is present rcfg, err := getReplicationConfig(ctx, bucket) if err == nil && rcfg != nil { for _, tgtArn := range rcfg.FilterTargetArns(replication.ObjectOpts{OpType: replication.AllReplicationType}) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bi.Name) if err != nil { return err } rcfg, err = getReplicationConfig(ctx, bi.Name) if err != nil { return err } } for setIdx, set := range pool.sets { filterLifecycle := func(bucket, object string, fi FileInfo) bool { if lc == nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 42.1K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bucket) if err != nil { return err } rcfg, err = getReplicationConfig(ctx, bucket) if err != nil { return err } } pool := z.serverPools[poolIdx] const envRebalanceWorkers = "_MINIO_REBALANCE_WORKERS"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 28.9K bytes - Viewed (0) -
cmd/metacache-set.go
vc, _ := globalBucketVersioningSys.Get(o.Bucket) // Check if bucket is object locked. rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket) replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket) tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket) o.Lifecycle = lc o.Versioning = vc o.Replication = replicationConfig{ Config: replCfg, remotes: tgts, }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0)