Компоненты для построения системы сбора, обработки и визуализации данных
[Документация](https://konstantin-dudersky.github.io/rsiot-docs/x86_64-unknown-linux-gnu/rsiot/index.html)
## Обзор
## Описание
**Компоненты** представляют собой асинхронные функции. У всех функций три аргумента:
```rust
async fn component<TMessage, TConfig>(
input: Option<tokio::sync::mpsc::Receiver<TMessage>>,
output: Option<tokio::sync::mpsc::Sender<TMessage>>,
config: TConfig,
) -> ()
where
TMessage: IMessage
{}
```
Сообщения между компонентами передаются через каналы "many producers to a single consumer"
библиотеки `tokio`.
Входной или выходной потоки могут быть не заданы, поэтому каналы обернуты в Option.
Структура конфигурации типа `TConfig` у каждого компонента своя.
Компоненты ничего не возвращают (точнее, возвращают тип `()`). Если в компоненте возникает
ошибка, логику перезапуска необходимо реализовать внутри данной функции. TODO - пересмотреть,
возможно стоит возвращать Result при критических ошибках.
**Сообщения** представляют собой тип enum, например:
```rust
use rsiot_messages_core::eav::EavModel;
use rsiot_messages_core::IMessage;
use serde::{Deserialize, Serialize};
[derive(Clone, Debug, Deserialize, Serialize)]
enum Message {
/// Текущее значение температуры
Temperature(f64),
/// Задание уставки
ChangeSetpoint(f64),
}
impl IMessage for Message {
fn into_eav(self) -> Vec<EavModel> {
vec![]
}}
```
Трейт `IMessage` реализует основные методы - см. документацию по крейту
[rsiot-messages-core](https://docs.rs/rsiot-messages-core/latest)
Для упрощения компоненты можно создавать и объединять в **цепочку компонентов**.
- может генерировать сообщения как на основе входных сообщений
- может генерировать сообщения периодически
## Флаги `feature`: