Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PendingStatus (0.22 sec)

  1. pkg/kubelet/prober/worker_test.go

    	for _, probeType := range [...]probeType{liveness, readiness, startup} {
    		// Test statuses.
    		runningStatus := getTestRunningStatusWithStarted(probeType != startup)
    		pendingStatus := getTestRunningStatusWithStarted(probeType != startup)
    		pendingStatus.ContainerStatuses[0].State.Running = nil
    		terminatedStatus := getTestRunningStatusWithStarted(probeType != startup)
    		terminatedStatus.ContainerStatuses[0].State.Running = nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 23:48:10 UTC 2023
    - 16.1K 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 20:27:52 UTC 2024
    - 17K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    	}
    	if dsc := mustReplicate(ctx, dstBucket, dstObject, srcInfo.getMustReplicateOptions(op, dstOpts)); dsc.ReplicateAny() {
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    	}
    	// Store the preserved compression metadata.
    	for k, v := range compressMetadata {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 124.2K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    				},
    			}, goi, opts, gerr)
    			if dsc.ReplicateAny() {
    				if object.VersionID != "" {
    					object.VersionPurgeStatus = Pending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    					object.DeleteMarkerReplicationStatus = dsc.PendingStatus()
    				}
    				object.ReplicateDecisionStr = dsc.String()
    			}
    		}
    		if object.VersionID != "" && hasLockEnabled {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  6. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
Back to top