Struct ReactiveFlowManagerImpl

pub struct ReactiveFlowManagerImpl { /* private fields */ }

Trait Implementations

impl Component for ReactiveFlowManagerImpl

fn create( instance_provider: &mut dyn ComponentInstanceProvider, ) -> Result<Self, ComponentInstanceProviderError>

Creates an instance of this component using dependencies from given [ComponentInstanceProvider].

impl ComponentDowncast<ReactiveFlowManagerImpl> for ReactiveFlowManagerImpl

fn downcast( source: ComponentInstanceAnyPtr, ) -> Result<ComponentInstancePtr<Self>, ComponentInstanceAnyPtr>

impl ComponentDowncast<ReactiveFlowManagerImpl> for dyn ReactiveFlowManager + Sync + Send

fn downcast( source: ComponentInstanceAnyPtr, ) -> Result<ComponentInstancePtr<Self>, ComponentInstanceAnyPtr>

impl Lifecycle for ReactiveFlowManagerImpl

fn init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called at initialization

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for shutdown

fn post_init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Called after initialization

fn pre_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Called before shutdown

impl ReactiveFlowManager for ReactiveFlowManagerImpl

fn has(&self, id: Uuid) -> bool

Returns true, if an flow instance exists with the given UUID.

fn get(&self, id: Uuid) -> Option<ReactiveFlow>

Returns the flow instance with the given UUID or None.

fn get_by_label(&self, label: &str) -> Option<ReactiveFlow>

Returns the flow instance that matches the given label or None.

fn get_all(&self) -> Vec<ReactiveFlow>

Returns all reactive flow instances.

fn get_by_type(&self, ty: &FlowTypeId) -> Vec<ReactiveFlow>

Returns all reactive entity instances of the given type.

fn count_flow_instances(&self) -> usize

Returns the count of registered reactive flow instances.

fn create_reactive_flow( &self, flow_instance: FlowInstance, ) -> Result<ReactiveFlow, ReactiveFlowCreationError>

Creates a new reactive flow instance from the given flow instance descriptor.

fn create_from_type( &self, ty: &FlowTypeId, id: Option<Uuid>, variables: PropertyInstances, properties: PropertyInstances, ) -> Result<ReactiveFlow, ReactiveFlowCreationError>

Create a new reactive flow instance from the flow type by the given name.

fn register_flow_instance_and_reactive_instances( &self, reactive_flow_instance: ReactiveFlow, )

Registers the given reactive flow instance and registers all of the reactive instances contained in the given reactive flow instance.

fn register_flow_instance(&self, reactive_flow_instance: ReactiveFlow)

Registers the given reactive flow instance. Does not register it’s reactive instances except the wrapper entity.

fn delete(&self, id: Uuid) -> bool

Deletes the flow instance with the given id.

fn register_provider(&self, id: Uuid, provider: Arc<dyn FlowInstanceProvider>)

Registers a flow instance provider.

fn unregister_provider(&self, id: &Uuid)

Unregisters a flow instance provider.

impl Injectable for ReactiveFlowManagerImpl