- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 232 for podB (0.03 sec)
-
hack/testdata/pod.yaml
apiVersion: v1 kind: Pod metadata: name: test-pod labels: name: test-pod-label spec: containers: - name: kubernetes-pause
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 172 bytes - Viewed (0) -
src/internal/coverage/pods/pods.go
} for _, e := range p.elements { pod.CounterDataFiles = append(pod.CounterDataFiles, e.file) pod.Origins = append(pod.Origins, e.origin) pod.ProcessIDs = append(pod.ProcessIDs, e.pid) } pods = append(pods, pod) } slices.SortFunc(pods, func(a, b Pod) int { return strings.Compare(a.MetaFile, b.MetaFile) }) return pods } func warning(s string, a ...interface{}) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// or are known to be fully terminated. This method should only be used // when the set of pods being filtered is upstream of the pod worker, i.e. // the pods the pod manager is aware of. func (kl *Kubelet) filterOutInactivePods(pods []*v1.Pod) []*v1.Pod { filteredPods := make([]*v1.Pod, 0, len(pods)) for _, p := range pods { // if a pod is fully terminated by UID, it should be excluded from the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
}) pod2 := makePod(v1.ResourceList{ v1.ResourceName(res2.resourceName): res2.resourceQuantity, }) activePods := []*v1.Pod{pod1, pod2} podsStub.updateActivePods(activePods) err = testManager.Allocate(pod1, &pod1.Spec.Containers[0]) as.Nil(err) err = testManager.Allocate(pod2, &pod2.Spec.Containers[0]) as.Nil(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the Permit plugins. RunPermitPlugins(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status // WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
} func (s *secretManager) RegisterPod(pod *v1.Pod) { s.manager.RegisterPod(pod) } func (s *secretManager) UnregisterPod(pod *v1.Pod) { s.manager.UnregisterPod(pod) } func getSecretNames(pod *v1.Pod) sets.Set[string] { result := sets.New[string]() podutil.VisitPodSecretNames(pod, func(name string) bool { result.Insert(name) return true }) return result
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// an actual pod condition type. type PodFailurePolicyOnPodConditionsPattern struct { // Specifies the required Pod condition type. To match a pod condition // it is required that specified type equals the pod condition type. Type corev1.PodConditionType `json:"type" protobuf:"bytes,1,req,name=type"` // Specifies the required Pod condition status. To match a pod condition
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
func (pc *PodCache) getPodByProxy(proxy *model.Proxy) *v1.Pod { var pod *v1.Pod key := podKeyByProxy(proxy) if key.Name != "" { pod = pc.getPodByKey(key) if pod != nil { return pod } } // only need to fetch the corresponding pod through the first IP, although there are multiple IP scenarios, // because multiple ips belong to the same pod proxyIP := proxy.IPAddresses[0]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
patchBytes: []byte(test.patch), } jp := jsonPatcher{patcher: p} codec := codecs.LegacyCodec(examplev1.SchemeGroupVersion) pod := &examplev1.Pod{} pod.Name = "podA" pod.ObjectMeta.Finalizers = []string{"foo"} versionedJS, err := runtime.Encode(codec, pod) if err != nil { t.Errorf("%s: unexpected error: %v", test.name, err) continue } _, _, err = jp.applyJSPatch(versionedJS)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager.go
} func (c *configMapManager) RegisterPod(pod *v1.Pod) { c.manager.RegisterPod(pod) } func (c *configMapManager) UnregisterPod(pod *v1.Pod) { c.manager.UnregisterPod(pod) } func getConfigMapNames(pod *v1.Pod) sets.Set[string] { result := sets.New[string]() podutil.VisitPodConfigmapNames(pod, func(name string) bool { result.Insert(name) return true })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0)