shepherd-rs 0.1.0

Shepherd is a resilient, non-blocking orchestrator that persistently transforms and delivers data—built for remote, compute-heavy workloads.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use crate::database::test::MockDB;
use crate::processor::{DefaultProcessor, ProcessorConfig};
use crate::transform::test::{MockTransformAttempt, MockTransformRequest};

type MockProcessor = DefaultProcessor<MockTransformRequest, MockTransformAttempt, MockDB>;

#[test]
fn processor_halts_emitter() {
    let config = ProcessorConfig {
        max_in_process_transform_attempts: 2,
    };

    // let handles = MockProcessor::new();
    // assert_eq!(result, 4);
}