Struct MsgClient

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

Msg defines the authz Msg service.

Implementations

impl MsgClient<Channel>

pub async fn connect<D>(dst: D) -> Result<MsgClient<Channel>, Error>

where D: TryInto<Endpoint>, <D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + Send + Sync>>,

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 + Send + Sync>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Body<Data = Bytes> + Send + 'static, <<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send,

pub fn new(inner: T) -> 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 + Send + Sync>> + Send + Sync,

pub fn send_gzip(self) -> MsgClient<T>

Compress requests with gzip.

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

pub fn accept_gzip(self) -> MsgClient<T>

Enable decompressing responses with gzip.

pub async fn grant( &mut self, request: impl IntoRequest<MsgGrant>, ) -> 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>, ) -> 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>, ) -> 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 duplicate 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.