Skip to main content

HttpRpcClient

Struct HttpRpcClient 

Source
pub struct HttpRpcClient { /* private fields */ }
Expand description

A JSON-RPC/HTTP Tendermint RPC client (implements crate::Client).

Supports both HTTP and HTTPS connections to Tendermint RPC endpoints, and allows for the use of HTTP proxies (see HttpClient::new_with_proxy for details).

Does not provide crate::event::Event subscription facilities (see [crate::WebSocketClient] for a client that does).

§Examples

use tendermint_rpc::{HttpClient, Client};

#[tokio::main]
async fn main() {
    let client = HttpClient::new("http://127.0.0.1:26657")
        .unwrap();

    let abci_info = client.abci_info()
        .await
        .unwrap();

    println!("Got ABCI info: {:?}", abci_info);
}

Implementations§

Source§

impl HttpClient

Source

pub fn new_from_parts(inner: Client, url: Url, compat: CompatMode) -> HttpClient

Construct a new Tendermint RPC HTTP/S client connecting to the given URL. This avoids using the Builder and thus does not perform any validation of the configuration.

Source

pub fn new<U>(url: U) -> Result<HttpClient, Error>
where U: TryInto<HttpClientUrl, Error = Error>,

Construct a new Tendermint RPC HTTP/S client connecting to the given URL.

Source

pub fn new_with_proxy<U, P>(url: U, proxy_url: P) -> Result<HttpClient, Error>
where U: TryInto<HttpClientUrl, Error = Error>, P: TryInto<HttpClientUrl, Error = Error>,

Construct a new Tendermint RPC HTTP/S client connecting to the given URL, but via the specified proxy’s URL.

If the RPC endpoint is secured (HTTPS), the proxy will automatically attempt to connect using the HTTP CONNECT method.

Source

pub fn builder(url: HttpClientUrl) -> Builder

Initiate a builder for a Tendermint RPC HTTP/S client connecting to the given URL, so that more configuration options can be specified with the builder.

Source

pub fn set_compat_mode(&mut self, compat: CompatMode)

Set compatibility mode on the instantiated client.

As the HTTP client is stateless and does not support subscriptions, the protocol version it uses can be changed at will, for example, as a result of version discovery over the /status endpoint.

Trait Implementations§

Source§

impl Client for HttpClient

Source§

