Add labels specified in serverless.yml functions to triggers (#223)

Author: lorenzo-ange

lib/deploy.js

@@ -400,9 +400,10 @@ function deployMQTrigger(mqType, name, namespace, topic, options) {
     metadata: {
       name: _.kebabCase(`${name}-${topic}`),
       namespace,
-      labels: {
-        'created-by': 'kubeless',
-      },
+      labels: Object.assign(
+        { 'created-by': 'kubeless' },
+        options.labels
+      ),
     },
     spec: {
       functionSelector: {
@@ -438,9 +439,10 @@ function deployScheduleTrigger(name, namespace, schedule, options) {
     metadata: {
       name,
       namespace,
-      labels: {
-        'created-by': 'kubeless',
-      },
+      labels: Object.assign(
+        { 'created-by': 'kubeless' },
+        options.labels
+      ),
     },
     spec: {
       'function-name': name,
@@ -474,9 +476,10 @@ function deployHttpTrigger(name, namespace, path, options) {
     metadata: {
       name,
       namespace,
-      labels: {
-        'created-by': 'kubeless',
-      },
+      labels: Object.assign(
+        { 'created-by': 'kubeless' },
+        options.labels
+      ),
       annotations: Object.assign(baseAnnotations, options.ingress.additionalAnnotations),
     },
     spec: {
@@ -590,7 +593,7 @@ function handleMQTDeployment(trigger, name, namespace, options) {
     name,
     namespace,
     mqTrigger.topic,
-    { log: options.log }
+    options
   );
 }
 
@@ -614,6 +617,7 @@ function deployTrigger(event, funcName, namespace, service, options) {
           log: options.log,
           ingress: options.ingress || {},
           hostname: event.hostname || options.hostname || defaultHostname,
+          labels: options.labels,
         }
       );
       break;
@@ -625,7 +629,10 @@ function deployTrigger(event, funcName, namespace, service, options) {
         event.trigger,
         funcName,
         namespace,
-        { log: options.log }
+        {
+          log: options.log,
+          labels: options.labels,
+        }
       );
       break;
     case 'schedule':
@@ -636,7 +643,10 @@ function deployTrigger(event, funcName, namespace, service, options) {
         funcName,
         namespace,
         event.schedule,
-        { log: options.log }
+        {
+          log: options.log,
+          labels: options.labels,
+        }
       );
       break;
     default:
@@ -661,6 +671,7 @@ function deploy(functions, runtime, service, options) {
         verbose: false,
         log: console.log,
         contentType: ('contentType' in description) ? description.contentType : 'text',
+        labels: description.labels || {},
       });
 
       const ns = description.namespace || opts.namespace;