knative
/
func
mirror of https://github.com/knative/func.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

style: formatting

This commit is contained in:
Matej Vasek 2020-06-18 21:48:58 +02:00
parent 22c60c7379
commit f3b97291ed
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
knative/updater.go
View File

@ -2,13 +2,15 @@ package knative
import (
"fmt"
"github.com/boson-project/faas/k8s"
"sort"
"time"
apiCoreV1 "k8s.io/api/core/v1"
apiMachineryV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/tools/clientcmd"
servingV1client "knative.dev/serving/pkg/client/clientset/versioned/typed/serving/v1"
"sort"
"time"
"github.com/boson-project/faas/k8s"
)
type Updater struct {
@ -17,7 +19,7 @@ type Updater struct {
client *servingV1client.ServingV1Client
}
func NewUpdater(namespace string) (updater *Updater, err error){
func NewUpdater(namespace string) (updater *Updater, err error) {
updater = &Updater{}
updater.namespace = namespace
loadingRules := clientcmd.NewDefaultClientConfigLoadingRules()
@ -33,9 +35,8 @@ func NewUpdater(namespace string) (updater *Updater, err error){
return
}
func (updater *Updater) Update(name, image string) error {
client, namespace := updater.client, updater.namespace
client, namespace := updater.client, updater.namespace
project, err := k8s.ToSubdomain(name)
if err != nil {
@ -73,11 +74,10 @@ func (updater *Updater) Update(name, image string) error {
})
container.Env = envs
_, err = client.Services(namespace).Update(service)
if err != nil {
return fmt.Errorf("updater failed to update the service: %v", err)
}
return nil
}
}