Added update to knative backend

pkg/backends/k8s.go

@@ -20,7 +20,6 @@ import (
 	"context"
 	"fmt"
 	"log"
-	"os"
 	"strings"
 
 	"github.com/goccy/go-yaml"
@@ -33,8 +32,6 @@ import (
 
 const ConfigMapNameOSCAR = "additional-oscar-config"
 
-var k8sLogger = log.New(os.Stdout, "[BACKEND-INFO] ", log.Flags())
-
 // KubeBackend struct to represent a Kubernetes client to store services as podTemplates
 type KubeBackend struct {
 	kubeClientset kubernetes.Interface
@@ -133,7 +130,6 @@ func (k *KubeBackend) CreateService(service types.Service) error {
 	}
 	//Create deaemonset to cache the service image on all the nodes
 	if service.ImagePrefetch {
-		k8sLogger.Println("Updating service image on all working nodes")
 		err = imagepuller.CreateDaemonset(k.config, service, k.kubeClientset)
 		if err != nil {
 			return err
@@ -222,7 +218,6 @@ func (k *KubeBackend) UpdateService(service types.Service) error {
 
 	//Create deaemonset to cache the service image on all the nodes
 	if service.ImagePrefetch {
-
 		err = imagepuller.CreateDaemonset(k.config, service, k.kubeClientset)
 		if err != nil {
 			return err

pkg/backends/knative.go

@@ -226,6 +226,14 @@ func (kn *KnativeBackend) UpdateService(service types.Service) error {
 		}
 	}
 
+	//Create deaemonset to cache the service image on all the nodes
+	if service.ImagePrefetch {
+		err = imagepuller.CreateDaemonset(kn.config, service, kn.kubeClientset)
+		if err != nil {
+			return err
+		}
+	}
+
 	return nil
 }
 

pkg/imagepuller/daemonset.go

@@ -73,8 +73,6 @@ func CreateDaemonset(cfg *types.Config, service types.Service, kubeClientset kub
 	if err != nil {
 		DaemonSetLoggerInfo.Println(err)
 		return fmt.Errorf("failed to create daemonset: %s", err.Error())
-	} else {
-		DaemonSetLoggerInfo.Println("Created daemonset for service:", service.Name)
 	}
 
 	//Set watcher informer