Struct InitMigration 

pub struct InitMigration;

Initial migration that creates the core database schema for Evento.

This migration creates the following database objects:

Event Table

The main table for storing domain events with the following columns:

• id - Event identifier (ULID format, VARCHAR(26))
• name - Event type name (VARCHAR(50))
• aggregator_type - Aggregate root type (VARCHAR(50))
• aggregator_id - Aggregate root instance ID (VARCHAR(26))
• version - Event sequence number within the aggregate
• data - Serialized event payload (BLOB)
• metadata - Serialized event metadata (BLOB)
• routing_key - Optional routing key for partitioning (VARCHAR(50))
• timestamp - Event timestamp in seconds (BIGINT)

Event Indexes

Several indexes are created for efficient querying:

• idx_event_type - Index on aggregator_type
• idx_event_type_id - Composite index on (aggregator_type, aggregator_id)
• idx_event_routing_key_type - Composite index on (routing_key, aggregator_type)
• Unique constraint on (aggregator_type, aggregator_id, version)

Snapshot Table

Table for storing aggregate snapshots (note: dropped in M0003):

• id - Snapshot identifier
• type - Snapshot type
• cursor - Event stream cursor
• revision - Revision identifier
• data - Serialized snapshot data
• Primary key: composite (type, id)

Subscriber Table

Table for tracking event subscription state:

• key - Subscriber identifier (primary key)
• worker_id - Associated worker ID
• cursor - Current event stream position
• lag - Subscription lag counter
• enabled - Whether subscription is active
• created_at / updated_at - Timestamps

Trait Implementations

impl Migration<MySql> for InitMigration

fn app(&self) -> &str

Returns the application name associated with the migration. This can be the name of the folder or library where the migration is located.

fn name(&self) -> &str

Returns the migration name, typically the file name without the extension.

fn parents(&self) -> Vec<Box<dyn Migration<MySql>>>

Returns the list of parent migrations.

fn operations(&self) -> Vec<Box<dyn Operation<MySql>>>

Returns the operations associated with this migration.

fn replaces(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration replaces.

fn run_before(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration must run before(when applying) or after (when reverting).

fn is_atomic(&self) -> bool

Indicates whether the migration is atomic. By default, this function returns true, meaning the migration is atomic.

fn is_virtual(&self) -> bool

Indicates whether the migration is virtual. By default, this function returns false, meaning the migration is not virtual.

impl Migration<Postgres> for InitMigration

fn app(&self) -> &str

Returns the application name associated with the migration. This can be the name of the folder or library where the migration is located.

fn name(&self) -> &str

Returns the migration name, typically the file name without the extension.

fn parents(&self) -> Vec<Box<dyn Migration<Postgres>>>

Returns the list of parent migrations.

fn operations(&self) -> Vec<Box<dyn Operation<Postgres>>>

Returns the operations associated with this migration.

fn replaces(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration replaces.

fn run_before(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration must run before(when applying) or after (when reverting).

fn is_atomic(&self) -> bool

Indicates whether the migration is atomic. By default, this function returns true, meaning the migration is atomic.

fn is_virtual(&self) -> bool

Indicates whether the migration is virtual. By default, this function returns false, meaning the migration is not virtual.

impl Migration<Sqlite> for InitMigration

fn app(&self) -> &str

Returns the application name associated with the migration. This can be the name of the folder or library where the migration is located.

fn name(&self) -> &str

Returns the migration name, typically the file name without the extension.

fn parents(&self) -> Vec<Box<dyn Migration<Sqlite>>>

Returns the list of parent migrations.

fn operations(&self) -> Vec<Box<dyn Operation<Sqlite>>>

Returns the operations associated with this migration.

fn replaces(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration replaces.

fn run_before(&self) -> Vec<Box<dyn Migration<DB>>>

Returns the list of migrations that this migration must run before(when applying) or after (when reverting).

fn is_atomic(&self) -> bool

Indicates whether the migration is atomic. By default, this function returns true, meaning the migration is atomic.

fn is_virtual(&self) -> bool

Indicates whether the migration is virtual. By default, this function returns false, meaning the migration is not virtual.