pub struct DaemonOptions {
pub slot: String,
pub publication: String,
pub skip_backfill: bool,
pub queue_capacity: usize,
pub pretty: bool,
pub lag_poll_interval: Duration,
}Expand description
How a Daemon run is parameterized — the pipeline knobs the CLI exposes as
flags. Transport settings (HTTP address, …) are the binary’s concern, not the
daemon’s, so they are not here.
Fields§
§slot: StringLogical replication slot to consume. Must already exist or be creatable.
publication: StringPublication to subscribe to.
skip_backfill: boolSkip the initial backfill and resume live capture only.
queue_capacity: usizeChanges buffered between capture and processing.
pretty: boolPretty-print documents on the stdout fallback sink (no sink configured).
lag_poll_interval: DurationHow often to sample source capture lag.
Trait Implementations§
Source§impl Clone for DaemonOptions
impl Clone for DaemonOptions
Source§fn clone(&self) -> DaemonOptions
fn clone(&self) -> DaemonOptions
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for DaemonOptions
impl Debug for DaemonOptions
Auto Trait Implementations§
impl Freeze for DaemonOptions
impl RefUnwindSafe for DaemonOptions
impl Send for DaemonOptions
impl Sync for DaemonOptions
impl Unpin for DaemonOptions
impl UnsafeUnpin for DaemonOptions
impl UnwindSafe for DaemonOptions
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