- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,369 for Pods (0.04 sec)
-
pkg/scheduler/internal/cache/snapshot_test.go
} } func TestCreateUsedPVCSet(t *testing.T) { tests := []struct { name string pods []*v1.Pod expected sets.Set[string] }{ { name: "empty pods list", pods: []*v1.Pod{}, expected: sets.New[string](), }, { name: "pods not scheduled", pods: []*v1.Pod{ st.MakePod().Name("foo").Namespace("foo").Obj(), st.MakePod().Name("bar").Namespace("bar").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1beta1/generated.proto
// An empty selector ({}) also selects no pods, which differs from standard behavior of selecting all pods. // In policy/v1, an empty selector will select all pods in the namespace. // +optional optional .k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector selector = 2; // An eviction is allowed if at most "maxUnavailable" pods selected by // "selector" are unavailable after the eviction, i.e. even in absence of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
makeGCSandbox(pods[1], 0, runtimeapi.PodSandboxState_SANDBOX_NOTREADY, true, false, 0), // exited sandbox without containers for deleted pods. makeGCSandbox(pods[2], 0, runtimeapi.PodSandboxState_SANDBOX_NOTREADY, false, true, 0), }, containers: []containerTemplate{ {pod: pods[1], container: &pods[1].Spec.Containers[0], sandboxAttempt: 1, state: runtimeapi.ContainerState_CONTAINER_EXITED}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0) -
staging/src/k8s.io/api/apps/v1beta1/generated.proto
// can be scaled down further, followed by scaling up the new ReplicaSet, ensuring // that the total number of pods available at all times during the update is at // least 70% of desired pods. // +optional optional .k8s.io.apimachinery.pkg.util.intstr.IntOrString maxUnavailable = 1; // The maximum number of pods that can be scheduled above the desired number of // pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 24.1K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_switch_test.go
pods := []types.UID{"pod-1", "pod-2"} testUserNsPodsManager := &testUserNsPodsManager{ podDir: t.TempDir(), // List the same pods we will record, so the second time we create the userns // manager, it will find these pods on disk with userns data. podList: pods, } m, err := MakeUserNsManager(testUserNsPodsManager) require.NoError(t, err) // Record the pods on disk. for _, podUID := range pods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5K bytes - Viewed (0) -
pkg/apis/policy/types.go
// Healthy pods will be subject to the PDB for eviction. // // AlwaysAllow policy means that all running pods (status.phase="Running"), // but not yet healthy are considered disrupted and can be evicted regardless // of whether the criteria in a PDB is met. This means perspective running // pods of a disrupted application might not get a chance to become healthy. // Healthy pods will be subject to the PDB for eviction. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 20:44:13 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kubelet/config/file.go
func newSourceFile(path string, nodeName types.NodeName, period time.Duration, updates chan<- interface{}) *sourceFile { send := func(objs []interface{}) { var pods []*v1.Pod for _, o := range objs { pods = append(pods, o.(*v1.Pod)) } updates <- kubetypes.PodUpdate{Pods: pods, Op: kubetypes.SET, Source: kubetypes.FileSource} } store := cache.NewUndeltaStore(send, cache.MetaNamespaceKeyFunc) return &sourceFile{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 6.2K bytes - Viewed (0) -
pkg/controller/controller_ref_manager_test.go
type test struct { name string manager *PodControllerRefManager pods []*v1.Pod claimed []*v1.Pod patches int } var tests = []test{ func() test { controller := v1.ReplicationController{} controller.Namespace = metav1.NamespaceDefault return test{ name: "Claim pods with correct label", manager: NewPodControllerRefManager(&FakePodControl{}, &controller,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 10 17:19:26 UTC 2021 - 10.6K bytes - Viewed (0) -
pkg/kubelet/container/runtime_cache.go
return err } r.pods, r.cacheTime = pods, timestamp return nil } // getPodsWithTimestamp records a timestamp and retrieves pods from the getter. func (r *runtimeCache) getPodsWithTimestamp(ctx context.Context) ([]*Pod, time.Time, error) { // Always record the timestamp before getting the pods to avoid stale pods. timestamp := time.Now() pods, err := r.getter.GetPods(ctx, false) return pods, timestamp, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 04:03:51 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/kclient/index_test.go
NodeName: "node", }, } assertIndex := func(k SaNode, pods ...*corev1.Pod) { t.Helper() assert.EventuallyEqual(t, func() []*corev1.Pod { return index.Lookup(k) }, pods, retry.Timeout(time.Second*5)) } // When we create a pod, we should (eventually) see it in the index c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod1, metav1.CreateOptions{}) assertIndex(k1, pod1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0)