To decouple the endpoint implementation from the data generator, first develop a simulated data stream using Go routines and channels. This simulated stream will allow testing and refinement of the processing pipeline before the actual sensor integration.

The target pipeline will follow this flow:

Fake Data Stream -> RabbitMQ Streams -> Consumer -> TimescaleDB -> Dashboard

This setup will help ensure that the endpoint can efficiently receive data from a remote sensor and store it in a relational database with time-series support (Postgres + TimescaleDB).