sqs-lambda 0.21.1

SQS Service helper library
Documentation
1
2
3
4
5
6
7
8
9
10
11
use async_trait::async_trait;

#[async_trait]
pub trait CompletionHandler {
    type Message;
    type CompletedEvent;

    async fn mark_complete(&self, msg: Self::Message, completed_event: Self::CompletedEvent);
    async fn ack_message(&self, msg: Self::Message);
    async fn ack_all(&self, notify: Option<tokio::sync::oneshot::Sender<()>>);
}