Struct LightwalletdRPC 

pub struct LightwalletdRPC<Rpc, ReadStateService, Mempool, Tip>
where
    Rpc: RpcMethods + Clone,
    ReadStateService: ReadState,
    Mempool: MempoolService,
    Tip: ChainTip + Clone + Send + Sync + 'static,
{
    pub(super) rpc: Rpc,
    pub(super) read_state: ReadStateService,
    pub(super) mempool: Mempool,
    pub(super) latest_chain_tip: Tip,
    pub(super) mempool_change: MempoolTxSubscriber,
    pub(super) network: Network,
}

Lightwalletd gRPC service.

Most methods are implemented by calling Zebra’s JSON-RPC methods in-process, in the same way lightwalletd calls them on zcashd. Compact blocks and mempool streams are built directly from the state and mempool services.

Fields

rpc: Rpc

read_state: ReadStateService

mempool: Mempool

latest_chain_tip: Tip

mempool_change: MempoolTxSubscriber

network: Network

Trait Implementations

impl<Rpc, ReadStateService, Mempool, Tip> CompactTxStreamer for LightwalletdRPC<Rpc, ReadStateService, Mempool, Tip>

where Rpc: RpcMethods + Clone, ReadStateService: ReadState, Mempool: MempoolService, Tip: ChainTip + Clone + Send + Sync + 'static,

type GetBlockRangeStream = Pin<Box<dyn Stream<Item = Result<CompactBlock, Status>> + Send>>

Server streaming response type for the GetBlockRange method.

type GetBlockRangeNullifiersStream = Pin<Box<dyn Stream<Item = Result<CompactBlock, Status>> + Send>>

Server streaming response type for the GetBlockRangeNullifiers method.

type GetTaddressTxidsStream = Pin<Box<dyn Stream<Item = Result<RawTransaction, Status>> + Send>>

Server streaming response type for the GetTaddressTxids method.

type GetTaddressTransactionsStream = Pin<Box<dyn Stream<Item = Result<RawTransaction, Status>> + Send>>

Server streaming response type for the GetTaddressTransactions method.

type GetMempoolTxStream = Pin<Box<dyn Stream<Item = Result<CompactTx, Status>> + Send>>

Server streaming response type for the GetMempoolTx method.

type GetMempoolStreamStream = Pin<Box<dyn Stream<Item = Result<RawTransaction, Status>> + Send>>

Server streaming response type for the GetMempoolStream method.

type GetSubtreeRootsStream = Pin<Box<dyn Stream<Item = Result<SubtreeRoot, Status>> + Send>>

Server streaming response type for the GetSubtreeRoots method.

type GetAddressUtxosStreamStream = Pin<Box<dyn Stream<Item = Result<GetAddressUtxosReply, Status>> + Send>>

Server streaming response type for the GetAddressUtxosStream method.

