Struct ibc_query::core::channel::ChannelQueryService

pub struct ChannelQueryService<I>
where
    I: QueryContext + Send + Sync + 'static,
    <I as ValidationContext>::AnyClientState: Into<Any>,
    <I as ValidationContext>::AnyConsensusState: Into<Any>,
{ /* private fields */ }

The generic I must be a type where writes from one thread are readable from another. This means using Arc<Mutex<_>> or Arc<RwLock<_>> in most cases.

Implementations

impl<I> ChannelQueryService<I>

where I: QueryContext + Send + Sync + 'static, <I as ValidationContext>::AnyClientState: Into<Any>, <I as ValidationContext>::AnyConsensusState: Into<Any>,

pub fn new(ibc_context: I) -> Self

The parameter ibc_context must be a type where writes from one thread are readable from another. This means using Arc<Mutex<_>> or Arc<RwLock<_>> in most cases.

Trait Implementations

impl<I> Query for ChannelQueryService<I>

where I: QueryContext + Send + Sync + 'static, <I as ValidationContext>::AnyClientState: Into<Any>, <I as ValidationContext>::AnyConsensusState: Into<Any>,

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

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

Returns all the acknowledgements if sequences is omitted.

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

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

Returns all the unreceived packets if sequences is omitted.

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

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

Returns all the unreceived acknowledgements if sequences is omitted.

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

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

Channel queries an IBC Channel.

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

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

Channels queries all the IBC channels of a chain.

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

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

ConnectionChannels queries all the channels associated with a connection end.

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

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

ChannelClientState queries for the client state for the channel associated with the provided channel identifiers.

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

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

ChannelConsensusState queries for the consensus state for the channel associated with the provided channel identifiers.

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

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

PacketCommitment queries a stored packet commitment hash.

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

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

PacketCommitments returns all the packet commitments hashes associated with a channel.

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

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

PacketReceipt queries if a given packet sequence has been received on the queried chain

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

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

PacketAcknowledgement queries a stored packet acknowledgement hash.

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

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

NextSequenceReceive returns the next receive sequence for a given channel.