Struct TriggerManager

pub struct TriggerManager {
    storage: Arc<Storage>,
    executor: Arc<WorkflowExecutor>,
    cron_scheduler: Arc<CronScheduler>,
}

Fields

storage: Arc<Storage>

executor: Arc<WorkflowExecutor>

cron_scheduler: Arc<CronScheduler>

Implementations

impl TriggerManager

pub fn new( storage: Arc<Storage>, executor: Arc<WorkflowExecutor>, cron_scheduler: Arc<CronScheduler>, ) -> Self

pub async fn init(&self) -> Result<()>

pub async fn activate_workflow( &self, workflow_id: &str, ) -> Result<Vec<ActiveTrigger>>

pub async fn deactivate_workflow(&self, workflow_id: &str) -> Result<()>

pub async fn handle_webhook( &self, webhook_id: &str, method: &str, headers: HashMap<String, String>, body: Value, ) -> Result<WebhookResponse>

fn verify_auth( &self, auth_config: &AuthConfig, headers: &HashMap<String, String>, ) -> Result<()>

pub async fn get_trigger_status( &self, workflow_id: &str, ) -> Result<Option<TriggerStatus>>