Struct ibc_proto::interchain_security::ccv::provider::v1::query_client::QueryClient
source · pub struct QueryClient<T> { /* private fields */ }
Implementations§
source§impl QueryClient<Channel>
impl QueryClient<Channel>
source§impl<T> QueryClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> QueryClient<T>where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>( inner: T, interceptor: F ) -> QueryClient<InterceptedService<T, F>>where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
sourcepub async fn query_consumer_genesis(
&mut self,
request: impl IntoRequest<QueryConsumerGenesisRequest>
) -> Result<Response<QueryConsumerGenesisResponse>, Status>
pub async fn query_consumer_genesis( &mut self, request: impl IntoRequest<QueryConsumerGenesisRequest> ) -> Result<Response<QueryConsumerGenesisResponse>, Status>
ConsumerGenesis queries the genesis state needed to start a consumer chain whose proposal has been accepted
sourcepub async fn query_consumer_chains(
&mut self,
request: impl IntoRequest<QueryConsumerChainsRequest>
) -> Result<Response<QueryConsumerChainsResponse>, Status>
pub async fn query_consumer_chains( &mut self, request: impl IntoRequest<QueryConsumerChainsRequest> ) -> Result<Response<QueryConsumerChainsResponse>, Status>
ConsumerChains queries active consumer chains supported by the provider chain
sourcepub async fn query_consumer_chain_starts(
&mut self,
request: impl IntoRequest<QueryConsumerChainStartProposalsRequest>
) -> Result<Response<QueryConsumerChainStartProposalsResponse>, Status>
pub async fn query_consumer_chain_starts( &mut self, request: impl IntoRequest<QueryConsumerChainStartProposalsRequest> ) -> Result<Response<QueryConsumerChainStartProposalsResponse>, Status>
QueryConsumerChainStarts queries consumer chain start proposals.
sourcepub async fn query_consumer_chain_stops(
&mut self,
request: impl IntoRequest<QueryConsumerChainStopProposalsRequest>
) -> Result<Response<QueryConsumerChainStopProposalsResponse>, Status>
pub async fn query_consumer_chain_stops( &mut self, request: impl IntoRequest<QueryConsumerChainStopProposalsRequest> ) -> Result<Response<QueryConsumerChainStopProposalsResponse>, Status>
QueryConsumerChainStops queries consumer chain stop proposals.
sourcepub async fn query_validator_consumer_addr(
&mut self,
request: impl IntoRequest<QueryValidatorConsumerAddrRequest>
) -> Result<Response<QueryValidatorConsumerAddrResponse>, Status>
pub async fn query_validator_consumer_addr( &mut self, request: impl IntoRequest<QueryValidatorConsumerAddrRequest> ) -> Result<Response<QueryValidatorConsumerAddrResponse>, Status>
QueryValidatorConsumerAddr queries the address assigned by a validator for a consumer chain.
sourcepub async fn query_validator_provider_addr(
&mut self,
request: impl IntoRequest<QueryValidatorProviderAddrRequest>
) -> Result<Response<QueryValidatorProviderAddrResponse>, Status>
pub async fn query_validator_provider_addr( &mut self, request: impl IntoRequest<QueryValidatorProviderAddrRequest> ) -> Result<Response<QueryValidatorProviderAddrResponse>, Status>
QueryProviderAddr returns the provider chain validator given a consumer chain validator address
sourcepub async fn query_throttle_state(
&mut self,
request: impl IntoRequest<QueryThrottleStateRequest>
) -> Result<Response<QueryThrottleStateResponse>, Status>
pub async fn query_throttle_state( &mut self, request: impl IntoRequest<QueryThrottleStateRequest> ) -> Result<Response<QueryThrottleStateResponse>, Status>
QueryThrottleState returns the main on-chain state relevant to currently throttled slash packets
sourcepub async fn query_throttled_consumer_packet_data(
&mut self,
request: impl IntoRequest<QueryThrottledConsumerPacketDataRequest>
) -> Result<Response<QueryThrottledConsumerPacketDataResponse>, Status>
pub async fn query_throttled_consumer_packet_data( &mut self, request: impl IntoRequest<QueryThrottledConsumerPacketDataRequest> ) -> Result<Response<QueryThrottledConsumerPacketDataResponse>, Status>
QueryThrottledConsumerPacketData returns a list of pending packet data instances (slash packet and vsc matured) for a single consumer chain
sourcepub async fn query_registered_consumer_reward_denoms(
&mut self,
request: impl IntoRequest<QueryRegisteredConsumerRewardDenomsRequest>
) -> Result<Response<QueryRegisteredConsumerRewardDenomsResponse>, Status>
pub async fn query_registered_consumer_reward_denoms( &mut self, request: impl IntoRequest<QueryRegisteredConsumerRewardDenomsRequest> ) -> Result<Response<QueryRegisteredConsumerRewardDenomsResponse>, Status>
QueryRegisteredConsumerRewardDenoms returns a list of consumer reward denoms that are registered
Trait Implementations§
source§impl<T: Clone> Clone for QueryClient<T>
impl<T: Clone> Clone for QueryClient<T>
source§fn clone(&self) -> QueryClient<T>
fn clone(&self) -> QueryClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto 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§
source§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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request