Struct TxoInsertQuery

pub(crate) struct TxoInsertQuery {
    staked_txo: Vec<Params>,
    unstaked_txo: Vec<Params>,
    staked_txo_asset: Vec<Params>,
    unstaked_txo_asset: Vec<Params>,
}

Insert TXO Query and Parameters

There are multiple possible parameters to a query, which are represented separately.

Fields

staked_txo: Vec<Params>

Staked TXO Data Parameters

unstaked_txo: Vec<Params>

Unstaked TXO Data Parameters

staked_txo_asset: Vec<Params>

Staked TXO Asset Data Parameters

unstaked_txo_asset: Vec<Params>

Unstaked TXO Asset Data Parameters

Implementations

impl TxoInsertQuery

pub(crate) fn new() -> Self

Create a new Insert TXO Query Batch

pub(crate) async fn prepare_batch( session: &Arc<Session>, cfg: &EnvVars, ) -> Result<(SkipMap<u16, Arc<Batch>>, SkipMap<u16, Arc<Batch>>, SkipMap<u16, Arc<Batch>>, SkipMap<u16, Arc<Batch>>)>

Prepare Batch of Insert TXI Index Data Queries

fn extract_stake_address( txo: &MultiEraOutput<'_>, slot_no: u64, txn_id: &str, ) -> Option<(Vec<u8>, String)>

Extracts a stake address from a TXO if possible. Returns None if it is not possible. If we want to index, but can not determine a stake key hash, then return a Vec with a single 0 byte. This is because the index DB needs data in the primary key, so we use a single byte of 0 to indicate that there is no stake address, and still have a primary key on the table. Otherwise return the stake key hash as a vec of 28 bytes.

pub(crate) fn index( &mut self, txs: &MultiEraTx<'_>, slot_no: u64, txn_hash: &[u8], txn: i16, )

Index the transaction Inputs.

pub(crate) fn execute( self, session: &Arc<CassandraSession>, ) -> Vec<JoinHandle<Result<Vec<QueryResult>>>>

Index the transaction Inputs.

Consumes self and returns a vector of futures.