Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for podKeys (0.19 sec)

  1. tools/bug-report/pkg/filter/filter.go

    		return false
    	}
    
    	if !match.MatchesGlobs(container, sp.Containers) {
    		return false
    	}
    
    	if !match.MatchesGlobs(container, sp.Containers) {
    		return false
    	}
    
    	key := cluster2.PodKey(namespace, pod)
    	if !match.MatchesMap(sp.Labels, cluster.Labels[key]) {
    		return false
    	}
    	if !match.MatchesMap(sp.Annotations, cluster.Annotations[key]) {
    		return false
    	}
    	return true
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 13 23:42:29 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  2. pkg/registry/core/pod/storage/storage.go

    func (r *BindingREST) setPodHostAndAnnotations(ctx context.Context, podUID types.UID, podResourceVersion, podID, machine string, annotations map[string]string, dryRun bool) (finalPod *api.Pod, err error) {
    	podKey, err := r.store.KeyFunc(ctx, podID)
    	if err != nil {
    		return nil, err
    	}
    
    	var preconditions *storage.Preconditions
    	if podUID != "" || podResourceVersion != "" {
    		preconditions = &storage.Preconditions{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

    				barThird := &example.Pod{ObjectMeta: metav1.ObjectMeta{Namespace: "third", Name: "bar"}}
    				podKey := fmt.Sprintf("/pods/%s/%s", barThird.Namespace, barThird.Name)
    				storedObj := &example.Pod{}
    
    				err := store.Create(context.Background(), podKey, barThird, storedObj, 0)
    				if err != nil {
    					t.Errorf("failed to create object: %v", err)
    				}
    			})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 12.3K bytes
    - Viewed (1)
  4. pkg/controller/podautoscaler/horizontal.go

    	a.hpaSelectorsMux.Lock()
    	defer a.hpaSelectorsMux.Unlock()
    
    	hpas := map[selectors.Key]struct{}{}
    	for _, p := range pods {
    		podKey := selectors.Key{Name: p.Name, Namespace: p.Namespace}
    		a.hpaSelectors.Put(podKey, p.Labels)
    
    		selectingHpas, ok := a.hpaSelectors.ReverseSelect(podKey)
    		if !ok {
    			continue
    		}
    		for _, hpa := range selectingHpas {
    			hpas[hpa] = struct{}{}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    				pod := &example.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      fmt.Sprintf("foo-%d", i),
    						Namespace: "test-ns",
    					},
    				}
    				podKey := computePodKey(pod)
    				if err := store.Create(ctx, podKey, pod, out, 0); err != nil {
    					errc <- fmt.Errorf("failed to create pod %v: %v", pod, err)
    					return
    				}
    				time.Sleep(10 * time.Millisecond)
    			}
    		}
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  6. pkg/controller/controller_utils.go

    		}
    	}
    	return filtered
    }
    
    // PodKey returns a key unique to the given pod within a cluster.
    // It's used so we consistently use the same key scheme in this module.
    // It does exactly what cache.MetaNamespaceKeyFunc would have done
    // except there's not possibility for error since we know the exact type.
    func PodKey(pod *v1.Pod) string {
    	return fmt.Sprintf("%v/%v", pod.Namespace, pod.Name)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/queue/scheduling_queue.go

    // is found in the map. It returns nil otherwise.
    func (u *UnschedulablePods) get(pod *v1.Pod) *framework.QueuedPodInfo {
    	podKey := u.keyFunc(pod)
    	if pInfo, exists := u.podInfoMap[podKey]; exists {
    		return pInfo
    	}
    	return nil
    }
    
    // clear removes all the entries from the unschedulable podInfoMap.
    func (u *UnschedulablePods) clear() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  8. pkg/controller/controller_utils_test.go

    		}
    
    		rcPodNames := []string{}
    		for i := range podList.Items {
    			p := &podList.Items[i]
    			p.Name = fmt.Sprintf("%v-%v", p.Name, rc.Name)
    			rcPodNames = append(rcPodNames, PodKey(p))
    		}
    		uidExp.ExpectDeletions(logger, rcKey, rcPodNames)
    
    		return rcKey, rcPodNames
    	}
    
    	tests := []test{
    		{name: "Replication controller with 2 replicas", numReplicas: 2},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
Back to top