- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 553 for isStatus (0.18 sec)
-
cmd/object-api-interface.go
func (o *ObjectOptions) PutReplicationState() (r ReplicationState) { rstatus, ok := o.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] if !ok { return } r.ReplicationStatusInternal = rstatus r.Targets = replicationStatusesMap(rstatus) return } // SetEvalMetadataFn sets the metadata evaluation function
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0) -
pkg/kube/inject/inject.go
statusBytes = []byte(value) } } if statusBytes == nil { return nil } // default case when injected pod has explicit status var iStatus SidecarInjectionStatus if err := json.Unmarshal(statusBytes, &iStatus); err != nil { return nil } return &iStatus } func parseDryTemplate(tmplStr string, funcMap map[string]any) (*template.Template, error) { temp := template.New("inject")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (1) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
cStatus := &runtimeapi.ContainerStatus{ Id: cid.ID, Metadata: meta, Image: imageSpec, State: runtimeapi.ContainerState_CONTAINER_RUNNING, CreatedAt: createdAt, StartedAt: startedAt, User: test.input, } actual := toKubeContainerStatus(cStatus, cid.Type) assert.EqualValues(t, test.expected, actual.User, desc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/resource.k8s.io.v1alpha2.Status.pb
SataQiu <******@****.***> 1713430345 +0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 234 bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/resource.k8s.io.v1alpha2.Status.yaml
group: groupValue kind: kindValue name: nameValue retryAfterSeconds: 5 uid: uidValue kind: Status message: messageValue metadata: continue: continueValue remainingItemCount: 4 resourceVersion: resourceVersionValue selfLink: selfLinkValue reason: reasonValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 432 bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
if e.Port != 0 && retrieveEndpointPort(ep) != e.Port { return false } if e.Cluster != "" && !strings.EqualFold(cluster, e.Cluster) { return false } status := retrieveEndpointStatus(ep) if e.Status != "" && !strings.EqualFold(core.HealthStatus_name[int32(status)], e.Status) { return false } return true } func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus { return ep.GetHealthStatus() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
// clobbering each other so the phase of a pod progresses monotonically. if isCached && isPodStatusByKubeletEqual(&cachedStatus.status, &status) && !forceUpdate { klog.V(3).InfoS("Ignoring same status for pod", "pod", klog.KObj(pod), "status", status) return } newStatus := versionedPodStatus{ status: status, version: cachedStatus.version + 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
UnschedulablePlugins: sets.New(status.Plugin()), }, } return framework.NewStatus(status.Code()).WithError(fitErr) } return status } // Run "prebind" plugins. if status := fwk.RunPreBindPlugins(ctx, state, assumedPod, scheduleResult.SuggestedHost); !status.IsSuccess() { if status.IsRejected() { fitErr := &framework.FitError{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
claim = claim.DeepCopy() claim.Status.ReservedFor = inUseClaim.Status.ReservedFor } return claim }, }, }, }, }, "missing-claim": { pod: podWithClaimTemplate, // status not set claims: []*resourcev1alpha2.ResourceClaim{allocatedClaim, otherClaim}, want: want{ preenqueue: result{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
if apierrors.IsNotFound(err) { // PVC is not found. This Pod will never be schedulable until PVC is created. return framework.NewStatus(framework.UnschedulableAndUnresolvable, err.Error()) } return framework.AsStatus(err) } // If the pod doesn't have any new CSI volumes, the predicate will always be true if len(newVolumes) == 0 { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0)