Struct DeviceBase

pub struct DeviceBase<TMsg, TFieldbusRequest, TFieldbusResponse, TBuffer, TAddress>
where
    TFieldbusRequest: RequestResponseBound<TAddress>,
    TAddress: AddressBound,
{
    pub address: TAddress,
    pub fn_init_requests: fn() -> Vec<TFieldbusRequest>,
    pub periodic_requests: Vec<ConfigPeriodicRequest<TFieldbusRequest, TBuffer>>,
    pub fn_msgs_to_buffer: fn(_: &Message<TMsg>, _: &mut TBuffer),
    pub fn_buffer_to_request: fn(_: &TBuffer) -> Vec<TFieldbusRequest>,
    pub fn_response_to_buffer: fn(_: TFieldbusResponse, _: &mut TBuffer),
    pub fn_buffer_to_msgs: fn(_: &TBuffer) -> Vec<Message<TMsg>>,
    pub buffer_default: TBuffer,
}

Базовое устройство для опроса по шине

Fields

address: TAddress

Адрес

fn_init_requests: fn() -> Vec<TFieldbusRequest>

Запросы при инициализации устройства

periodic_requests: Vec<ConfigPeriodicRequest<TFieldbusRequest, TBuffer>>

Периодические запросы

fn_msgs_to_buffer: fn(_: &Message<TMsg>, _: &mut TBuffer)

Обновление буфера на основе входящих сообщений

Обычно соответствует параметру fn_input конфигурации устройства

Пример

let msgs = [Custom::AllInputs(buffer.all_inputs)];
let msgs = msgs.iter().map(|m| Message::new_custom(*m)).collect();
msgs

fn_buffer_to_request: fn(_: &TBuffer) -> Vec<TFieldbusRequest>

Преобразование данных из буфера в массив запросов на шине

fn_response_to_buffer: fn(_: TFieldbusResponse, _: &mut TBuffer)

Обновление буфера на основе данных, полученных с устройства

fn_buffer_to_msgs: fn(_: &TBuffer) -> Vec<Message<TMsg>>

Функция создания сообщений на основе буфера

Обычно соответствует параметру fn_output кофигурации устройства

Пример:

|buffer| {vec![]}

buffer_default: TBuffer

Значения в буфере при инициализации

Implementations

impl<TMsg, TRequest, TResponse, TBuffer, TAddress> DeviceBase<TMsg, TRequest, TResponse, TBuffer, TAddress>

where TRequest: 'static + RequestResponseBound<TAddress>, TResponse: 'static + RequestResponseBound<TAddress>, TMsg: MsgDataBound + 'static, TBuffer: 'static + BufferBound, TAddress: 'static + AddressBound,

pub async fn spawn( self, ch_rx_msgbus_to_device: Receiver<Message<TMsg>>, ch_tx_device_to_fieldbus: Sender<TRequest>, ch_rx_fieldbus_to_device: Receiver<TResponse>, ch_tx_device_to_msgbus: Sender<Message<TMsg>>, ) -> Result<()>

Запустить работу

Trait Implementations

impl<TMsg, TFieldbusRequest, TFieldbusResponse, TBuffer, TAddress> Default for DeviceBase<TMsg, TFieldbusRequest, TFieldbusResponse, TBuffer, TAddress>

where TFieldbusRequest: RequestResponseBound<TAddress>, TBuffer: Default, TAddress: AddressBound,

fn default() -> Self

Returns the “default value” for a type.