update

Signed-off-by: laminar <fangtian@kubesphere.io>

Author: laminar

examples/README.md

@@ -0,0 +1,14 @@
+# Examples
+
+## OpenFunction Context Function
+
+- Dapr bindings
+  - [gRPC example](dapr-demos/README.md#bindings-via-grpc)
+  - [HTTP example](dapr-demos/README.md#bindings-via-http)
+
+- Dapr pubsub
+  - [gRPC example](dapr-demos/README.md#pubsub-via-grpc)
+  
+- Dapr service invocation
+  - [gRPC example](dapr-demos/README.md#service-invocation-via-grpc)
+

examples/client/grpc/pubsub_client.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	dapr "github.com/dapr/go-sdk/client"
+)
+
+func main() {
+	// just for this demo
+	ctx := context.Background()
+	json := `{ "message": "hello" }`
+	data := []byte(json)
+	pubsub := "msg"
+	topic := "my_topic"
+
+	// create the client
+	client, err := dapr.NewClient()
+	if err != nil {
+		panic(err)
+	}
+	defer client.Close()
+
+	// publish a message to the topic demo
+	if err := client.PublishEvent(ctx, pubsub, topic, data); err != nil {
+		panic(err)
+	}
+	fmt.Println("data published")
+
+	fmt.Println("DONE (CTRL+C to Exit)")
+}

examples/client/grpc/service_client.go

@@ -0,0 +1,32 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	dapr "github.com/dapr/go-sdk/client"
+)
+
+func main() {
+	// just for this demo
+	ctx := context.Background()
+
+	// create the client
+	client, err := dapr.NewClient()
+	if err != nil {
+		panic(err)
+	}
+	defer client.Close()
+
+	// invoke a method called EchoMethod on another dapr enabled service
+	content := &dapr.DataContent{
+		ContentType: "text/plain",
+		Data:        []byte("hellow"),
+	}
+	resp, err := client.InvokeMethodWithContent(ctx, "serving_function", "echo", "post", content)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Printf("service method invoked, response: %s\n", string(resp))
+
+	fmt.Println("DONE (CTRL+C to Exit)")
+}

examples/config/cron.yaml

@@ -0,0 +1,10 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: cron_input
+spec:
+  type: bindings.cron
+  version: v1
+  metadata:
+    - name: schedule
+      value: "@every 10s"

examples/config/pubsub.yaml

@@ -0,0 +1,12 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: msg
+spec:
+  type: pubsub.redis
+  version: v1
+  metadata:
+    - name: redisHost
+      value: localhost:6379
+    - name: redisPassword
+      value: ""

examples/config/statestore.yaml

@@ -0,0 +1,14 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: statestore
+spec:
+  type: state.redis
+  version: v1
+  metadata:
+    - name: redisHost
+      value: localhost:6379
+    - name: redisPassword
+      value: ""
+    - name: actorStateStore
+      value: "true"