Struct ibc_proto::ibc::core::channel::v1::query_client::QueryClient
source · [−]pub struct QueryClient<T> { /* private fields */ }
Expand description
Query provides defines the gRPC querier service
Implementations
impl<T> QueryClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> QueryClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> QueryClient<InterceptedService<T, F>> where
F: Interceptor,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
Compress requests with gzip
.
This requires the server to support it otherwise it might respond with an error.
Enable decompressing responses with gzip
.
pub async fn channel(
&mut self,
request: impl IntoRequest<QueryChannelRequest>
) -> Result<Response<QueryChannelResponse>, Status>
pub async fn channel(
&mut self,
request: impl IntoRequest<QueryChannelRequest>
) -> Result<Response<QueryChannelResponse>, Status>
Channel queries an IBC Channel.
pub async fn channels(
&mut self,
request: impl IntoRequest<QueryChannelsRequest>
) -> Result<Response<QueryChannelsResponse>, Status>
pub async fn channels(
&mut self,
request: impl IntoRequest<QueryChannelsRequest>
) -> Result<Response<QueryChannelsResponse>, Status>
Channels queries all the IBC channels of a chain.
pub async fn connection_channels(
&mut self,
request: impl IntoRequest<QueryConnectionChannelsRequest>
) -> Result<Response<QueryConnectionChannelsResponse>, Status>
pub async fn connection_channels(
&mut self,
request: impl IntoRequest<QueryConnectionChannelsRequest>
) -> Result<Response<QueryConnectionChannelsResponse>, Status>
ConnectionChannels queries all the channels associated with a connection end.
pub async fn channel_client_state(
&mut self,
request: impl IntoRequest<QueryChannelClientStateRequest>
) -> Result<Response<QueryChannelClientStateResponse>, Status>
pub async fn channel_client_state(
&mut self,
request: impl IntoRequest<QueryChannelClientStateRequest>
) -> Result<Response<QueryChannelClientStateResponse>, Status>
ChannelClientState queries for the client state for the channel associated with the provided channel identifiers.
pub async fn channel_consensus_state(
&mut self,
request: impl IntoRequest<QueryChannelConsensusStateRequest>
) -> Result<Response<QueryChannelConsensusStateResponse>, Status>
pub async fn channel_consensus_state(
&mut self,
request: impl IntoRequest<QueryChannelConsensusStateRequest>
) -> Result<Response<QueryChannelConsensusStateResponse>, Status>
ChannelConsensusState queries for the consensus state for the channel associated with the provided channel identifiers.
pub async fn packet_commitment(
&mut self,
request: impl IntoRequest<QueryPacketCommitmentRequest>
) -> Result<Response<QueryPacketCommitmentResponse>, Status>
pub async fn packet_commitment(
&mut self,
request: impl IntoRequest<QueryPacketCommitmentRequest>
) -> Result<Response<QueryPacketCommitmentResponse>, Status>
PacketCommitment queries a stored packet commitment hash.
pub async fn packet_commitments(
&mut self,
request: impl IntoRequest<QueryPacketCommitmentsRequest>
) -> Result<Response<QueryPacketCommitmentsResponse>, Status>
pub async fn packet_commitments(
&mut self,
request: impl IntoRequest<QueryPacketCommitmentsRequest>
) -> Result<Response<QueryPacketCommitmentsResponse>, Status>
PacketCommitments returns all the packet commitments hashes associated with a channel.
pub async fn packet_receipt(
&mut self,
request: impl IntoRequest<QueryPacketReceiptRequest>
) -> Result<Response<QueryPacketReceiptResponse>, Status>
pub async fn packet_receipt(
&mut self,
request: impl IntoRequest<QueryPacketReceiptRequest>
) -> Result<Response<QueryPacketReceiptResponse>, Status>
PacketReceipt queries if a given packet sequence has been received on the queried chain
pub async fn packet_acknowledgement(
&mut self,
request: impl IntoRequest<QueryPacketAcknowledgementRequest>
) -> Result<Response<QueryPacketAcknowledgementResponse>, Status>
pub async fn packet_acknowledgement(
&mut self,
request: impl IntoRequest<QueryPacketAcknowledgementRequest>
) -> Result<Response<QueryPacketAcknowledgementResponse>, Status>
PacketAcknowledgement queries a stored packet acknowledgement hash.
pub async fn packet_acknowledgements(
&mut self,
request: impl IntoRequest<QueryPacketAcknowledgementsRequest>
) -> Result<Response<QueryPacketAcknowledgementsResponse>, Status>
pub async fn packet_acknowledgements(
&mut self,
request: impl IntoRequest<QueryPacketAcknowledgementsRequest>
) -> Result<Response<QueryPacketAcknowledgementsResponse>, Status>
PacketAcknowledgements returns all the packet acknowledgements associated with a channel.
pub async fn unreceived_packets(
&mut self,
request: impl IntoRequest<QueryUnreceivedPacketsRequest>
) -> Result<Response<QueryUnreceivedPacketsResponse>, Status>
pub async fn unreceived_packets(
&mut self,
request: impl IntoRequest<QueryUnreceivedPacketsRequest>
) -> Result<Response<QueryUnreceivedPacketsResponse>, Status>
UnreceivedPackets returns all the unreceived IBC packets associated with a channel and sequences.
pub async fn unreceived_acks(
&mut self,
request: impl IntoRequest<QueryUnreceivedAcksRequest>
) -> Result<Response<QueryUnreceivedAcksResponse>, Status>
pub async fn unreceived_acks(
&mut self,
request: impl IntoRequest<QueryUnreceivedAcksRequest>
) -> Result<Response<QueryUnreceivedAcksResponse>, Status>
UnreceivedAcks returns all the unreceived IBC acknowledgements associated with a channel and sequences.
pub async fn next_sequence_receive(
&mut self,
request: impl IntoRequest<QueryNextSequenceReceiveRequest>
) -> Result<Response<QueryNextSequenceReceiveResponse>, Status>
pub async fn next_sequence_receive(
&mut self,
request: impl IntoRequest<QueryNextSequenceReceiveRequest>
) -> Result<Response<QueryNextSequenceReceiveResponse>, Status>
NextSequenceReceive returns the next receive sequence for a given channel.
Trait Implementations
Auto Trait Implementations
impl<T> RefUnwindSafe for QueryClient<T> where
T: RefUnwindSafe,
impl<T> Send for QueryClient<T> where
T: Send,
impl<T> Sync for QueryClient<T> where
T: Sync,
impl<T> Unpin for QueryClient<T> where
T: Unpin,
impl<T> UnwindSafe for QueryClient<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more