Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PendingStatus (0.17 sec)

  1. cmd/bucket-replication-utils.go

    	if d.targetsMap == nil {
    		d.targetsMap = make(map[string]replicateTargetDecision)
    	}
    	d.targetsMap[t.Arn] = t
    }
    
    // PendingStatus returns a stringified representation of internal replication status with all targets marked as `PENDING`
    func (d ReplicateDecision) PendingStatus() string {
    	b := new(bytes.Buffer)
    	for _, k := range d.targetsMap {
    		if k.Replicate {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. cmd/object-api-interface.go

    	}
    	switch {
    	case o.VersionID == "":
    		o.DeleteReplication.ReplicationStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.Targets = replicationStatusesMap(o.DeleteReplication.ReplicationStatusInternal)
    	default:
    		o.DeleteReplication.VersionPurgeStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.PurgeTargets = versionPurgeStatusesMap(o.DeleteReplication.VersionPurgeStatusInternal)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    		metadata[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    		metadata[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    	}
    
    	// We need to preserve the encryption headers set in EncryptRequest,
    	// so we do not want to override them, copy them instead.
    	for k, v := range encMetadata {
    		metadata[k] = v
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
Back to top