pub struct OrchestrationEngine { /* private fields */ }
Expand description
Orchestration engine for managing distributed workflows
Implementations§
Source§impl OrchestrationEngine
impl OrchestrationEngine
Sourcepub fn register_node(&self, node: OrchestratorNode) -> CoreResult<()>
pub fn register_node(&self, node: OrchestratorNode) -> CoreResult<()>
Register a node with the orchestrator
Sourcepub fn submit_workflow(&self, workflow: Workflow) -> CoreResult<()>
pub fn submit_workflow(&self, workflow: Workflow) -> CoreResult<()>
Submit a workflow for execution
Sourcepub fn submit_task(&self, task: Task) -> CoreResult<()>
pub fn submit_task(&self, task: Task) -> CoreResult<()>
Submit a single task for execution
Sourcepub fn process_task_queue(&self) -> CoreResult<()>
pub fn process_task_queue(&self) -> CoreResult<()>
Process the task queue and assign tasks to available nodes
Sourcepub fn complete_task(&mut self, taskid: &str) -> CoreResult<()>
pub fn complete_task(&mut self, taskid: &str) -> CoreResult<()>
Mark a task as completed
Sourcepub fn get_statistics(&self) -> CoreResult<OrchestrationStats>
pub fn get_statistics(&self) -> CoreResult<OrchestrationStats>
Get orchestration statistics
Trait Implementations§
Source§impl Debug for OrchestrationEngine
impl Debug for OrchestrationEngine
Auto Trait Implementations§
impl Freeze for OrchestrationEngine
impl RefUnwindSafe for OrchestrationEngine
impl Send for OrchestrationEngine
impl Sync for OrchestrationEngine
impl Unpin for OrchestrationEngine
impl UnwindSafe for OrchestrationEngine
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> 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 more