- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for scheduleReplicationDelete (0.11 sec)
-
cmd/bucket-replication.go
} if err == nil { tgs, _ = tags.MapToObjectTags(tagSlc[idx]) } } if len(errs) == 1 { proxy.Err = errs[0] } return tgs, proxy } func scheduleReplicationDelete(ctx context.Context, dv DeletedObjectReplicationInfo, o ObjectLayer) { globalReplicationPool.Get().queueReplicaDeleteTask(dv) for arn := range dv.ReplicationState.Targets {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/object-handlers.go
DeleteMarker: objInfo.DeleteMarker, ReplicationState: objInfo.ReplicationState(), }, Bucket: bucket, EventType: ReplicateIncomingDelete, } scheduleReplicationDelete(ctx, dobj, objectAPI) } // Remove the transitioned object whose object version is being overwritten. if !globalTierConfigMgr.Empty() { os.Sweep() } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0)