Struct solana_client::transaction_executor::TransactionExecutor

pub struct TransactionExecutor {
    sig_clear_t: JoinHandle<()>,
    sigs: Arc<RwLock<Vec<(Signature, u64, u64)>>>,
    cleared: Arc<RwLock<Vec<u64>>>,
    exit: Arc<AtomicBool>,
    counter: AtomicU64,
    client: Arc<RpcClient>,
}

Fields

sig_clear_t: JoinHandle<()>

sigs: Arc<RwLock<Vec<(Signature, u64, u64)>>>

cleared: Arc<RwLock<Vec<u64>>>

exit: Arc<AtomicBool>

counter: AtomicU64

client: Arc<RpcClient>

Implementations

impl TransactionExecutor

pub fn new(entrypoint_addr: SocketAddr) -> Self

pub fn new_with_url<U: ToString>(url: U) -> Self

pub fn new_with_rpc_client(client: Arc<RpcClient>) -> Self

pub fn num_outstanding(&self) -> usize

pub fn push_transactions(&self, txs: Vec<Transaction>) -> Vec<u64>

pub fn drain_cleared(&self) -> Vec<u64>

pub fn close(self)

fn start_sig_clear_thread( exit: &Arc<AtomicBool>, sigs: &Arc<RwLock<Vec<(Signature, u64, u64)>>>, cleared: &Arc<RwLock<Vec<u64>>>, client: &Arc<RpcClient> ) -> JoinHandle<()>