- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,749 for outdated (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storageversion/updater_test.go
sv := &v1alpha1.StorageVersion{Status: tc.old} updated := localUpdateStorageVersion(sv, tc.newSSV.APIServerID, tc.newSSV.EncodingVersion, tc.newSSV.DecodableVersions, tc.newSSV.ServedVersions) if tc.expectLastTransitionTimeUpdate == updated.Status.Conditions[0].LastTransitionTime.IsZero() { t.Errorf("unexpected LastTransitionTime, expected update: %v, got: %v", tc.expectLastTransitionTimeUpdate, updated.Status.Conditions[0].LastTransitionTime) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 22:40:54 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher_test.go
steps := []struct { added *v1.ConfigMap updated *v1.ConfigMap deleted *v1.ConfigMap expect *meshconfig.MeshConfig }{ {expect: mesh.DefaultMeshConfig()}, {added: cm, expect: m}, // Handle misconfiguration errors. {updated: badCM, expect: m}, {updated: cm, expect: m}, {updated: badCM2, expect: m}, {updated: badCM, expect: m}, {updated: cm, expect: m},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
// In other words, every claim/volume change performed by the controller ends // here. // This callback checks versions of the updated objects and refuse those that // are too old (simulating real etcd). // All updated objects are stored locally to keep track of object versions and // to evaluate test results. // All updated objects are also inserted into changedObjects queue and // optionally sent back to the controller via its watchers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
// back to true to indicate this node status needs to be updated again. logger.V(2).Info("Error retrieving nodes from node lister", "err", err) nsu.actualStateOfWorld.SetNodeStatusUpdateNeeded(logger, nodeName) return err } err = nsu.updateNodeStatus(logger, nodeName, nodeObj, attachedVolumes) if errors.IsNotFound(err) { // If node does not exist, its status cannot be updated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
tests/update_test.go
if users[0].Name != "updates_01_newname" || users[0].Age != 100 { t.Errorf("Record should be updated also with map") } if users[0].UpdatedAt.UnixNano() == lastUpdatedAt.UnixNano() { t.Errorf("User's updated at should be changed, but got %v, was %v", users[0].UpdatedAt.UnixNano(), lastUpdatedAt) } // user2 should not be updated var user1, user2 User DB.First(&user1, users[0].ID) DB.First(&user2, users[1].ID)
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Dec 04 03:50:58 UTC 2023 - 30.3K bytes - Viewed (0) -
src/net/interface.go
toName: make(map[int]string), } // update refreshes the network interface information if the cache was last // updated more than 1 minute ago, or if force is set. It reports whether the // cache was updated. func (zc *ipv6ZoneCache) update(ift []Interface, force bool) (updated bool) { zc.Lock() defer zc.Unlock() now := time.Now() if !force && zc.lastFetched.After(now.Add(-60*time.Second)) { return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry) if err := r.runOnce(); err != nil { t.Fatal(err) } if !registry.updateCalled || registry.updated == nil || registry.updated.Range != pr.String() || registry.updated != registry.item { t.Errorf("unexpected registry: %#v", registry) } repairErrors, err := testutil.GetCounterMetricValue(nodePortRepairReconcileErrors) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
src/runtime/mkduff.go
// AX: zero // DI: ptr to memory to be zeroed // DI is updated as a side effect. fmt.Fprintln(w, "TEXT runtime·duffzero(SB), NOSPLIT, $0-0") for i := 0; i < 128; i++ { fmt.Fprintln(w, "\tSTOSL") } fmt.Fprintln(w, "\tRET") } func copy386(w io.Writer) { // SI: ptr to source memory // DI: ptr to destination memory // SI and DI are updated as a side effect. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 19:04:21 UTC 2023 - 8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater.go
if updateErr == nil { return nil } if updated, err := ssu.setLister.StatefulSets(set.Namespace).Get(set.Name); err == nil { // make a copy so we don't mutate the shared cache set = updated.DeepCopy() } else { utilruntime.HandleError(fmt.Errorf("error getting updated StatefulSet %s/%s from lister: %v", set.Namespace, set.Name, err)) } return updateErr }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue_test.go
if request == nil { return } updated := make([]string, 0, len(request.ConfigsUpdated)) for configkey := range request.ConfigsUpdated { updated = append(updated, fmt.Sprintf("%d", configkey.Kind)) } sort.Slice(updated, func(i, j int) bool { l, _ := strconv.Atoi(updated[i]) r, _ := strconv.Atoi(updated[j]) return l < r })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0)