Expand description
Компоненты для построения системы сбора, обработки и визуализации данных
§Обзор
§Описание
Компоненты представляют собой асинхронные функции. У всех функций три аргумента:
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, например:
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
Для упрощения компоненты можно создавать и объединять в цепочку компонентов.
- может генерировать сообщения как на основе входных сообщений
- может генерировать сообщения периодически
§Флаги feature
:
env_vars
— Конфигурирование через переменныеexecutor
— Базовые компонентыlogging
— Настройка логгирования сообщенийsingle-thread
— Работа в однопоточном режимеcmp_auth
— Компонент аутентификацииcmp_http_client
— Компонент http-клиентcmp_http_client_wasm
— Компонент http-клиент для платформы WASMcmp_http_server
— Компонент http-серверcmp_esp
— Компоненты для работы с микроконтроллером ESPcmp_influxdb
— Компонент сохранения в БД InfluxDBcmp_leptos
— Компонент для создания интерфейсов на базе Leptoscmp_modbus_client
— Компонент Modbus клиентcmp_mqtt_client
— Комонент клиента MQTTcmp_plc
— Компонент ПЛКcmp_raspberrypi
— Работа с периферией Raspberry Picmp_redis_client
— Компонент клиента Rediscmp_slint
— Компонент пользовательского интерфейса, реализованного с помощью библиотеки Slintcmp_surrealdb
— Компонент доступа к БД SurrealDBcmp_system_info
— Компонент получает системную информациюcmp_timescaledb
— Компонент сохранения в БД TimescaleDBcmp_websocket_client
— Компонент websocket клиентаcmp_websocket_client_wasm
— Компонент websocket клиентаcmp_websocket_server
— Компонент websocket сервераcmp_webstorage
— Хранение и загрузка сообщений используя Web Storage API браузера
Modules§
- Компоненты
- Структуры для конфигурации компонентов.
- Исполнитель - структура для запуска компонентов
- Настройки логгирования для разных платформ.
- Представление сообщений в системе.