fn broadcast_evidence<'life0, 'async_trait>( &'life0 self, evidence: Evidence, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/broadcast_evidence: broadcast an evidence.

Source§

fn perform<'life0, 'async_trait, R>( &'life0 self, request: R, ) -> Pin<Box<dyn Future<Output = Result<<R as SimpleRequest>::Output, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, R: SimpleRequest + 'async_trait, HttpClient: 'async_trait,

Perform a request against the RPC endpoint. Read more
Source§

fn block<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, HttpClient: 'async_trait,

/block: get block at a given height.
Source§

fn block_by_hash<'life0, 'async_trait>( &'life0 self, hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/block_by_hash: get block by hash.
Source§

fn latest_block<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/block: get the latest block.
Source§

fn block_results<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, HttpClient: 'async_trait,

/block_results: get ABCI results for a block at a particular height.
Source§

fn latest_block_results<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/block_results: get ABCI results for the latest block.
/block_search: search for blocks by BeginBlock and EndBlock events.
Source§

fn header<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, HttpClient: 'async_trait,

/header: get block header at a given height.
Source§

fn header_by_hash<'life0, 'async_trait>( &'life0 self, hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/header_by_hash: get block by hash.
Source§

fn tx<'life0, 'async_trait>( &'life0 self, hash: Hash, prove: bool, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, HttpClient: 'async_trait,

/tx: find transaction by hash.
/tx_search: search for transactions with their results.
Source§

fn broadcast_tx_commit<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, HttpClient: 'async_trait,

/broadcast_tx_commit: broadcast a transaction, returning the response from DeliverTx.
Source§

fn abci_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Info, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/abci_info: get information about the ABCI application.
Source§

fn abci_query<'life0, 'async_trait, V>( &'life0 self, path: Option<String>, data: V, height: Option<Height>, prove: bool, ) -> Pin<Box<dyn Future<Output = Result<AbciQuery, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, V: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait,

/abci_query: query the ABCI application
Source§

fn blockchain<'life0, 'async_trait, H>( &'life0 self, min: H, max: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, Self: Sync + 'async_trait,

/blockchain: get block headers for min <= height <= max. Read more
Source§

fn broadcast_tx_async<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait,

/broadcast_tx_async: broadcast a transaction, returning immediately.
Source§

fn broadcast_tx_sync<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait,

/broadcast_tx_sync: broadcast a transaction, returning the response from CheckTx.
Source§

fn commit<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, Self: Sync + 'async_trait,

/commit: get block commit at a given height.
Source§

fn consensus_params<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, Self: Sync + 'async_trait,

/consensus_params: get current consensus parameters at the specified height.
Source§

fn consensus_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/consensus_state: get current consensus state
Source§

fn validators<'life0, 'async_trait, H>( &'life0 self, height: H, paging: Paging, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, Self: Sync + 'async_trait,

/validators: get validators a given height.
Source§

fn latest_consensus_params<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/consensus_params: get the latest consensus parameters.
Source§

fn latest_commit<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/commit: get the latest block commit
Source§

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/health: get node health. Read more
Source§

fn genesis<'life0, 'async_trait, AppState>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Genesis<AppState>, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, AppState: Debug + Serialize + DeserializeOwned + Send + 'async_trait, Self: Sync + 'async_trait,

/genesis: get genesis file.
Source§

fn genesis_chunked<'life0, 'async_trait>( &'life0 self, chunk: u64, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

Source§

fn genesis_chunked_stream<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Result<Vec<u8>, Error>> + 'life0>>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/genesis_chunked: get genesis file in multiple chunks.
Source§

fn net_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/net_info: obtain information about P2P and other network connections.
Source§

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sync + 'async_trait,

/status: get Tendermint status including node info, pubkey, latest block hash, app hash, block height and time.
Source§

fn wait_until_healthy<'life0, 'async_trait, T>( &'life0 self, timeout: T, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Duration> + Send + 'async_trait, Self: Sync + 'async_trait,

Poll the /health endpoint until it returns a successful result or the given timeout has elapsed.
Source§

impl Clone for HttpClient

Source§

fn clone(&self) -> HttpClient

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for HttpClient

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<U> As for U

Source§

fn as_<T>(self) -> T
where T: CastFrom<U>, U: Sized,

Casts self to type T. The semantics of numeric casting with the as operator are followed, so <T as As>::as_::<U> can be used in the same way as T as U for numeric conversions. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> Classify for T

Source§

type Classified = T

Source§

fn classify(self) -> T

Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> CosmWasmClient for T

Source§

fn make_abci_query<'life0, 'async_trait, Req, Res>( &'life0 self, path: Option<String>, req: Req, ) -> Pin<Box<dyn Future<Output = Result<Res, NyxdError>> + Send + 'async_trait>>
where Req: Message + 'async_trait, Res: Message + Default + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_chain_id<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Id, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_height<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Height, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_account<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<Option<Account>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_sequence<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<SequenceResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_block<'life0, 'async_trait>( &'life0 self, height: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<BlockResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_balance<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, search_denom: String, ) -> Pin<Box<dyn Future<Output = Result<Option<Coin>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_all_balances<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Coin>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_total_supply<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Coin>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_tx<'life0, 'async_trait>( &'life0 self, id: Hash, ) -> Pin<Box<dyn Future<Output = Result<TxResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn search_tx<'life0, 'async_trait>( &'life0 self, query: Query, ) -> Pin<Box<dyn Future<Output = Result<Vec<TxResponse>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn broadcast_tx_async<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, NyxdError>> + Send + 'async_trait>>
where T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

Broadcast a transaction, returning immediately.
Source§

fn broadcast_tx_sync<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, NyxdError>> + Send + 'async_trait>>
where T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

Broadcast a transaction, returning the response from CheckTx.
Source§

fn broadcast_tx_commit<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, NyxdError>> + Send + 'async_trait>>
where T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

Broadcast a transaction, returning the response from DeliverTx.
Source§

fn broadcast_tx<'life0, 'async_trait, T>( &'life0 self, tx: T, timeout: impl 'async_trait + Into<Option<Duration>> + Send, poll_interval: impl 'async_trait + Into<Option<Duration>> + Send, ) -> Pin<Box<dyn Future<Output = Result<TxResponse, NyxdError>> + Send + 'async_trait>>
where T: Into<Vec<u8>> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_codes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<CodeInfoResponse>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_code_details<'life0, 'async_trait>( &'life0 self, code_id: ContractCodeId, ) -> Pin<Box<dyn Future<Output = Result<CodeDetails, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_contracts<'life0, 'async_trait>( &'life0 self, code_id: ContractCodeId, ) -> Pin<Box<dyn Future<Output = Result<Vec<AccountId>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn get_contract<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<Contract, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_contract_code_history<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<Vec<ContractCodeHistoryEntry>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn query_all_contract_state<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Model>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn query_contract_raw<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 AccountId, query_data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn query_contract_smart<'life0, 'life1, 'life2, 'async_trait, M, T>( &'life0 self, address: &'life1 AccountId, query_msg: &'life2 M, ) -> Pin<Box<dyn Future<Output = Result<T, NyxdError>> + Send + 'async_trait>>
where M: ?Sized + Serialize + Sync + 'async_trait, for<'a> T: Deserialize<'a> + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source§

fn query_simulate<'life0, 'async_trait>( &'life0 self, tx_bytes: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<SimulateResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

impl<T> Declassify for T

Source§

impl<T> Deprecatable for T

Source§

fn deprecate(self) -> Deprecated<Self>
where Self: Sized,

Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> OptionalSet for T

Source§

fn with_optional<F, T>(self, f: F, val: Option<T>) -> Self
where F: Fn(Self, T) -> Self, Self: Sized,

If the value is available (i.e. Some), the provided closure is applied. Otherwise self is returned with no modifications.
Source§

fn with_validated_optional<F, T, V, E>( self, f: F, value: Option<T>, validate: V, ) -> Result<Self, E>
where F: Fn(Self, T) -> Self, V: Fn(&T) -> Result<(), E>, Self: Sized,

If the value is available (i.e. Some) it is validated and then the provided closure is applied. Otherwise self is returned with no modifications.
Source§

fn with_optional_env<F, T>(self, f: F, val: Option<T>, env_var: &str) -> Self
where F: Fn(Self, T) -> Self, T: FromStr, <T as FromStr>::Err: Debug, Self: Sized,

If the value is available (i.e. Some), the provided closure is applied. Otherwise, if the environment was configured and the corresponding variable was set, the value is parsed using the FromStr implementation and the closure is applied on that instead. Finally, if none of those were available, self is returned with no modifications.
Source§

fn with_optional_custom_env<F, T, G>( self, f: F, val: Option<T>, env_var: &str, parser: G, ) -> Self
where F: Fn(Self, T) -> Self, G: Fn(&str) -> T, Self: Sized,

If the value is available (i.e. Some), the provided closure is applied. Otherwise, if the environment was configured and the corresponding variable was set, the value is parsed using the provided parser and the closure is applied on that instead. Finally, if none of those were available, self is returned with no modifications.
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> StakingQueryClient for T
where T: CosmWasmClient,

Source§

fn historical_info<'life0, 'async_trait>( &'life0 self, height: i64, ) -> Pin<Box<dyn Future<Output = Result<QueryHistoricalInfoResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn validator<'life0, 'async_trait>( &'life0 self, validator_addr: AccountId, ) -> Pin<Box<dyn Future<Output = Result<QueryValidatorResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

fn validators<'life0, 'async_trait>( &'life0 self, status: String, pagination: Option<PageRequest>, ) -> Pin<Box<dyn Future<Output = Result<QueryValidatorsResponse, NyxdError>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Source§

impl<C> TendermintRpcClient for C
where C: Client + Sync,

Source§

fn abci_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Info, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/abci_info: get information about the ABCI application.
Source§

fn abci_query<'life0, 'async_trait, V>( &'life0 self, path: Option<String>, data: V, height: Option<Height>, prove: bool, ) -> Pin<Box<dyn Future<Output = Result<AbciQuery, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, V: Into<Vec<u8>> + Send + 'async_trait, C: 'async_trait,

/abci_query: query the ABCI application
Source§

fn block<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/block: get block at a given height.
Source§

fn block_by_hash<'life0, 'async_trait>( &'life0 self, hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/block_by_hash: get block by hash.
Source§

fn latest_block<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/block: get the latest block.
Source§

fn header<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/header: get block header at a given height.
Source§

fn header_by_hash<'life0, 'async_trait>( &'life0 self, hash: Hash, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/header_by_hash: get block by hash.
Source§

fn block_results<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/block_results: get ABCI results for a block at a particular height.
Source§

fn latest_block_results<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/block_results: get ABCI results for the latest block.
Source§

fn block_search<'life0, 'async_trait>( &'life0 self, query: Query, page: u32, per_page: u8, order: Order, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/block_search: search for blocks by BeginBlock and EndBlock events.
Source§

fn blockchain<'life0, 'async_trait, H>( &'life0 self, min: H, max: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/blockchain: get block headers for min <= height <= max. Read more
Source§

fn broadcast_tx_async<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, C: 'async_trait,

/broadcast_tx_async: broadcast a transaction, returning immediately.
Source§

fn broadcast_tx_sync<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, C: 'async_trait,

/broadcast_tx_sync: broadcast a transaction, returning the response from CheckTx.
Source§

fn broadcast_tx_commit<'life0, 'async_trait, T>( &'life0 self, tx: T, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: Into<Vec<u8>> + Send + 'async_trait, C: 'async_trait,

/broadcast_tx_commit: broadcast a transaction, returning the response from DeliverTx.
Source§

fn commit<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/commit: get block commit at a given height.
Source§

fn consensus_params<'life0, 'async_trait, H>( &'life0 self, height: H, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/consensus_params: get current consensus parameters at the specified height.
Source§

fn consensus_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/consensus_state: get current consensus state
Source§

fn validators<'life0, 'async_trait, H>( &'life0 self, height: H, paging: Paging, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, H: Into<Height> + Send + 'async_trait, C: 'async_trait,

/validators: get validators a given height.
Source§

fn latest_consensus_params<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/consensus_params: get the latest consensus parameters.
Source§

fn latest_commit<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/commit: get the latest block commit
Source§

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/health: get node health. Read more
Source§

fn genesis<'life0, 'async_trait, AppState>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Genesis<AppState>, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, AppState: Debug + Serialize + DeserializeOwned + Send + 'async_trait, C: 'async_trait,

/genesis: get genesis file.
Source§

fn net_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/net_info: obtain information about P2P and other network connections.
Source§

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/status: get Tendermint status including node info, pubkey, latest block hash, app hash, block height and time.
Source§

fn broadcast_evidence<'life0, 'async_trait>( &'life0 self, e: Evidence, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/broadcast_evidence: broadcast an evidence.
Source§

fn tx<'life0, 'async_trait>( &'life0 self, hash: Hash, prove: bool, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/tx: find transaction by hash.
Source§

fn tx_search<'life0, 'async_trait>( &'life0 self, query: Query, prove: bool, page: u32, per_page: u8, order: Order, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, C: 'async_trait,

/tx_search: search for transactions with their results.
Source§

fn perform<'life0, 'async_trait, R>( &'life0 self, request: R, ) -> Pin<Box<dyn Future<Output = Result<<R as SimpleRequest>::Output, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, R: SimpleRequest + 'async_trait, C: 'async_trait,

Perform a request against the RPC endpoint. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more