Struct sea_streamer::SeaProducer

pub struct SeaProducer { /* private fields */ }

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of Producer.

Trait Implementations

impl Clone for SeaProducer

fn clone(&self) -> SeaProducer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SeaProducer

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

Formats the value using the given formatter.

impl From<KafkaProducer> for SeaProducer

fn from(i: KafkaProducer) -> SeaProducer

Converts to this type from the input type.

impl From<StdioProducer> for SeaProducer

fn from(i: StdioProducer) -> SeaProducer

Converts to this type from the input type.

impl Producer for SeaProducer

type Error = BackendErr

type SendFuture = SendFuture

fn send_to<S>( &self, stream: &StreamKey, payload: S ) -> Result<<SeaProducer as Producer>::SendFuture, StreamErr<BackendErr>>

where S: Buffer,

Send a message to a particular stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.

async fn end(self) -> Result<(), StreamErr<BackendErr>>

End this producer, only after flushing all it’s pending messages.

async fn flush(&mut self) -> Result<(), StreamErr<BackendErr>>

Flush all pending messages.

fn anchor(&mut self, stream: StreamKey) -> Result<(), StreamErr<BackendErr>>

Lock this producer to a particular stream. This function can only be called once. Subsequent calls should return StreamErr::AlreadyAnchored error.

fn anchored(&self) -> Result<&StreamKey, StreamErr<BackendErr>>

If the producer is already anchored, return a reference to the StreamKey. If the producer is not anchored, this will return StreamErr::NotAnchored error.

fn send<S>( &self, payload: S ) -> Result<Self::SendFuture, StreamErr<Self::Error>>

where S: Buffer,

Send a message to the already anchored stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.

impl SeaStreamerBackend for SeaProducer

type Kafka = KafkaProducer

type Stdio = StdioProducer

fn backend(&self) -> Backend

Identifies the underlying backend

fn get_kafka( &mut self ) -> Option<&mut <SeaProducer as SeaStreamerBackend>::Kafka>

Get the concrete type for the Kafka backend. None if it’s another Backend

fn get_stdio( &mut self ) -> Option<&mut <SeaProducer as SeaStreamerBackend>::Stdio>

Get the concrete type for the Stdio backend. None if it’s another Backend