samples of OpenFunction v0.6.0

Signed-off-by: laminar <[email protected]>

Author: tpiperatgod

README.md

@@ -1,9 +1,5 @@
 # OpenFunction function samples
 
-For samples of the latest stable version, please visit here:
-
--> [v0.5.0 samples](https://github.com/openFunction/samples/tree/release-0.5)
-
 ## Function samples
 
 The following are samples of OpenFunction function.

functions-framework/README.md

@@ -34,28 +34,28 @@ The processing in the plugin is as follows:
 plugin-custom
 
 ```go
-func (p *PluginCustom) ExecPreHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) ExecPreHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	p.stateC = 3
 	p.StateC = 3
 	return nil
 }
 
-func (p *PluginCustom) ExecPostHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) ExecPostHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	return nil
 }
 ```
 
 plugin-example
 
 ```go
-func (p *PluginExample) ExecPreHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginExample) ExecPreHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	r := preHookLogic(ctx.Ctx)
 	p.stateA = 1
 	p.stateB = r
 	return nil
 }
 
-func (p *PluginExample) ExecPostHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginExample) ExecPostHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	// Get data from another plugin via Plugin.Get()
 	plgName := "plugin-custom"
 	keyName := "StateC"

functions-framework/golang/Async/bindings/README.md

@@ -23,8 +23,8 @@ Prepare a context as follows, name it `function.json`. (You can refer to [OpenFu
   "inputs": {
     "cron": {
       "uri": "cron_input",
-      "type": "bindings",
-      "component": "cron_input"
+      "componentType": "bindings.cron",
+      "componentName": "cron_input"
     }
   },
   "outputs": {},
@@ -37,7 +37,8 @@ Prepare a context as follows, name it `function.json`. (You can refer to [OpenFu
 Create an environment variable `FUNC_CONTEXT` and assign the above context to it.
 
 ```shell
-export FUNC_CONTEXT='{"name":"bindings","version":"v1","requestID":"a0f2ad8d-5062-4812-91e9-95416489fb01","port":"50002","inputs":{"cron":{"uri":"cron_input","type":"bindings","component":"cron_input"}},"outputs":{},"runtime":"Async","prePlugins":["plugin-custom","plugin-example"],"postPlugins":["plugin-custom","plugin-example"]}'
+export FUNC_CONTEXT='{"name":"bindings","version":"v1","requestID":"a0f2ad8d-5062-4812-91e9-95416489fb01","port":"50002","inputs":{"cron":{"uri":"cron_input","componentType":"bindings.cron","componentName":"cron_input"}},"outputs":{},"runtime":"Async","prePlugins":["plugin-custom","plugin-example"],"postPlugins":["plugin-custom","plugin-example"]}'
+export CONTEXT_MODE='self-host'
 ```
 
 ### Run
@@ -52,7 +53,7 @@ dapr run --app-id bindings_grpc \
     --app-port 50002 \
     --dapr-grpc-port 50001 \
     --components-path ../../components \
-    go run ./main.go ./plugin.go
+    go run ./main.go
 ```
 
 ## Bindings with output
@@ -100,20 +101,20 @@ In this example, the proxy address of Dapr will be used as the target of output.
   "inputs": {
     "cron": {
       "uri": "cron_input",
-      "type": "bindings",
-      "component": "cron_input"
+      "componentType": "bindings.cron",
+      "componentName": "cron_input"
     }
   },
   "outputs": {
     "echo": {
       "uri": "echo",
       "operation": "create",
-      "component": "echo",
+      "componentName": "echo",
       "metadata": {
         "path": "echo",
         "Content-Type": "application/json; charset=utf-8"
       },
-      "type": "bindings"
+      "componentType": "bindings.http"
     }
   },
   "runtime": "Async",
@@ -125,7 +126,8 @@ In this example, the proxy address of Dapr will be used as the target of output.
 Create an environment variable `FUNC_CONTEXT` and assign the above context to it.
 
 ```shell
-export FUNC_CONTEXT='{"name":"bindings","version":"v1","requestID":"a0f2ad8d-5062-4812-91e9-95416489fb01","port":"50002","inputs":{"cron":{"uri":"cron_input","type":"bindings","component":"cron_input"}},"outputs":{"echo":{"uri":"echo","operation":"create","component":"echo","metadata":{"path":"echo","Content-Type":"application/json; charset=utf-8"},"type":"bindings"}},"runtime":"Async","prePlugins":["plugin-custom","plugin-example"],"postPlugins":["plugin-custom","plugin-example"]}'
+export FUNC_CONTEXT='{"name":"bindings","version":"v1","requestID":"a0f2ad8d-5062-4812-91e9-95416489fb01","port":"50002","inputs":{"cron":{"uri":"cron_input","componentType":"bindings.cron","componentName":"cron_input"}},"outputs":{"echo":{"uri":"echo","operation":"create","componentName":"echo","metadata":{"path":"echo","Content-Type":"application/json; charset=utf-8"},"componentType":"bindings.http"}},"runtime":"Async","prePlugins":["plugin-custom","plugin-example"],"postPlugins":["plugin-custom","plugin-example"]}'
+export CONTEXT_MODE='self-host'
 ```
 
 ### Run
@@ -139,7 +141,7 @@ dapr run --app-id bindings_grpc \
     --app-port 50002 \
     --dapr-grpc-port 50001 \
     --components-path ../../components \
-    go run ./main.go ./plugin.go
+    go run ./main.go
 ```
 
 

functions-framework/golang/Async/bindings/with-output/go.mod

@@ -1,9 +1,9 @@
 module main.go
 
-go 1.15
+go 1.16
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.1.2-0.20220109033919-0fb66d159417
+	github.com/OpenFunction/functions-framework-go v0.2.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.40.1
 )

functions-framework/golang/Async/bindings/with-output/main.go

@@ -4,8 +4,10 @@ import (
 	"context"
 
 	"github.com/OpenFunction/functions-framework-go/framework"
+	"github.com/OpenFunction/functions-framework-go/plugin"
 	"k8s.io/klog/v2"
 	"main.go/userfunction"
+	pluginCustom "main.go/userfunction/plugins/plugin-custom"
 )
 
 func main() {
@@ -22,3 +24,15 @@ func main() {
 		klog.Exit(err)
 	}
 }
+
+func getLocalPlugins() map[string]plugin.Plugin {
+	localPlugins := map[string]plugin.Plugin{
+		pluginCustom.Name: pluginCustom.New(),
+	}
+
+	if len(localPlugins) == 0 {
+		return nil
+	} else {
+		return localPlugins
+	}
+}

functions-framework/golang/Async/bindings/with-output/plugin.go

@@ -32,13 +32,17 @@ func (p *PluginCustom) Version() string {
 	return Version
 }
 
-func (p *PluginCustom) ExecPreHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) Init() plugin.Plugin {
+	return New()
+}
+
+func (p *PluginCustom) ExecPreHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	p.stateC = 3
 	p.StateC = 3
 	return nil
 }
 
-func (p *PluginCustom) ExecPostHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) ExecPostHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	return nil
 }
 

functions-framework/golang/Async/bindings/with-output/userfunction/plugins/plugin-custom/plugin-custom.go

@@ -1,9 +1,9 @@
 module main.go
 
-go 1.15
+go 1.16
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.1.2-0.20220109033919-0fb66d159417
+	github.com/OpenFunction/functions-framework-go v0.2.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.40.1
 )

functions-framework/golang/Async/bindings/without-output/go.mod

@@ -4,8 +4,10 @@ import (
 	"context"
 
 	"github.com/OpenFunction/functions-framework-go/framework"
+	"github.com/OpenFunction/functions-framework-go/plugin"
 	"k8s.io/klog/v2"
 	"main.go/userfunction"
+	pluginCustom "main.go/userfunction/plugins/plugin-custom"
 )
 
 func main() {
@@ -22,3 +24,15 @@ func main() {
 		klog.Exit(err)
 	}
 }
+
+func getLocalPlugins() map[string]plugin.Plugin {
+	localPlugins := map[string]plugin.Plugin{
+		pluginCustom.Name: pluginCustom.New(),
+	}
+
+	if len(localPlugins) == 0 {
+		return nil
+	} else {
+		return localPlugins
+	}
+}

functions-framework/golang/Async/bindings/without-output/main.go

@@ -32,13 +32,17 @@ func (p *PluginCustom) Version() string {
 	return Version
 }
 
-func (p *PluginCustom) ExecPreHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) Init() plugin.Plugin {
+	return New()
+}
+
+func (p *PluginCustom) ExecPreHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	p.stateC = 3
 	p.StateC = 3
 	return nil
 }
 
-func (p *PluginCustom) ExecPostHook(ctx ofctx.Context, plugins map[string]plugin.Plugin) error {
+func (p *PluginCustom) ExecPostHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
 	return nil
 }
 

functions-framework/golang/Async/bindings/without-output/plugin.go

@@ -0,0 +1,14 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: msg
+spec:
+  type: pubsub.kafka
+  version: v1
+  metadata:
+    - name: brokers
+      value: "kafka-server-kafka-brokers:9092"
+    - name: consumerGroup
+      value: "group1"
+    - name: authRequired
+      value: "false"