Struct ExecutionHistoryStorage

pub struct ExecutionHistoryStorage {
    db: Arc<Database>,
}

Fields

db: Arc<Database>

Implementations

impl ExecutionHistoryStorage

pub fn new(db: Arc<Database>) -> Result<Self>

pub fn record_task_created( &self, workflow_id: &str, execution_id: &str, created_at_nano: i64, ) -> Result<()>

pub fn record_task_completed( &self, workflow_id: &str, execution_id: &str, timestamp_ms: i64, ) -> Result<()>

pub fn record_task_failed( &self, workflow_id: &str, execution_id: &str, timestamp_ms: i64, ) -> Result<()>

pub fn list_paginated( &self, workflow_id: &str, page: usize, page_size: usize, ) -> Result<ExecutionHistoryPage>

fn index_key( workflow_id: &str, started_at_ms: i64, execution_id: &str, ) -> String