Struct kannon::task::group::GroupManager

pub struct GroupManager { /* fields omitted */ }

Implementations

impl GroupManager

pub fn new() -> Self

#[must_use]

pub fn create_group(&mut self, name: &str) -> Result<Group, TaskError>

Create new group that can contain tasks and executable in topology.

If name was empty or any following internal logic, function would be failed and group item can not be created.

Arguments

• name - Not empty, valid group name.

pub fn groups(&self) -> &Vec<GroupHandle>

pub fn is_cyclic(&self) -> bool

pub fn rearrange_groups(&mut self)

Remove invalidated group from list and rerrange them.

pub fn rearrange_tasks(&mut self)

Remove invalidated tasks from list of valid groups.