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
16
17

//! The crate provides a general framework for writing schedulers
//! which transforms input data into output data by invoking workers.
//! These workers can be implemented in various ways, such as
//! - separate processes
//! - remote services directly
//! - via Apache Kafka
//!
//! Once the transformation is complete, the output data can be
//! sent to a remote service, written to a file, or stored in a database.
#![feature(associated_type_defaults)]

pub mod database;
pub mod emitter;
#[cfg(feature = "instrumentation")]
pub mod instrumentation;
pub mod processor;
pub mod transform;