- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 143 for replicaSet (0.28 sec)
-
pkg/controller/replication/replication_controller.go
"k8s.io/kubernetes/pkg/controller/replicaset" ) const ( BurstReplicas = replicaset.BurstReplicas ) // ReplicationManager is responsible for synchronizing ReplicationController objects stored // in the system with actual running pods. // It is actually just a wrapper around ReplicaSetController. type ReplicationManager struct { replicaset.ReplicaSetController }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/controller/deployment/recreate.go
func oldPodsRunning(newRS *apps.ReplicaSet, oldRSs []*apps.ReplicaSet, podMap map[types.UID][]*v1.Pod) bool { if oldPods := util.GetActualReplicaCountForReplicaSets(oldRSs); oldPods > 0 { return true } for rsUID, podList := range podMap { // If the pods belong to the new ReplicaSet, ignore. if newRS != nil && newRS.UID == rsUID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
return out } makeReplicaSet := func(name string) *example2v1.ReplicaSet { return &example2v1.ReplicaSet{ ObjectMeta: metav1.ObjectMeta{Namespace: "ns", Name: name}, } } createReplicaSet := func(obj *example2v1.ReplicaSet) *example2v1.ReplicaSet { key := "replicasets/" + obj.Namespace + "/" + obj.Name out := &example2v1.ReplicaSet{} err := etcdStorage.Create(context.TODO(), key, obj, out, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/example/zz_generated.deepcopy.go
func (in *ReplicaSet) DeepCopyInto(out *ReplicaSet) { *out = *in out.TypeMeta = in.TypeMeta in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) out.Spec = in.Spec out.Status = in.Status return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicaSet. func (in *ReplicaSet) DeepCopy() *ReplicaSet { if in == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 6.1K bytes - Viewed (0) -
pkg/controller/deployment/progress.go
// for example a resync of the deployment after it was scaled up. In those cases, // we shouldn't try to estimate any progress. func (dc *DeploymentController) syncRolloutStatus(ctx context.Context, allRSs []*apps.ReplicaSet, newRS *apps.ReplicaSet, d *apps.Deployment) error { newStatus := calculateStatus(allRSs, newRS, d) // If there is no progressDeadlineSeconds set, remove any Progressing condition. if !util.HasProgressDeadline(d) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/controller/replicaset/metrics/metrics.go
"the sorting (and deletion) of pods when a replicaset scales down. This only considers Ready pods when calculating and reporting.", Buckets: metrics.ExponentialBuckets(0.25, 2, 6), StabilityLevel: metrics.ALPHA, }, ) // Register registers ReplicaSet controller metrics. func Register(registrationFunc func(metrics.Registerable) error) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 15:28:42 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/controller/deployment/rollback.go
v, err := deploymentutil.Revision(rs) if err != nil { logger.V(4).Info("Unable to extract revision from deployment's replica set", "replicaSet", klog.KObj(rs), "err", err) continue } if v == rollbackTo.Revision { logger.V(4).Info("Found replica set with desired revision", "replicaSet", klog.KObj(rs), "revision", v) // rollback by copying podTemplate.Spec from the replica set
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/registry/apps/rest/storage_apps.go
storage[resource+"/status"] = daemonSetStatusStorage } // replicasets if resource := "replicasets"; apiResourceConfigSource.ResourceEnabled(appsapiv1.SchemeGroupVersion.WithResource(resource)) { replicaSetStorage, err := replicasetstore.NewStorage(restOptionsGetter) if err != nil { return storage, err } storage[resource] = replicaSetStorage.ReplicaSet storage[resource+"/status"] = replicaSetStorage.Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/apis/config/types.go
poautosclerconfig "k8s.io/kubernetes/pkg/controller/podautoscaler/config" podgcconfig "k8s.io/kubernetes/pkg/controller/podgc/config" replicasetconfig "k8s.io/kubernetes/pkg/controller/replicaset/config" replicationconfig "k8s.io/kubernetes/pkg/controller/replication/config" resourcequotaconfig "k8s.io/kubernetes/pkg/controller/resourcequota/config"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 20:41:50 UTC 2023 - 8.1K bytes - Viewed (0) -
pkg/controller/replication/replication_controller_utils.go
See the License for the specific language governing permissions and limitations under the License. */ // If you make changes to this file, you should also make the corresponding change in ReplicaSet. package replication import ( "k8s.io/api/core/v1" ) // GetCondition returns a replication controller condition with the provided type if it exists.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 28 14:41:20 UTC 2023 - 2.3K bytes - Viewed (0)