Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 603 for Replicas (0.17 sec)

  1. pkg/controller/deployment/rolling.go

    	if *(newRS.Spec.Replicas) == *(deployment.Spec.Replicas) {
    		// Scaling not required.
    		return false, nil
    	}
    	if *(newRS.Spec.Replicas) > *(deployment.Spec.Replicas) {
    		// Scale down.
    		scaled, _, err := dc.scaleReplicaSetAndRecordEvent(ctx, newRS, *(deployment.Spec.Replicas), deployment)
    		return scaled, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 07:09:11 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  2. pkg/registry/core/replicationcontroller/storage/storage_test.go

    	if err != nil {
    		t.Fatalf("error fetching scale for %s: %v", name, err)
    	}
    	scale := obj.(*autoscaling.Scale)
    	if scale.Spec.Replicas != replicas {
    		t.Errorf("wrong replicas count expected: %d got: %d", replicas, rc.Spec.Replicas)
    	}
    
    	update.ResourceVersion = rc.ResourceVersion
    	update.Spec.Replicas = 15
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 16 06:57:01 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  3. pkg/controller/deployment/util/deployment_util.go

    		scaleUpCount = min(scaleUpCount, *(deployment.Spec.Replicas)-*(newRS.Spec.Replicas))
    		return *(newRS.Spec.Replicas) + scaleUpCount, nil
    	case apps.RecreateDeploymentStrategyType:
    		return *(deployment.Spec.Replicas), nil
    	default:
    		return 0, fmt.Errorf("deployment type %v isn't supported", deployment.Spec.Strategy.Type)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 07:09:11 UTC 2023
    - 39.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/apps/v1beta1/generated.proto

      // the replica count to be deleted.
      optional string whenScaled = 2;
    }
    
    // A StatefulSetSpec is the specification of a StatefulSet.
    message StatefulSetSpec {
      // replicas is the desired number of replicas of the given Template.
      // These are replicas in the sense that they are instantiations of the
      // same Template, but individual replicas also have a consistent identity.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  5. pkg/controller/deployment/util/deployment_util_test.go

    		},
    		{
    			name: "not complete: still running old pods",
    
    			// old replica set: spec.replicas=1, status.replicas=1, status.availableReplicas=1
    			// new replica set: spec.replicas=1, status.replicas=1, status.availableReplicas=0
    			d:        deployment(1, 2, 1, 1, 0, 1),
    			expected: false,
    		},
    		{
    			name: "not complete: one replica deployment never comes up",
    
    			d:        deployment(1, 1, 1, 0, 1, 1),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 37.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go

    	status := content["status"].(map[string]interface{})
    
    	if spec["replicas"].(int64) != 7 {
    		t.Errorf("we expected .spec.replicas to not be updated but it was updated to %v", spec["replicas"].(int64))
    	}
    	if status["replicas"].(int64) != 7 {
    		t.Errorf("we expected .status.replicas to be updated to %d but it was %v", 7, status["replicas"].(int64))
    	}
    }
    
    func TestScaleGet(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  7. pkg/controller/deployment/sync_test.go

    			wasntUpdated: map[string]bool{"foo-v2": true, "foo-v1": true},
    		},
    		// Scenario: deployment.spec.replicas == 3 ( foo-v1.spec.replicas == foo-v2.spec.replicas == foo-v3.spec.replicas == 1 )
    		// Deployment is scaled to 5. foo-v3.spec.replicas and foo-v2.spec.replicas should increment by 1 but foo-v2 fails to
    		// update.
    		{
    			name:          "failed rs update",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  8. pkg/controller/statefulset/stateful_set_control.go

    		}
    	}
    
    	if identityMatches(set, replicas[i]) && storageMatches(set, replicas[i]) && retentionMatch {
    		return false, nil
    	}
    
    	// Make a deep copy so we don't mutate the shared cache
    	replica := replicas[i].DeepCopy()
    	if err := ssc.podControl.UpdateStatefulPod(ctx, updateSet, replica); err != nil {
    		return true, err
    	}
    
    	return false, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/apps/v1beta1/types.go

    	// to number replicas from an alternate index (eg: 1-indexed) over the default
    	// 0-indexed names, or to orchestrate progressive movement of replicas from
    	// one StatefulSet to another.
    	// If set, replica indices will be in the range:
    	//   [.spec.ordinals.start, .spec.ordinals.start + .spec.replicas).
    	// If unset, defaults to 0. Replica indices will be in the range:
    	//   [0, .spec.replicas).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 27 20:06:24 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  10. pkg/controller/deployment/recreate_test.go

    			oldRSs = append(oldRSs, rs)
    
    			rsCopy := rs.DeepCopy()
    
    			zero := int32(0)
    			rsCopy.Spec.Replicas = &zero
    			expected = append(expected, rsCopy)
    
    			if *(oldRSs[n].Spec.Replicas) == *(expected[n].(*apps.ReplicaSet).Spec.Replicas) {
    				t.Errorf("broken test - original and expected RS have the same size")
    			}
    		}
    
    		kc := fake.NewSimpleClientset(expected...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
Back to top