Struct kinesis_firehose_producer::sync_producer::Producer

pub struct Producer<C: PutRecordBatcher> { /* fields omitted */ }

The producer itself. Create one with Producer<KinesisFirehoseClient>::new or Producer::with_client

Unlike the Async Producer, this one WILL flush on Drop, so you don’t need to flush it manually Maybe you still should, though, in case it fails.

Implementations

impl Producer<KinesisFirehoseClient>

pub fn new(stream_name: String) -> Result<Self, Error>

Create a Producer with a new KinesisFirehoseClient gleaned from the environment

impl<C: PutRecordBatcher> Producer<C>

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

Buffer a record to be sent to Kinesis Firehose. If this record fills up the buffer, it will be flushed.

This function WILL add newlines to the end of each record. Don’t add them yourself.

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

Make the producer flush its buffer.

pub fn with_client(client: C, stream_name: String) -> Result<Self, Error>

Create a Producer with an existing KinesisFirehoseClient

Trait Implementations

impl<C: PutRecordBatcher> Drop for Producer<C>

Flush on Drop

fn drop(&mut self)

Executes the destructor for this type.