Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for PDB (0.03 sec)

  1. pkg/registry/policy/poddisruptionbudget/strategy_test.go

    		},
    	}
    
    	Strategy.PrepareForCreate(ctx, pdb)
    	errs := Strategy.Validate(ctx, pdb)
    	if len(errs) != 0 {
    		if !tc.expectedValidationErr {
    			t.Errorf("Unexpected error validating %v", errs)
    		}
    		return // no point going further when we have invalid PDB
    	}
    	if len(errs) == 0 && tc.expectedValidationErr {
    		t.Errorf("Expected error validating")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  2. pkg/controller/disruption/disruption.go

    	pdb := dc.getPdbForPod(logger, pod)
    	if pdb == nil {
    		logger.V(4).Info("No matching PDB for pod", "pod", klog.KObj(pod))
    		return
    	}
    	logger.V(4).Info("DeletePod -> PDB", "pod", klog.KObj(pod), "podDisruptionBudget", klog.KObj(pdb))
    	dc.enqueuePdb(logger, pdb)
    }
    
    func (dc *DisruptionController) enqueuePdb(logger klog.Logger, pdb *policy.PodDisruptionBudget) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/policy/v1/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: Thu May 23 17:42:49 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. pkg/registry/core/pod/storage/eviction_test.go

    }
    
    func TestEvictionPDBStatus(t *testing.T) {
    	testcases := []struct {
    		name                       string
    		pdb                        *policyv1.PodDisruptionBudget
    		expectedDisruptionsAllowed int32
    		expectedReason             string
    	}{
    		{
    			name: "pdb status is updated after eviction",
    			pdb: &policyv1.PodDisruptionBudget{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: "default"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 09:26:37 UTC 2024
    - 40K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/policy/v1beta1/generated.proto

      // disrupted (status.currentHealthy is at least equal to status.desiredHealthy).
      // 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.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/preemption/preemption.go

    // along with the list of victims that should be evicted for the preemptor to fit the node.
    type Candidate interface {
    	// Victims wraps a list of to-be-preempted Pods and the number of PDB violation.
    	Victims() *extenderv1.Victims
    	// Name returns the target node name where the preemptor gets nominated to run.
    	Name() string
    }
    
    type candidate struct {
    	victims *extenderv1.Victims
    	name    string
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  7. operator/cmd/mesh/manifest-generate_test.go

    		service := mustFindObject(t, objs, cname, name.ServiceStr)
    		pdb := mustFindObject(t, objs, cname, name.PDBStr)
    		hpa := mustFindObject(t, objs, cname, name.HPAStr)
    		podLabels := mustGetLabels(t, deployment, "spec.template.metadata.labels")
    		// Check all selectors align
    		mustSelect(t, mustGetLabels(t, pdb, "spec.selector.matchLabels"), podLabels)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 04 18:05:06 UTC 2024
    - 43.5K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/preemption/preemption_test.go

    		name               string
    		nodes              []*v1.Node
    		testPods           []*v1.Pod
    		initPods           []*v1.Pod
    		numViolatingVictim int
    		expected           [][]Candidate
    	}{
    		{
    			name: "no pdb violation",
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node1").Capacity(veryLargeRes).Obj(),
    				st.MakeNode().Name("node2").Capacity(veryLargeRes).Obj(),
    			},
    			testPods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  9. pkg/scheduler/testing/framework/fake_extender.go

    // Returns:
    // 1. More victim pods (if any) amended by preemption phase of extender.
    // 2. Number of violating victim (used to calculate PDB).
    // 3. Fits or not after preemption phase on extender's side.
    func (f *FakeExtender) selectVictimsOnNodeByExtender(logger klog.Logger, pod *v1.Pod, node *framework.NodeInfo) ([]*v1.Pod, int, bool, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top