Struct StreamVersioning 

pub struct StreamVersioning<T>
where
    T: Clone + Send + Sync + Serialize + for<'de> Deserialize<'de> + 'static,
{ /* private fields */ }

Stream versioning manager

Implementations

impl<T> StreamVersioning<T>

where T: Clone + Send + Sync + Serialize + for<'de> Deserialize<'de> + 'static,

pub fn new(config: VersioningConfig) -> Self

Create a new stream versioning manager

pub async fn create_version( &self, events: Vec<T>, description: &str, ) -> Result<VersionId, StreamError>

Create a new version with events

pub async fn add_events(&self, events: Vec<T>) -> Result<usize, StreamError>

Add events to current version

pub async fn time_travel_query( &self, query: TimeTravelQuery, ) -> Result<Vec<VersionedEvent<T>>, StreamError>

Execute a time-travel query

pub async fn get_at_version( &self, version_id: VersionId, ) -> Result<Vec<VersionedEvent<T>>, StreamError>

Get events at a specific version

pub async fn get_at_timestamp( &self, timestamp: SystemTime, ) -> Result<Vec<VersionedEvent<T>>, StreamError>

Get events at a specific timestamp

pub async fn create_snapshot(&self, name: &str) -> Result<String, StreamError>

Create a snapshot

pub async fn restore_snapshot( &self, snapshot_id: &str, ) -> Result<VersionId, StreamError>

Restore from snapshot

pub async fn create_branch( &self, name: &str, description: &str, ) -> Result<BranchId, StreamError>

Create a new branch

pub async fn switch_branch(&self, branch_id: &str) -> Result<(), StreamError>

Switch to a different branch

pub async fn merge_branch( &self, source_branch_id: &str, ) -> Result<VersionId, StreamError>

Merge a branch into the current branch

pub async fn diff( &self, from_version: VersionId, to_version: VersionId, ) -> Result<VersionDiff<T>, StreamError>

Get diff between two versions

pub async fn generate_changeset( &self, from_version: VersionId, to_version: VersionId, ) -> Result<Changeset<T>, StreamError>

Generate changeset between versions

pub async fn get_version_history(&self) -> Vec<VersionMetadata>

Get version history

pub async fn get_branches(&self) -> Vec<Branch>

Get all branches

pub async fn current_version(&self) -> VersionId

Get current version

pub async fn current_branch(&self) -> BranchId

Get current branch

pub async fn get_stats(&self) -> VersioningStats

Get statistics

pub async fn tag_version( &self, version_id: VersionId, key: &str, value: &str, ) -> Result<(), StreamError>

Tag a version

pub async fn find_by_tag(&self, key: &str, value: &str) -> Vec<VersionId>

Find versions by tag

pub async fn delete_branch(&self, branch_id: &str) -> Result<(), StreamError>

Delete a branch

pub async fn compact(&self) -> Result<usize, StreamError>

Compact old versions