Struct TaskManager 

pub struct TaskManager<S: DataStore<DataStoreKey>> {
    pub event_tx: Sender<TraversalEvent>,
    pub event_rx: Receiver<TraversalEvent>,
    pub is_working: bool,
    /* private fields */
}

Fields

event_tx: Sender<TraversalEvent>

event_rx: Receiver<TraversalEvent>

is_working: bool

Implementations

impl<S: DataStore<DataStoreKey>> TaskManager<S>

pub fn new() -> Self

pub fn is_done(&self) -> bool

pub fn start(&mut self, input: Vec<DataStoreKey>, logger: &mut Logger)

pub fn process_results(&mut self, store: &mut S, logger: &mut Logger)

pub fn process_path_sync( &self, store: &mut S, path: &DataStoreKey, ) -> Vec<DataStoreKey>

pub fn iter_from_path( root_path: &PathBuf, ) -> WalkDirGeneric<((), Option<Result<EntryState, Error>>)>

Trait Implementations

impl<S: Debug + DataStore<DataStoreKey>> Debug for TaskManager<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: DataStore<DataStoreKey>> Default for TaskManager<S>

fn default() -> Self

Returns the “default value” for a type.