Struct Rbac509InsertQuery 

pub(crate) struct Rbac509InsertQuery {
    pub(crate) registrations: Vec<Params>,
    pub(crate) invalid: Vec<Params>,
    catalyst_id_for_txn_id: Vec<Params>,
    catalyst_id_for_stake_address: Vec<Params>,
    catalyst_id_for_public_key: Vec<Params>,
}

Index RBAC 509 Registration Query Parameters

Fields

registrations: Vec<Params>

RBAC Registration Data captured during indexing.

invalid: Vec<Params>

An invalid RBAC registration data.

catalyst_id_for_txn_id: Vec<Params>

A Catalyst ID for transaction ID Data captured during indexing.

catalyst_id_for_stake_address: Vec<Params>

A Catalyst ID for stake address data captured during indexing.

catalyst_id_for_public_key: Vec<Params>

A Catalyst ID for public key data captured during indexing.

Implementations

impl Rbac509InsertQuery

pub(crate) fn new() -> Self

Creates new data set for RBAC 509 Registrations Insert 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>>, SkipMap<u16, Arc<Batch>>)>

Prepare Batch of Insert RBAC 509 Registration Data Queries

pub(crate) async fn index( &mut self, txn_hash: TransactionId, index: TxnIndex, block: &MultiEraBlock, pending_blocks: &mut Receiver<BTreeSet<Slot>>, our_end: Slot, context: &mut RbacBlockIndexingContext, ) -> Result<()>

Index the RBAC 509 registrations in a transaction.

async fn try_record_chain_update( &mut self, reg: &Cip509, previous_txn: TransactionId, is_persistent: bool, context: &mut RbacBlockIndexingContext, ) -> Result<()>

Validating the provided registration as an update for an existing chain, preparing corresponding updates

async fn try_record_new_chain( &mut self, reg: &Cip509, is_persistent: bool, context: &mut RbacBlockIndexingContext, ) -> Result<()>

Validating the provided registration as a beginning of a new chain, preparing corresponding updates

fn record_valid_registration( &mut self, txn_hash: TransactionId, index: TxnIndex, slot: Slot, catalyst_id: CatalystId, previous_transaction: Option<TransactionId>, stake_addresses: HashSet<StakeAddress>, public_keys: HashSet<VerifyingKey>, modified_chains: HashMap<CatalystId, HashSet<StakeAddress>>, purpose: Option<UuidV4>, context: &mut RbacBlockIndexingContext, )

Making corresponding records according to the valid registration

fn record_invalid_registration( &mut self, txn_hash: TransactionId, index: TxnIndex, slot: Slot, catalyst_id: CatalystId, previous_transaction: Option<TransactionId>, purpose: Option<UuidV4>, report: ProblemReport, )

Making corresponding records according to the valid registration

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

Execute the RBAC 509 Registration Indexing Queries.

Consumes the self and returns a vector of futures.

Trait Implementations

impl Debug for Rbac509InsertQuery

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

Formats the value using the given formatter.