Merge pull request #112 from andresmgot/k0.6.0

Upgrade Kubeless version to 0.6.0. Add golang example

Author: andresmgot

.travis.yml

@@ -10,7 +10,7 @@ services:
   - docker
 env:
   global:
-    - KUBELESS_VERSION: v0.5.0
+    - KUBELESS_VERSION: v0.6.0
     - MINIKUBE_VERSION: v0.25.2
     - REPO_DOMAIN: serverless
     - REPO_NAME: serverless-kubeless

examples/post-go/README.md

@@ -0,0 +1,13 @@
+# Simple Hello World function
+
+This function returns the given data capitalizing the first word.
+
+```console
+$ npm install
+$ serverless deploy
+$ serverless invoke -f go-echo -l --data 'hello!'
+Serverless: Calling function: go-echo...
+--------------------------------------------------------------------
+hello!
+$ serverless remove
+```

examples/post-go/handler.go

@@ -0,0 +1,13 @@
+package kubeless
+
+import (
+	"fmt"
+
+	"github.com/kubeless/kubeless/pkg/functions"
+)
+
+// Handler sample function with data
+func Handler(event functions.Event, context functions.Context) (string, error) {
+	fmt.Println(event)
+	return event.Data, nil
+}

examples/post-go/package.json

@@ -0,0 +1,14 @@
+{
+  "name": "go-echo",
+  "version": "1.0.0",
+  "description": "Example function for serverless kubeless",
+  "dependencies": {
+    "serverless-kubeless": "^0.4.0"
+  },
+  "devDependencies": {},
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "Apache-2.0"
+}

examples/post-go/serverless.yml

@@ -0,0 +1,12 @@
+service: go-echo
+
+provider:
+  name: kubeless
+  runtime: go1.10
+
+plugins:
+  - serverless-kubeless
+
+functions:
+  go-echo:
+    handler: handler.Handler

scripts/integration-tests.sh

@@ -24,7 +24,7 @@ install_kubecfg() {
 
 install_kubeless() {
     kubectl create ns kubeless
-    kubectl create -f https://github.com/kubeless/kubeless/releases/download/$KUBELESS_VERSION/kubeless-rbac-$KUBELESS_VERSION.yaml
+    kubectl create -f https://github.com/kubeless/kubeless/releases/download/$KUBELESS_VERSION/kubeless-$KUBELESS_VERSION.yaml
     kubectl create -f https://github.com/kubeless/kubeless/releases/download/$KUBELESS_VERSION/kafka-zookeeper-$KUBELESS_VERSION.yaml
     curl -LO https://github.com/kubeless/kubeless/releases/download/$KUBELESS_VERSION/kubeless_linux-amd64.zip
     unzip kubeless_linux-amd64.zip

test/examples-test.js

@@ -104,6 +104,7 @@ describe('Examples', () => {
     'post-nodejs': { cwd: null, path: 'post-nodejs' },
     'post-python': { cwd: null, path: 'post-python' },
     'post-php': { cwd: null, path: 'post-php' },
+    'post-go': { cwd: null, path: 'post-go' },
     'post-ruby': { cwd: null, path: 'post-ruby' },
     'scheduled-node': { cwd: null, path: 'scheduled-node' },
     'todo-app': { cwd: null, path: 'todo-app/backend' },
@@ -386,6 +387,39 @@ describe('Examples', () => {
         });
     });
   });
+  describe('post-go', function () {
+    const exampleName = 'post-go';
+    before(function (done) {
+      examples[exampleName].cwd = path.join(cwd, examples[exampleName].path);
+      this.timeout(300000);
+      prepareExample(cwd, exampleName, (e) => {
+        if (e) {
+          throw e;
+        }
+        deployExample(examples[exampleName].cwd, (ee) => {
+          if (ee) {
+            throw ee;
+          }
+          done();
+        });
+      });
+    });
+    after(function (done) {
+      this.timeout(100000);
+      removeExample(examples[exampleName].cwd, () => {
+        done();
+      });
+    });
+    this.timeout(10000);
+    it('should return a "hello"', (done) => {
+      exec('serverless invoke -f go-echo -l --data \'hello!\'',
+        { cwd: examples['post-go'].cwd }, (err, stdout) => {
+          if (err) throw err;
+          expect(stdout).to.contain('hello!');
+          done();
+        });
+    });
+  });
   describe('scheduled-node', function () {
     const exampleName = 'scheduled-node';
     before(function (done) {