pub struct MQClient { /* private fields */ }
Expand description
A client for the AmazonMQ API.
Implementations
sourceimpl MQClient
impl MQClient
sourcepub fn new(region: Region) -> MQClient
pub fn new(region: Region) -> MQClient
Creates a client backed by the default tokio event loop.
The client will use the default credentials provider and tls client.
pub fn new_with<P, D>(
request_dispatcher: D,
credentials_provider: P,
region: Region
) -> MQClient where
P: ProvideAwsCredentials + Send + Sync + 'static,
D: DispatchSignedRequest + Send + Sync + 'static,
pub fn new_with_client(client: Client, region: Region) -> MQClient
Trait Implementations
sourceimpl MQ for MQClient
impl MQ for MQClient
sourcefn create_broker<'life0, 'async_trait>(
&'life0 self,
input: CreateBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<CreateBrokerResponse, RusotoError<CreateBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn create_broker<'life0, 'async_trait>(
&'life0 self,
input: CreateBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<CreateBrokerResponse, RusotoError<CreateBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Creates a broker. Note: This API is asynchronous.
sourcefn create_configuration<'life0, 'async_trait>(
&'life0 self,
input: CreateConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<CreateConfigurationResponse, RusotoError<CreateConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn create_configuration<'life0, 'async_trait>(
&'life0 self,
input: CreateConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<CreateConfigurationResponse, RusotoError<CreateConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).
Add a tag to a resource.
sourcefn create_user<'life0, 'async_trait>(
&'life0 self,
input: CreateUserRequest
) -> Pin<Box<dyn Future<Output = Result<CreateUserResponse, RusotoError<CreateUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn create_user<'life0, 'async_trait>(
&'life0 self,
input: CreateUserRequest
) -> Pin<Box<dyn Future<Output = Result<CreateUserResponse, RusotoError<CreateUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Creates an ActiveMQ user.
sourcefn delete_broker<'life0, 'async_trait>(
&'life0 self,
input: DeleteBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteBrokerResponse, RusotoError<DeleteBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn delete_broker<'life0, 'async_trait>(
&'life0 self,
input: DeleteBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteBrokerResponse, RusotoError<DeleteBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Deletes a broker. Note: This API is asynchronous.
Removes a tag from a resource.
sourcefn delete_user<'life0, 'async_trait>(
&'life0 self,
input: DeleteUserRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteUserResponse, RusotoError<DeleteUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn delete_user<'life0, 'async_trait>(
&'life0 self,
input: DeleteUserRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteUserResponse, RusotoError<DeleteUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Deletes an ActiveMQ user.
sourcefn describe_broker<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerResponse, RusotoError<DescribeBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_broker<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerResponse, RusotoError<DescribeBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns information about the specified broker.
sourcefn describe_broker_engine_types<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerEngineTypesRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerEngineTypesResponse, RusotoError<DescribeBrokerEngineTypesError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_broker_engine_types<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerEngineTypesRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerEngineTypesResponse, RusotoError<DescribeBrokerEngineTypesError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Describe available engine types and versions.
sourcefn describe_broker_instance_options<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerInstanceOptionsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerInstanceOptionsResponse, RusotoError<DescribeBrokerInstanceOptionsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_broker_instance_options<'life0, 'async_trait>(
&'life0 self,
input: DescribeBrokerInstanceOptionsRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeBrokerInstanceOptionsResponse, RusotoError<DescribeBrokerInstanceOptionsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Describe available broker instance options.
sourcefn describe_configuration<'life0, 'async_trait>(
&'life0 self,
input: DescribeConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationResponse, RusotoError<DescribeConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_configuration<'life0, 'async_trait>(
&'life0 self,
input: DescribeConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationResponse, RusotoError<DescribeConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns information about the specified configuration.
sourcefn describe_configuration_revision<'life0, 'async_trait>(
&'life0 self,
input: DescribeConfigurationRevisionRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationRevisionResponse, RusotoError<DescribeConfigurationRevisionError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_configuration_revision<'life0, 'async_trait>(
&'life0 self,
input: DescribeConfigurationRevisionRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationRevisionResponse, RusotoError<DescribeConfigurationRevisionError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns the specified configuration revision for the specified configuration.
sourcefn describe_user<'life0, 'async_trait>(
&'life0 self,
input: DescribeUserRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeUserResponse, RusotoError<DescribeUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn describe_user<'life0, 'async_trait>(
&'life0 self,
input: DescribeUserRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeUserResponse, RusotoError<DescribeUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns information about an ActiveMQ user.
sourcefn list_brokers<'life0, 'async_trait>(
&'life0 self,
input: ListBrokersRequest
) -> Pin<Box<dyn Future<Output = Result<ListBrokersResponse, RusotoError<ListBrokersError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_brokers<'life0, 'async_trait>(
&'life0 self,
input: ListBrokersRequest
) -> Pin<Box<dyn Future<Output = Result<ListBrokersResponse, RusotoError<ListBrokersError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns a list of all brokers.
sourcefn list_configuration_revisions<'life0, 'async_trait>(
&'life0 self,
input: ListConfigurationRevisionsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationRevisionsResponse, RusotoError<ListConfigurationRevisionsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_configuration_revisions<'life0, 'async_trait>(
&'life0 self,
input: ListConfigurationRevisionsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationRevisionsResponse, RusotoError<ListConfigurationRevisionsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns a list of all revisions for the specified configuration.
sourcefn list_configurations<'life0, 'async_trait>(
&'life0 self,
input: ListConfigurationsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationsResponse, RusotoError<ListConfigurationsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_configurations<'life0, 'async_trait>(
&'life0 self,
input: ListConfigurationsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationsResponse, RusotoError<ListConfigurationsError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns a list of all configurations.
Lists tags for a resource.
sourcefn list_users<'life0, 'async_trait>(
&'life0 self,
input: ListUsersRequest
) -> Pin<Box<dyn Future<Output = Result<ListUsersResponse, RusotoError<ListUsersError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_users<'life0, 'async_trait>(
&'life0 self,
input: ListUsersRequest
) -> Pin<Box<dyn Future<Output = Result<ListUsersResponse, RusotoError<ListUsersError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Returns a list of all ActiveMQ users.
sourcefn reboot_broker<'life0, 'async_trait>(
&'life0 self,
input: RebootBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<RebootBrokerResponse, RusotoError<RebootBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn reboot_broker<'life0, 'async_trait>(
&'life0 self,
input: RebootBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<RebootBrokerResponse, RusotoError<RebootBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Reboots a broker. Note: This API is asynchronous.
sourcefn update_broker<'life0, 'async_trait>(
&'life0 self,
input: UpdateBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateBrokerResponse, RusotoError<UpdateBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn update_broker<'life0, 'async_trait>(
&'life0 self,
input: UpdateBrokerRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateBrokerResponse, RusotoError<UpdateBrokerError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Adds a pending configuration change to a broker.
sourcefn update_configuration<'life0, 'async_trait>(
&'life0 self,
input: UpdateConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateConfigurationResponse, RusotoError<UpdateConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn update_configuration<'life0, 'async_trait>(
&'life0 self,
input: UpdateConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateConfigurationResponse, RusotoError<UpdateConfigurationError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Updates the specified configuration.
sourcefn update_user<'life0, 'async_trait>(
&'life0 self,
input: UpdateUserRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateUserResponse, RusotoError<UpdateUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn update_user<'life0, 'async_trait>(
&'life0 self,
input: UpdateUserRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateUserResponse, RusotoError<UpdateUserError>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Updates the information for an ActiveMQ user.
Auto Trait Implementations
impl !RefUnwindSafe for MQClient
impl Send for MQClient
impl Sync for MQClient
impl Unpin for MQClient
impl !UnwindSafe for MQClient
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more