pollen-rs 0.1.0

Embedded decentralized distributed task scheduler
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! Pollen: Embedded Decentralized Distributed Task Scheduler
//!
//! Pollen is like SQLite for task scheduling, but with peer-to-peer cluster capabilities.
//!
//! # Quick Start
//!
//! ```rust,no_run
//! use pollen::{Pollen, Schedule, Storage};
//! use std::time::Duration;
//!
//! #[tokio::main]
//! async fn main() -> pollen::Result<()> {
//!     // Single-node mode
//!     let scheduler = Pollen::builder()
//!         .storage(Storage::sqlite("./pollen.db"))
//!         .build()
//!         .await?;
//!
//!     // Define a task with cron schedule
//!     scheduler.define("daily_report")
//!         .schedule(Schedule::cron("0 9 * * *"))
//!         .handler(|| async { Ok(()) })
//!         .register()
//!         .await?;
//!
//!     Ok(())
//! }
//! ```
//!
//! # Features
//!
//! - `metrics` - Enable Prometheus metrics collection
//! - `otel` - Enable OpenTelemetry integration
//! - `full` - Enable all optional features

mod builder;

#[cfg(feature = "metrics")]
pub mod metrics;

pub use builder::*;
pub use pollen_types::prelude::*;

/// Re-export commonly used types
pub mod prelude {
    pub use crate::builder::*;
    pub use pollen_types::prelude::*;
}