Struct FDv2StreamingBuilder 

pub struct FDv2StreamingBuilder<T: HttpTransport = HyperTransport> { /* private fields */ }

Configures an FDv2 streaming source, which can only act as a synchronizer.

Implementations

impl<T: HttpTransport + Clone + Send + Sync + 'static> FDv2StreamingBuilder<T>

pub fn new() -> Self

Creates a builder with default values.

pub fn initial_reconnect_delay(&mut self, duration: Duration) -> &mut Self

Sets the initial reconnect delay for the streaming connection.

Examples

    let mut source = FDv2StreamingBuilder::<HyperTransport>::new();
    source.initial_reconnect_delay(Duration::from_secs(10));

pub fn base_url(&mut self, url: &str) -> &mut Self

Sets the streaming base URL, overriding the configured service endpoints.

Examples

    let mut source = FDv2StreamingBuilder::<HyperTransport>::new();
    source.base_url("https://stream.example.com");

pub fn transport(&mut self, transport: T) -> &mut Self

Sets the transport to use, instead of the default HTTPS transport.

Trait Implementations

impl<T: Clone + HttpTransport> Clone for FDv2StreamingBuilder<T>

fn clone(&self) -> FDv2StreamingBuilder<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: HttpTransport + Clone + Send + Sync + 'static> Default for FDv2StreamingBuilder<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: HttpTransport + Clone + Send + Sync + 'static> FDv2SynchronizerConfig for FDv2StreamingBuilder<T>

fn build_synchronizer( &self, context: &DataSourceBuildContext<'_>, ) -> Result<Box<dyn SynchronizerFactory>, BuildError>

Builds a synchronizer factory from this configuration.

fn to_owned(&self) -> Box<dyn FDv2SynchronizerConfig>

Clones this configuration into a new box.