Struct FlowBuilder 

pub struct FlowBuilder { /* private fields */ }

Implementations

impl FlowBuilder

pub fn new() -> Self

Create a new FlowBuilder with default settings

pub fn consumer_id(self, id: CdcConsumerId) -> Self

Set the consumer ID for the flow subsystem

pub fn poll_interval(self, interval: Duration) -> Self

Set the poll interval for checking new CDC events

pub fn priority(self, priority: Priority) -> Self

Set the priority for the polling task in the worker pool

pub fn max_batch_size(self, size: u64) -> Self

Set the maximum batch size for CDC polling

pub fn operators_dir(self, path: PathBuf) -> Self

Set the directory to scan for FFI operator shared libraries

pub fn register_operator<F>(self, name: impl Into<String>, factory: F) -> Self

where F: Fn(FlowNodeId, &[Expression<'static>]) -> Result<Box<dyn Operator>> + Send + Sync + 'static,

Register a custom operator factory

Trait Implementations

impl Default for FlowBuilder

fn default() -> Self

Returns the “default value” for a type.