From 612138b22d62ee8beb9160f285134c36440d40c5 Mon Sep 17 00:00:00 2001 From: Daniele Martinoli Date: Tue, 12 Jul 2022 14:48:12 +0200 Subject: [PATCH 1/3] Updated version to v1 --- src/serverless.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/serverless.js b/src/serverless.js index 9b77f61..115fc2d 100644 --- a/src/serverless.js +++ b/src/serverless.js @@ -3,7 +3,7 @@ const { isEmpty, mergeDeepRight } = require('ramda') const kubernetes = require('@kubernetes/client-node') const { Component } = require('@serverless/core') -const knativeVersion = 'v1alpha1' +const knativeVersion = 'v1' const defaults = { kubeConfigPath: path.join(process.env.HOME, '.kube', 'config'), From 7a40b3ef65ead507ec6688db591594ac4394322e Mon Sep 17 00:00:00 2001 From: Daniele Martinoli Date: Tue, 12 Jul 2022 15:13:09 +0200 Subject: [PATCH 2/3] Added annotationto create Broker if missing --- src/serverless.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/serverless.js b/src/serverless.js index 115fc2d..db76ca9 100644 --- a/src/serverless.js +++ b/src/serverless.js @@ -69,7 +69,10 @@ class KnativeEventing extends Component { apiVersion: `${knativeGroup}/${knativeVersion}`, kind, metadata: { - name, + annotations: { + "eventing.knative.dev/injection": "enabled" + }, + name, namespace }, spec From 60dcabfb89d31435d91722987ab74cd7e2c23fda Mon Sep 17 00:00:00 2001 From: Daniele Martinoli Date: Tue, 12 Jul 2022 15:35:25 +0200 Subject: [PATCH 3/3] Integrated changes for new Framework requirements --- src/serverless.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/serverless.js b/src/serverless.js index db76ca9..df63613 100644 --- a/src/serverless.js +++ b/src/serverless.js @@ -14,7 +14,7 @@ const defaults = { } class KnativeEventing extends Component { - async deploy(inputs = {}) { + async default(inputs = {}) { const config = mergeDeepRight(defaults, inputs) const k8sCustom = this.getKubernetesClient(config.kubeConfigPath, kubernetes.CustomObjectsApi) @@ -36,6 +36,7 @@ class KnativeEventing extends Component { } this.state = config + await this.save() return this.state } @@ -53,6 +54,7 @@ class KnativeEventing extends Component { await this.deleteEvent(k8sCustom, params) this.state = {} + await this.save() return {} }