- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,123 for Relist (0.14 sec)
-
pkg/controller/cronjob/cronjob_controllerv2.go
// We found an unfinished job that has us as the parent, but it is not in our Active list. // This could happen if we crashed right after creating the Job and before updating the status, // or if our jobs list is newer than our cj status after a relist, or if someone intentionally created // a job that they wanted us to adopt. } else if found && jobutil.IsJobFinished(j) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
opts = append([]setupOption{withDefaults}, opts...) for _, opt := range opts { opt(&setupOpts) } server, etcdStorage := newEtcdTestStorage(t, etcd3testing.PathPrefix()) // Inject one list error to make sure we test the relist case. wrappedStorage := &storagetesting.StorageInjectingListErrors{ Interface: etcdStorage, Errors: 1, } config := Config{ Storage: wrappedStorage,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
func (ssc *StatefulSetController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not // in the list, leading to the insertion of a tombstone object which contains // the deleted key/value. Note that this value might be stale. if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
dsList, err := dsc.dsLister.List(labels.Everything()) if err != nil { logger.V(4).Info("Error enqueueing daemon sets", "err", err) return } node := obj.(*v1.Node) for _, ds := range dsList { if shouldRun, _ := NodeShouldRunDaemonPod(node, ds); shouldRun { dsc.enqueueDaemonSet(ds) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if condition := findConditionByType(list, cType); condition != nil { if condition.Status != status || condition.Reason != reason || condition.Message != message { *condition = *newCondition(cType, status, reason, message, now) return list, true } return list, false } // A condition with that type doesn't exist in the list. if status != v1.ConditionFalse {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
} } func (dc *DisruptionController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not // in the list, leading to the insertion of a tombstone object which contains // the deleted key/value. Note that this value might be stale. If the pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
return nil } // list all pods to include the pods that don't match the rs`s selector // anymore but has the stale controller ref. // TODO: Do the List and Filter in a single pass, or use an index. allPods, err := rsc.podLister.Pods(rs.Namespace).List(labels.Everything()) if err != nil { return err } // Ignore inactive pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
pod := attrs.Pod newAllocatableResource := node.Allocatable.Clone() for _, container := range pod.Spec.Containers { for resource := range container.Resources.Requests { newQuantity, exist := updateResourceMap[resource] if !exist { continue } if newQuantity.Value() < 0 { return fmt.Errorf("Allocation failed") } newAllocatableResource.ScalarResources[resource] = newQuantity.Value()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.17.md
- When the go-client reflector relists, the ResourceVersion list option is set to the reflector's latest synced resource version to ensure the reflector does not "go back in time" and reprocess events older than it has already processed. If the server responds with an HTTP 410 (Gone) status code response, the relist falls back to using `resourceVersion=""`. ([#83520](https://github.com/kubernetes/kubernetes/pull/83520), ...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 28 10:44:33 UTC 2021 - 346.2K bytes - Viewed (1) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ListSubListTester.java
assertEquals(-1, tail.indexOf(list.get(0))); } @CollectionSize.Require(absent = {ZERO, ONE}) public void testSubList_lastIndexOf() { List<E> list = getList(); int size = list.size(); List<E> copy = list.subList(0, size); List<E> head = list.subList(0, size - 1); List<E> tail = list.subList(1, size); assertEquals(size - 1, copy.lastIndexOf(list.get(size - 1)));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 13.4K bytes - Viewed (0)