Struct StreamIdentity 

pub struct StreamIdentity { /* private fields */ }

Stable event-stream identity used by persistence backends.

Durable stores should key aggregate streams by both aggregate type and aggregate id. ID-only repository APIs remain available for the synchronous in-memory path, but production adapters should prefer this type.

Implementations

impl StreamIdentity

pub fn new( aggregate_type: impl Into<String>, aggregate_id: impl Into<String>, ) -> Result<Self, RepositoryError>

Create a validated stream identity.

pub fn aggregate_type(&self) -> &str

Stable aggregate type component.

pub fn aggregate_id(&self) -> &str

Aggregate id component.

Trait Implementations

impl Clone for StreamIdentity

fn clone(&self) -> StreamIdentity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamIdentity

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

Formats the value using the given formatter.

impl Display for StreamIdentity

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

Formats the value using the given formatter.

impl Eq for StreamIdentity

impl Hash for StreamIdentity

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamIdentity

fn eq(&self, other: &StreamIdentity) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamIdentity