Struct InMemorySwapStorage 

pub struct InMemorySwapStorage { /* private fields */ }

In-memory implementation of SwapStorage.

This implementation stores swap data in memory using a HashMap protected by a Mutex. Data is lost when the application restarts, making this suitable for development, testing, and scenarios where persistence is not required.

Implementations

impl InMemorySwapStorage

pub fn new() -> Self

Create a new in-memory swap storage.

Examples

use ark_client::InMemorySwapStorage;

let storage = InMemorySwapStorage::new();

Trait Implementations

impl Default for InMemorySwapStorage

fn default() -> Self

Returns the “default value” for a type.

impl SwapStorage for InMemorySwapStorage

fn insert_submarine<'life0, 'async_trait>( &'life0 self, id: String, data: SubmarineSwapData, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store submarine swap data.

fn insert_reverse<'life0, 'async_trait>( &'life0 self, id: String, data: ReverseSwapData, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store reverse submarine swap data.

fn get_submarine<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SubmarineSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve submarine swap data by ID.

fn get_reverse<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ReverseSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve reverse submarine swap data by ID.

fn update_status_submarine<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, status: SwapStatus, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the status of an existing submarine swap.

fn update_status_reverse<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, status: SwapStatus, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the status of an existing reverse submarine swap.

fn update_reverse<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, data: ReverseSwapData, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update an existing reverse submarine swap.

fn list_all_submarine<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<SubmarineSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all stored submarine swaps.

fn list_all_reverse<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ReverseSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all stored reverse submarine swaps.

fn remove_submarine<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SubmarineSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove submarine swap data by ID.

fn remove_reverse<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ReverseSwapData>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove reverse submarine swap data by ID.