pub enum Client {
Http(HttpClient),
Ws(WsReconnectClient<WsClient>),
}Available on non-WebAssembly only.
Expand description
Json RPC client.
Variants§
Http(HttpClient)
A client using ‘http[s]’ protocol.
Ws(WsReconnectClient<WsClient>)
A client using ‘ws[s]’ protocol.
Implementations§
Source§impl Client
impl Client
Sourcepub async fn new(
url: &str,
auth_token: Option<&str>,
connect_timeout: Option<Duration>,
request_timeout: Option<Duration>,
) -> Result<Self, Error>
pub async fn new( url: &str, auth_token: Option<&str>, connect_timeout: Option<Duration>, request_timeout: Option<Duration>, ) -> Result<Self, Error>
Create a new Json RPC client.
Only ‘http[s]’ and ‘ws[s]’ protocols are supported and they should
be specified in the provided url. For more flexibility
consider creating the client using jsonrpsee directly.
Please note that currently the celestia-node supports only ‘http’ and ‘ws’. For a secure connection you have to hide it behind a proxy.
Trait Implementations§
Source§impl ClientT for Client
impl ClientT for Client
Source§async fn notification<Params>(
&self,
method: &str,
params: Params,
) -> Result<(), ClientError>where
Params: ToRpcParams + Send,
async fn notification<Params>(
&self,
method: &str,
params: Params,
) -> Result<(), ClientError>where
Params: ToRpcParams + Send,
Send a notification request
Source§async fn request<R, Params>(
&self,
method: &str,
params: Params,
) -> Result<R, ClientError>
async fn request<R, Params>( &self, method: &str, params: Params, ) -> Result<R, ClientError>
Send a method call request.
Source§async fn batch_request<'a, R>(
&self,
batch: BatchRequestBuilder<'a>,
) -> Result<BatchResponse<'a, R>, ClientError>where
R: DeserializeOwned + Debug + 'a,
async fn batch_request<'a, R>(
&self,
batch: BatchRequestBuilder<'a>,
) -> Result<BatchResponse<'a, R>, ClientError>where
R: DeserializeOwned + Debug + 'a,
Send a batch request. Read more
Source§impl SubscriptionClientT for Client
impl SubscriptionClientT for Client
Source§async fn subscribe<'a, N, Params>(
&self,
subscribe_method: &'a str,
params: Params,
unsubscribe_method: &'a str,
) -> Result<Subscription<N>, ClientError>
async fn subscribe<'a, N, Params>( &self, subscribe_method: &'a str, params: Params, unsubscribe_method: &'a str, ) -> Result<Subscription<N>, ClientError>
Initiate a subscription by performing a JSON-RPC method call where the server responds with
a
Subscription ID that is used to fetch messages on that subscription, Read moreSource§async fn subscribe_to_method<N>(
&self,
method: &str,
) -> Result<Subscription<N>, ClientError>where
N: DeserializeOwned,
async fn subscribe_to_method<N>(
&self,
method: &str,
) -> Result<Subscription<N>, ClientError>where
N: DeserializeOwned,
Register a method subscription, this is used to filter only server notifications that a user is interested in. Read more
Auto Trait Implementations§
impl !Freeze for Client
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl UnsafeUnpin for Client
impl !UnwindSafe for Client
Blanket Implementations§
Source§impl<T> BlobClient for Twhere
T: ClientT,
impl<T> BlobClient for Twhere
T: ClientT,
Source§fn blob_get<'a, 'fut>(
&'a self,
height: u64,
namespace: Namespace,
commitment: Commitment,
) -> impl Future<Output = Result<Blob, Error>> + Send + 'fut
fn blob_get<'a, 'fut>( &'a self, height: u64, namespace: Namespace, commitment: Commitment, ) -> impl Future<Output = Result<Blob, Error>> + Send + 'fut
Get retrieves the blob by commitment under the given namespace and height.
Source§fn blob_get_all<'a, 'b, 'fut>(
&'a self,
height: u64,
namespaces: &'b [Namespace],
) -> impl Future<Output = Result<Option<Vec<Blob>>, Error>> + Send + 'fut
fn blob_get_all<'a, 'b, 'fut>( &'a self, height: u64, namespaces: &'b [Namespace], ) -> impl Future<Output = Result<Option<Vec<Blob>>, Error>> + Send + 'fut
GetAll returns all blobs under the given namespaces and height.
Source§fn blob_get_proof<'a, 'fut>(
&'a self,
height: u64,
namespace: Namespace,
commitment: Commitment,
) -> impl Future<Output = Result<Vec<NamespaceProof>, Error>> + Send + 'fut
fn blob_get_proof<'a, 'fut>( &'a self, height: u64, namespace: Namespace, commitment: Commitment, ) -> impl Future<Output = Result<Vec<NamespaceProof>, Error>> + Send + 'fut
GetProof retrieves proofs in the given namespaces at the given height by commitment.
Source§fn blob_included<'a, 'b, 'fut>(
&'a self,
height: u64,
namespace: Namespace,
proof: &'b NamespaceProof,
commitment: Commitment,
) -> impl Future<Output = Result<bool, Error>> + Send + 'fut
fn blob_included<'a, 'b, 'fut>( &'a self, height: u64, namespace: Namespace, proof: &'b NamespaceProof, commitment: Commitment, ) -> impl Future<Output = Result<bool, Error>> + Send + 'fut
Included checks whether a blob’s given commitment(Merkle subtree root) is included at given height and under the namespace.
Source§fn blob_submit<'a, 'b, 'fut>(
&'a self,
blobs: &'b [Blob],
opts: TxConfig,
) -> impl Future<Output = Result<u64, Error>> + Send + 'fut
fn blob_submit<'a, 'b, 'fut>( &'a self, blobs: &'b [Blob], opts: TxConfig, ) -> impl Future<Output = Result<u64, Error>> + Send + 'fut
Submit sends Blobs and reports the height in which they were included. Allows sending multiple Blobs atomically synchronously. Uses default wallet registered on the Node.
Source§impl<T> BlobstreamClient for Twhere
T: ClientT,
impl<T> BlobstreamClient for Twhere
T: ClientT,
Source§fn blobstream_get_data_root_tuple_root<'a, 'fut>(
&'a self,
start: u64,
end: u64,
) -> impl Future<Output = Result<Hash, Error>> + Send + 'fut
fn blobstream_get_data_root_tuple_root<'a, 'fut>( &'a self, start: u64, end: u64, ) -> impl Future<Output = Result<Hash, Error>> + Send + 'fut
Collects the data roots over a provided ordered range of blocks, and then
creates a new Merkle root of those data roots. Read more
Source§fn blobstream_get_data_root_tuple_inclusion_proof<'a, 'fut>(
&'a self,
height: u64,
start: u64,
end: u64,
) -> impl Future<Output = Result<MerkleProof, Error>> + Send + 'fut
fn blobstream_get_data_root_tuple_inclusion_proof<'a, 'fut>( &'a self, height: u64, start: u64, end: u64, ) -> impl Future<Output = Result<MerkleProof, Error>> + Send + 'fut
Creates an inclusion proof, for the data root tuple of block height
height,
in the set of blocks defined by start and end. Read moreSource§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<TypeJsonRpseeInternal> DasClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
impl<TypeJsonRpseeInternal> DasClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
Source§fn das_sampling_stats(
&self,
) -> impl Future<Output = Result<SamplingStats, Error>> + Send
fn das_sampling_stats( &self, ) -> impl Future<Output = Result<SamplingStats, Error>> + Send
Retrieves the current statistics over the DA sampling process.
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.Source§impl<T> FraudClient for Twhere
T: ClientT,
impl<T> FraudClient for Twhere
T: ClientT,
Source§impl<T> HeaderClient for Twhere
T: ClientT,
impl<T> HeaderClient for Twhere
T: ClientT,
Source§fn header_get_by_hash<'a, 'fut>(
&'a self,
hash: Hash,
) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
fn header_get_by_hash<'a, 'fut>( &'a self, hash: Hash, ) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
GetByHash returns the header of the given hash from the node’s header store.
Source§fn header_get_by_height<'a, 'fut>(
&'a self,
height: u64,
) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
fn header_get_by_height<'a, 'fut>( &'a self, height: u64, ) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
GetByHeight returns the ExtendedHeader at the given height if it is currently available.
Source§fn header_get_range_by_height<'a, 'b, 'fut>(
&'a self,
from: ExtendedHeader,
to: u64,
) -> impl Future<Output = Result<Vec<ExtendedHeader>, Error>> + Send + 'fut
fn header_get_range_by_height<'a, 'b, 'fut>( &'a self, from: ExtendedHeader, to: u64, ) -> impl Future<Output = Result<Vec<ExtendedHeader>, Error>> + Send + 'fut
GetRangeByHeight returns the given range (from:to) of ExtendedHeaders from the node’s header store and verifies that the returned headers are adjacent to each other.
Source§fn header_local_head<'a, 'fut>(
&'a self,
) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
fn header_local_head<'a, 'fut>( &'a self, ) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
LocalHead returns the ExtendedHeader of the chain head.
Source§fn header_network_head<'a, 'fut>(
&'a self,
) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
fn header_network_head<'a, 'fut>( &'a self, ) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
NetworkHead provides the Syncer’s view of the current network head.
Source§fn header_subscribe<'a>(
&'a self,
) -> Pin<Box<dyn Stream<Item = Result<ExtendedHeader, Error>> + Send + 'a>>
fn header_subscribe<'a>( &'a self, ) -> Pin<Box<dyn Stream<Item = Result<ExtendedHeader, Error>> + Send + 'a>>
Subscribe to recent ExtendedHeaders from the network. Read more
Source§fn header_sync_state<'a, 'fut>(
&'a self,
) -> impl Future<Output = Result<SyncState, Error>> + Send + 'fut
fn header_sync_state<'a, 'fut>( &'a self, ) -> impl Future<Output = Result<SyncState, Error>> + Send + 'fut
SyncState returns the current state of the header Syncer.
Source§fn header_sync_wait<'a, 'fut>(
&'a self,
) -> impl Future<Output = Result<(), Error>> + Send + 'fut
fn header_sync_wait<'a, 'fut>( &'a self, ) -> impl Future<Output = Result<(), Error>> + Send + 'fut
SyncWait blocks until the header Syncer is synced to network head.
Source§fn header_wait_for_height<'a, 'fut>(
&'a self,
height: u64,
) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
fn header_wait_for_height<'a, 'fut>( &'a self, height: u64, ) -> impl Future<Output = Result<ExtendedHeader, Error>> + Send + 'fut
WaitForHeight blocks until the header at the given height has been processed by the store or context deadline is exceeded.
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<TypeJsonRpseeInternal> P2PClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
impl<TypeJsonRpseeInternal> P2PClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
Source§fn p2p_bandwidth_for_peer(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
fn p2p_bandwidth_for_peer( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
Available on crate feature
p2p only.BandwidthForPeer returns a Stats struct with bandwidth metrics associated with the given peer.ID. The metrics returned include all traffic sent / received for the peer, regardless of protocol.
Source§fn p2p_bandwidth_for_protocol(
&self,
protocol_id: &str,
) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
fn p2p_bandwidth_for_protocol( &self, protocol_id: &str, ) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
Available on crate feature
p2p only.BandwidthForProtocol returns a Stats struct with bandwidth metrics associated with the given protocol.ID.
Source§fn p2p_bandwidth_stats(
&self,
) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
fn p2p_bandwidth_stats( &self, ) -> impl Future<Output = Result<BandwidthStats, Error>> + Send
Available on crate feature
p2p only.BandwidthStats returns a Stats struct with bandwidth metrics for all data sent/received by the local peer, regardless of protocol or remote peer IDs.
Source§fn p2p_block_peer(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<(), Error>> + Send
fn p2p_block_peer( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<(), Error>> + Send
Available on crate feature
p2p only.BlockPeer adds a peer to the set of blocked peers.
Source§fn p2p_close_peer(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<(), Error>> + Send
fn p2p_close_peer( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<(), Error>> + Send
Available on crate feature
p2p only.ClosePeer closes the connection to a given peer.
Source§fn p2p_connect(
&self,
address: &AddrInfo,
) -> impl Future<Output = Result<(), Error>> + Send
fn p2p_connect( &self, address: &AddrInfo, ) -> impl Future<Output = Result<(), Error>> + Send
Available on crate feature
p2p only.Connect ensures there is a connection between this host and the peer with given peer.
Source§fn p2p_connectedness(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<Connectedness, Error>> + Send
fn p2p_connectedness( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<Connectedness, Error>> + Send
Available on crate feature
p2p only.Connectedness returns a state signaling connection capabilities.
Source§fn p2p_info(&self) -> impl Future<Output = Result<AddrInfo, Error>> + Send
fn p2p_info(&self) -> impl Future<Output = Result<AddrInfo, Error>> + Send
Available on crate feature
p2p only.Info returns address information about the host.
Source§fn p2p_is_protected(
&self,
peer_id: &PeerId,
tag: &str,
) -> impl Future<Output = Result<bool, Error>> + Send
fn p2p_is_protected( &self, peer_id: &PeerId, tag: &str, ) -> impl Future<Output = Result<bool, Error>> + Send
Available on crate feature
p2p only.IsProtected returns whether the given peer is protected.
Source§fn p2p_list_blocked_peers(
&self,
) -> impl Future<Output = Result<Vec<PeerId>, Error>> + Send
fn p2p_list_blocked_peers( &self, ) -> impl Future<Output = Result<Vec<PeerId>, Error>> + Send
Available on crate feature
p2p only.ListBlockedPeers returns a list of blocked peers.
Source§fn p2p_nat_status(
&self,
) -> impl Future<Output = Result<Reachability, Error>> + Send
fn p2p_nat_status( &self, ) -> impl Future<Output = Result<Reachability, Error>> + Send
Available on crate feature
p2p only.NATStatus returns the current NAT status.
Source§fn p2p_peer_info(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<AddrInfo, Error>> + Send
fn p2p_peer_info( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<AddrInfo, Error>> + Send
Available on crate feature
p2p only.PeerInfo returns a small slice of information Peerstore has on the given peer.
Source§fn p2p_peers(&self) -> impl Future<Output = Result<Vec<PeerId>, Error>> + Send
fn p2p_peers(&self) -> impl Future<Output = Result<Vec<PeerId>, Error>> + Send
Available on crate feature
p2p only.Peers returns connected peers.
Source§fn p2p_protect(
&self,
peer_id: &PeerId,
tag: &str,
) -> impl Future<Output = Result<(), Error>> + Send
fn p2p_protect( &self, peer_id: &PeerId, tag: &str, ) -> impl Future<Output = Result<(), Error>> + Send
Available on crate feature
p2p only.Protect adds a peer to the list of peers who have a bidirectional peering agreement that they are protected from being trimmed, dropped or negatively scored.
Source§fn p2p_pub_sub_peers(
&self,
topic: &str,
) -> impl Future<Output = Result<Option<Vec<PeerId>>, Error>> + Send
fn p2p_pub_sub_peers( &self, topic: &str, ) -> impl Future<Output = Result<Option<Vec<PeerId>>, Error>> + Send
Available on crate feature
p2p only.PubSubPeers returns the peer IDs of the peers joined on the given topic.
Source§fn p2p_resource_state(
&self,
) -> impl Future<Output = Result<ResourceManagerStats, Error>> + Send
fn p2p_resource_state( &self, ) -> impl Future<Output = Result<ResourceManagerStats, Error>> + Send
Available on crate feature
p2p only.ResourceState returns the state of the resource manager.
Source§fn p2p_unblock_peer(
&self,
peer_id: &PeerId,
) -> impl Future<Output = Result<(), Error>> + Send
fn p2p_unblock_peer( &self, peer_id: &PeerId, ) -> impl Future<Output = Result<(), Error>> + Send
Available on crate feature
p2p only.UnblockPeer removes a peer from the set of blocked peers.
Source§fn p2p_unprotect(
&self,
peer_id: &PeerId,
tag: &str,
) -> impl Future<Output = Result<bool, Error>> + Send
fn p2p_unprotect( &self, peer_id: &PeerId, tag: &str, ) -> impl Future<Output = Result<bool, Error>> + Send
Available on crate feature
p2p only.Unprotect removes a peer from the list of peers who have a bidirectional peering agreement that they are protected from being trimmed, dropped or negatively scored, returning a bool representing whether the given peer is protected or not.
Source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.GetEDS gets the full EDS identified at the specified height.
Retrieves a list of shares and their corresponding proof. Read more
Retrieves multiple shares from the
ExtendedDataSquare at the given height
at the given sample coordinates. Read moreGetShare gets the list of shares in a single row.
GetShare gets a Share by coordinates in EDS.
GetNamespaceData gets all shares from an EDS within the given namespace. Read more
SharesAvailable subjectively validates if Shares committed to the given Root are available on the Network.
Source§impl<TypeJsonRpseeInternal> StateClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
impl<TypeJsonRpseeInternal> StateClient for TypeJsonRpseeInternalwhere
TypeJsonRpseeInternal: ClientT,
Source§fn state_account_address(
&self,
) -> impl Future<Output = Result<Address, Error>> + Send
fn state_account_address( &self, ) -> impl Future<Output = Result<Address, Error>> + Send
Returns the default account address for the node.
Source§fn state_balance(&self) -> impl Future<Output = Result<Coin, Error>> + Send
fn state_balance(&self) -> impl Future<Output = Result<Coin, Error>> + Send
Returns the balance for the node’s default account.
Source§fn state_balance_for_address(
&self,
addr: Address,
) -> impl Future<Output = Result<Coin, Error>> + Send
fn state_balance_for_address( &self, addr: Address, ) -> impl Future<Output = Result<Coin, Error>> + Send
Retrieves the Celestia coin balance for a specific address.
Verifies the returned balance against the corresponding block’s AppHash.
Source§fn state_begin_redelegate(
&self,
src: ValAddress,
dest: ValAddress,
amount: u64,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_begin_redelegate( &self, src: ValAddress, dest: ValAddress, amount: u64, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Begins a redelegation from one validator to another.
Source§fn state_cancel_unbonding_delegation(
&self,
addr: ValAddress,
amount: u64,
height: u64,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_cancel_unbonding_delegation( &self, addr: ValAddress, amount: u64, height: u64, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Cancels an unbonding delegation at a specific height.
Source§fn state_delegate(
&self,
addr: ValAddress,
amount: u64,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_delegate( &self, addr: ValAddress, amount: u64, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Delegates tokens to a validator.
Source§fn state_is_stopped(&self) -> impl Future<Output = Result<bool, Error>> + Send
fn state_is_stopped(&self) -> impl Future<Output = Result<bool, Error>> + Send
Checks whether the state service is stopped.
Source§fn state_query_delegation(
&self,
addr: ValAddress,
) -> impl Future<Output = Result<QueryDelegationResponse, Error>> + Send
fn state_query_delegation( &self, addr: ValAddress, ) -> impl Future<Output = Result<QueryDelegationResponse, Error>> + Send
Queries delegation details for the given validator address.
Source§fn state_query_redelegations(
&self,
src: ValAddress,
dest: ValAddress,
) -> impl Future<Output = Result<QueryRedelegationsResponse, Error>> + Send
fn state_query_redelegations( &self, src: ValAddress, dest: ValAddress, ) -> impl Future<Output = Result<QueryRedelegationsResponse, Error>> + Send
Queries redelegations between the given validators.
Source§fn state_query_unbonding(
&self,
addr: ValAddress,
) -> impl Future<Output = Result<QueryUnbondingDelegationResponse, Error>> + Send
fn state_query_unbonding( &self, addr: ValAddress, ) -> impl Future<Output = Result<QueryUnbondingDelegationResponse, Error>> + Send
Queries unbonding delegations for the given validator address.
Source§fn state_submit_pay_for_blob(
&self,
blobs: Vec<RawBlob>,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_submit_pay_for_blob( &self, blobs: Vec<RawBlob>, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Submits a pay-for-blob transaction for the provided blobs.
Source§fn state_transfer(
&self,
to: AccAddress,
amount: u64,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_transfer( &self, to: AccAddress, amount: u64, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Transfers tokens to a destination account.
Source§fn state_undelegate(
&self,
addr: ValAddress,
amount: u64,
config: TxConfig,
) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
fn state_undelegate( &self, addr: ValAddress, amount: u64, config: TxConfig, ) -> impl Future<Output = Result<RawTxResponse, Error>> + Send
Undelegates tokens from a validator.
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.