Struct Fabric 

pub struct Fabric { /* private fields */ }

Implementations

impl Fabric

pub async fn new(base: &str) -> Result<Self, Error>

Create Fabric by opening RocksDb at base/fabric

pub fn with_db(db: RocksDb) -> Self

Create Fabric from an already opened RocksDb handle

pub fn db(&self) -> &RocksDb

pub async fn cleanup(&self)

pub fn insert_entry( &self, hash: &Hash, height: u64, slot: u64, entry_bin: &[u8], seen_millis: u64, ) -> Result<(), Error>

pub fn entries_by_height(&self, height: u64) -> Result<Vec<Vec<u8>>, Error>

pub fn entries_by_slot(&self, slot: u64) -> Result<Vec<Vec<u8>>, Error>

pub fn get_entry_by_hash(&self, hash: &Hash) -> Option<Entry>

pub fn my_attestation_by_entryhash( &self, hash: &[u8], ) -> Result<Option<Attestation>, Error>

pub fn get_or_resign_my_attestation( &self, config: &Config, entry_hash: &Hash, ) -> Result<Option<Attestation>, Error>

pub fn insert_consensus(&self, consensus: &Consensus) -> Result<(), Error>

pub fn validate_consensus( &self, consensus: &Consensus, ) -> Result<BitVec<u8, Msb0>, Error>

Validate consensus vs chain state:

• Entry must exist and not be in the future vs current temporal_height
• Aggregate signature must verify against the set of trainers unmasked by mask

On success, sets consensus.score = Some(score) and returns Ok(())

pub fn best_consensus_by_entryhash( &self, trainers: &[PublicKey], entry_hash: &[u8], ) -> Result<(Option<[u8; 32]>, Option<f64>, Option<StoredConsensus>), Error>

pub fn set_temporal_hash_height(&self, entry: &Entry) -> Result<(), Error>

Sets temporal entry hash and height

pub fn get_temporal_entry(&self) -> Result<Option<Entry>, Error>

pub fn get_temporal_hash(&self) -> Result<Option<[u8; 32]>, Error>

pub fn get_temporal_height(&self) -> Result<Option<u64>, Error>

pub fn set_rooted_hash_height(&self, entry: &Entry) -> Result<(), Error>

Sets rooted entry hash and height

pub fn get_rooted_entry(&self) -> Result<Option<Entry>, Error>

pub fn get_rooted_hash(&self) -> Result<Option<[u8; 32]>, Error>

pub fn get_rooted_height(&self) -> Result<Option<u64>, Error>

pub fn get_temporal_height_or_0(&self) -> u64

pub fn get_chain_epoch_or_0(&self) -> u64

pub fn trainers_for_height(&self, height: u64) -> Option<Vec<PublicKey>>

pub fn get_muts_rev(&self, hash: &Hash) -> Result<Option<Vec<u8>>, Error>

pub fn put_muts_rev(&self, hash: &Hash, data: &[u8]) -> Result<(), Error>

pub fn delete_muts_rev(&self, hash: &Hash) -> Result<(), Error>

pub fn get_muts(&self, hash: &Hash) -> Result<Option<Vec<u8>>, Error>

pub fn put_muts(&self, hash: &Hash, data: &[u8]) -> Result<(), Error>

pub fn put_attestation(&self, hash: &Hash, data: &[u8]) -> Result<(), Error>

pub fn delete_attestation(&self, hash: &Hash) -> Result<(), Error>

pub fn put_entry_seen_time( &self, hash: &Hash, seen_time: u64, ) -> Result<(), Error>

pub fn delete_entry_seen_time(&self, hash: &Hash) -> Result<(), Error>

pub fn get_entry_seen_time(&self, hash: &Hash) -> Result<Option<u64>, Error>

pub fn delete_consensus(&self, hash: &Hash) -> Result<(), Error>

pub fn delete_entry(&self, hash: &Hash) -> Result<(), Error>

pub fn delete_entry_by_height(&self, height_key: &[u8]) -> Result<(), Error>

pub fn delete_entry_by_slot(&self, slot_key: &[u8]) -> Result<(), Error>

pub fn put_tx_metadata(&self, key: &[u8], tx: &[u8]) -> Result<(), Error>

pub fn delete_tx_metadata(&self, hash: &Hash) -> Result<(), Error>

pub fn put_tx_account_nonce( &self, key: &[u8], tx_hash: &Hash, ) -> Result<(), Error>

pub fn delete_tx_account_nonce(&self, key: &[u8]) -> Result<(), Error>

pub fn put_entry_raw(&self, hash: &Hash, data: &[u8]) -> Result<(), Error>

pub fn get_entry_raw(&self, hash: &Hash) -> Result<Option<Vec<u8>>, Error>

pub fn are_we_trainer(&self, config: &Config) -> bool

Return true if our trainer_pk is included in trainers_for_height(chain_height()+1)

pub fn get_trainer_for_slot(&self, height: u64, slot: u64) -> Option<PublicKey>

Select trainer for a slot from the roster for the corresponding height

pub fn get_trainer_for_current_slot(&self) -> Option<PublicKey>

pub fn get_trainer_for_next_slot(&self) -> Option<PublicKey>

pub fn are_we_trainer_for_next_slot(&self, config: &Config) -> bool

pub fn is_in_chain(&self, target_hash: &Hash) -> bool

pub fn validate_entry_slot_trainer(&self, entry: &Entry, prev_slot: u64) -> bool

Check if entry is in its designated slot

pub fn start_proc_consensus(&self)

pub fn stop_proc_consensus(&self)

pub fn is_proc_consensus(&self) -> bool

pub fn chain_nonce(&self, public_key: &[u8]) -> Option<u64>

Get the chain nonce for a given public key

pub fn chain_balance(&self, public_key: &[u8]) -> i128

Get the chain balance for a given public key (native AMA token)

pub fn chain_diff_bits(&self) -> u64

Get the chain difficulty bits

pub fn chain_segment_vr_hash(&self) -> Option<Vec<u8>>

Get the chain segment VR hash

pub fn chain_balance_symbol(&self, public_key: &[u8], symbol: &[u8]) -> i128

Get balance for a specific account and symbol from the chain state

pub fn chain_total_sols(&self) -> u64

Get the total number of solutions from the chain state

Trait Implementations

impl Clone for Fabric

fn clone(&self) -> Fabric

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Fabric

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

Formats the value using the given formatter.