The main point of this repository is to create working example of WME target architecture.
Getting started:
First of all you need go, docker and docker-compose installed on your machine.
First step is to setup infrastructure on your local machine by running:
docker-compose up
After that you need to create bucket inside the minio console. You should be able to access that by going to http://localhost:9200/. Login is admin and password is password. Go to buckets page and create one with a name of wme-data-bk.
After that's done you can start event bridge by running:
go run bridge/main.go
While bridge is running you can start collection data in your bucket by running:
go run store/main.go
To run streaming examples you need to start by creating the streams by running:
go run example/create/main.go
If streams are successfully created you can run:
go run example/query/main.go
If you want to change the streams or add the new one you can delete all of the streams by running: