- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 95 for apipod (0.12 sec)
-
pkg/kubelet/prober/prober_manager_test.go
defer cleanup(t, m) if err := expectProbes(m, nil); err != nil { t.Error(err) } // Adding a pod with no probes should be a no-op. m.AddPod(&noProbePod) if err := expectProbes(m, nil); err != nil { t.Error(err) } // Adding a pod with probes. m.AddPod(&probePod) probePaths := []probeKey{ {"probe_pod", "readiness", readiness}, {"probe_pod", "liveness", liveness},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_test.go
"configmap:ns/cm3": {"pod:ns/pod2", "pod:ns/pod3"}, "serviceAccount:ns/sa1": {"pod:ns/pod2", "pod:ns/pod3"}, }) expectIndex(map[string][]string{}) // add two to get above the threshold addPod(1, 1) addPod(4, 1) expectGraph(map[string][]string{ "node:node1": {}, "node:node2": {}, "node:node3": {}, "pod:ns/pod1": {"node:node1"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:14:19 UTC 2022 - 12.3K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
// Annotations maps a pod name to a map of annotation key-values. Annotations map[string]map[string]string // Pod maps a pod name to its Pod info. The key is namespace/pod-name. Pod map[string]*corev1.Pod // CniPod CniPod map[string]*corev1.Pod } func (r *Resources) insertContainer(namespace, deployment, pod, container string) { if r.Root == nil { r.Root = make(map[string]any) } if r.Root[namespace] == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (1) -
pkg/scheduler/internal/cache/fake/fake_cache.go
// ForgetPod is a fake method for testing. func (c *Cache) ForgetPod(logger klog.Logger, pod *v1.Pod) error { c.ForgetFunc(pod) return nil } // AddPod is a fake method for testing. func (c *Cache) AddPod(logger klog.Logger, pod *v1.Pod) error { return nil } // UpdatePod is a fake method for testing. func (c *Cache) UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 2.8K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
slices resourcev1alpha2informers.ResourceSliceInformer, ) { g := &graphPopulator{ graph: graph, } podHandler, _ := pods.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPod, UpdateFunc: g.updatePod, DeleteFunc: g.deletePod, }) pvsHandler, _ := pvs.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPV, UpdateFunc: g.updatePV,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
// probe (AddPod). The worker periodically probes its assigned container and caches the results. The // manager use the cached probe results to set the appropriate Ready state in the PodStatus when // requested (UpdatePodStatus). Updating probe parameters is not currently supported. type Manager interface { // AddPod creates new probe workers for every container probe. This should be called for every
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/server_test.go
w.WriteHeader(http.StatusOK) }), MaxHeaderBytes: 1 << 20, TLSConfig: tlsConfig, } listener, _, err := createListener("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } apiPort := listener.Addr().String() go func() { t.Logf("listening on %s", listener.Addr().String()) listener = tls.NewListener(listener, server.TLSConfig) if err := server.ServeTLS(listener, "", ""); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 6K bytes - Viewed (0) -
misc/ios/detect.go
check(err) pcert, err := x509.ParseCertificate(cert) check(err) fmt.Printf("export GOIOS_DEV_ID=\"%s\"\n", pcert.Subject.CommonName) appID, err := plistExtract(fname, "Entitlements:application-identifier") check(err) fmt.Printf("export GOIOS_APP_ID=%s\n", appID) teamID, err := plistExtract(fname, "Entitlements:com.apple.developer.team-identifier") check(err) fmt.Printf("export GOIOS_TEAM_ID=%s\n", teamID) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:30 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
syncer := newTestManager(&fake.Clientset{}) pod := getTestPod() pod.UID = "first" syncer.podManager.(mutablePodManager).AddPod(pod) differentPod := getTestPod() differentPod.UID = "second" syncer.podManager.(mutablePodManager).AddPod(differentPod) syncer.kubeClient = fake.NewSimpleClientset(pod) syncer.SetPodStatus(differentPod, getRandomPodStatus())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// ForgetPod removes an assumed pod from cache. ForgetPod(logger klog.Logger, pod *v1.Pod) error // AddPod either confirms a pod if it's assumed, or adds it back if it's expired. // If added back, the pod's information would be added again. AddPod(logger klog.Logger, pod *v1.Pod) error // UpdatePod removes oldPod's information and adds newPod's information.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0)