Struct RisLiveSourceBuilder 

pub struct RisLiveSourceBuilder { /* private fields */ }

Builder for RisLiveSource.

Implementations

impl RisLiveSourceBuilder

pub fn new(id: impl Into<String>) -> Self

Creates a new builder.

pub fn with_websocket_url(self, websocket_url: impl Into<String>) -> Self

pub fn with_client_name(self, client_name: impl Into<String>) -> Self

pub fn with_optional_client_name(self, client_name: Option<String>) -> Self

pub fn with_host(self, host: impl Into<String>) -> Self

pub fn with_optional_host(self, host: Option<String>) -> Self

pub fn with_message_type(self, message_type: impl Into<String>) -> Self

pub fn with_optional_message_type(self, message_type: Option<String>) -> Self

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

pub fn with_prefixes(self, prefixes: Vec<String>) -> Self

pub fn with_optional_prefixes(self, prefixes: Option<Vec<String>>) -> Self

pub fn with_more_specific(self, more_specific: bool) -> Self

pub fn with_optional_more_specific(self, more_specific: Option<bool>) -> Self

pub fn with_less_specific(self, less_specific: bool) -> Self

pub fn with_optional_less_specific(self, less_specific: Option<bool>) -> Self

pub fn with_path(self, path: impl Into<String>) -> Self

pub fn with_optional_path(self, path: Option<String>) -> Self

pub fn with_peer(self, peer: impl Into<String>) -> Self

pub fn with_optional_peer(self, peer: Option<String>) -> Self

pub fn with_require(self, require: impl Into<String>) -> Self

pub fn with_optional_require(self, require: Option<String>) -> Self

pub fn with_include_peer_state(self, include_peer_state: bool) -> Self

pub fn with_reconnect_delay_secs(self, reconnect_delay_secs: u64) -> Self

pub fn with_clear_state_on_start(self, clear_state_on_start: bool) -> Self

pub fn with_start_from_beginning(self) -> Self

pub fn with_start_from_now(self) -> Self

pub fn with_start_from_timestamp(self, timestamp_ms: i64) -> Self

pub fn with_start_from(self, start_from: StartFrom) -> Self

pub fn with_state_store(self, state_store: Arc<dyn StateStoreProvider>) -> Self

pub fn with_dispatch_mode(self, mode: DispatchMode) -> Self

pub fn with_dispatch_buffer_capacity(self, capacity: usize) -> Self

pub fn with_bootstrap_provider( self, provider: impl BootstrapProvider + 'static, ) -> Self

pub fn with_auto_start(self, auto_start: bool) -> Self

pub fn build(self) -> Result<RisLiveSource>