Trait rustot::ota::data_interface::DataInterface

pub trait DataInterface {
    const PROTOCOL: Protocol;

    fn init_file_transfer(
        &self, 
        file_ctx: &mut FileContext
    ) -> Result<(), OtaError>;
    fn request_file_block(
        &self, 
        file_ctx: &mut FileContext, 
        config: &Config
    ) -> Result<(), OtaError>;
    fn decode_file_block<'a>(
        &self, 
        file_ctx: &mut FileContext, 
        payload: &'a mut [u8]
    ) -> Result<FileBlock<'a>, OtaError>;
    fn cleanup(
        &self, 
        file_ctx: &mut FileContext, 
        config: &Config
    ) -> Result<(), OtaError>;
}

Associated Constants

const PROTOCOL: Protocol

Required methods

fn init_file_transfer(&self, file_ctx: &mut FileContext) -> Result<(), OtaError>

fn request_file_block(
    &self,
    file_ctx: &mut FileContext,
    config: &Config
) -> Result<(), OtaError>

fn decode_file_block<'a>(
    &self,
    file_ctx: &mut FileContext,
    payload: &'a mut [u8]
) -> Result<FileBlock<'a>, OtaError>

fn cleanup(
    &self,
    file_ctx: &mut FileContext,
    config: &Config
) -> Result<(), OtaError>

Implementations on Foreign Types

impl<'a, M> DataInterface for &'a M where
    M: Mqtt, 

fn init_file_transfer(&self, file_ctx: &mut FileContext) -> Result<(), OtaError>

Init file transfer by subscribing to the OTA data stream topic

fn request_file_block(
    &self,
    file_ctx: &mut FileContext,
    config: &Config
) -> Result<(), OtaError>

Request file block by publishing to the get stream topic

fn decode_file_block<'c>(
    &self,
    _file_ctx: &mut FileContext,
    payload: &'c mut [u8]
) -> Result<FileBlock<'c>, OtaError>

Decode a cbor encoded fileblock received from streaming service

fn cleanup(
    &self,
    file_ctx: &mut FileContext,
    config: &Config
) -> Result<(), OtaError>

Perform any cleanup operations required for data plane

const PROTOCOL: Protocol

Implementors

impl DataInterface for NoInterface

const PROTOCOL: Protocol