Struct sea_streamer::SeaStreamer

pub struct SeaStreamer { /* private fields */ }

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of Streamer.

Trait Implementations

impl Debug for SeaStreamer

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

Formats the value using the given formatter.

impl From<KafkaStreamer> for SeaStreamer

fn from(i: KafkaStreamer) -> SeaStreamer

Converts to this type from the input type.

impl From<StdioStreamer> for SeaStreamer

fn from(i: StdioStreamer) -> SeaStreamer

Converts to this type from the input type.

impl SeaStreamerBackend for SeaStreamer

type Kafka = KafkaStreamer

type Stdio = StdioStreamer

fn backend(&self) -> Backend

Identifies the underlying backend

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

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

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

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

impl Streamer for SeaStreamer

type Error = BackendErr

type Producer = SeaProducer

type Consumer = SeaConsumer

type ConnectOptions = SeaConnectOptions

type ConsumerOptions = SeaConsumerOptions

type ProducerOptions = SeaProducerOptions

fn connect<'async_trait>( uri: StreamerUri, options: <SeaStreamer as Streamer>::ConnectOptions ) -> Pin<Box<dyn Future<Output = Result<SeaStreamer, StreamErr<BackendErr>>> + Send + 'async_trait, Global>>where SeaStreamer: 'async_trait,

Establish a connection to the streaming server.

fn disconnect<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Result<(), StreamErr<BackendErr>>> + Send + 'async_trait, Global>>where SeaStreamer: 'async_trait,

Flush and disconnect from the streaming server.

fn create_generic_producer<'life0, 'async_trait>( &'life0 self, options: <SeaStreamer as Streamer>::ProducerOptions ) -> Pin<Box<dyn Future<Output = Result<<SeaStreamer as Streamer>::Producer, StreamErr<BackendErr>>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, SeaStreamer: 'async_trait,

Create a producer that can stream to any stream key.

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, streams: &'life1 [StreamKey], options: <SeaStreamer as Streamer>::ConsumerOptions ) -> Pin<Box<dyn Future<Output = Result<<SeaStreamer as Streamer>::Consumer, StreamErr<BackendErr>>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, SeaStreamer: 'async_trait,

Create a consumer subscribing to the specified streams.

fn create_producer<'life0, 'async_trait>( &'life0 self, stream: StreamKey, options: Self::ProducerOptions ) -> Pin<Box<dyn Future<Output = Result<Self::Producer, StreamErr<Self::Error>>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self: Sync + 'async_trait,

Create a producer that streams to the specified stream.