forked from kubernetes/dashboard
-
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.
Implements rollout APIs for deployment (kubernetes#5917)
* Implements rollout APIs for deployment This implements REST APIs for `kubectl rollout deployment` command. Also, implements frontend for `kubectl rollout restart deployment` command. Co-authored-by: ZeHuaiWang <[email protected]> * Implements REST APIs for pause and resume Also, refactor followings: - Change http method for rollout actions to PUT, following other actions. - Define annotation keys as const. * Remove MatDialogRef Co-authored-by: ZeHuaiWang <[email protected]>
- Loading branch information
1 parent
421557f
commit a64a975
Showing
16 changed files
with
2,838 additions
and
2,142 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| // Copyright 2017 The Kubernetes Authors. | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package deployment | ||
|
|
||
| import ( | ||
| "context" | ||
| "errors" | ||
| "time" | ||
|
|
||
| v1 "k8s.io/api/apps/v1" | ||
| metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| client "k8s.io/client-go/kubernetes" | ||
| ) | ||
|
|
||
| const ( | ||
| // FirstRevision is a first revision number | ||
| FirstRevision = "1" | ||
| // RestartedAtAnnotationKey is an annotation key for rollout restart | ||
| RestartedAtAnnotationKey = "kubectl.kubernetes.io/restartedAt" | ||
| // RevisionAnnotationKey is an annotation key for rollout targeted or resulted revision | ||
| RevisionAnnotationKey = "deployment.kubernetes.io/revision" | ||
| ) | ||
|
|
||
| // RolloutSpec is a specification for deployment rollout | ||
| type RolloutSpec struct { | ||
| // Revision is the requested/resulted revision number of the ReplicateSet to rollback. | ||
| Revision string `json:"revision"` | ||
| } | ||
|
|
||
| // RollbackDeployment rollback to a specific ReplicaSet revision | ||
| func RollbackDeployment(client client.Interface, rolloutSpec *RolloutSpec, namespace, name string) (*RolloutSpec, error) { | ||
| deployment, err := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| currRevision := deployment.Annotations[RevisionAnnotationKey] | ||
| if currRevision == FirstRevision { | ||
| return nil, errors.New("No revision for rolling back ") | ||
| } | ||
| matchRS, err := GetReplicaSetFromDeployment(client, namespace, name) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| for _, rs := range matchRS { | ||
| if rs.Annotations[RevisionAnnotationKey] == rolloutSpec.Revision { | ||
| updateDeployment := deployment.DeepCopy() | ||
| updateDeployment.Spec.Template.Spec = rs.Spec.Template.Spec | ||
| res, err := client.AppsV1().Deployments(namespace).Update(context.TODO(), updateDeployment, metaV1.UpdateOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &RolloutSpec{ | ||
| Revision: res.Annotations[RevisionAnnotationKey], | ||
| }, nil | ||
| } | ||
| } | ||
| return nil, errors.New("There is no ReplicaSet that has the requested revision for the Deployment.") | ||
| } | ||
|
|
||
| // PauseDeployment is used to pause a deployment | ||
| func PauseDeployment(client client.Interface, namespace, name string) (*v1.Deployment, error) { | ||
| deployment, err := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if !deployment.Spec.Paused { | ||
| deployment.Spec.Paused = true | ||
| _, err = client.AppsV1().Deployments(namespace).Update(context.TODO(), deployment, metaV1.UpdateOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return deployment, nil | ||
| } | ||
| return nil, errors.New("The Deployment is already paused.") | ||
| } | ||
|
|
||
| // ResumeDeployment is used to resume a deployment | ||
| func ResumeDeployment(client client.Interface, namespace, name string) (*v1.Deployment, error) { | ||
| deployment, err := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if deployment.Spec.Paused { | ||
| deployment.Spec.Paused = false | ||
| _, err = client.AppsV1().Deployments(namespace).Update(context.TODO(), deployment, metaV1.UpdateOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return deployment, nil | ||
| } | ||
| return nil, errors.New("The deployment is already resumed.") | ||
| } | ||
|
|
||
| // RestartDeployment restarts a deployment in the manner of `kubectl rollout restart`. | ||
| func RestartDeployment(client client.Interface, namespace, name string) (*RolloutSpec, error) { | ||
| deployment, err := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| if deployment.Spec.Template.ObjectMeta.Annotations == nil { | ||
| deployment.Spec.Template.ObjectMeta.Annotations = map[string]string{} | ||
| } | ||
| deployment.Spec.Template.ObjectMeta.Annotations[RestartedAtAnnotationKey] = time.Now().Format(time.RFC3339) | ||
| res, err := client.AppsV1().Deployments(namespace).Update(context.TODO(), deployment, metaV1.UpdateOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &RolloutSpec{ | ||
| Revision: res.Annotations[RevisionAnnotationKey], | ||
| }, nil | ||
| } | ||
|
|
||
| // GetReplicaSetFromDeployment return all replicaSet which is belong to the deployment | ||
| func GetReplicaSetFromDeployment(client client.Interface, namespace, name string) ([]v1.ReplicaSet, error) { | ||
| deployment, err := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{}) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| selector, err := metaV1.LabelSelectorAsSelector(deployment.Spec.Selector) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| options := metaV1.ListOptions{LabelSelector: selector.String()} | ||
| allRS, err := client.AppsV1().ReplicaSets(namespace).List(context.TODO(), options) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| var result []v1.ReplicaSet | ||
| for _, rs := range allRS.Items { | ||
| if metaV1.IsControlledBy(&rs, deployment) { | ||
| result = append(result, rs) | ||
| } | ||
| } | ||
| return result, nil | ||
| } |
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,25 @@ | ||
| // Copyright 2017 The Kubernetes Authors. | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| import {Component, Inject} from '@angular/core'; | ||
| import {MAT_DIALOG_DATA} from '@angular/material/dialog'; | ||
| import {ResourceMeta} from '../../services/global/actionbar'; | ||
|
|
||
| @Component({ | ||
| selector: 'kd-restart-resource-dialog', | ||
| templateUrl: 'template.html', | ||
| }) | ||
| export class RestartResourceDialog { | ||
| constructor(@Inject(MAT_DIALOG_DATA) public data: ResourceMeta) {} | ||
| } |
Oops, something went wrong.