hello-cloudevents

CloudEvents is a common format for events. This is a very simple demo showing how you can pass an event through an event gateway.

Executables

These use https://github.com/cloudevents/sdk-go.

receiver receives an event sender generates an event

Depending on environment variables sender can send directly to receiver, or via an event gateway.

Build with GOOS=linux go build . run in sender and receiver directories.

Set up the event gateway

The yaml directory has YAML for etcd and the event-gateway (which uses etcd for storage).

Event Gateway API

API documentation

• Get EVENT_GATEWAY_IP from the IP address of event-gateway Kubernetes service.

• Create an event type called aquaEvent:

curl --request POST --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/eventtypes --header 'content-type: application/json' --data '{"name": "aquaEvent"}'

• Register the receiver function which runs on the local machine

curl --request POST --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/functions --header 'content-type: application/json' --data '{"functionId": "receiver", "type": "http", "provider":{"url":"http://172.28.128.3:8080"}}'

• Subscribe the function to the event

curl --request POST --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/subscriptions --header 'content-type: application/json' --data '{"functionId": "receiver", "event": "http", "type":"async", "eventType": "aquaEvent", "path": "/hello", "method": "POST"}'

• Get event types

curl --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/eventtypes | jq

• Get subscriptions

curl --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/subscriptions | jq

• Get functions

curl --url http://$EVENT_GATEWAY_IP:4001/v1/spaces/default/functions | jq