Trait sea_streamer::ConnectOptions

pub trait ConnectOptions: Default + Clone + Send {
    type Error: Error;

    // Required methods
    fn timeout(&self) -> Result<Duration, StreamErr<Self::Error>>;
    fn set_timeout(
        &mut self,
        d: Duration
    ) -> Result<&mut Self, StreamErr<Self::Error>>;
}

Common options when connecting to a streamer.

Required Associated Types

type Error: Error

Required Methods

fn timeout(&self) -> Result<Duration, StreamErr<Self::Error>>

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

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl ConnectOptions for KafkaConnectOptions

fn set_timeout( &mut self, v: Duration ) -> Result<&mut KafkaConnectOptions, StreamErr<KafkaError>>

Timeout for network requests. Default is 1 min

type Error = KafkaError

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

impl ConnectOptions for StdioConnectOptions

fn set_timeout( &mut self, _: Duration ) -> Result<&mut StdioConnectOptions, StreamErr<StdioErr>>

This parameter is ignored because connection can never fail

type Error = StdioErr

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

Implementors

impl ConnectOptions for SeaConnectOptions

type Error = BackendErr