Struct GrpcIndexer 

pub struct GrpcIndexer { /* private fields */ }

gRPC-backed Indexer that connects to a Zcash chain indexer (server).

Implementations

impl GrpcIndexer

pub async fn new(uri: Uri) -> Result<Self, GetClientError>

pub fn uri(&self) -> &Uri

Returns URI the gRPC client(s) are connected to.

pub async fn get_clear_net_client(&self) -> CompactTxStreamerClient<Channel>

Returns the “surface net” gRPC client where the IP address is not obfuscated.

Trait Implementations

impl Clone for GrpcIndexer

fn clone(&self) -> GrpcIndexer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcIndexer

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

Formats the value using the given formatter.

impl Indexer for GrpcIndexer

async fn get_lightd_info( &mut self, timeout: Duration, ) -> Result<LightdInfo, Status>

Return server metadata (chain name, block height, version, etc.).

async fn get_latest_block( &mut self, timeout: Duration, ) -> Result<BlockId, Status>

Return the height and hash of the chain tip.

async fn send_transaction( &mut self, tx: RawTransaction, timeout: Duration, ) -> Result<String, Status>

Submit a raw transaction to the network.

async fn get_tree_state( &mut self, block_id: BlockId, timeout: Duration, ) -> Result<TreeState, Status>

Fetch the note commitment tree state for the given block.

async fn get_block( &mut self, block_id: BlockId, timeout: Duration, ) -> Result<CompactBlock, Status>

Return the compact block at the given height.

async fn get_block_nullifiers( &mut self, block_id: BlockId, timeout: Duration, ) -> Result<CompactBlock, Status>

👎Deprecated:

use get_block instead

Return the compact block at the given height, containing only nullifiers.

async fn get_block_range( &mut self, range: BlockRange, timeout: Duration, ) -> Result<Streaming<CompactBlock>, Status>

Return a stream of consecutive compact blocks for the given range.

async fn get_block_range_nullifiers( &mut self, range: BlockRange, timeout: Duration, ) -> Result<Streaming<CompactBlock>, Status>

👎Deprecated:

use get_block_range instead

Return a stream of consecutive compact blocks (nullifiers only) for the given range.

async fn get_transaction( &mut self, filter: TxFilter, timeout: Duration, ) -> Result<RawTransaction, Status>

Return the full serialized transaction matching the given filter.

async fn get_mempool_tx( &mut self, request: GetMempoolTxRequest, timeout: Duration, ) -> Result<Streaming<CompactTx>, Status>

Return a stream of compact transactions currently in the mempool.

async fn get_mempool_stream( &mut self, timeout: Duration, ) -> Result<Streaming<RawTransaction>, Status>

Return a stream of raw mempool transactions.

async fn get_latest_tree_state( &mut self, timeout: Duration, ) -> Result<TreeState, Status>

Return the note commitment tree state at the chain tip.

async fn get_subtree_roots( &mut self, arg: GetSubtreeRootsArg, timeout: Duration, ) -> Result<Streaming<SubtreeRoot>, Status>

Return a stream of subtree roots for the given shielded protocol.