sqs_lambda/
completion_handler.rs

1use async_trait::async_trait;
2
3#[async_trait]
4pub trait CompletionHandler {
5    type Message;
6    type CompletedEvent;
7
8    async fn mark_complete(&self, msg: Self::Message, completed_event: Self::CompletedEvent);
9    async fn ack_message(&self, msg: Self::Message);
10    async fn ack_all(&self, notify: Option<tokio::sync::oneshot::Sender<()>>);
11}