Struct kinesis_firehose_producer::async_producer_pool::AsyncProducerPool

pub struct AsyncProducerPool { /* fields omitted */ }

The Producer Pool. Create one with AsyncProducerPool::of_size

Panics

This can panic at pretty much any point if a member Producer throws an error. Currently there is an error channel which waits for errors and panics, but we could do something else here? If we get in that state, though, it’s likely the situation won’t benefit from additional retries. So what else would we do?

Implementations

impl AsyncProducerPool

pub async fn of_size(stream_name: String, size: usize) -> Result<Self, Error>

Create a pool of size size

pub async fn of_size_with_client(
    stream_name: String,
    size: usize,
    client: KinesisFirehoseClient
) -> Result<Self, Error>

Create a pool of size size with a given client The client will be cloned for each pool member

Panics

If size < 1

pub async fn produce(&mut self, rec: String) -> Result<(), Error>

Produce a message; send a string to a producer. Panics if the pool has been shutdown

pub async fn flush(&mut self) -> Result<(), Error>

Queue a flush for each of the members. Doesn’t wait for them to finish

pub async fn shutdown(&mut self) -> Result<(), Error>

Shut down the pool. You MUST call this when you’re done, otherwise we’ll drop data.

Trait Implementations

impl Debug for AsyncProducerPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for AsyncProducerPool

fn drop(&mut self)

Executes the destructor for this type.