Struct adventure_rusoto_sqs::AwsSqs

pub struct AwsSqs<T> { /* fields omitted */ }

A wrapper for various type of requests in rusoto_sqs.

Trait Implementations

impl<T: Clone> Clone for AwsSqs<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<AddPermissionRequest> for AwsSqs<AddPermissionRequest>

fn from(req: AddPermissionRequest) -> Self

Performs the conversion.

impl From<ChangeMessageVisibilityRequest> for AwsSqs<ChangeMessageVisibilityRequest>

fn from(req: ChangeMessageVisibilityRequest) -> Self

Performs the conversion.

impl From<ChangeMessageVisibilityBatchRequest> for AwsSqs<ChangeMessageVisibilityBatchRequest>

fn from(req: ChangeMessageVisibilityBatchRequest) -> Self

Performs the conversion.

impl From<CreateQueueRequest> for AwsSqs<CreateQueueRequest>

fn from(req: CreateQueueRequest) -> Self

Performs the conversion.

impl From<DeleteMessageRequest> for AwsSqs<DeleteMessageRequest>

fn from(req: DeleteMessageRequest) -> Self

Performs the conversion.

impl From<DeleteMessageBatchRequest> for AwsSqs<DeleteMessageBatchRequest>

fn from(req: DeleteMessageBatchRequest) -> Self

Performs the conversion.

impl From<DeleteQueueRequest> for AwsSqs<DeleteQueueRequest>

fn from(req: DeleteQueueRequest) -> Self

Performs the conversion.

impl From<GetQueueAttributesRequest> for AwsSqs<GetQueueAttributesRequest>

fn from(req: GetQueueAttributesRequest) -> Self

Performs the conversion.

impl From<GetQueueUrlRequest> for AwsSqs<GetQueueUrlRequest>

fn from(req: GetQueueUrlRequest) -> Self

Performs the conversion.

impl From<ListDeadLetterSourceQueuesRequest> for AwsSqs<ListDeadLetterSourceQueuesRequest>

fn from(req: ListDeadLetterSourceQueuesRequest) -> Self

Performs the conversion.

impl From<ListQueueTagsRequest> for AwsSqs<ListQueueTagsRequest>

fn from(req: ListQueueTagsRequest) -> Self

Performs the conversion.

impl From<ListQueuesRequest> for AwsSqs<ListQueuesRequest>

fn from(req: ListQueuesRequest) -> Self

Performs the conversion.

impl From<PurgeQueueRequest> for AwsSqs<PurgeQueueRequest>

fn from(req: PurgeQueueRequest) -> Self

Performs the conversion.

impl From<ReceiveMessageRequest> for AwsSqs<ReceiveMessageRequest>

fn from(req: ReceiveMessageRequest) -> Self

Performs the conversion.

impl From<RemovePermissionRequest> for AwsSqs<RemovePermissionRequest>

fn from(req: RemovePermissionRequest) -> Self

Performs the conversion.

impl From<SendMessageRequest> for AwsSqs<SendMessageRequest>

fn from(req: SendMessageRequest) -> Self

Performs the conversion.

impl From<SendMessageBatchRequest> for AwsSqs<SendMessageBatchRequest>

fn from(req: SendMessageBatchRequest) -> Self

Performs the conversion.

impl From<SetQueueAttributesRequest> for AwsSqs<SetQueueAttributesRequest>

fn from(req: SetQueueAttributesRequest) -> Self

Performs the conversion.

impl From<TagQueueRequest> for AwsSqs<TagQueueRequest>

fn from(req: TagQueueRequest) -> Self

Performs the conversion.

impl From<UntagQueueRequest> for AwsSqs<UntagQueueRequest>

fn from(req: UntagQueueRequest) -> Self

Performs the conversion.

impl<T: Debug> Debug for AwsSqs<T>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<C> OneshotRequest<C> for AwsSqs<AddPermissionRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, AddPermissionError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ChangeMessageVisibilityRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, ChangeMessageVisibilityError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ChangeMessageVisibilityBatchRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, ChangeMessageVisibilityBatchError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<CreateQueueRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, CreateQueueError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<DeleteMessageRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, DeleteMessageError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<DeleteMessageBatchRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, DeleteMessageBatchError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<DeleteQueueRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, DeleteQueueError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<GetQueueAttributesRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, GetQueueAttributesError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<GetQueueUrlRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, GetQueueUrlError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ListDeadLetterSourceQueuesRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, ListDeadLetterSourceQueuesError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ListQueueTagsRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, ListQueueTagsError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ListQueuesRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, ListQueuesError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<PurgeQueueRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, PurgeQueueError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<RemovePermissionRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, RemovePermissionError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<SendMessageRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, SendMessageError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<SendMessageBatchRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, SendMessageBatchError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<SetQueueAttributesRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, SetQueueAttributesError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<TagQueueRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, TagQueueError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<UntagQueueRequest> where
    C: AsSqs, 

type Response = RusotoResponse<Self::Ok, UntagQueueError>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl<C> OneshotRequest<C> for AwsSqs<ReceiveMessageRequest> where
    C: AsSqs, 

type Response = Future01Response<Box<dyn Future<Item = Self::Ok, Error = Self::Error> + Send + 'static>>

The type of corresponding responses of this request.

fn send_once(self, client: C) -> Self::Response

Send this request to the given client, by consuming itself.

fn repeat(self) -> Repeat<Self> where
    Self: Clone, 

