Struct DeviceBase

pub struct DeviceBase<TMsg, TFieldbusRequest, TFieldbusResponse, TBuffer>
where
    TFieldbusRequest: RequestResponseBound,
{
    pub fn_init_requests: fn(&TBuffer) -> 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) -> Result<Vec<TFieldbusRequest>>,
    pub fn_response_to_buffer: fn(TFieldbusResponse, &mut TBuffer) -> Result<()>,
    pub fn_buffer_to_msgs: fn(&mut TBuffer) -> Vec<Message<TMsg>>,
    pub buffer_default: TBuffer,
}

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

Fields

fn_init_requests: fn(&TBuffer) -> 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) -> Result<Vec<TFieldbusRequest>>

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

fn_response_to_buffer: fn(TFieldbusResponse, &mut TBuffer) -> Result<()>

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

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

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

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

Пример:

|buffer| {vec![]}

buffer_default: TBuffer

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

Implementations

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

where TRequest: 'static + RequestResponseBound, TResponse: 'static + RequestResponseBound, TMsg: MsgDataBound + 'static, TBuffer: 'static + BufferBound,

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> Default for DeviceBase<TMsg, TFieldbusRequest, TFieldbusResponse, TBuffer>

where TFieldbusRequest: RequestResponseBound, TBuffer: Default,

fn default() -> Self

Returns the “default value” for a type.