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
15
16
17
18
19
20
21
22
23
24
25
26

//! # Worker Instance Trait
//!
//! This trait defines the behavior of worker instances in the shepherd
//! framework.
//!
//! ## Overview
//! - **WorkerInstance**: Represents a worker instance that processes
//!   transformation attempts.
//!
//! ## Example
//! ```rust
//! struct MyWorkerInstance;
//!
//! impl WorkerInstance for MyWorkerInstance {
//!     // Implementation details...
//! }
//! ```

use async_trait::async_trait;

#[async_trait]
pub trait WorkerInstance {
    type TransformAttempt;

    async fn wi_loop();
}