Merge pull request #92 from wrongerror/main

benjaminhuo · web-flow · commit 7916404d2747 · 2022-10-12T15:10:51.000+08:00
support dapr-proxy
diff --git a/functions-framework/golang/Async/bindings/with-output/go.mod b/functions-framework/golang/Async/bindings/with-output/go.mod
@@ -3,7 +3,7 @@ module main.go
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.40.1
 )
diff --git a/functions-framework/golang/Async/bindings/without-output/go.mod b/functions-framework/golang/Async/bindings/without-output/go.mod
@@ -3,7 +3,7 @@ module main.go
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.40.1
 )
diff --git a/functions-framework/golang/Async/pubsub/pub/go.mod b/functions-framework/golang/Async/pubsub/pub/go.mod
@@ -3,7 +3,7 @@ module main.go
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	k8s.io/klog/v2 v2.40.1
 )
 
diff --git a/functions-framework/golang/Async/pubsub/sub/go.mod b/functions-framework/golang/Async/pubsub/sub/go.mod
@@ -3,7 +3,7 @@ module main.go
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	k8s.io/klog/v2 v2.40.1
 )
 
diff --git a/functions-framework/golang/Knative/cloudevents/go.mod b/functions-framework/golang/Knative/cloudevents/go.mod
@@ -4,7 +4,7 @@ go 1.17
 
 require (
 	github.com/cloudevents/sdk-go/v2 v2.4.1
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.30.0
 )
diff --git a/functions-framework/golang/Knative/http/go.mod b/functions-framework/golang/Knative/http/go.mod
@@ -3,7 +3,7 @@ module main.go
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/fatih/structs v1.1.0
 	k8s.io/klog/v2 v2.30.0
 )
diff --git a/functions/async/bindings/cron-input-kafka-output/go.mod b/functions/async/bindings/cron-input-kafka-output/go.mod
@@ -2,4 +2,4 @@ module example.com/bindings
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/async/bindings/cron-input/go.mod b/functions/async/bindings/cron-input/go.mod
@@ -2,4 +2,4 @@ module example.com/bindings
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/async/bindings/cron-input/plugins/plugin-custom/plugin-custom.go b/functions/async/bindings/cron-input/plugins/plugin-custom/plugin-custom.go
@@ -0,0 +1,53 @@
+package plugin_custom
+
+import (
+	ofctx "github.com/OpenFunction/functions-framework-go/context"
+	"github.com/OpenFunction/functions-framework-go/plugin"
+	"github.com/fatih/structs"
+)
+
+const (
+	Name    = "plugin-custom"
+	Version = "v1"
+)
+
+type PluginCustom struct {
+	PluginName    string
+	PluginVersion string
+	StateC        int64
+}
+
+var _ plugin.Plugin = &PluginCustom{}
+
+func New() *PluginCustom {
+	return &PluginCustom{
+		StateC: int64(0),
+	}
+}
+
+func (p *PluginCustom) Name() string {
+	return Name
+}
+
+func (p *PluginCustom) Version() string {
+	return Version
+}
+
+func (p *PluginCustom) Init() plugin.Plugin {
+	return New()
+}
+
+func (p *PluginCustom) ExecPreHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
+	p.StateC++
+	return nil
+}
+
+func (p *PluginCustom) ExecPostHook(ctx ofctx.RuntimeContext, plugins map[string]plugin.Plugin) error {
+	return nil
+}
+
+func (p *PluginCustom) Get(fieldName string) (interface{}, bool) {
+	plgMap := structs.Map(p)
+	value, ok := plgMap[fieldName]
+	return value, ok
+}
diff --git a/functions/async/bindings/kafka-input/go.mod b/functions/async/bindings/kafka-input/go.mod
@@ -2,4 +2,4 @@ module example.com/bindings
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/async/logs-handler-function/go.mod b/functions/async/logs-handler-function/go.mod
@@ -3,6 +3,6 @@ module example.com/logshandler
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/prometheus/alertmanager v0.22.2
 )
diff --git a/functions/async/pubsub/subscriber/go.mod b/functions/async/pubsub/subscriber/go.mod
@@ -2,4 +2,4 @@ module example.com/subscriber
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/knative/hello-world-go/go.mod b/functions/knative/hello-world-go/go.mod
@@ -2,4 +2,4 @@ module example.com/hello
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/knative/multiple-functions-go/go.mod b/functions/knative/multiple-functions-go/go.mod
@@ -2,4 +2,4 @@ module example.com/hello
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/knative/path-parameters-function-go/go.mod b/functions/knative/path-parameters-function-go/go.mod
@@ -2,4 +2,4 @@ module example.com/hello
 
 go 1.17
 
-require github.com/OpenFunction/functions-framework-go v0.4.0
+require github.com/OpenFunction/functions-framework-go v0.5.0
diff --git a/functions/knative/with-output-binding/go.mod b/functions/knative/with-output-binding/go.mod
@@ -3,6 +3,6 @@ module example.com/bindings
 go 1.17
 
 require (
-	github.com/OpenFunction/functions-framework-go v0.4.0
+	github.com/OpenFunction/functions-framework-go v0.5.0
 	github.com/fatih/structs v1.1.0
 )

Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,7 @@ module main.go`
`3`	`3`	`go 1.17`
`4`	`4`
`5`	`5`	`require (`
`6`		`- github.com/OpenFunction/functions-framework-go v0.4.0`
	`6`	`+ github.com/OpenFunction/functions-framework-go v0.5.0`
`7`	`7`	`github.com/fatih/structs v1.1.0`
`8`	`8`	`k8s.io/klog/v2 v2.40.1`
`9`	`9`	`)`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ go 1.17`
`4`	`4`
`5`	`5`	`require (`
`6`	`6`	`github.com/cloudevents/sdk-go/v2 v2.4.1`
`7`		`- github.com/OpenFunction/functions-framework-go v0.4.0`
	`7`	`+ github.com/OpenFunction/functions-framework-go v0.5.0`
`8`	`8`	`github.com/fatih/structs v1.1.0`
`9`	`9`	`k8s.io/klog/v2 v2.30.0`
`10`	`10`	`)`
Original file line number	Diff line number	Diff line change
`@@ -2,4 +2,4 @@ module example.com/bindings`
`2`	`2`
`3`	`3`	`go 1.17`
`4`	`4`
`5`		`-require github.com/OpenFunction/functions-framework-go v0.4.0`
	`5`	`+require github.com/OpenFunction/functions-framework-go v0.5.0`