Struct boot_core::cosmos_modules::authz::msg_client::MsgClient

pub struct MsgClient<T> { /* private fields */ }

Msg defines the authz Msg service.

Implementations

impl MsgClient<Channel>

pub async fn connect<D>(
    dst: D
) -> impl Future<Output = Result<MsgClient<Channel>, Error>>where
    D: TryInto<Endpoint>,
    <D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> MsgClient<T>where
    T: GrpcService<UnsyncBoxBody<Bytes, Status>>,
    <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,
    <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: 'static + Body<Data = Bytes> + Send,
    <<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send,

pub fn new(inner: T) -> MsgClient<T>

pub fn with_origin(inner: T, origin: Uri) -> MsgClient<T>

pub fn with_interceptor<F>(
    inner: T,
    interceptor: F
) -> MsgClient<InterceptedService<T, F>>where
    F: Interceptor,
    <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Default,
    T: Service<Request<UnsyncBoxBody<Bytes, Status>>, Response = Response<<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody>>,
    <T as Service<Request<UnsyncBoxBody<Bytes, Status>>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> MsgClient<T>

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> MsgClient<T>

Enable decompressing responses.

pub async fn grant(
    &mut self,
    request: impl IntoRequest<MsgGrant>
) -> impl Future<Output = Result<Response<MsgGrantResponse>, Status>>

Grant grants the provided authorization to the grantee on the granter’s account with the provided expiration time. If there is already a grant for the given (granter, grantee, Authorization) triple, then the grant will be overwritten.

pub async fn exec(
    &mut self,
    request: impl IntoRequest<MsgExec>
) -> impl Future<Output = Result<Response<MsgExecResponse>, Status>>

Exec attempts to execute the provided messages using authorizations granted to the grantee. Each message should have only one signer corresponding to the granter of the authorization.

pub async fn revoke(
    &mut self,
    request: impl IntoRequest<MsgRevoke>
) -> impl Future<Output = Result<Response<MsgRevokeResponse>, Status>>

Revoke revokes any authorization corresponding to the provided method name on the granter’s account that has been granted to the grantee.

Trait Implementations

impl<T> Clone for MsgClient<T>where
    T: Clone,

fn clone(&self) -> MsgClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for MsgClient<T>where
    T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.