Struct Config

pub struct Config<TMsg>
where
    TMsg: MsgDataBound,
{
    pub serde_alg: SerdeAlgKind,
    pub client_id: String,
    pub host: String,
    pub port: u16,
    pub client_capacity: usize,
    pub publish: ConfigPublish<TMsg>,
    pub subscribe: ConfigSubscribe<TMsg>,
}

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

Fields

serde_alg: SerdeAlgKind

Алгоритм сериализации / десериализации

client_id: String

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

host: String

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

Примеры:

• localhost

port: u16

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

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

client_capacity: usize

Ёмкость клиента.

Можно задать 100

publish: ConfigPublish<TMsg>

Настройка публикации данных в брокере

subscribe: ConfigSubscribe<TMsg>

Настройка подписки на данные из брокера

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> IComponentProcess<Config<TMsg>, TMsg> for Component<Config<TMsg>, TMsg>

where TMsg: MsgDataBound + 'static,

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

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

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