Struct sea_streamer::SeaStreamer
source · pub struct SeaStreamer { /* private fields */ }
Available on crate feature
sea-streamer-socket
only.Expand description
sea-streamer-socket
concrete type of Streamer.
Trait Implementations§
source§impl Debug for SeaStreamer
impl Debug for SeaStreamer
source§impl From<KafkaStreamer> for SeaStreamer
impl From<KafkaStreamer> for SeaStreamer
source§fn from(i: KafkaStreamer) -> SeaStreamer
fn from(i: KafkaStreamer) -> SeaStreamer
Converts to this type from the input type.
source§impl From<StdioStreamer> for SeaStreamer
impl From<StdioStreamer> for SeaStreamer
source§fn from(i: StdioStreamer) -> SeaStreamer
fn from(i: StdioStreamer) -> SeaStreamer
Converts to this type from the input type.
source§impl SeaStreamerBackend for SeaStreamer
impl SeaStreamerBackend for SeaStreamer
type Kafka = KafkaStreamer
type Stdio = StdioStreamer
source§fn get_kafka(
&mut self
) -> Option<&mut <SeaStreamer as SeaStreamerBackend>::Kafka>
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
source§fn get_stdio(
&mut self
) -> Option<&mut <SeaStreamer as SeaStreamerBackend>::Stdio>
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
source§impl Streamer for SeaStreamer
impl Streamer for SeaStreamer
type Error = BackendErr
type Producer = SeaProducer
type Consumer = SeaConsumer
type ConnectOptions = SeaConnectOptions
type ConsumerOptions = SeaConsumerOptions
type ProducerOptions = SeaProducerOptions
source§async fn connect(
uri: StreamerUri,
options: <SeaStreamer as Streamer>::ConnectOptions
) -> Result<SeaStreamer, StreamErr<BackendErr>>
async fn connect( uri: StreamerUri, options: <SeaStreamer as Streamer>::ConnectOptions ) -> Result<SeaStreamer, StreamErr<BackendErr>>
Establish a connection to the streaming server.
source§async fn disconnect(self) -> Result<(), StreamErr<BackendErr>>
async fn disconnect(self) -> Result<(), StreamErr<BackendErr>>
Flush and disconnect from the streaming server.
source§async fn create_generic_producer(
&self,
options: <SeaStreamer as Streamer>::ProducerOptions
) -> Result<<SeaStreamer as Streamer>::Producer, StreamErr<BackendErr>>
async fn create_generic_producer( &self, options: <SeaStreamer as Streamer>::ProducerOptions ) -> Result<<SeaStreamer as Streamer>::Producer, StreamErr<BackendErr>>
Create a producer that can stream to any stream key.
source§async fn create_consumer(
&self,
streams: &[StreamKey],
options: <SeaStreamer as Streamer>::ConsumerOptions
) -> Result<<SeaStreamer as Streamer>::Consumer, StreamErr<BackendErr>>
async fn create_consumer( &self, streams: &[StreamKey], options: <SeaStreamer as Streamer>::ConsumerOptions ) -> Result<<SeaStreamer as Streamer>::Consumer, StreamErr<BackendErr>>
Create a consumer subscribing to the specified streams.
Auto Trait Implementations§
impl Freeze for SeaStreamer
impl RefUnwindSafe for SeaStreamer
impl Send for SeaStreamer
impl Sync for SeaStreamer
impl Unpin for SeaStreamer
impl UnwindSafe for SeaStreamer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more