Struct mainnet_lib::db_sync::in_memory::InMemoryDbSync

pub struct InMemoryDbSync {
    pub(crate) transactions: HashMap<u32, Vec<Transaction>>,
    pub(crate) blocks: Vec<Block>,
    stakes: HashMap<String, BigNum>,
    settings: Settings,
}

Mock of real cardano db sync. At this moment we only stores transactions metadata as the only purpose of existance for this struct is to provide catalyst voting registrations Struct can be persisted and restored from json file using serde_json.

Fields

transactions: HashMap<u32, Vec<Transaction>>

blocks: Vec<Block>

stakes: HashMap<String, BigNum>

settings: Settings

Implementations

impl InMemoryDbSync

pub fn from_block0(block0: &Block0) -> Self

Creates new instance out of block0

pub fn empty() -> Self

Create an empty instance

pub fn connect_to_node(self, node: &mut InMemoryNode) -> SharedInMemoryDbSync

Connects to Cardano mock node using simple observer/observable mechanism

Panics

On accessing db sync state

pub fn try_as_string(&self) -> Result<String, Error>

Retrieves db sync content as string

Errors

On deserialization issues

pub fn on_block_propagation(&mut self, block: &Block)

Accept new block

Panics

On integer overflow

pub fn transaction_by_hash( &self, hash: &str ) -> Vec<(Option<&Block>, &Transaction)>

Query transaction by it’s hash representation

pub fn query_all_registration_transactions( &self ) -> Vec<GeneralTransactionMetadata>

Gets all transactions metadata without bounds

pub fn metadata(&self) -> HashMap<u32, Vec<GeneralTransactionMetadata>>

Gets all metadata per block number

pub fn query_voting_transactions_with_bounds( &self, lower: u64, upper: u64 ) -> HashMap<u32, Vec<GeneralTransactionMetadata>>

Gets all transactions metadata with slot_no upper and lower bounds

pub fn settings(&self) -> &Settings

gets reference to db sync connection settings

pub fn stakes(&self) -> &HashMap<String, BigNum>

gets all known to dbsync wallet ada distribution

pub fn persist(&self, path: impl AsRef<Path>) -> Result<(), Error>

Persists current state of db sync

Errors

If cannot create file or cannot serialize to json

pub fn restore(path: impl AsRef<Path>) -> Result<Self, Error>

Restores current state of db sync from json file

Errors

If file cannot be opened or cannot deserialize from json

Trait Implementations

impl Debug for InMemoryDbSync

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

Formats the value using the given formatter.

impl Default for InMemoryDbSync

fn default() -> InMemoryDbSync

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for InMemoryDbSync

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InMemoryDbSync

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

Serialize this value into the given Serde serializer.