forked from openkruise/rollouts
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Kuromesi <[email protected]>
- Loading branch information
Showing
85 changed files
with
2,189 additions
and
2,016 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,87 @@ | ||
| package v1beta1 | ||
|
|
||
| import ( | ||
| apps "k8s.io/api/apps/v1" | ||
| "k8s.io/apimachinery/pkg/util/intstr" | ||
| ) | ||
|
|
||
| const ( | ||
| // DeploymentStrategyAnnotation is annotation for deployment, | ||
| // which is strategy fields of Advanced Deployment. | ||
| DeploymentStrategyAnnotation = "rollouts.kruise.io/deployment-strategy" | ||
|
|
||
| // DeploymentExtraStatusAnnotation is annotation for deployment, | ||
| // which is extra status field of Advanced Deployment. | ||
| DeploymentExtraStatusAnnotation = "rollouts.kruise.io/deployment-extra-status" | ||
|
|
||
| // DeploymentStableRevisionLabel is label for deployment, | ||
| // which record the stable revision during the current rolling process. | ||
| DeploymentStableRevisionLabel = "rollouts.kruise.io/stable-revision" | ||
|
|
||
| // AdvancedDeploymentControlLabel is label for deployment, | ||
| // which labels whether the deployment is controlled by advanced-deployment-controller. | ||
| AdvancedDeploymentControlLabel = "rollouts.kruise.io/controlled-by-advanced-deployment-controller" | ||
| ) | ||
|
|
||
| // DeploymentStrategy is strategy field for Advanced Deployment | ||
| type DeploymentStrategy struct { | ||
| // RollingStyle define the behavior of rolling for deployment. | ||
| RollingStyle RollingStyleType `json:"rollingStyle,omitempty"` | ||
| // original deployment strategy rolling update fields | ||
| RollingUpdate *apps.RollingUpdateDeployment `json:"rollingUpdate,omitempty"` | ||
| // Paused = true will block the upgrade of Pods | ||
| Paused bool `json:"paused,omitempty"` | ||
| // Partition describe how many Pods should be updated during rollout. | ||
| // We use this field to implement partition-style rolling update. | ||
| Partition intstr.IntOrString `json:"partition,omitempty"` | ||
| } | ||
|
|
||
| type RollingStyleType string | ||
|
|
||
| const ( | ||
| // PartitionRollingStyle means rolling in batches just like CloneSet, and will NOT create any extra Deployment; | ||
| PartitionRollingStyle RollingStyleType = "Partition" | ||
| // CanaryRollingStyle means rolling in canary way, and will create a canary Deployment. | ||
| CanaryRollingStyle RollingStyleType = "Canary" | ||
| ) | ||
|
|
||
| // DeploymentExtraStatus is extra status field for Advanced Deployment | ||
| type DeploymentExtraStatus struct { | ||
| // UpdatedReadyReplicas the number of pods that has been updated and ready. | ||
| UpdatedReadyReplicas int32 `json:"updatedReadyReplicas,omitempty"` | ||
| // ExpectedUpdatedReplicas is an absolute number calculated based on Partition | ||
| // and Deployment.Spec.Replicas, means how many pods are expected be updated under | ||
| // current strategy. | ||
| // This field is designed to avoid users to fall into the details of algorithm | ||
| // for Partition calculation. | ||
| ExpectedUpdatedReplicas int32 `json:"expectedUpdatedReplicas,omitempty"` | ||
| } | ||
|
|
||
| func SetDefaultDeploymentStrategy(strategy *DeploymentStrategy) { | ||
| if strategy.RollingStyle == CanaryRollingStyle { | ||
| return | ||
| } | ||
| if strategy.RollingUpdate == nil { | ||
| strategy.RollingUpdate = &apps.RollingUpdateDeployment{} | ||
| } | ||
| if strategy.RollingUpdate.MaxUnavailable == nil { | ||
| // Set MaxUnavailable as 25% by default | ||
| maxUnavailable := intstr.FromString("25%") | ||
| strategy.RollingUpdate.MaxUnavailable = &maxUnavailable | ||
| } | ||
| if strategy.RollingUpdate.MaxSurge == nil { | ||
| // Set MaxSurge as 25% by default | ||
| maxSurge := intstr.FromString("25%") | ||
| strategy.RollingUpdate.MaxUnavailable = &maxSurge | ||
| } | ||
|
|
||
| // Cannot allow maxSurge==0 && MaxUnavailable==0, otherwise, no pod can be updated when rolling update. | ||
| maxSurge, _ := intstr.GetScaledValueFromIntOrPercent(strategy.RollingUpdate.MaxSurge, 100, true) | ||
| maxUnavailable, _ := intstr.GetScaledValueFromIntOrPercent(strategy.RollingUpdate.MaxUnavailable, 100, true) | ||
| if maxSurge == 0 && maxUnavailable == 0 { | ||
| strategy.RollingUpdate = &apps.RollingUpdateDeployment{ | ||
| MaxSurge: &intstr.IntOrString{Type: intstr.Int, IntVal: 0}, | ||
| MaxUnavailable: &intstr.IntOrString{Type: intstr.Int, IntVal: 1}, | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.