Struct OkrRepository 

pub struct OkrRepository { /* private fields */ }

Repository for OKR persistence operations

Implementations

impl OkrRepository

pub fn new(base_path: PathBuf) -> Self

Create a new OKR repository with the given base path

pub async fn from_config() -> Result<Self>

Create repository from Config::data_dir() or fallback to temp

pub async fn create_okr(&self, okr: Okr) -> Result<Okr>

Create a new OKR

pub async fn get_okr(&self, id: Uuid) -> Result<Option<Okr>>

Get an OKR by ID

pub async fn update_okr(&self, okr: Okr) -> Result<Okr>

Update an existing OKR

pub async fn delete_okr(&self, id: Uuid) -> Result<bool>

Delete an OKR by ID

pub async fn list_okrs(&self) -> Result<Vec<Okr>>

List all OKRs

pub async fn query_okrs_by_status(&self, status: OkrStatus) -> Result<Vec<Okr>>

Query OKRs by status

pub async fn query_okrs_by_owner(&self, owner: &str) -> Result<Vec<Okr>>

Query OKRs by owner

pub async fn query_okrs_by_tenant(&self, tenant_id: &str) -> Result<Vec<Okr>>

Query OKRs by tenant

pub async fn create_run(&self, run: OkrRun) -> Result<OkrRun>

Create a new OKR run

pub async fn get_run(&self, id: Uuid) -> Result<Option<OkrRun>>

Get a run by ID

pub async fn update_run(&self, run: OkrRun) -> Result<OkrRun>

Update a run

pub async fn delete_run(&self, id: Uuid) -> Result<bool>

Delete a run

pub async fn list_runs(&self) -> Result<Vec<OkrRun>>

List all runs

pub async fn query_runs_by_okr(&self, okr_id: Uuid) -> Result<Vec<OkrRun>>

Query runs by OKR ID

pub async fn query_runs_by_status( &self, status: OkrRunStatus, ) -> Result<Vec<OkrRun>>

Query runs by status

pub async fn query_runs_by_correlation( &self, correlation_id: &str, ) -> Result<Vec<OkrRun>>

Query runs by correlation ID

pub async fn query_runs_by_checkpoint( &self, checkpoint_id: &str, ) -> Result<Vec<OkrRun>>

Query runs by relay checkpoint ID

pub async fn query_runs_by_session( &self, session_id: &str, ) -> Result<Vec<OkrRun>>

Query runs by session ID

pub async fn clear_cache(&self)

Clear the in-memory cache (useful for forcing reload from disk)

pub async fn stats(&self) -> Result<OkrRepositoryStats>

Get statistics about the repository