impl RetriableRequest for AwsSqs<AddPermissionRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ChangeMessageVisibilityRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ChangeMessageVisibilityBatchRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<CreateQueueRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<DeleteMessageRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<DeleteMessageBatchRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<DeleteQueueRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<GetQueueAttributesRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<GetQueueUrlRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ListDeadLetterSourceQueuesRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ListQueueTagsRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ListQueuesRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<PurgeQueueRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<RemovePermissionRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<SendMessageRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<SendMessageBatchRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<SetQueueAttributesRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<TagQueueRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<UntagQueueRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl RetriableRequest for AwsSqs<ReceiveMessageRequest>

fn should_retry(&self, err: &Self::Error, _next_interval: Duration) -> bool

fn retry(self) -> Retrying<Self, TokioTimer, ExponentialBackoff, ()>

Wrap this request to retry itself on failure, with a default [ExponentialBackoff] strategy.

fn retry_with_backoff<B>(self, backoff: B) -> Retrying<Self, TokioTimer, B, ()> where
    B: Backoff,
    Self: BaseRequest, 

Wrap this request to retry itself on failure, with a given backoff strategy.

impl BaseRequest for AwsSqs<AddPermissionRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<AddPermissionError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ChangeMessageVisibilityRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<ChangeMessageVisibilityError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ChangeMessageVisibilityBatchRequest>

type Ok = ChangeMessageVisibilityBatchResult

The type of successful values from the corresponding response.

type Error = RusotoError<ChangeMessageVisibilityBatchError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<CreateQueueRequest>

type Ok = CreateQueueResult

The type of successful values from the corresponding response.

type Error = RusotoError<CreateQueueError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<DeleteMessageRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<DeleteMessageError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<DeleteMessageBatchRequest>

type Ok = DeleteMessageBatchResult

The type of successful values from the corresponding response.

type Error = RusotoError<DeleteMessageBatchError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<DeleteQueueRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<DeleteQueueError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<GetQueueAttributesRequest>

type Ok = GetQueueAttributesResult

The type of successful values from the corresponding response.

type Error = RusotoError<GetQueueAttributesError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<GetQueueUrlRequest>

type Ok = GetQueueUrlResult

The type of successful values from the corresponding response.

type Error = RusotoError<GetQueueUrlError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ListDeadLetterSourceQueuesRequest>

type Ok = ListDeadLetterSourceQueuesResult

The type of successful values from the corresponding response.

type Error = RusotoError<ListDeadLetterSourceQueuesError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ListQueueTagsRequest>

type Ok = ListQueueTagsResult

The type of successful values from the corresponding response.

type Error = RusotoError<ListQueueTagsError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ListQueuesRequest>

type Ok = ListQueuesResult

The type of successful values from the corresponding response.

type Error = RusotoError<ListQueuesError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<PurgeQueueRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<PurgeQueueError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<ReceiveMessageRequest>

type Ok = Vec<Message>

The type of successful values from the corresponding response.

type Error = RusotoError<ReceiveMessageError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<RemovePermissionRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<RemovePermissionError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<SendMessageRequest>

type Ok = SendMessageResult

The type of successful values from the corresponding response.

type Error = RusotoError<SendMessageError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<SendMessageBatchRequest>

type Ok = SendMessageBatchResult

The type of successful values from the corresponding response.

type Error = RusotoError<SendMessageBatchError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<SetQueueAttributesRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<SetQueueAttributesError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<TagQueueRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<TagQueueError>

The type of failures from the corresponding response.

impl BaseRequest for AwsSqs<UntagQueueRequest>

type Ok = ()

The type of successful values from the corresponding response.

type Error = RusotoError<UntagQueueError>

The type of failures from the corresponding response.

impl<C> Request<C> for AwsSqs<AddPermissionRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ChangeMessageVisibilityRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ChangeMessageVisibilityBatchRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<CreateQueueRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<DeleteMessageRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<DeleteMessageBatchRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<DeleteQueueRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<GetQueueAttributesRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<GetQueueUrlRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ListDeadLetterSourceQueuesRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ListQueueTagsRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ListQueuesRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<PurgeQueueRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<RemovePermissionRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<SendMessageRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<SendMessageBatchRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<SetQueueAttributesRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<TagQueueRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<UntagQueueRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl<C> Request<C> for AwsSqs<ReceiveMessageRequest> where
    C: AsSqs, 

type Response = Self::Response

The type of corresponding responses of this request.

fn send(self: Pin<&mut Self>, client: C) -> Self::Response

fn oneshot(self) -> Oneshot<Self>

fn retry_if<F>(
    self,
    pred: F
) -> Retrying<Self, TokioTimer, ExponentialBackoff, F> where
    F: RetrialPredicate<Self>, 

Wrap this request to retry if the given predicate returns true.

fn retry_with_config<T, B, F>(
    self,
    timer: T,
    pred: F,
    backoff: B
) -> Retrying<Self, T, B, F> where
    B: Backoff,
    F: RetrialPredicate<Self>,
    T: Timer + Unpin, 

Wrap this request to retry with customizable options, including the timer implementation.

impl PagedRequest for AwsSqs<ReceiveMessageRequest>

fn advance(&mut self, response: &Self::Ok) -> bool

Modify itself to retrive the next response, of return false if the given response was the last one.

fn paginate<C>(self, client: C) -> Paginator<C, Self> where
    Self: Request<C>,