pub struct FlowBuilder { /* private fields */ }Implementations§
Source§impl FlowBuilder
impl FlowBuilder
Sourcepub fn operators_dir(self, path: PathBuf) -> Self
pub fn operators_dir(self, path: PathBuf) -> Self
Set the directory to scan for FFI operator shared libraries
Sourcepub fn num_workers(self, count: usize) -> Self
pub fn num_workers(self, count: usize) -> Self
Set the number of worker threads for flow processing. Defaults to 1 if not set.
Sourcepub fn register_operator(
self,
name: impl Into<String>,
factory: impl Fn(FlowNodeId, &BTreeMap<String, Value>) -> Result<BoxedOperator> + Send + Sync + 'static,
) -> Self
pub fn register_operator( self, name: impl Into<String>, factory: impl Fn(FlowNodeId, &BTreeMap<String, Value>) -> Result<BoxedOperator> + Send + Sync + 'static, ) -> Self
Register a native Rust operator factory by name.
Sourcepub fn register_source<S: FFISource + FFISourceMetadata>(self) -> Self
pub fn register_source<S: FFISource + FFISourceMetadata>(self) -> Self
Register a native Rust source connector.
Sourcepub fn register_sink<S: FFISink + FFISinkMetadata>(self) -> Self
pub fn register_sink<S: FFISink + FFISinkMetadata>(self) -> Self
Register a native Rust sink connector.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for FlowBuilder
impl !RefUnwindSafe for FlowBuilder
impl Send for FlowBuilder
impl Sync for FlowBuilder
impl Unpin for FlowBuilder
impl UnsafeUnpin for FlowBuilder
impl !UnwindSafe for FlowBuilder
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
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
Set the “status” flags for the
self file descriptor. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request