Skip to main content

Module stream_versioning

Module stream_versioning 

Source
Expand description

Stream Versioning and Time-Travel Queries

This module provides comprehensive stream versioning capabilities with time-travel query support for historical data analysis and replay.

§Features

  • Version Management: Track and manage stream data versions
  • Time-Travel Queries: Query historical stream states
  • Snapshot Management: Create and restore point-in-time snapshots
  • Branching: Create branches for what-if analysis
  • Diff Operations: Compare versions and generate changesets
  • Retention Policies: Automatic version cleanup and archival

Structs§

Branch
Branch information
Change
A single change in a changeset
Changeset
Changeset between versions
Snapshot
A snapshot of stream state at a point in time
StreamVersioning
Stream versioning manager
TimeTravelQuery
Time-travel query specification
VersionDiff
Diff between two versions
VersionMetadata
Version metadata
VersionedEvent
A versioned event with metadata
VersioningConfig
Stream versioning configuration
VersioningStats
Versioning statistics

Enums§

ChangeType
Change operation type
TimeTravelTarget
Target for time-travel query

Type Aliases§

BranchId
Branch identifier type
VersionId
Version identifier type