mocra 0.3.0

A distributed, event-driven crawling and data collection framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

mod fencing;
mod graph;
mod guard;
mod scheduler;
mod types;

pub use fencing::InMemoryDagFencingStore;
pub use graph::{Dag, DagChainBuilder, DagNodePtr};
pub use guard::InMemoryDagRunGuard;
pub use scheduler::{DagExecutionReport, DagScheduler, DagSchedulerOptions, NodeExecutionResult};
pub use types::{
    DagAdvanceGate, DagError, DagErrorClass, DagErrorCode, DagFencingStore, DagNodeDispatcher,
    DagNodeExecutionPolicy, DagNodeRecord, DagNodeRetryMode, DagNodeRunState,
    DagNodeRuntimeOverride, DagNodeStatus, DagNodeSyncState, DagNodeTrait, DagRunGuard,
    DagRunGuardAcquireOutcome, DagRunResumeState, DagRunState, DagRunStateStore, DagRunStatus,
    DagStopSignal, LocalNodeDispatcher, NodeExecutionContext, NodePlacement, TaskPayload,
};

#[cfg(test)]
mod tests;