fn get_latest_block<'life0, 'async_trait>( &'life0 self, _request: Request<ChainSpec>, ) -> Pin<Box<dyn Future<Output = Result<Response<BlockId>, Status>> + Send + 'async_trait>>

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

Return the BlockID of the block at the tip of the best chain

fn get_block<'life0, 'async_trait>( &'life0 self, request: Request<BlockId>, ) -> Pin<Box<dyn Future<Output = Result<Response<CompactBlock>, Status>> + Send + 'async_trait>>

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

Return the compact block corresponding to the given block identifier

fn get_block_nullifiers<'life0, 'async_trait>( &'life0 self, request: Request<BlockId>, ) -> Pin<Box<dyn Future<Output = Result<Response<CompactBlock>, Status>> + Send + 'async_trait>>

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

Same as GetBlock except actions contain only nullifiers

fn get_block_range<'life0, 'async_trait>( &'life0 self, request: Request<BlockRange>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetBlockRangeStream>, Status>> + Send + 'async_trait>>

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

Return a list of consecutive compact blocks

fn get_block_range_nullifiers<'life0, 'async_trait>( &'life0 self, request: Request<BlockRange>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetBlockRangeNullifiersStream>, Status>> + Send + 'async_trait>>

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

Same as GetBlockRange except actions contain only nullifiers

fn get_transaction<'life0, 'async_trait>( &'life0 self, request: Request<TxFilter>, ) -> Pin<Box<dyn Future<Output = Result<Response<RawTransaction>, Status>> + Send + 'async_trait>>

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

Return the requested full (not compact) transaction (as from zcashd)

fn send_transaction<'life0, 'async_trait>( &'life0 self, request: Request<RawTransaction>, ) -> Pin<Box<dyn Future<Output = Result<Response<SendResponse>, Status>> + Send + 'async_trait>>

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

Submit the given transaction to the Zcash network

fn get_taddress_txids<'life0, 'async_trait>( &'life0 self, request: Request<TransparentAddressBlockFilter>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetTaddressTxidsStream>, Status>> + Send + 'async_trait>>

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

Return the transactions corresponding to the given t-address within the given block range NB - this method is misnamed, it returns transactions, not transaction IDs. NOTE: this method is deprecated, please use GetTaddressTransactions instead.

fn get_taddress_transactions<'life0, 'async_trait>( &'life0 self, request: Request<TransparentAddressBlockFilter>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetTaddressTransactionsStream>, Status>> + Send + 'async_trait>>

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

Return the transactions corresponding to the given t-address within the given block range

fn get_taddress_balance<'life0, 'async_trait>( &'life0 self, request: Request<AddressList>, ) -> Pin<Box<dyn Future<Output = Result<Response<Balance>, Status>> + Send + 'async_trait>>

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

fn get_taddress_balance_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<Address>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Balance>, Status>> + Send + 'async_trait>>

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

fn get_mempool_tx<'life0, 'async_trait>( &'life0 self, request: Request<Exclude>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetMempoolTxStream>, Status>> + Send + 'async_trait>>

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

Return the compact transactions currently in the mempool; the results can be a few seconds out of date. If the Exclude list is empty, return all transactions; otherwise return all except those in the Exclude list (if any); this allows the client to avoid receiving transactions that it already has (from an earlier call to this rpc). The transaction IDs in the Exclude list can be shortened to any number of bytes to make the request more bandwidth-efficient; if two or more transactions in the mempool match a shortened txid, they are all sent (none is excluded). Transactions in the exclude list that don’t exist in the mempool are ignored.

fn get_mempool_stream<'life0, 'async_trait>( &'life0 self, _request: Request<Empty>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetMempoolStreamStream>, Status>> + Send + 'async_trait>>

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

Return a stream of current Mempool transactions. This will keep the output stream open while there are mempool transactions. It will close the returned stream when a new block is mined.

fn get_tree_state<'life0, 'async_trait>( &'life0 self, request: Request<BlockId>, ) -> Pin<Box<dyn Future<Output = Result<Response<TreeState>, Status>> + Send + 'async_trait>>

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

GetTreeState returns the note commitment tree state corresponding to the given block. See section 3.7 of the Zcash protocol specification. It returns several other useful values also (even though they can be obtained using GetBlock). The block can be specified by either height or hash.

fn get_latest_tree_state<'life0, 'async_trait>( &'life0 self, _request: Request<Empty>, ) -> Pin<Box<dyn Future<Output = Result<Response<TreeState>, Status>> + Send + 'async_trait>>

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

fn get_subtree_roots<'life0, 'async_trait>( &'life0 self, request: Request<GetSubtreeRootsArg>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetSubtreeRootsStream>, Status>> + Send + 'async_trait>>

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

Returns a stream of information about roots of subtrees of the note commitment tree for the specified shielded protocol (Sapling, Orchard, or Ironwood).

fn get_address_utxos<'life0, 'async_trait>( &'life0 self, request: Request<GetAddressUtxosArg>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAddressUtxosReplyList>, Status>> + Send + 'async_trait>>

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

fn get_address_utxos_stream<'life0, 'async_trait>( &'life0 self, request: Request<GetAddressUtxosArg>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetAddressUtxosStreamStream>, Status>> + Send + 'async_trait>>

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

fn get_lightd_info<'life0, 'async_trait>( &'life0 self, _request: Request<Empty>, ) -> Pin<Box<dyn Future<Output = Result<Response<LightdInfo>, Status>> + Send + 'async_trait>>

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

Return information about this lightwalletd instance and the blockchain

fn ping<'life0, 'async_trait>( &'life0 self, _request: Request<Duration>, ) -> Pin<Box<dyn Future<Output = Result<Response<PingResponse>, Status>> + Send + 'async_trait>>

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

Testing-only, requires lightwalletd –ping-very-insecure (do not enable in production)

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.