Merge pull request #117 from XavierGeerinck/master

Add parking garage example

Author: XavierGeerinck

documentation/development.md

@@ -38,8 +38,13 @@ Tests are written per protocol layer: http or grpc. This is done because Dapr re
 docker run -d --rm --name emqx -p 1883:1883 -p 8081:8081 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 emqx/emqx
 
 # Start gRPC tests
-npm run test:dapr:grpc
+npm run test:e2e:grpc:main
 
 # Start HTTP tests
-npm run test:dapr:http
+npm run test:e2e:http:main
+npm run test:e2e:http:actors
 ```
+
+## Publishing
+
+./scripts/publish.sh

examples/http/actor-parking-sensor/README.md

@@ -0,0 +1,61 @@
+# Examples - Hello World
+
+## TODO
+
+```bash
+# Run InfluxDB
+# Note: it auto removes after shutdown
+# Note: non-persistent volume, add "-v influxdb2:/var/lib/influxdb2" to make it persistent
+docker run --rm -it -d \
+    -e DOCKER_INFLUXDB_INIT_MODE=setup \
+    -e DOCKER_INFLUXDB_INIT_USERNAME=admin \
+    -e DOCKER_INFLUXDB_INIT_PASSWORD=MyAdmin@123! \
+    -e DOCKER_INFLUXDB_INIT_ADMIN_TOKEN=my-token \
+    -e DOCKER_INFLUXDB_INIT_ORG=my-parking-garage \
+    -e DOCKER_INFLUXDB_INIT_BUCKET=my-sensors \
+    --net=host \
+    --name influxdb \
+    influxdb:2.0
+
+# Run Telegraf
+docker run --rm -it -d \
+    --net=host \
+    --name=telegraf \
+    telegraf
+
+# Run Grafana
+# Note: non-persistent volume, add "-v influxdb2:/var/lib/influxdb2" to make it persistent
+docker run --rm -it -d \
+    --name=grafana \
+    --net=host \
+    grafana/grafana
+```
+
+## Running
+
+```bash
+# Build the Source (from the root)
+./build.sh
+
+# Install (from the example directory)
+npm install
+
+# Start a RabbitMQ Container (for the binding example part)
+# note: mgmt interface at http://localhost:15672 
+docker run -d --rm --hostname my-rabbitmq --name my-rabbitmq \
+    -e RABBITMQ_DEFAULT_USER=test-user -e RABBITMQ_DEFAULT_PASS=test-password \
+    -p 0.0.0.0:5672:5672 -p 0.0.0.0:15672:15672 \
+    rabbitmq:3-management
+
+# Run the example
+npm run start:dapr
+```
+
+```
+from(bucket: "my-sensors")
+  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
+  |> filter(fn: (r) => r["_measurement"] == "sensor-states")
+  |> pivot(columnKey: ["_field"], rowKey: ["_time"], valueColumn: "_value")
+  |> group()
+  |> yield(name: "last")
+```

examples/http/actor-parking-sensor/components/binding-influxdb.yaml

@@ -0,0 +1,18 @@
+# https://docs.dapr.io/reference/components-reference/supported-bindings/influxdb/
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: binding-influxdb
+  namespace: default
+spec:
+  type: bindings.influx
+  version: v1
+  metadata:
+  - name: url # Required
+    value: "http://127.0.0.1:8086"
+  - name: token # Required
+    value: my-token
+  - name: org # Required
+    value: my-parking-garage
+  - name: bucket # Required
+    value: my-sensors

examples/http/actor-parking-sensor/components/pubsub-redis.yaml

@@ -0,0 +1,18 @@
+# https://docs.dapr.io/reference/components-reference/supported-bindings/rabbitmq/
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: pubsub-redis
+  namespace: default
+spec:
+  type: pubsub.redis
+  version: v1
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""
+  - name: consumerID
+    value: "myGroup"
+  - name: enableTLS
+    value: "false"

examples/http/actor-parking-sensor/components/state-redis.yaml

@@ -0,0 +1,20 @@
+# https://docs.dapr.io/reference/components-reference/supported-bindings/rabbitmq/
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: state-redis
+  namespace: default
+spec:
+  type: state.redis
+  version: v1
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""
+  - name: enableTLS
+    value: "false"
+  - name: failover
+    value: "false"
+  - name: actorStateStore
+    value: "true"

examples/http/actor-parking-sensor/dapr-config.yaml

@@ -0,0 +1,7 @@
+apiVersion: dapr.io/v1alpha1
+kind: Configuration
+metadata:
+  name: daprConfig
+spec:
+  tracing:
+    enabled: false