Struct raiden_rs :: raiden_state_machine :: storage :: StateStorage Copy item path

impl StateStorage

pub fn new(conn: Connection) -> StateStorage

Create an instance of StateStorage.

pub fn setup_database(&self) -> Result<(), StorageError>

Create tables if not already created.

pub fn store_snapshot( &self, state: ChainState, state_change_id: Option<StorageID> ) -> Result<(), StorageError>

Store chain state snapshot.

pub fn state_changes(&self) -> Result<Vec<StateChangeRecord>, StorageError>

Return all state changes.

pub fn store_state_change( &self, state_change: StateChange ) -> Result<StorageID, StorageError>

Store a state change.

pub fn store_events( &self, state_change_id: StorageID, events: Vec<Event> ) -> Result<(), StorageError>

Store a list of events.

pub fn get_snapshot_before_state_change( &self, state_change_id: StorageID ) -> Result<SnapshotRecord, StorageError>

Get the last snapshot prior to a specific state change identifier.

pub fn get_state_changes_in_range( &self, start_state_change: StorageID, end_state_change: StorageID ) -> Result<Vec<StateChangeRecord>, StorageError>

Get the list of state changes in range of ULIDs.

pub fn get_latest_state_change_by_data_field( &self, criteria: Vec<(String, String)> ) -> Result<Option<StateChangeRecord>, StorageError>

Get a state change based on data field attributes.

pub fn get_state_change_with_balance_proof_by_balance_hash( &self, canonical_identifier: CanonicalIdentifier, balance_hash: H256, recipient: H160 ) -> Result<Option<StateChangeRecord>, StorageError>

Get a state change that contains a balance proof that matches the provided balance_hash.

pub fn get_state_change_with_balance_proof_by_locksroot( &self, canonical_identifier: CanonicalIdentifier, locksroot: H256, recipient: H160 ) -> Result<Option<StateChangeRecord>, StorageError>

Get a state change that contains a balance proof that matches the provided locksroot.

pub fn get_latest_event_by_data_field( &self, criteria: Vec<(String, String)> ) -> Result<Option<EventRecord>, StorageError>

Get the latest event filtered by criteria of data field attributes.

pub fn get_event_with_balance_proof_by_balance_hash( &self, canonical_identifier: CanonicalIdentifier, balance_hash: H256, recipient: H160 ) -> Result<Option<EventRecord>, StorageError>

Get an event with a balance proof filtered by the balance_hash.

pub fn get_event_with_balance_proof_by_locksroot( &self, canonical_identifier: CanonicalIdentifier, locksroot: H256, recipient: H160 ) -> Result<Option<EventRecord>, StorageError>

Get an event with a balance proof filtered by the locksroot.

pub fn get_events_with_timestamps( &self ) -> Result<Vec<EventRecord>, StorageError>

Return events with timestamps.

pub fn get_events_payment_history_with_timestamps( &self, token_network_address: Option<H160>, partner_address: Option<H160> ) -> Result<Vec<EventRecord>, StorageError>

Get events of payments with timestamps attached.

Auto Trait Implementations§

impl UnwindSafe for StateStorage

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Az for T

fn az<Dst>(self) -> Dst
where T: Cast<Dst>,

Casts the value.

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<Src, Dst> CastFrom<Src> for Dst
where Src: Cast<Dst>,

fn cast_from(src: Src) -> Dst

Casts the value.

impl<T> CheckedAs for T

fn checked_as<Dst>(self) -> Option<Dst>
where T: CheckedCast<Dst>,

Casts the value.

impl<Src, Dst> CheckedCastFrom<Src> for Dst
where Src: CheckedCast<Dst>,

fn checked_cast_from(src: Src) -> Option<Dst>

Casts the value.

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> OverflowingAs for T

fn overflowing_as<Dst>(self) -> (Dst, bool)
where T: OverflowingCast<Dst>,

Casts the value.

impl<Src, Dst> OverflowingCastFrom<Src> for Dst
where Src: OverflowingCast<Dst>,

fn overflowing_cast_from(src: Src) -> (Dst, bool)

Casts the value.

impl<T> Same for T

type Output = T

Should always be Self

impl<T> SaturatingAs for T

fn saturating_as<Dst>(self) -> Dst
where T: SaturatingCast<Dst>,

Casts the value.

impl<Src, Dst> SaturatingCastFrom<Src> for Dst
where Src: SaturatingCast<Dst>,

fn saturating_cast_from(src: Src) -> Dst

Casts the value.

impl<T, U> TryFrom for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

impl<T, U> TryInto for T
where U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<T> Typeable for T
where T: Any,

fn get_type(&self) -> TypeId

Get the TypeId of this object.

impl<T> UnwrappedAs for T

fn unwrapped_as<Dst>(self) -> Dst
where T: UnwrappedCast<Dst>,

Casts the value.

impl<Src, Dst> UnwrappedCastFrom<Src> for Dst
where Src: UnwrappedCast<Dst>,

fn unwrapped_cast_from(src: Src) -> Dst

Casts the value.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

impl<T> WrappingAs for T

fn wrapping_as<Dst>(self) -> Dst
where T: WrappingCast<Dst>,

Casts the value.

impl<Src, Dst> WrappingCastFrom<Src> for Dst
where Src: WrappingCast<Dst>,

fn wrapping_cast_from(src: Src) -> Dst

Casts the value.

impl<T> Any for T
where T: Any,

impl<T> SendOutsideWasm for T
where T: Send,