Struct LockedStore 

pub struct LockedStore { /* private fields */ }

A GritStore with filesystem-level exclusive lock.

The lock is held for the lifetime of this struct and automatically released when dropped. This prevents multiple processes from opening the same sled database concurrently.

Implementations

impl LockedStore

pub fn inner(&self) -> &GritStore

Get a reference to the inner GritStore

Methods from Deref<Target = GritStore>

pub fn insert_event(&self, event: &Event) -> Result<(), GriteError>

Insert an event and update projections

pub fn get_event(&self, event_id: &EventId) -> Result<Option<Event>, GriteError>

Get an event by ID

pub fn get_issue( &self, issue_id: &IssueId, ) -> Result<Option<IssueProjection>, GriteError>

Get an issue projection by ID

pub fn list_issues( &self, filter: &IssueFilter, ) -> Result<Vec<IssueSummary>, GriteError>

List issues with optional filtering

pub fn get_issue_events( &self, issue_id: &IssueId, ) -> Result<Vec<Event>, GriteError>

Get all events for an issue, sorted by (ts, actor, event_id)

pub fn get_all_events(&self) -> Result<Vec<Event>, GriteError>

Get all events in the store

pub fn rebuild(&self) -> Result<RebuildStats, GriteError>

Rebuild all projections from events

pub fn rebuild_from_events( &self, events: &[Event], ) -> Result<RebuildStats, GriteError>

Rebuild all projections from provided events (for snapshot-based rebuild)

This is useful when rebuilding from a snapshot + WAL combination, where events come from external sources rather than the local store.

pub fn stats(&self, path: &Path) -> Result<DbStats, GriteError>

Get database statistics

pub fn get_dependencies( &self, issue_id: &IssueId, ) -> Result<Vec<(IssueId, DependencyType)>, GriteError>

Get all outgoing dependencies for an issue

pub fn get_dependents( &self, issue_id: &IssueId, ) -> Result<Vec<(IssueId, DependencyType)>, GriteError>

Get all incoming dependencies (what depends on this issue)

pub fn would_create_cycle( &self, source: &IssueId, target: &IssueId, dep_type: &DependencyType, ) -> Result<bool, GriteError>

Check if adding a dependency would create a cycle. Only checks for Blocks/DependsOn (acyclic types).

pub fn topological_order( &self, filter: &IssueFilter, ) -> Result<Vec<IssueSummary>, GriteError>

Get issues in topological order based on dependency relationships. Issues with no dependencies come first.

pub fn get_file_context( &self, path: &str, ) -> Result<Option<FileContext>, GriteError>

Get file context for a specific path

pub fn query_symbols( &self, query: &str, ) -> Result<Vec<(String, String)>, GriteError>

Query symbols by name prefix

pub fn list_context_files(&self) -> Result<Vec<String>, GriteError>

List all indexed file paths

pub fn get_project_context( &self, key: &str, ) -> Result<Option<ProjectContextEntry>, GriteError>

Get a project context entry by key

pub fn list_project_context( &self, ) -> Result<Vec<(String, ProjectContextEntry)>, GriteError>

List all project context entries

pub fn flush(&self) -> Result<(), GriteError>

Flush pending writes to disk

Trait Implementations

impl Debug for LockedStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for LockedStore

type Target = GritStore

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for LockedStore

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.