Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for scheduleReplicationDelete (0.18 sec)

  1. cmd/bucket-handlers.go

    				dobj.VersionID = nullVersionID
    			}
    			dv := DeletedObjectReplicationInfo{
    				DeletedObject: dobj,
    				Bucket:        bucket,
    				EventType:     ReplicateIncomingDelete,
    			}
    			scheduleReplicationDelete(ctx, dv, objectAPI)
    		}
    
    		eventName := event.ObjectRemovedDelete
    		objInfo := ObjectInfo{
    			Name:         dobj.ObjectName,
    			VersionID:    dobj.VersionID,
    			DeleteMarker: dobj.DeleteMarker,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
Back to top