Struct Operator

pub struct Operator<Block, CBlock, Client, CClient, TransactionPool, Backend, E>
where
    Block: BlockT,
    CBlock: BlockT,
{
    pub transaction_pool: Arc<TransactionPool>,
    pub keystore: KeystorePtr,
    /* private fields */
}

Domain operator.

Fields

transaction_pool: Arc<TransactionPool>

keystore: KeystorePtr

Implementations

impl<Block, CBlock, Client, CClient, TransactionPool, Backend, E> Operator<Block, CBlock, Client, CClient, TransactionPool, Backend, E>

where Block: BlockT, Block::Hash: Into<H256>, CBlock: BlockT, NumberFor<CBlock>: From<NumberFor<Block>> + Into<NumberFor<Block>>, CBlock::Hash: From<Block::Hash>, Client: HeaderBackend<Block> + BlockBackend<Block> + AuxStore + ProvideRuntimeApi<Block> + ProofProvider<Block> + Finalizer<Block, Backend> + BlockImport<Block> + BlockchainEvents<Block> + 'static, for<'a> &'a Client: BlockImport<Block>, Client::Api: DomainCoreApi<Block> + MessengerApi<Block, NumberFor<CBlock>, CBlock::Hash> + BlockBuilder<Block> + ApiExt<Block> + TaggedTransactionQueue<Block>, CClient: HeaderBackend<CBlock> + HeaderMetadata<CBlock, Error = Error> + BlockBackend<CBlock> + ProvideRuntimeApi<CBlock> + ProofProvider<CBlock> + BlockchainEvents<CBlock> + Send + Sync + 'static, CClient::Api: DomainsApi<CBlock, Block::Header> + MessengerApi<CBlock, NumberFor<CBlock>, CBlock::Hash> + BundleProducerElectionApi<CBlock, Balance> + FraudProofApi<CBlock, Block::Header> + MmrApi<CBlock, H256, NumberFor<CBlock>>, Backend: Backend<Block> + Send + Sync + 'static, TransactionPool: TransactionPool<Block = Block, Hash = Block::Hash> + 'static, E: CodeExecutor,

pub async fn new<IBNS, CIBNS, NSNS, ASS, CNR>( spawn_essential: Box<dyn SpawnEssentialNamed>, params: OperatorParams<Block, CBlock, Client, CClient, TransactionPool, Backend, E, IBNS, CIBNS, NSNS, ASS, CNR>, ) -> Result<Self, Error>

where IBNS: Stream<Item = (NumberFor<CBlock>, Sender<()>)> + Send + Unpin + 'static, CIBNS: Stream<Item = BlockImportNotification<CBlock>> + Send + Unpin + 'static, NSNS: Stream<Item = (Slot, PotOutput)> + Send + 'static, ASS: Stream<Item = Sender<()>> + Send + 'static, CNR: NetworkRequest + Send + Sync + 'static,

Create a new instance.

pub fn fraud_proof_generator( &self, ) -> FraudProofGenerator<Block, CBlock, Client, CClient, Backend, E>

pub fn import_notification_stream( &self, ) -> DomainImportNotifications<Block, CBlock>

Get system domain block import notification stream.

NOTE: Unlike BlockchainEvents::import_notification_stream(), this notification won’t be fired until the system domain block’s receipt processing is done.

Trait Implementations

impl<Block, CBlock, Client, CClient, TransactionPool, Backend, E> Clone for Operator<Block, CBlock, Client, CClient, TransactionPool, Backend, E>

where Block: BlockT, CBlock: BlockT,

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.