Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
1.0 kB · 35 lines
Rust
123456789101112131415161718192021222324252627282930313233343536use std::future::Future;use std::pin::Pin;use std::sync::Arc;use std::sync::atomic::AtomicU64;
use bobbin_edge_index::{CoverageWatch, EdgeStore};use bobbin_record_lru::NoopRecordStore;use bobbin_runtime::{Clock, Entropy, MemHttpResponder, MemWsResponder};use tokio_util::sync::CancellationToken;
use crate::report::SimReport;
pub struct WorkloadCtx { pub seed: u64, pub clock: Arc<dyn Clock>, pub entropy: Arc<dyn Entropy>, pub store: Arc<EdgeStore>, pub coverage: Arc<CoverageWatch>, pub records: Arc<NoopRecordStore>, pub cancel: CancellationToken, pub consumer_too_slow_count: Arc<AtomicU64>,}
pub type WorkloadScript = Pin<Box<dyn Future<Output = SimReport> + Send + 'static>>;
pub struct WorkloadHooks { pub slingshot: Arc<dyn MemHttpResponder>, pub hydrant: Arc<dyn MemWsResponder>, pub script: WorkloadScript,}
pub trait Workload: Send + 'static { fn name(&self) -> &'static str; fn build(self: Box<Self>, ctx: WorkloadCtx) -> WorkloadHooks;}