Struct warp_api_ffi::lw_rpc::compact_tx_streamer_client::CompactTxStreamerClient

pub struct CompactTxStreamerClient<T> { /* private fields */ }

Implementations

impl CompactTxStreamerClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

Attempt to create a new client by connecting to a given endpoint.

impl<T> CompactTxStreamerClient<T> where
    T: GrpcService<BoxBody>,
    T::Error: Into<StdError>,
    T::ResponseBody: Body<Data = Bytes> + Send + 'static,
    <T::ResponseBody as Body>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor<F>(
    inner: T,
    interceptor: F
) -> CompactTxStreamerClient<InterceptedService<T, F>> where
    F: Interceptor,
    T::ResponseBody: Default,
    T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
    <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync, 

pub fn send_gzip(self) -> Self

Compress requests with gzip.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

pub async fn get_latest_block(
    &mut self,
    request: impl IntoRequest<ChainSpec>
) -> Result<Response<BlockId>, Status>

Return the height of the tip of the best chain

pub async fn get_block(
    &mut self,
    request: impl IntoRequest<BlockId>
) -> Result<Response<CompactBlock>, Status>

Return the compact block corresponding to the given block identifier

pub async fn get_block_range(
    &mut self,
    request: impl IntoRequest<BlockRange>
) -> Result<Response<Streaming<CompactBlock>>, Status>

Return a list of consecutive compact blocks

pub async fn get_transaction(
    &mut self,
    request: impl IntoRequest<TxFilter>
) -> Result<Response<RawTransaction>, Status>

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

pub async fn send_transaction(
    &mut self,
    request: impl IntoRequest<RawTransaction>
) -> Result<Response<SendResponse>, Status>

Submit the given transaction to the Zcash network

pub async fn get_taddress_txids(
    &mut self,
    request: impl IntoRequest<TransparentAddressBlockFilter>
) -> Result<Response<Streaming<RawTransaction>>, Status>

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

pub async fn get_taddress_balance(
    &mut self,
    request: impl IntoRequest<AddressList>
) -> Result<Response<Balance>, Status>

pub async fn get_taddress_balance_stream(
    &mut self,
    request: impl IntoStreamingRequest<Message = Address>
) -> Result<Response<Balance>, Status>

pub async fn get_mempool_tx(
    &mut self,
    request: impl IntoRequest<Exclude>
) -> Result<Response<Streaming<CompactTx>>, Status>

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.

pub async fn get_mempool_stream(
    &mut self,
    request: impl IntoRequest<Empty>
) -> Result<Response<Streaming<RawTransaction>>, Status>

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.

pub async fn get_tree_state(
    &mut self,
    request: impl IntoRequest<BlockId>
) -> Result<Response<TreeState>, Status>

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.

pub async fn get_address_utxos(
    &mut self,
    request: impl IntoRequest<GetAddressUtxosArg>
) -> Result<Response<GetAddressUtxosReplyList>, Status>

pub async fn get_address_utxos_stream(
    &mut self,
    request: impl IntoRequest<GetAddressUtxosArg>
) -> Result<Response<Streaming<GetAddressUtxosReply>>, Status>

pub async fn get_lightd_info(
    &mut self,
    request: impl IntoRequest<Empty>
) -> Result<Response<LightdInfo>, Status>

Return information about this lightwalletd instance and the blockchain

pub async fn ping(
    &mut self,
    request: impl IntoRequest<Duration>
) -> Result<Response<PingResponse>, Status>

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

Trait Implementations

impl<T: Clone> Clone for CompactTxStreamerClient<T>

fn clone(&self) -> CompactTxStreamerClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for CompactTxStreamerClient<T>

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

Formats the value using the given formatter.