Struct Miner

pub struct Miner {
    pub locks: MinerLocks,
    pub notifier_pending_txs: Sender<Hash>,
    pub notifier_blocks: Sender<BlockHeader>,
    pub notifier_logs: Sender<LogMined>,
    /* private fields */
}

Fields

locks: MinerLocks

notifier_pending_txs: Sender<Hash>

Broadcasts pending transactions events.

notifier_blocks: Sender<BlockHeader>

Broadcasts new mined blocks events.

notifier_logs: Sender<LogMined>

Broadcasts transaction logs events.

Implementations

impl Miner

pub fn new(storage: Arc<StratusStorage>, mode: MinerMode) -> Self

pub async fn start_interval_mining(self: &Arc<Self>, block_time: Duration)

Spawns a new thread that keep mining blocks in the specified interval.

Also unpauses Miner if it was paused.

pub async fn switch_to_external_mode(self: &Arc<Self>)

Shuts down interval miner, set miner mode to External.

pub fn unpause(&self)

pub fn pause(&self)

pub fn is_paused(&self) -> bool

pub fn mode(&self) -> MinerMode

pub fn is_interval_miner_running(&self) -> bool

pub fn save_execution( &self, tx_execution: TransactionExecution, check_conflicts: bool, is_local: bool, ) -> Result<(), StratusError>

Persists a transaction execution.

pub fn mine_external(&self, external_block: ExternalBlock) -> Result<Block>

Mines external block and external transactions.

Local transactions are not allowed to be part of the block.

pub fn mine_local_and_commit(&self) -> Result<(), StorageError>

Same as Self::mine_local, but automatically commits the block instead of returning it. mainly used when is_automine is enabled.

pub fn mine_local(&self) -> Result<Block, StorageError>

Mines local transactions.

External transactions are not allowed to be part of the block.

pub fn commit(&self, item: CommitItem) -> Result<(), StorageError>

pub fn commit_block(&self, block: Block) -> Result<(), StorageError>

Persists a mined block to permanent storage and prepares new block.