Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for scheduleReplicationDelete (0.11 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K 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 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