Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,571 for updatePod (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	ns := "default"
    	noxuNamespacedResourceClient := newNamespacedCustomResourceVersionedClient(ns, dynamicClient, noxuDefinition, "v1beta1")
    
    	updateCRD := func() {
    		noxuDefinitionToUpdate, err := apiExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), noxuDefinition.Name, metav1.GetOptions{})
    		if err != nil {
    			t.Error(err)
    			return
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:59:03 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. 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)
  7. cmd/metacache-bucket.go

    	}
    }
    
    // updateCacheEntry will update a cache.
    // Returns the updated status.
    func (b *bucketMetacache) updateCacheEntry(update metacache) (metacache, error) {
    	b.mu.Lock()
    	defer b.mu.Unlock()
    	existing, ok := b.caches[update.id]
    	if !ok {
    		return update, errFileNotFound
    	}
    	existing.update(update)
    	b.caches[update.id] = existing
    	b.updated = true
    	return existing, nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top