shepherd-rs 0.2.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

//! # A module for handling consumption attempts
//!
//! This module defines components related to consumption attempts and their
//! management. It includes traits and utilities for creating and processing
//! consumption attempts.

pub mod attempt;
pub mod attempt_creator;
pub mod consumer;
pub use attempt::ConsumeAttempt;
#[cfg(test)]
pub(crate) use attempt::NilCA;
pub use attempt_creator::ConsumeAttemptCreator;
pub use consumer::Consumer;