- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 115 for Updatef (0.26 sec)
-
pkg/registry/batch/job/strategy_test.go
enableJobPodReplacementPolicy bool enableJobSuccessPolicy bool job batch.Job updatedJob batch.Job wantJob batch.Job }{ "update job with a new field; updated when JobSuccessPolicy enabled": { enableJobSuccessPolicy: true, job: batch.Job{ ObjectMeta: getValidObjectMeta(0), Spec: batch.JobSpec{ Selector: validSelector,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 101.5K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
expectedPodStatusUpdates int }{ // Node created long time ago, with status updated by kubelet exceeds grace period. // First monitorNodeHealth check will update pod status to NotReady. // Second monitorNodeHealth check will do no updates (no retry). { desc: "successful pod status update, no retry required", fakeNodeHandler: &testutil.FakeNodeHandler{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} if !test.err && test.expectedUpdate != nil && update != nil && test.expectedUpdate.Revision != update.Revision { t.Errorf("%s: for update revision want %d got %d", test.name, test.expectedUpdate.Revision, update.Revision) } } updateRevision := func(cr *apps.ControllerRevision, revision int64) *apps.ControllerRevision { clone := cr.DeepCopy() clone.Revision = revision
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
handler.HandlePodSyncs(podsToSync) case update := <-kl.livenessManager.Updates(): if update.Result == proberesults.Failure { handleProbeSync(kl, update, handler, "liveness", "unhealthy") } case update := <-kl.readinessManager.Updates(): ready := update.Result == proberesults.Success kl.statusManager.SetContainerReadiness(update.PodUID, update.ContainerID, ready) status := "" if ready {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/apis/apps/validation/validation_test.go
name string old apps.StatefulSet update apps.StatefulSet errs field.ErrorList } successCases := []testCase{{ name: "update replica count", old: mkStatefulSet(&validPodTemplate), update: mkStatefulSet(&validPodTemplate, tweakReplicas(3)), }, { name: "update containers 1", old: mkStatefulSet(&validPodTemplate), update: mkStatefulSet(addContainersValidTemplate), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 111.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 229.4K bytes - Viewed (0) -
cmd/site-replication.go
return nil } } opts := updateServiceAccountOpts{ secretKey: change.Update.SecretKey, status: change.Update.Status, name: change.Update.Name, description: change.Update.Description, sessionPolicy: sp, expiration: change.Update.Expiration, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
} if updated == nil { t.Fatalf("Failed to get updated status") } if got, want := updated.Status.DesiredNumberScheduled, int32(podControl.FakePodControl.CreateLimit)*10; got != want { t.Errorf("Status.DesiredNumberScheduled = %v, want %v", got, want) } if got, want := updated.Status.CurrentNumberScheduled, int32(podControl.FakePodControl.CreateLimit); got != want {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
} updated, err := strategicpatch.StrategicMergePatch(original, patch, v1.Node{}) if err != nil { return nil, fmt.Errorf("failed to apply strategic merge patch %q on node %#v: %v", patch, originalNode, err) } updatedNode := &v1.Node{} if err := json.Unmarshal(updated, updatedNode); err != nil { return nil, fmt.Errorf("failed to unmarshal updated node %q: %v", updated, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if err == nil { t.Errorf("expected admission error on update") } // normal update and verify if !updateAndVerify(t, testContext, registry, podB) { t.Errorf("Unexpected error updating podB") } // unconditional update // NOTE: The logic for unconditional updates doesn't make sense to me, and imho should be removed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0)