pub struct AdvancedDistributedComputer { /* private fields */ }
Expand description
Central coordinator for distributed advanced computing
Implementations§
Source§impl AdvancedDistributedComputer
impl AdvancedDistributedComputer
Sourcepub fn new() -> CoreResult<Self>
pub fn new() -> CoreResult<Self>
Create a new distributed computer with default configuration
Sourcepub fn with_config(config: DistributedComputingConfig) -> CoreResult<Self>
pub fn with_config(config: DistributedComputingConfig) -> CoreResult<Self>
Create a new distributed computer with custom configuration
Sourcepub fn submit_task(&self, task: DistributedTask) -> CoreResult<TaskId>
pub fn submit_task(&self, task: DistributedTask) -> CoreResult<TaskId>
Submit a distributed task for execution with intelligent scheduling
Sourcepub fn submit_batch_tasks(
&self,
tasks: Vec<DistributedTask>,
) -> CoreResult<Vec<TaskId>>
pub fn submit_batch_tasks( &self, tasks: Vec<DistributedTask>, ) -> CoreResult<Vec<TaskId>>
Batch submit multiple tasks with optimal load distribution
Sourcepub fn submit_with_fault_tolerance(
&self,
task: DistributedTask,
fault_tolerance_config: FaultToleranceConfig,
) -> CoreResult<TaskId>
pub fn submit_with_fault_tolerance( &self, task: DistributedTask, fault_tolerance_config: FaultToleranceConfig, ) -> CoreResult<TaskId>
Submit a task with fault tolerance and automatic retry
Sourcepub fn get_task_status(&self, taskid: &TaskId) -> CoreResult<Option<TaskStatus>>
pub fn get_task_status(&self, taskid: &TaskId) -> CoreResult<Option<TaskStatus>>
Get task status
Sourcepub fn cancel_task(&self, taskid: &TaskId) -> CoreResult<()>
pub fn cancel_task(&self, taskid: &TaskId) -> CoreResult<()>
Cancel a task
Sourcepub fn get_cluster_status(&self) -> CoreResult<ClusterStatistics>
pub fn get_cluster_status(&self) -> CoreResult<ClusterStatistics>
Get cluster status
Sourcepub fn scale_cluster(&self, targetnodes: usize) -> CoreResult<()>
pub fn scale_cluster(&self, targetnodes: usize) -> CoreResult<()>
Scale cluster up or down
Sourcepub fn start(&self) -> CoreResult<()>
pub fn start(&self) -> CoreResult<()>
Start distributed computing operations
Sourcepub fn stop(&self) -> CoreResult<()>
pub fn stop(&self) -> CoreResult<()>
Stop distributed computing operations
Trait Implementations§
Source§impl Debug for AdvancedDistributedComputer
impl Debug for AdvancedDistributedComputer
Auto Trait Implementations§
impl Freeze for AdvancedDistributedComputer
impl RefUnwindSafe for AdvancedDistributedComputer
impl Send for AdvancedDistributedComputer
impl Sync for AdvancedDistributedComputer
impl Unpin for AdvancedDistributedComputer
impl UnwindSafe for AdvancedDistributedComputer
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