Enum AwsAdapter 

pub enum AwsAdapter {
    Sqs(Arc<SqsAdapter>),
    EventBridge(Arc<EventBridgeAdapter>),
    Both {
        sqs: Arc<SqsAdapter>,
        eventbridge: Arc<EventBridgeAdapter>,
        default_type: AwsAdapterType,
    },
}

Variants

Sqs(Arc<SqsAdapter>)

EventBridge(Arc<EventBridgeAdapter>)

Both

Fields

sqs: Arc<SqsAdapter>

eventbridge: Arc<EventBridgeAdapter>

default_type: AwsAdapterType

Implementations

impl AwsAdapter

pub async fn new( adapter_type: AwsAdapterType, config: AwsConfig, ) -> Result<Self>

pub async fn new_with_both( default_type: AwsAdapterType, config: AwsConfig, ) -> Result<Self>

pub async fn publish( &self, topic: impl Into<String>, payload: Value, ) -> Result<()>

pub async fn publish_with_type( &self, topic: impl Into<String>, payload: Value, adapter_type: Option<&str>, ) -> Result<()>

pub async fn subscribe_fn<F, Fut>( &self, topic: impl Into<String>, handler: F, ) -> Result<()>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub async fn subscribe_with_type<F, Fut>( &self, topic: impl Into<String>, handler: F, adapter_type: Option<&str>, ) -> Result<()>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub async fn list_topics(&self) -> Vec<String>