Struct Projection 

pub struct Projection { /* private fields */ }

Domain Entity: Projection

Represents a projection that aggregates events into a queryable view. Projections are materialized views derived from the event stream.

Domain Rules:

• Name must be unique within a tenant
• Name cannot be empty
• Version starts at 1 and increments
• Cannot change projection type after creation
• Status transitions must follow lifecycle rules
• Stats are accurate and updated on each event

Implementations

impl Projection

pub fn new( tenant_id: TenantId, name: String, version: u32, projection_type: ProjectionType, ) -> Result<Self>

Create a new projection with validation

pub fn new_v1( tenant_id: TenantId, name: String, projection_type: ProjectionType, ) -> Result<Self>

Create first version of a projection

pub fn reconstruct( id: Uuid, tenant_id: TenantId, name: String, version: u32, projection_type: ProjectionType, status: ProjectionStatus, config: ProjectionConfig, stats: ProjectionStats, created_at: DateTime<Utc>, updated_at: DateTime<Utc>, started_at: Option<DateTime<Utc>>, stopped_at: Option<DateTime<Utc>>, description: Option<String>, event_types: Vec<EventType>, metadata: Value, ) -> Self

Reconstruct projection from storage (bypasses validation)

pub fn id(&self) -> Uuid

pub fn tenant_id(&self) -> &TenantId

pub fn name(&self) -> &str

pub fn version(&self) -> u32

pub fn projection_type(&self) -> ProjectionType

pub fn status(&self) -> ProjectionStatus

pub fn config(&self) -> &ProjectionConfig

pub fn stats(&self) -> &ProjectionStats

pub fn created_at(&self) -> DateTime<Utc>

pub fn updated_at(&self) -> DateTime<Utc>

pub fn description(&self) -> Option<&str>

pub fn event_types(&self) -> &[EventType]

pub fn metadata(&self) -> &Value

pub fn start(&mut self) -> Result<()>

Start the projection

pub fn pause(&mut self) -> Result<()>

Pause the projection

pub fn stop(&mut self) -> Result<()>

Stop the projection

pub fn mark_failed(&mut self)

Mark projection as failed

pub fn start_rebuild(&mut self) -> Result<()>

Start rebuilding the projection

pub fn update_config(&mut self, config: ProjectionConfig)

Update configuration

pub fn set_description(&mut self, description: String) -> Result<()>

Set description

pub fn add_event_type(&mut self, event_type: EventType) -> Result<()>

Add event type filter

pub fn remove_event_type(&mut self, event_type: &EventType) -> Result<()>

Remove event type filter

pub fn processes_event_type(&self, event_type: &EventType) -> bool

Check if projection processes this event type

pub fn update_metadata(&mut self, metadata: Value)

Update metadata

pub fn stats_mut(&mut self) -> &mut ProjectionStats

Get mutable access to stats (for recording events)

pub fn is_first_version(&self) -> bool

Check if projection is first version

pub fn belongs_to_tenant(&self, tenant_id: &TenantId) -> bool

Check if projection belongs to tenant

pub fn create_next_version(&self) -> Result<Projection>

Create next version

Trait Implementations

impl Clone for Projection

fn clone(&self) -> Projection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Projection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Projection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&Projection> for ProjectionDto

fn from(projection: &Projection) -> Self

Converts to this type from the input type.

impl From<Projection> for ProjectionDto

fn from(projection: Projection) -> Self

Converts to this type from the input type.

impl Serialize for Projection

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.