Struct RpcImpl

pub struct RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>
where
    Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static,
    Mempool::Future: Send,
    State: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static,
    State::Future: Send,
    ReadState: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static,
    ReadState::Future: Send,
    Tip: ChainTip + Clone + Send + Sync + 'static,
    AddressBook: AddressBookPeers + Clone + Send + Sync + 'static,
    BlockVerifierRouter: Service<Request, Response = Hash, Error = BoxError> + Clone + Send + Sync + 'static,
    <BlockVerifierRouter as Service<Request>>::Future: Send,
    SyncStatus: ChainSyncStatus + Clone + Send + Sync + 'static,
{ /* private fields */ }

RPC method implementations.

Implementations

impl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus> RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, Mempool::Future: Send, State: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, State::Future: Send, ReadState: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static, ReadState::Future: Send, Tip: ChainTip + Clone + Send + Sync + 'static, AddressBook: AddressBookPeers + Clone + Send + Sync + 'static, BlockVerifierRouter: Service<Request, Response = Hash, Error = BoxError> + Clone + Send + Sync + 'static, <BlockVerifierRouter as Service<Request>>::Future: Send, SyncStatus: ChainSyncStatus + Clone + Send + Sync + 'static,

pub fn new<VersionString, UserAgentString>( network: Network, mining_config: Config, debug_force_finished_sync: bool, build_version: VersionString, user_agent: UserAgentString, mempool: Mempool, state: State, read_state: ReadState, block_verifier_router: BlockVerifierRouter, sync_status: SyncStatus, latest_chain_tip: Tip, address_book: AddressBook, last_warn_error_log_rx: LoggedLastEvent, mined_block_sender: Option<Sender<(Hash, Height)>>, ) -> (Self, JoinHandle<()>)

where VersionString: ToString + Clone + Send + 'static, UserAgentString: ToString + Clone + Send + 'static,

Create a new instance of the RPC handler.

pub fn network(&self) -> &Network

Returns a reference to the configured network.

Trait Implementations

impl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus> Clone for RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static + Clone, Mempool::Future: Send, State: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static + Clone, State::Future: Send, ReadState: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static + Clone, ReadState::Future: Send, Tip: ChainTip + Clone + Send + Sync + 'static + Clone, AddressBook: AddressBookPeers + Clone + Send + Sync + 'static + Clone, BlockVerifierRouter: Service<Request, Response = Hash, Error = BoxError> + Clone + Send + Sync + 'static + Clone, <BlockVerifierRouter as Service<Request>>::Future: Send, SyncStatus: ChainSyncStatus + Clone + Send + Sync + 'static + Clone,

fn clone( &self, ) -> RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus> Debug for RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, Mempool::Future: Send, State: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, State::Future: Send, ReadState: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static, ReadState::Future: Send, Tip: ChainTip + Clone + Send + Sync + 'static, AddressBook: AddressBookPeers + Clone + Send + Sync + 'static, BlockVerifierRouter: Service<Request, Response = Hash, Error = BoxError> + Clone + Send + Sync + 'static, <BlockVerifierRouter as Service<Request>>::Future: Send, SyncStatus: ChainSyncStatus + Clone + Send + Sync + 'static,

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

Formats the value using the given formatter.

impl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus> RpcServer for RpcImpl<Mempool, State, ReadState, Tip, AddressBook, BlockVerifierRouter, SyncStatus>

where Mempool: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, Mempool::Future: Send, State: Service<Request, Response = Response, Error = BoxError> + Clone + Send + Sync + 'static, State::Future: Send, ReadState: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static, ReadState::Future: Send, Tip: ChainTip + Clone + Send + Sync + 'static, AddressBook: AddressBookPeers + Clone + Send + Sync + 'static, BlockVerifierRouter: Service<Request, Response = Hash, Error = BoxError> + Clone + Send + Sync + 'static, <BlockVerifierRouter as Service<Request>>::Future: Send, SyncStatus: ChainSyncStatus + Clone + Send + Sync + 'static,

fn get_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<GetInfoResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns software information from the RPC server, as a GetInfo JSON struct.

fn get_blockchain_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<GetBlockchainInfoResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns blockchain state information, as a GetBlockchainInfoResponse JSON struct.

