Struct StreamRegistry 

pub struct StreamRegistry { /* private fields */ }

In-memory registry of durable streams.

Implementations

impl StreamRegistry

pub fn new() -> StreamRegistry

pub fn create_stream( &self, scope: StreamScope, name: impl Into<String>, retention: StreamRetention, ) -> Result<(), StreamError>

Declare a new stream. Returns StreamError::AlreadyExists if (scope, name) is already registered. The new stream is immediately discoverable via Self::list_streams.

pub fn exists(&self, scope: &StreamScope, name: &str) -> bool

Whether (scope, name) is registered.

pub fn list_streams(&self, scope: &StreamScope) -> Vec<StreamDescriptor>

Snapshot every stream in scope. Used by introspection surfaces (e.g. a future red.streams virtual table). Order is unspecified; callers that need stable order should sort on name.

pub fn describe( &self, scope: &StreamScope, name: &str, ) -> Option<StreamDescriptor>

Describe a single stream, or None if not registered.

pub fn append( &self, scope: StreamScope, name: impl Into<String>, key: Option<String>, payload: impl Into<String>, now_ms: u128, ) -> Result<u64, StreamError>

Append an event. Returns the engine-assigned offset. Retention pruning runs after the append, so the new event is always retained even if it pushes the head past the cap — only older events are dropped.

pub fn append_authorized( &self, principal_tenant: Option<&str>, target: StreamScope, name: impl Into<String>, key: Option<String>, payload: impl Into<String>, has_cross_tenant_cap: bool, now_ms: u128, ) -> Result<u64, StreamError>

Authorization-gated Self::append.

pub fn read_since( &self, scope: &StreamScope, name: &str, from: u64, limit: usize, ) -> Result<Vec<StreamEvent>, StreamError>

Read up to limit events with offset >= from. Pure read — does not create pending delivery state, does not advance any consumer’s saved offset, and does not require ACK/NACK. If from is below the current head (because retention has pruned older events), the returned slice simply starts at the head with no error.

pub fn read_since_authorized( &self, principal_tenant: Option<&str>, target: StreamScope, name: impl Into<String>, from: u64, limit: usize, has_cross_tenant_cap: bool, ) -> Result<Vec<StreamEvent>, StreamError>

Authorization-gated Self::read_since.

pub fn save_offset( &self, scope: &StreamScope, name: &str, consumer: &str, offset: u64, ) -> Result<u64, StreamError>

Persist a consumer’s offset on (scope, name). Monotonic: if offset is less than or equal to the currently saved value, the save is a no-op and the existing value is returned. Otherwise the new value is stored and returned. This makes the operation safe to retry on duplicate or stale “I’m done with offset N” notifications — a consumer can never rewind past events it already finished.

pub fn get_offset( &self, scope: &StreamScope, name: &str, consumer: &str, ) -> Result<u64, StreamError>

Retrieve a consumer’s saved offset for (scope, name). Returns 0 for consumers that have never saved — 0 is the reserved “no progress yet” sentinel since the first real event is at offset 1.

Trait Implementations

impl Clone for StreamRegistry

fn clone(&self) -> StreamRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for StreamRegistry

fn default() -> StreamRegistry

Returns the “default value” for a type.