pub struct FlowEngineInner { /* private fields */ }Implementations§
Source§impl FlowEngineInner
impl FlowEngineInner
pub fn register( &mut self, txn: &mut CommandTransaction, flow: FlowDag, ) -> Result<()>
pub fn register_with_transaction( &mut self, txn: &mut Transaction<'_>, flow: FlowDag, ) -> Result<()>
pub fn add( &mut self, txn: &mut Transaction<'_>, flow: &FlowDag, node: &FlowNode, ) -> Result<()>
pub fn add_source(&mut self, flow: FlowId, node: FlowNodeId, shape: ShapeId)
pub fn add_sink(&mut self, flow: FlowId, node: FlowNodeId, sink: ShapeId)
Source§impl FlowEngineInner
impl FlowEngineInner
pub fn new( catalog: Catalog, executor: Executor, event_bus: EventBus, runtime_context: RuntimeContext, custom_operators: CustomOperators, allocators: FlowAllocators, ) -> Self
pub fn clock(&self) -> &Clock
pub fn operator(&self, node_id: FlowNodeId) -> Option<OperatorCell>
pub fn insert_operator(&mut self, node_id: FlowNodeId, operator: OperatorCell)
pub fn register_flow_dag(&mut self, flow: FlowDag)
pub fn flow_by_id(&self, flow_id: FlowId) -> Option<FlowDag>
pub fn has_sources(&self) -> bool
pub fn flows_for_source_shape( &self, shape: ShapeId, ) -> Option<Vec<(FlowId, FlowNodeId)>>
pub fn flow_ids(&self) -> BTreeSet<FlowId>
pub fn clear(&mut self)
pub fn remove_flow(&mut self, flow_id: FlowId)
pub fn get_dependency_graph(&self) -> FlowDependencyGraph
pub fn get_flows_depending_on_table(&self, table_id: TableId) -> Vec<FlowId>
pub fn get_flows_depending_on_view(&self, view_id: ViewId) -> Vec<FlowId>
pub fn get_flow_producing_view(&self, view_id: ViewId) -> Option<FlowId>
pub fn calculate_execution_levels(&self) -> Vec<Vec<FlowId>>
pub fn calculate_schedule(&self) -> FlowSchedule
Source§impl FlowEngineInner
impl FlowEngineInner
pub fn process( &self, txn: &mut FlowTransaction, change: Change, flow_id: FlowId, ) -> Result<()>
pub fn process_batch( &self, txn: &mut FlowTransaction, changes: Vec<Change>, flow_id: FlowId, ) -> Result<()>
Source§impl FlowEngineInner
impl FlowEngineInner
pub fn process_tick( &self, txn: &mut FlowTransaction, flow_id: FlowId, timestamp: DateTime, ) -> Result<()>
Auto Trait Implementations§
impl !Freeze for FlowEngineInner
impl !RefUnwindSafe for FlowEngineInner
impl !UnwindSafe for FlowEngineInner
impl Send for FlowEngineInner
impl Sync for FlowEngineInner
impl Unpin for FlowEngineInner
impl UnsafeUnpin for FlowEngineInner
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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: Sized + AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + 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