Struct ChannelQueryService

pub struct ChannelQueryService<I>
where
    I: QueryContext + Send + Sync + 'static,
    ConsensusStateRef<I>: 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, ConsensusStateRef<I>: 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, ConsensusStateRef<I>: 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 are 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 are 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 are 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.

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

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

NextSequenceSend returns the next send sequence for a given channel.

fn upgrade_error<'life0, 'async_trait>( &'life0 self, _request: Request<QueryUpgradeErrorRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryUpgradeErrorResponse>, Status>> + Send + 'async_trait>>

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

UpgradeError returns the error receipt if the upgrade handshake failed.

fn upgrade<'life0, 'async_trait>( &'life0 self, _request: Request<QueryUpgradeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryUpgradeResponse>, Status>> + Send + 'async_trait>>

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

Upgrade returns the upgrade for a given port and channel id.

fn channel_params<'life0, 'async_trait>( &'life0 self, _request: Request<QueryChannelParamsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryChannelParamsResponse>, Status>> + Send + 'async_trait>>

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

ChannelParams queries all parameters of the ibc channel submodule.