Struct Pollen 

pub struct Pollen { /* private fields */ }

Main Pollen scheduler instance

Implementations

impl Pollen

pub fn builder() -> PollenBuilder

Create a new builder

pub fn node_id(&self) -> NodeId

Get the local node ID

pub fn is_cluster_mode(&self) -> bool

Check if running in cluster mode

pub fn define(&self, name: &str) -> TaskBuilder

Define a new task

pub fn get_task(&self, name: &str) -> Option<TaskDef>

Get a task by name

pub async fn trigger(&self, name: &str) -> Result<()>

Trigger immediate execution of a task

pub async fn trigger_with_payload( &self, name: &str, payload: Bytes, ) -> Result<()>

Trigger a task with payload

pub fn task_info(&self, name: &str) -> Option<TaskInfo>

Get task information

pub fn list_tasks(&self) -> Vec<TaskDef>

List all registered tasks

pub fn cluster_state(&self) -> Option<ClusterState>

Get cluster state (if in cluster mode)

pub fn cluster_size(&self) -> usize

Get the number of nodes in the cluster

pub async fn shutdown(self)

Shutdown the scheduler gracefully