Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for scheduleReplicationDelete (0.08 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top