Skip to content

Develop#6

Merged
LightInTheFire merged 10 commits into
mainfrom
develop
Mar 10, 2026
Merged

Develop#6
LightInTheFire merged 10 commits into
mainfrom
develop

Conversation

@LightInTheFire

Copy link
Copy Markdown
Owner

Реализован модуль telemetry состоящий из

  • Collector - принимает по grpc запросы от hub-router и сохраняет их в топики telemetry.sensors.v1 и telemetry.hubs.v1
  • Aggregator - читает сообщения из топика telemetry.sensors.v1, анализирует наличие изменений и сохраняет их в топик telemetry.snapshots.v1
  • Analyzer - читает сообщения из топиков telemetry.hubs.v1 и telemetry.snapshots.v1, из первого сохраняет/удаляет датчики и сценарии. Из второго читает снэпшоты состояний датчиков и проверяет их на соответствие какому-то из сценариев. При наличии сценария отправляет запрос выполнения действий на hub-router

* feat: add hub and sensor proto schemas

* feat: add grpc

* Normalize line endings to LF

* spotless apply

* feat: add gitattr

* fix crlf
* feat: add sensor snapshot avdl protocol

* feat: add base for Aggregator app module

* feat: add dependencies

* feat: implement avro serializer and deserializers

* feat: add kafka config properties

* feat: add Producer and Consumer kafka autoconfigurations

* feat: implement snapshot and aggregation service

* feat: implement kafka event loop runner
* feat: add run configs to project

* feat: add database to compose file

* feat: add analyzer module

* feat: add testcontainers run class and application properties

* feat: add schema.sql

* spotless apply

* feat: update prod properties

* feat: add hubrouter controller proto

* chore: rename runner to proccesor

* feat: move avro serializers and deserializers to avro module

* feat: add hubevent and snapshot avro deserializers

* feat: add schema dependencies

* feat: add kafka consumers properties

* feat: add KafkaConsumer beans

* feat: log on deserialization error

* feat: update scripts to correctly show text in terminal

* remove unused imports

* feat: add persistence models

* feat: add jpa repositories for model

* feat: add grpc client dependency and it's configuration

* feat: change String types in models to enums

* feat: add builder to model

* update gitignore

* feat: add hubrouter client

* feat: add validation dependency

* feat: add hub events handling

* fix: hub client now accepts array

* feat: implement snapshot service

* feat: add processors to start kafka listeners

* fix

* fix run config

* feat: remove devtools

* spottless apply

* fix: inject correct config

* rename Snapshot service to Snapshot Cache service
@LightInTheFire LightInTheFire merged commit ab0b42a into main Mar 10, 2026
2 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants