Struct StoredProcessedDeviceSyncMessages 

pub struct StoredProcessedDeviceSyncMessages {
    pub message_id: Vec<u8>,
    pub attempts: i32,
    pub state: DeviceSyncProcessingState,
}

Fields

message_id: Vec<u8>

attempts: i32

Number of processing attempts remaining

state: DeviceSyncProcessingState

Current processing state

Implementations

impl StoredProcessedDeviceSyncMessages

pub fn new(message_id: Vec<u8>) -> Self

Create a new stored processed device sync message with default values

Trait Implementations

impl Clone for StoredProcessedDeviceSyncMessages

fn clone(&self) -> StoredProcessedDeviceSyncMessages

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StoredProcessedDeviceSyncMessages

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StoredProcessedDeviceSyncMessages

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl HasTable for StoredProcessedDeviceSyncMessages

type Table = table

The table this type is associated with.

fn table() -> <Self as HasTable>::Table

Returns the table this type is associated with.

impl<'ident> Identifiable for &'ident StoredProcessedDeviceSyncMessages

type Id = &'ident Vec<u8>

The type of this struct’s identifier.

fn id(self) -> <Self as Identifiable>::Id

Returns the identifier for this record.

impl<'insert> Insertable<table> for &'insert StoredProcessedDeviceSyncMessages

where &'insert Vec<u8>: AsExpression<<message_id as Expression>::SqlType>, &'insert i32: AsExpression<<attempts as Expression>::SqlType>, &'insert DeviceSyncProcessingState: AsExpression<<state as Expression>::SqlType>,

type Values = <(Option<Grouped<Eq<message_id, <&'insert Vec<u8> as AsExpression<<message_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <&'insert i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<state, <&'insert DeviceSyncProcessingState as AsExpression<<state as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<message_id, &'insert Vec<u8>>>, Option<Eq<attempts, &'insert i32>>, Option<Eq<state, &'insert DeviceSyncProcessingState>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl Insertable<table> for StoredProcessedDeviceSyncMessages

where Vec<u8>: AsExpression<<message_id as Expression>::SqlType>, i32: AsExpression<<attempts as Expression>::SqlType>, DeviceSyncProcessingState: AsExpression<<state as Expression>::SqlType>,

type Values = <(Option<Grouped<Eq<message_id, <Vec<u8> as AsExpression<<message_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<state, <DeviceSyncProcessingState as AsExpression<<state as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<message_id, Vec<u8>>>, Option<Eq<attempts, i32>>, Option<Eq<state, DeviceSyncProcessingState>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl PartialEq for StoredProcessedDeviceSyncMessages

fn eq(&self, other: &StoredProcessedDeviceSyncMessages) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__DB: Backend, __ST0, __ST1, __ST2> Queryable<(__ST0, __ST1, __ST2), __DB> for StoredProcessedDeviceSyncMessages

where (Vec<u8>, i32, DeviceSyncProcessingState): FromStaticSqlRow<(__ST0, __ST1, __ST2), __DB>,

type Row = (Vec<u8>, i32, DeviceSyncProcessingState)

The Rust type you’d like to map from.

fn build(row: (Vec<u8>, i32, DeviceSyncProcessingState)) -> Result<Self>

Construct an instance of this type

impl Serialize for StoredProcessedDeviceSyncMessages

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<C> Store<C> for StoredProcessedDeviceSyncMessages

where C: ConnectionExt,

type Output = ()

fn store(&self, into: &C) -> Result<(), StorageError>

impl<C> StoreOrIgnore<C> for StoredProcessedDeviceSyncMessages

where C: ConnectionExt,

type Output = ()

fn store_or_ignore(&self, into: &C) -> Result<(), StorageError>

impl StructuralPartialEq for StoredProcessedDeviceSyncMessages

impl UndecoratedInsertRecord<table> for StoredProcessedDeviceSyncMessages