pub struct FlowConfigurator { /* private fields */ }Implementations§
Source§impl FlowConfigurator
impl FlowConfigurator
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 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 FlowConfigurator
impl !RefUnwindSafe for FlowConfigurator
impl Send for FlowConfigurator
impl Sync for FlowConfigurator
impl Unpin for FlowConfigurator
impl UnsafeUnpin for FlowConfigurator
impl !UnwindSafe for FlowConfigurator
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