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 that must be applied before this migration can be applied.

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

Returns the list of operations that make up the 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 should be run before this migration when applying. but when reverting this migration these migrations should be reverted after this migration is reverted.

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 that must be applied before this migration can be applied.

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

Returns the list of operations that make up the 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 should be run before this migration when applying. but when reverting this migration these migrations should be reverted after this migration is reverted.

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 that must be applied before this migration can be applied.

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

Returns the list of operations that make up the 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 should be run before this migration when applying. but when reverting this migration these migrations should be reverted after this migration is reverted.

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.