Fix typos and clean up

Makefile

@@ -38,7 +38,7 @@ binary-cross:
 
 all-yaml: kubeless.yaml kubeless-non-rbac.yaml kubeless-openshift.yaml kafka-zookeeper.yaml
 
-kubeless.yaml: kubeless.jsonnet
+kubeless.yaml: kubeless.jsonnet kubeless-non-rbac.jsonnet
 
 kubeless-non-rbac.yaml: kubeless-non-rbac.jsonnet
 

cmd/kubeless/function/call.go

@@ -97,7 +97,7 @@ var callCmd = &cobra.Command{
 			logrus.Fatalf("Unable to generate ID %v", err)
 		}
 		req.SetHeader("event-id", eventID)
-		req.SetHeader("event-time", timestamp.String())
+		req.SetHeader("event-time", timestamp.Format(time.RFC3339))
 		req.SetHeader("event-namespace", "cli.kubeless.io")
 		res, err := req.Do().Raw()
 		if err != nil {

cmd/kubeless/trigger/kafka/create.go

@@ -113,7 +113,7 @@ var createCmd = &cobra.Command{
 func init() {
 	createCmd.Flags().StringP("namespace", "n", "", "Specify namespace for the kafka trigger")
 	createCmd.Flags().StringP("trigger-topic", "", "", "Specify topic to listen to in Kafka broker")
-	createCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. -function-selector key1=value1,key2=value2)")
+	createCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. --function-selector key1=value1,key2=value2)")
 	createCmd.MarkFlagRequired("trigger-topic")
 	createCmd.MarkFlagRequired("function-selector")
 	createCmd.Flags().Bool("dryrun", false, "Output JSON manifest of the function without creating it")

cmd/kubeless/trigger/kafka/update.go

@@ -107,7 +107,7 @@ var updateCmd = &cobra.Command{
 func init() {
 	updateCmd.Flags().StringP("namespace", "n", "", "Specify namespace for the function")
 	updateCmd.Flags().StringP("trigger-topic", "", "", "Specify topic to listen to in Kafka broker")
-	updateCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. -function-selector key1=value1,key2=value2)")
+	updateCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. --function-selector key1=value1,key2=value2)")
 	updateCmd.Flags().Bool("dryrun", false, "Output JSON manifest of the function without creating it")
 	updateCmd.Flags().StringP("output", "o", "yaml", "Output format")
 }

cmd/kubeless/trigger/nats/create.go

@@ -114,7 +114,7 @@ var createCmd = &cobra.Command{
 func init() {
 	createCmd.Flags().StringP("namespace", "n", "", "Specify namespace for the NATS trigger")
 	createCmd.Flags().StringP("trigger-topic", "", "", "Specify topic to listen to in NATS")
-	createCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. -function-selector key1=value1,key2=value2)")
+	createCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. --function-selector key1=value1,key2=value2)")
 	createCmd.MarkFlagRequired("trigger-topic")
 	createCmd.MarkFlagRequired("function-selector")
 	createCmd.Flags().Bool("dryrun", false, "Output JSON manifest of the function without creating it")

cmd/kubeless/trigger/nats/update.go

@@ -107,7 +107,7 @@ var updateCmd = &cobra.Command{
 func init() {
 	updateCmd.Flags().StringP("namespace", "n", "", "Specify namespace for the NATS trigger")
 	updateCmd.Flags().StringP("trigger-topic", "", "", "Specify topic to listen to in NATS")
-	updateCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. -function-selector key1=value1,key2=value2)")
+	updateCmd.Flags().StringP("function-selector", "", "", "Selector (label query) to select function on (e.g. --function-selector key1=value1,key2=value2)")
 	updateCmd.Flags().Bool("dryrun", false, "Output JSON manifest of the function without creating it")
 	updateCmd.Flags().StringP("output", "o", "yaml", "Output format")
 }

docs/advanced-function-deployment.md

@@ -8,6 +8,9 @@ kind: Function
 metadata:
   name: get-python
   namespace: default
+  label:
+    created-by: kubeless
+    function: get-python
 spec:
   runtime: python2.7
   timeout: "180"

pkg/controller/function_controller.go

@@ -230,7 +230,7 @@ func (c *FunctionController) processItem(key string) error {
 			c.logger.Errorf("Failed to remove function controller as finalizer to Function Obj: %s object due to: %v: ", key, err)
 			return err
 		}
-		c.logger.Infof("Function object %s has been successfully processed and marked for deleteion", key)
+		c.logger.Infof("Function object %s has been successfully processed and marked for deletion", key)
 		return nil
 	}
 

pkg/utils/kubelessutil.go

@@ -641,6 +641,8 @@ func EnsureFuncDeployment(client kubernetes.Interface, funcObj *kubelessApi.Func
 				Value: dpm.Spec.Template.Spec.Containers[0].Resources.Limits.Memory().String(),
 			},
 		)
+	} else {
+		logrus.Warn("Expected non-empty handler and non-empty function content")
 	}
 
 	dpm.Spec.Template.Spec.Containers[0].Env = append(dpm.Spec.Template.Spec.Containers[0].Env,

script/binary

@@ -23,9 +23,7 @@ BUILD_FLAGS=(-ldflags="-w -X github.com/kubeless/kubeless/pkg/version.Version=${
 # Get rid of existing binary
 echo "Removing Old Kubeless binaries"
 rm -f ${GOPATH%%:*}/bin/kubeless
-rm -f ${GOPATH%%:*}/bin/kafka-trigger-controller
-rm -f ${GOPATH%%:*}/bin/kubeless-controller-manager
-rm -f ${GOPATH%%:*}/bin/nats-trigger-controller
+rm -f ${GOPATH%%:*}/bin/function-controller
 
 echo "Build Kubeless Components binaries"
 # Build binary