fn get_address_balance<'life0, 'async_trait>( &'life0 self, address_strings: GetAddressBalanceRequest, ) -> Pin<Box<dyn Future<Output = Result<GetAddressBalanceResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the total balance of a provided addresses in an AddressBalance instance.

fn send_raw_transaction<'life0, 'async_trait>( &'life0 self, raw_transaction_hex: String, _allow_high_fees: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<SendRawTransactionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends the raw bytes of a signed transaction to the local node’s mempool, if the transaction is valid. Returns the SentTransactionHash for the transaction, as a JSON string.

fn get_block<'life0, 'async_trait>( &'life0 self, hash_or_height: String, verbosity: Option<u8>, ) -> Pin<Box<dyn Future<Output = Result<GetBlockResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the requested block by hash or height, as a GetBlock JSON string. If the block is not in Zebra’s state, returns error code -8. if a height was passed or -5 if a hash was passed.

fn get_block_header<'life0, 'async_trait>( &'life0 self, hash_or_height: String, verbose: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<GetBlockHeaderResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the requested block header by hash or height, as a GetBlockHeader JSON string. If the block is not in Zebra’s state, returns error code -8. if a height was passed or -5 if a hash was passed.

fn get_best_block_hash(&self) -> Result<GetBlockHashResponse>

Returns the hash of the current best blockchain tip block, as a GetBlockHash JSON string.

fn get_best_block_height_and_hash( &self, ) -> Result<GetBlockHeightAndHashResponse>

Returns the height and hash of the current best blockchain tip block, as a GetBlockHeightAndHashResponse JSON struct.

fn get_raw_mempool<'life0, 'async_trait>( &'life0 self, verbose: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<GetRawMempoolResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns all transaction ids in the memory pool, as a JSON array.

fn get_raw_transaction<'life0, 'async_trait>( &'life0 self, txid: String, verbose: Option<u8>, block_hash: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<GetRawTransactionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the raw transaction data, as a GetRawTransaction JSON string or structure.

fn z_get_treestate<'life0, 'async_trait>( &'life0 self, hash_or_height: String, ) -> Pin<Box<dyn Future<Output = Result<GetTreestateResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns information about the given block’s Sapling & Orchard tree state.

fn z_get_subtrees_by_index<'life0, 'async_trait>( &'life0 self, pool: String, start_index: NoteCommitmentSubtreeIndex, limit: Option<NoteCommitmentSubtreeIndex>, ) -> Pin<Box<dyn Future<Output = Result<GetSubtreesByIndexResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns information about a range of Sapling or Orchard subtrees.

fn get_address_tx_ids<'life0, 'async_trait>( &'life0 self, request: GetAddressTxIdsRequest, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the transaction ids made by the provided transparent addresses.

fn get_address_utxos<'life0, 'async_trait>( &'life0 self, address_strings: AddressStrings, ) -> Pin<Box<dyn Future<Output = Result<GetAddressUtxosResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns all unspent outputs for a list of addresses.

fn stop(&self) -> Result<String>

Stop the running zebrad process.

fn get_block_count(&self) -> Result<u32>

Returns the height of the most recent block in the best valid block chain (equivalently, the number of blocks in this chain excluding the genesis block).

fn get_block_hash<'life0, 'async_trait>( &'life0 self, index: i32, ) -> Pin<Box<dyn Future<Output = Result<GetBlockHashResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the hash of the block of a given height iff the index argument correspond to a block in the best chain.

fn get_block_template<'life0, 'async_trait>( &'life0 self, parameters: Option<GetBlockTemplateParameters>, ) -> Pin<Box<dyn Future<Output = Result<GetBlockTemplateResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns a block template for mining new Zcash blocks.

fn submit_block<'life0, 'async_trait>( &'life0 self, __arg1: HexData, _parameters: Option<SubmitBlockParameters>, ) -> Pin<Box<dyn Future<Output = Result<SubmitBlockResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits block to the node to be validated and committed. Returns the SubmitBlockResponse for the operation, as a JSON string.

fn get_mining_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<GetMiningInfoResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns mining-related information.

fn get_network_sol_ps<'life0, 'async_trait>( &'life0 self, num_blocks: Option<i32>, height: Option<i32>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the estimated network solutions per second based on the last num_blocks before height.

fn get_peer_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns data about each connected network node.

fn validate_address<'life0, 'async_trait>( &'life0 self, raw_address: String, ) -> Pin<Box<dyn Future<Output = Result<ValidateAddressResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if a zcash transparent address of type P2PKH, P2SH or TEX is valid. Returns information about the given address if valid.

fn z_validate_address<'life0, 'async_trait>( &'life0 self, raw_address: String, ) -> Pin<Box<dyn Future<Output = Result<ZValidateAddressResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if a zcash address of type P2PKH, P2SH, TEX, SAPLING or UNIFIED is valid. Returns information about the given address if valid.

fn get_block_subsidy<'life0, 'async_trait>( &'life0 self, height: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<GetBlockSubsidyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the block subsidy reward of the block at height, taking into account the mining slow start. Returns an error if height is less than the height of the first halving for the current network.

fn get_difficulty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<f64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the proof-of-work difficulty as a multiple of the minimum difficulty.

fn z_list_unified_receivers<'life0, 'async_trait>( &'life0 self, address: String, ) -> Pin<Box<dyn Future<Output = Result<ZListUnifiedReceiversResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the list of individual payment addresses given a unified address.

fn invalidate_block<'life0, 'async_trait>( &'life0 self, block_hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Invalidates a block if it is not yet finalized, removing it from the non-finalized state if it is present and rejecting it during contextual validation if it is submitted.

fn reconsider_block<'life0, 'async_trait>( &'life0 self, block_hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<Vec<Hash>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reconsiders a previously invalidated block if it exists in the cache of previously invalidated blocks.

fn generate<'life0, 'async_trait>( &'life0 self, num_blocks: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<Hash>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mine blocks immediately. Returns the block hashes of the generated blocks.

fn add_node<'life0, 'async_trait>( &'life0 self, addr: PeerSocketAddr, command: AddNodeCommand, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add or remove a node from the address book.

fn get_network_hash_ps<'life0, 'async_trait>( &'life0 self, num_blocks: Option<i32>, height: Option<i32>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the estimated network solutions per second based on the last num_blocks before height.

fn into_rpc(self) -> RpcModule<Self>

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.