- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for updateDir (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
toUpdate, err := getFn(ctx, foo) if err != nil { t.Errorf("unexpected error: %v", err) } toUpdate = updateFn(toUpdate) toUpdateMeta := t.getObjectMetaOrFail(toUpdate) updated, created, err := t.storage.(rest.Updater).Update(ctx, toUpdateMeta.GetName(), rest.DefaultUpdatedObjectInfo(toUpdate), rest.ValidateAllObjectFunc, rest.ValidateAllObjectUpdateFunc, false, &metav1.UpdateOptions{}) if err != nil { t.Errorf("unexpected error: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
// Act // Mark the node unhealthy node2 := node1.DeepCopy() node2.Status.Conditions[0].Status = v1.ConditionFalse updateErr := informerFactory.Core().V1().Nodes().Informer().GetStore().Update(node2) if updateErr != nil { t.Fatalf("Update node failed. Expected: <no error> Actual: <%v>", updateErr) } // Assert -- Detach was not triggered after maxWaitForUnmountDuration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
istiotest "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) func setupTest(t *testing.T) (model.ConfigStoreController, kubernetes.Interface, *xdsfake.Updater) { t.Helper() client := kubeclient.NewFakeClient() endpoints := model.NewEndpointIndex(model.DisabledCache{}) delegate := model.NewEndpointIndexUpdater(endpoints) xdsUpdater := xdsfake.NewWithDelegate(delegate)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Name: "http-example", Protocol: corev1.ProtocolTCP, // Not added automatically by fake }, }, }, }) log.Infof("Created service %s", n) cl.opts.XDSUpdater.(*xdsfake.Updater).WaitOrFail(t, "service") } func TestController_GetPodLocality(t *testing.T) { pod1 := generatePod("128.0.1.1", "pod1", "nsA", "", "node1", map[string]string{"app": "prod-app"}, map[string]string{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
zeroWidthPending = false for _, varID := range state.changedVars.contents() { state.updateVar(VarID(varID), v.Block, v) } state.changedVars.clear() } for _, varID := range state.changedVars.contents() { state.updateVar(VarID(varID), b, BlockEnd) } prevBlock = b } if state.loggingLevel > 0 { state.logf("location lists:\n")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
toUpdate.Status.NumberAvailable = int32(numberAvailable) toUpdate.Status.NumberUnavailable = int32(numberUnavailable) if _, updateErr = dsClient.UpdateStatus(ctx, toUpdate, metav1.UpdateOptions{}); updateErr == nil { return nil } // Stop retrying if we exceed statusUpdateRetries - the DaemonSet will be requeued with a rate limit. if i >= StatusUpdateRetries {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
gracefulDeleter, isGracefulDeleter := storage.(rest.GracefulDeleter) collectionDeleter, isCollectionDeleter := storage.(rest.CollectionDeleter) updater, isUpdater := storage.(rest.Updater) patcher, isPatcher := storage.(rest.Patcher) watcher, isWatcher := storage.(rest.Watcher) connecter, isConnecter := storage.(rest.Connecter) storageMeta, isMetadata := storage.(rest.StorageMetadata)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
if err != nil { t.Errorf("error occurred crearting ServiceEntry config: %v", err) } } } type Event = xdsfake.Event func initServiceDiscovery(t test.Failer) (model.ConfigStore, *Controller, *xdsfake.Updater) { return initServiceDiscoveryWithOpts(t, false) } // initServiceDiscoveryWithoutEvents initializes a test setup with no events. This avoids excessive attempts to push // EDS updates to a full queue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
setUp(parameters.first, parameters.second) val creator = cache.edit("k1")!! creator.setString(0, "A") creator.setString(1, "B") creator.commit() val updater = cache.edit("k1")!! updater.setString(0, "C") updater.commit() val snapshot = cache["k1"]!! snapshot.assertValue(0, "C") snapshot.assertValue(1, "B") snapshot.close() } @ParameterizedTest
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
coreClient, testrestmapper.TestOnlyStaticRESTMapper(scheme), fakeScaleClient, fakeDiscovery, fakeClock, stalePodDisruptionTimeout, ) dc.getUpdater = func() updater { return ps.Set } dc.podListerSynced = alwaysReady dc.pdbListerSynced = alwaysReady dc.rcListerSynced = alwaysReady dc.rsListerSynced = alwaysReady dc.dListerSynced = alwaysReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0)