- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PendingStatus (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
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)