Struct HistoryCheckpoint 

pub struct HistoryCheckpoint {
    pub device_id: String,
    pub current_param: HistoryParamCheckpoint,
    pub resume_index: u16,
    pub total_readings: u16,
    pub completed_params: Vec<HistoryParamCheckpoint>,
    pub created_at: OffsetDateTime,
    pub downloaded_data: Option<PartialHistoryData>,
}

Checkpoint data for resuming interrupted history downloads.

This can be serialized and saved to disk to allow resuming downloads after disconnection or application restart.

Fields

device_id: String

Device identifier this checkpoint belongs to.

current_param: HistoryParamCheckpoint

The parameter currently being downloaded.

resume_index: u16

Index where download should resume for current parameter.

total_readings: u16

Total readings on the device when checkpoint was created.

completed_params: Vec<HistoryParamCheckpoint>

Which parameters have been fully downloaded.

created_at: OffsetDateTime

Timestamp when checkpoint was created.

downloaded_data: Option<PartialHistoryData>

Downloaded values for completed parameters (serialized).

Implementations

impl HistoryCheckpoint

pub fn new( device_id: &str, total_readings: u16, first_param: HistoryParam, ) -> Self

Create a new checkpoint for starting a fresh download.

pub fn is_valid(&self, current_total_readings: u16) -> bool

Check if this checkpoint is still valid for the given device state.

pub fn complete_param(&mut self, param: HistoryParam, values: Vec<u16>)

Update the checkpoint after completing a parameter.

pub fn complete_radon_param(&mut self, values: Vec<u32>)

Update the checkpoint after completing a radon parameter.

Trait Implementations

impl Clone for HistoryCheckpoint

fn clone(&self) -> HistoryCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HistoryCheckpoint

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HistoryCheckpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HistoryCheckpoint

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.