Struct GitEventStore 

pub struct GitEventStore { /* private fields */ }

Implementations

impl GitEventStore

pub fn open( repo_root: impl Into<PathBuf>, worker_id: impl Into<String>, ) -> Result<Self, StateError>

Open a GASP agent repo. repo_root must be inside a git work tree; worker_id names this writer in the lease and must be unique per worker.

pub fn with_lease_ttl(self, ttl: Duration) -> Self

pub fn events_path(&self) -> PathBuf

pub fn release_lease(&self) -> Result<(), StateError>

Release the lease if this worker holds it. A corrupt or unreadable lease file is an error — silently leaving it in place would deadlock every future acquire_lease.

pub fn commit_run( &self, run_id: &RunId, goal: &GoalId, outcome: &str, extra_paths: &[&str], ) -> Result<Option<String>, StateError>

The run-boundary commit: stage the log plus any projection paths and commit only those paths with the GASP trailers (content staged by anyone else stays staged, untouched). Requires the lease. Returns the commit sha, or Ok(None) when nothing in the requested paths changed — unrelated dirty files in the worktree do not affect the outcome.

Trait Implementations

impl Clone for GitEventStore

fn clone(&self) -> GitEventStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GitEventStore

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

Formats the value using the given formatter.

impl EventStore for GitEventStore

fn append<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventId>, StateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn scan<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, StateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn scan_after<'life0, 'async_trait>( &'life0 self, event_id: Option<EventId>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, StateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,