Struct sea_streamer::SeaConnectOptions

pub struct SeaConnectOptions { /* private fields */ }

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of ConnectOptions.

Implementations

impl SeaConnectOptions

pub fn into_kafka_connect_options(self) -> KafkaConnectOptions

pub fn into_stdio_connect_options(self) -> StdioConnectOptions

pub fn set_kafka_connect_options<F>(&mut self, func: F)where F: FnOnce(&mut KafkaConnectOptions),

Set options that only applies to Kafka

pub fn set_stdio_connect_options<F>(&mut self, func: F)where F: FnOnce(&mut StdioConnectOptions),

Set options that only applies to Stdio

Trait Implementations

impl Clone for SeaConnectOptions

fn clone(&self) -> SeaConnectOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ConnectOptions for SeaConnectOptions

type Error = BackendErr

fn timeout(&self) -> Result<Duration, StreamErr<BackendErr>>

fn set_timeout( &mut self, d: Duration ) -> Result<&mut SeaConnectOptions, StreamErr<BackendErr>>

impl Debug for SeaConnectOptions

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

Formats the value using the given formatter.

impl Default for SeaConnectOptions

fn default() -> SeaConnectOptions

Returns the “default value” for a type.