Struct sqs_lambda::event_emitter::S3EventEmitter

pub struct S3EventEmitter<S, F> where
    S: S3 + Send + 'static,
    F: Fn(&[u8]) -> String,  { /* fields omitted */ }

Methods

impl<S, F> S3EventEmitter<S, F> where
    S: S3 + Send + 'static,
    F: Fn(&[u8]) -> String, 

pub fn new(s3: S, output_bucket: impl Into<String>, key_fn: F) -> Self

Trait Implementations

impl<S: Clone, F: Clone> Clone for S3EventEmitter<S, F> where
    S: S3 + Send + 'static,
    F: Fn(&[u8]) -> String, 

fn clone(&self) -> S3EventEmitter<S, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, F> EventEmitter for S3EventEmitter<S, F> where
    S: S3 + Send + Sync + 'static,
    F: Fn(&[u8]) -> String + Send + Sync, 

type Event = Vec<u8>

type Error = Box<dyn Error>

fn emit_event<'life0, 'async_trait>(
    &'life0 mut self,
    events: Vec<Self::Event>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,