Struct TestBridge 

pub struct TestBridge<M>
where
    M: Copy,
{ /* private fields */ }

Implementations

impl<M> TestBridge<M>

where M: Copy,

pub fn new(worker_count: usize, worker_req_cap: usize) -> Self

pub fn tx_count(&self) -> usize

pub fn contains_tx(&self, key: TransactionKey) -> bool

pub fn queue_progress(&mut self, progress: ProgressMessage)

pub fn queue_tpu(&mut self, tx: &VersionedTransaction)

pub fn queue_check_response_ok( &mut self, batch: &ScheduleBatch<Vec<KeyedTransactionMeta<M>>>, index: usize, keys: Option<Vec<Pubkey>>, )

pub fn queue_check_response( &mut self, batch: &ScheduleBatch<Vec<KeyedTransactionMeta<M>>>, index: usize, keys: Option<Vec<Pubkey>>, response: CheckResponse, )

pub fn queue_all_checks_ok(&mut self)

pub fn queue_execute_response( &mut self, batch: &ScheduleBatch<Vec<KeyedTransactionMeta<M>>>, index: usize, response: ExecutionResponse, )

pub fn queue_unprocessed_response( &mut self, batch: &ScheduleBatch<Vec<KeyedTransactionMeta<M>>>, index: usize, )

pub fn pop_schedule( &mut self, ) -> Option<ScheduleBatch<Vec<KeyedTransactionMeta<M>>>>

pub fn check_ok(&self) -> CheckResponse

pub fn execute_ok(&self) -> ExecutionResponse

pub fn execute_err(&self, reason: u8) -> ExecutionResponse

Methods from Deref<Target = SchedulerBindingsBridge<M>>

pub fn allocator(&self) -> &Allocator

pub fn state(&self) -> &SlotMap<TransactionKey, TransactionState>

pub fn runtime(&self) -> &RuntimeState

pub fn progress(&self) -> &ProgressMessage

pub fn worker_count(&self) -> usize

pub fn worker(&mut self, id: usize) -> &mut SchedulerWorker

Looks up the given worker by ID.

Panics

• If the worker does not exist.

pub fn transaction(&self, key: TransactionKey) -> &TransactionState

Looks up the given transaction key.

Panics

• If the transaction does not exist.

pub fn insert_transaction( &mut self, tx: &[u8], ) -> Result<TransactionKey, TransactionInsertError>

Inserts a non TPU transaction into the bridge.

Panics

• If the transaction exceeds 4096 bytes.

pub fn drop_transaction(&mut self, key: TransactionKey)

pub fn drain_progress(&mut self) -> Option<ProgressMessage>

pub fn tpu_len(&mut self) -> usize

pub fn drain_tpu( &mut self, callback: impl FnMut(&mut Self, TransactionKey) -> TxDecision, max_count: usize, ) -> usize

pub fn drain_worker( &mut self, worker: usize, callback: impl FnMut(&mut Self, WorkerResponse<'_, M>) -> TxDecision, max_count: usize, )

pub fn schedule( &mut self, _: ScheduleBatch<&[KeyedTransactionMeta<M>]>, ) -> Result<(), ScheduleError>

Builds & schedules the provided batch.

Panics

• If the worker index does not exist.
• If any transaction in the batch does not exist.
• If the batch size exceeds MAX_TRANSACTIONS_PER_MESSAGE.

Trait Implementations

impl<M> Deref for TestBridge<M>

where M: Copy,

type Target = SchedulerBindingsBridge<M>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<M> DerefMut for TestBridge<M>

where M: Copy,

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.