go-pkg/drone-kubernetes
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 4 Wiki Activity

Compare commits

base: go-pkg:master
Branches Tags
go-pkg:master
go-pkg:v1.0.4
go-pkg:v1.0.3
go-pkg:v1.0.2
go-pkg:v1.0.1
..
compare: go-pkg:v1.0.3
Branches Tags
go-pkg:master
go-pkg:v1.0.4
go-pkg:v1.0.3
go-pkg:v1.0.2
go-pkg:v1.0.1

No commits in common. "master" and "v1.0.3" have entirely different histories.
master ... v1.0.3

1 changed files with 6 additions and 3 deletions
Show Stats Expand all files Collapse all files

9
k8s/client.go
View File

@ -7,6 +7,7 @@ import (
"fmt" "fmt"
appv1 "k8s.io/api/apps/v1" appv1 "k8s.io/api/apps/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/json"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
kindv1 "k8s.io/client-go/kubernetes/typed/apps/v1" kindv1 "k8s.io/client-go/kubernetes/typed/apps/v1"
"time" "time"
@ -69,9 +70,7 @@ func (c client) Do(namespace, kind, resourceName, actionMethod, repo string) (er
return fmt.Errorf("repo not empty") return fmt.Errorf("repo not empty")
} }
repo = utils.ParseImage(repo) resource.(*appv1.Deployment).Spec.Template.Spec.Containers[0].Image = utils.ParseImage(repo)
resource.(*appv1.Deployment).Spec.Template.Spec.Containers[0].Image = repo
_, err = kindType.(kindv1.DeploymentInterface).Update(context.Background(), resource.(*appv1.Deployment), metav1.UpdateOptions{}) _, err = kindType.(kindv1.DeploymentInterface).Update(context.Background(), resource.(*appv1.Deployment), metav1.UpdateOptions{})
@ -95,6 +94,10 @@ func (c client) Do(namespace, kind, resourceName, actionMethod, repo string) (er
return fmt.Errorf("get deployment error: %v", err.Error()) return fmt.Errorf("get deployment error: %v", err.Error())
} }
rJ, _ := json.Marshal(resource)
fmt.Println(string(rJ))
resource.(*appv1.Deployment).Spec.Template.ObjectMeta.Annotations["kubectl.kubernetes.io/restartedAt"] = time.Now().Local().String() resource.(*appv1.Deployment).Spec.Template.ObjectMeta.Annotations["kubectl.kubernetes.io/restartedAt"] = time.Now().Local().String()
_, err = kindType.(kindv1.DeploymentInterface).Update(context.Background(), resource.(*appv1.Deployment), metav1.UpdateOptions{}) _, err = kindType.(kindv1.DeploymentInterface).Update(context.Background(), resource.(*appv1.Deployment), metav1.UpdateOptions{})
if err != nil { if err != nil {