[−][src]Struct sqs_lambda::sqs_completion_handler::SqsCompletionHandler

pub struct SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> where
    CPE: Debug + Send + Sync + 'static,
    CP: CompletionEventSerializer<CompletedEvent = CE, Output = Payload, Error = CPE> + Send + Sync + 'static,
    Payload: Send + Sync + 'static,
    CE: Send + Sync + Clone + 'static,
    EE: EventEmitter<Event = Payload> + Send + Sync + 'static,
    OA: Fn(SqsCompletionHandlerActor<CE, ProcErr>, Result<String, String>) + Send + Sync + 'static,
    CacheT: Cache<CacheErr> + Send + Sync + Clone + 'static,
    CacheErr: Debug + Clone + Send + Sync + 'static,
    ProcErr: Debug + Clone + Send + Sync + 'static,  { /* fields omitted */ }

Methods

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> where
    CPE: Debug + Send + Sync + 'static,
    CP: CompletionEventSerializer<CompletedEvent = CE, Output = Payload, Error = CPE> + Send + Sync + 'static,
    Payload: Send + Sync + 'static,
    CE: Send + Sync + Clone + 'static,
    EE: EventEmitter<Event = Payload> + Send + Sync + 'static,
    OA: Fn(SqsCompletionHandlerActor<CE, ProcErr>, Result<String, String>) + Send + Sync + 'static,
    CacheT: Cache<CacheErr> + Send + Sync + Clone + 'static,
    CacheErr: Debug + Clone + Send + Sync + 'static,
    ProcErr: Debug + Clone + Send + Sync + 'static, [src]

pub fn new(
    sqs_client: SqsClient,
    queue_url: String,
    completion_serializer: CP,
    event_emitter: EE,
    completion_policy: CompletionPolicy,
    on_ack: OA,
    cache: CacheT
) -> Self[src]

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> where
    CPE: Debug + Send + Sync + 'static,
    CP: CompletionEventSerializer<CompletedEvent = CE, Output = Payload, Error = CPE> + Send + Sync + 'static,
    Payload: Send + Sync + 'static,
    CE: Send + Sync + Clone + 'static,
    EE: EventEmitter<Event = Payload> + Send + Sync + 'static,
    OA: Fn(SqsCompletionHandlerActor<CE, ProcErr>, Result<String, String>) + Send + Sync + 'static,
    CacheT: Cache<CacheErr> + Send + Sync + Clone + 'static,
    CacheErr: Debug + Clone + Send + Sync + 'static,
    ProcErr: Debug + Clone + Send + Sync + 'static, [src]

pub async fn mark_complete<'_>(
    &'_ mut self,
    sqs_message: SqsMessage,
    completed: OutputEvent<CE, ProcErr>
)[src]

pub async fn ack_all<'_>(&'_ mut self, notify: Option<Sender<()>>)[src]

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> where
    CPE: Debug + Send + Sync + 'static,
    CP: CompletionEventSerializer<CompletedEvent = CE, Output = Payload, Error = CPE> + Send + Sync + 'static,
    Payload: Send + Sync + 'static,
    CE: Send + Sync + Clone + 'static,
    EE: EventEmitter<Event = Payload> + Send + Sync + 'static,
    OA: Fn(SqsCompletionHandlerActor<CE, ProcErr>, Result<String, String>) + Send + Sync + 'static,
    CacheT: Cache<CacheErr> + Send + Sync + Clone + 'static,
    CacheErr: Debug + Clone + Send + Sync + 'static,
    ProcErr: Debug + Clone + Send + Sync + 'static, [src]

pub async fn route_message<'_>(
    &'_ mut self,
    msg: SqsCompletionHandlerMessage<CE, ProcErr>
)[src]

Auto Trait Implementations

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> !RefUnwindSafe for SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr>

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> Send for SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr>

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> Sync for SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr>

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> Unpin for SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> where
    CE: Unpin,
    CP: Unpin,
    CacheErr: Unpin,
    CacheT: Unpin,
    EE: Unpin,
    OA: Unpin,
    ProcErr: Unpin, 

impl<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr> !UnwindSafe for SqsCompletionHandler<CPE, CP, CE, Payload, EE, OA, CacheT, CacheErr, ProcErr>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,