Struct SqliteStorage 

pub struct SqliteStorage { /* private fields */ }

SQLite-based storage implementation.

Implementations

impl SqliteStorage

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open or create a SQLite database at the given path.

pub fn in_memory() -> Result<Self>

Create an in-memory SQLite database.

Trait Implementations

impl Storage for SqliteStorage

fn create_issue(&self, issue: &Issue) -> Result<()>

Create a new issue.

fn create_issues(&self, issues: &[Issue]) -> Result<()>

Create multiple issues in a batch.

fn get_issue(&self, id: &str) -> Result<Option<Issue>>

Get an issue by ID.

fn get_issue_by_external_ref(&self, external_ref: &str) -> Result<Option<Issue>>

Get an issue by external reference.

fn update_issue(&self, issue: &Issue) -> Result<()>

Update an existing issue.

fn close_issue(&self, id: &str, actor: &str, reason: Option<&str>) -> Result<()>

Close an issue.

fn delete_issue( &self, id: &str, actor: &str, reason: Option<&str>, ) -> Result<()>

Soft-delete an issue (tombstone).

fn search_issues(&self, filter: &IssueFilter) -> Result<Vec<Issue>>

Search issues with filters.

fn add_dependency(&self, dep: &Dependency) -> Result<()>

Add a dependency between issues.

fn remove_dependency(&self, issue_id: &str, depends_on_id: &str) -> Result<()>

Remove a dependency between issues.

fn get_dependencies(&self, issue_id: &str) -> Result<Vec<Dependency>>

Get all dependencies for an issue (issues this one depends on).

fn get_dependents(&self, issue_id: &str) -> Result<Vec<Dependency>>

Get all dependents of an issue (issues that depend on this one).

fn would_create_cycle( &self, from_id: &str, to_id: &str, dep_type: DependencyType, ) -> Result<bool>

Check if adding a dependency would create a cycle.

fn get_ready_work(&self) -> Result<Vec<Issue>>

Get all issues that are ready for work (open, no blocking dependencies).

fn get_blocked_issues(&self) -> Result<Vec<BlockedIssue>>

Get all blocked issues with their blocking counts.

fn is_blocked(&self, issue_id: &str) -> Result<bool>

Check if an issue is blocked.

fn add_label(&self, issue_id: &str, label: &str) -> Result<()>

Add a label to an issue.

fn remove_label(&self, issue_id: &str, label: &str) -> Result<()>

Remove a label from an issue.

fn get_labels(&self, issue_id: &str) -> Result<Vec<String>>

Get all labels for an issue.

fn get_issues_by_label(&self, label: &str) -> Result<Vec<Issue>>

Get all issues with a specific label.

fn add_comment(&self, issue_id: &str, author: &str, text: &str) -> Result<i64>

Add a comment to an issue.

fn get_comments(&self, issue_id: &str) -> Result<Vec<Comment>>

Get all comments for an issue.

fn get_events(&self, issue_id: &str) -> Result<Vec<Event>>

Get all events for an issue.

fn set_config(&self, key: &str, value: &str) -> Result<()>

Set a configuration value.

fn get_config(&self, key: &str) -> Result<Option<String>>

Get a configuration value.

fn delete_config(&self, key: &str) -> Result<()>

Delete a configuration value.

fn get_all_config(&self) -> Result<HashMap<String, String>>

Get all configuration values.

fn mark_dirty(&self, issue_id: &str) -> Result<()>

Mark an issue as dirty (needs export).

fn get_dirty_issues(&self) -> Result<Vec<String>>

Get all dirty issue IDs.

fn clear_dirty(&self, issue_ids: &[String]) -> Result<()>

Clear dirty flags for specific issues.

fn get_statistics(&self) -> Result<Statistics>

Get database statistics.

fn next_child_counter(&self, parent_id: &str) -> Result<u32>

Get the next child counter for a parent issue.

fn transaction<F, T>(&self, f: F) -> Result<T>

where F: FnOnce() -> Result<T>,

Run a function within a transaction.

fn close(&self) -> Result<()>

Close the storage connection.