Struct Config

pub struct Config<TMsg>
where
    TMsg: MsgDataBound,
{
    pub client_id: String,
    pub host: String,
    pub port: u16,
    pub fn_input: ConfigFnInput<TMsg>,
    pub fn_output: ConfigFnOutput<TMsg>,
}

Конфигурация cmp_mqtt_client

Fields

client_id: String

Идентификатор клиента MQTT

host: String

Адрес брокера

Примеры:

• localhost

port: u16

Порт брокера.

По-умолчанию - 1883

fn_input: ConfigFnInput<TMsg>

Функция преобразования входящих сообщений в данные для публикации в брокере

Примеры

• ничего не отправлять в брокер

fn_input: |_| Ok(None)

• сериализация данных без фильтрации

fn_input: |msg| Ok(Some(msg.serialize()?.into_bytes()))

fn_output: ConfigFnOutput<TMsg>

Функция преобразования данных, полученных из брокера, в исходящие сообщения

Примеры

• ничего не получать из брокера

fn_output: |_| Ok(None)

• десериализация данных без фильтрации

fn_output: |payload: &[u8]| {
    let payload = String::from_utf8_lossy(&payload);
    let msg = Message::deserialize(&payload)?;
    Ok(Some(msg))
}

Trait Implementations

impl<TMsg> Clone for Config<TMsg>

where TMsg: MsgDataBound + Clone,

fn clone(&self) -> Config<TMsg>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<TMsg, TService> IComponentProcess<Config<TMsg>, TMsg, TService> for Component<Config<TMsg>, TMsg, TService>

where TMsg: MsgDataBound + 'static, TService: ServiceBound + 'static,

fn process<'life0, 'async_trait>( &'life0 self, config: Config<TMsg>, in_out: CmpInOut<TMsg, TService>, ) -> Pin<Box<dyn Future<Output = CmpResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Основная функция компонента