Enum CatalogCommand 

pub enum CatalogCommand {
    CreateTable {
        name: String,
        schema: Schema,
        created_epoch: u64,
    },
    DropTable {
        name: String,
        at_epoch: u64,
    },
    RenameTable {
        name: String,
        new_name: String,
        at_epoch: u64,
    },
    AlterColumn {
        table: String,
        column: ColumnDef,
    },
    AddColumn {
        table: String,
        column: ColumnDef,
    },
    DropColumn {
        table: String,
        column: String,
    },
    AddIndex {
        table: String,
        index: IndexDef,
    },
    RemoveIndex {
        table: String,
        name: String,
    },
    CreateUser {
        username: String,
        password_hash: String,
        is_admin: bool,
        created_epoch: u64,
    },
    DropUser {
        username: String,
    },
    AlterUserPassword {
        username: String,
        password_hash: String,
    },
    SetUserAdmin {
        username: String,
        is_admin: bool,
    },
    CreateRole {
        name: String,
        created_epoch: u64,
    },
    DropRole {
        name: String,
    },
    GrantRole {
        username: String,
        role: String,
    },
    RevokeRole {
        username: String,
        role: String,
    },
    GrantPermission {
        role: String,
        permission: Permission,
    },
    RevokePermission {
        role: String,
        permission: Permission,
    },
    EnableRls {
        table: String,
    },
    DisableRls {
        table: String,
    },
    SetRowPolicy {
        policy: RowPolicy,
    },
    DropRowPolicy {
        table: String,
        name: String,
    },
    SetColumnMask {
        mask: ColumnMask,
    },
    DropColumnMask {
        table: String,
        name: String,
    },
    SetSecurityCatalog {
        security: SecurityCatalog,
    },
    CreateTrigger {
        trigger: StoredTrigger,
    },
    DropTrigger {
        name: String,
    },
    CreateProcedure {
        procedure: StoredProcedure,
    },
    DropProcedure {
        name: String,
    },
    CreateMaterializedView {
        definition: MaterializedViewEntry,
    },
    DropMaterializedView {
        name: String,
    },
    RefreshMaterializedView {
        name: String,
        at_epoch: u64,
        checkpoint_event_id: Option<String>,
    },
    SetResourceGroup {
        group: ResourceGroupDef,
    },
    RemoveResourceGroup {
        name: String,
    },
    SubmitJob {
        job: JobDefinition,
    },
    SetJobState {
        job_id: u64,
        state: JobState,
        at_epoch: u64,
    },
    ReplaceTrigger {
        trigger: StoredTrigger,
    },
    ReplaceProcedure {
        procedure: StoredProcedure,
    },
}

One logical catalog mutation (spec §10.6, S1F-001).

Variants carry already-validated payloads (mirroring how DdlOp records carry resolved ColumnDef/schema JSON): deep semantic validation (expression trees, SQL typing) happens at the emitting layer, while apply enforces the catalog-level structural invariants fail-closed (existence, uniqueness, id allocation, reference integrity).

Variants

CreateTable

Create a live table. table_id is allocated deterministically from next_table_id at apply time and stamped as schema.schema_id.

Fields

name: String

schema: Schema

created_epoch: u64

DropTable

Logically drop a live table. Cascades to triggers targeting the table, the same-named materialized-view definition, RLS state, policies, masks, and table-scoped role permissions (mirrors Database::drop_table).

Fields

name: String

at_epoch: u64

RenameTable

Rename a live table. Retargets triggers and renames the same-named materialized-view definition. name == new_name is a recorded no-op (mirrors Database::rename_table).

Fields

name: String

new_name: String

at_epoch: u64

AlterColumn

Replace one existing column definition (same id) with an already-validated one. Mirrors DdlOp::AlterTable.

Fields

table: String

column: ColumnDef

AddColumn

Add a column with a caller-allocated, unused id.

Fields

table: String

column: ColumnDef

DropColumn

Drop a column by name; indexes referencing it are dropped too (mirrors the SQL ALTER TABLE ... DROP COLUMN rebuild path).

Fields

table: String

column: String

AddIndex

Add a secondary index definition to a live table.

Fields

table: String

index: IndexDef

RemoveIndex

Remove one index by exact name. Compound SQL index names expand to one command per IndexDef at the emitting layer.

Fields

table: String

name: String

CreateUser

Create a user. id is allocated deterministically from next_user_id (minimum 1) at apply time.

Fields

username: String

password_hash: String

is_admin: bool

created_epoch: u64

DropUser

Fields

username: String

AlterUserPassword

Fields

username: String

password_hash: String

SetUserAdmin

Fields

username: String

is_admin: bool

CreateRole

Fields

name: String

created_epoch: u64

DropRole

Drop a role and strip it from every user (mirrors Database::drop_role).

Fields

name: String

GrantRole

Grant a role to a user. Idempotent: granting an already-held role is a recorded no-op (mirrors Database::grant_role).

Fields

username: String

role: String

RevokeRole

Revoke a role from a user. Idempotent no-op when not held.

Fields

username: String

role: String

GrantPermission

Grant a permission to a role, merging column lists for column-scoped grants. Idempotent no-op when the merged set is unchanged.

Fields

role: String

permission: Permission

RevokePermission

Revoke a permission from a role. Idempotent no-op when unchanged.

Fields

role: String

permission: Permission

EnableRls

Fields

table: String

DisableRls

Fields

table: String

SetRowPolicy

Create or replace a row policy keyed by (table, name).

Fields

policy: RowPolicy

DropRowPolicy

Fields

table: String

name: String

SetColumnMask

Create or replace a column mask keyed by (table, name).

Fields

mask: ColumnMask

DropColumnMask

Fields

table: String

name: String

SetSecurityCatalog

Wholesale security-catalog replacement (RLS tables, policies, masks), mirroring Database::set_security_catalog. Validated against the candidate catalog exactly like the legacy path.

Fields

security: SecurityCatalog

CreateTrigger

Fields

trigger: StoredTrigger

DropTrigger

Fields

name: String

CreateProcedure

Fields

procedure: StoredProcedure

DropProcedure

Fields

name: String

CreateMaterializedView

Create or replace a materialized-view definition. The backing live table must already exist (mirrors Database::set_materialized_view).

Fields

definition: MaterializedViewEntry

DropMaterializedView

Drop only the definition; the physical table is dropped separately via CatalogCommand::DropTable (which also cascades definitions).

Fields

name: String

RefreshMaterializedView

Record refresh bookkeeping: bump last_refresh_epoch and, for incremental views, advance the CDC checkpoint when provided.

Fields

name: String

at_epoch: u64

checkpoint_event_id: Option<String>

SetResourceGroup

Create or replace a resource group.

Fields

group: ResourceGroupDef

RemoveResourceGroup

Fields

name: String

SubmitJob

Submit a new persistent job. job_id must be unused.

Fields

job: JobDefinition

SetJobState

Record a job state change. Transitions out of terminal states (Succeeded/Failed) fail closed; S1F-002 owns the full machine.

Fields

job_id: u64

state: JobState

at_epoch: u64

ReplaceTrigger

Create or replace a trigger, keyed by name. trigger is the resolved image: the emitter stamps created_epoch/updated_epoch/version from the commit epoch (and bumps version on replacement) before proposing, so replay is verbatim (mirrors Database::create_or_replace_trigger).

Fields

trigger: StoredTrigger

ReplaceProcedure

Create or replace a stored procedure, keyed by name; the payload is the epoch-resolved image (mirrors Database::create_or_replace_procedure).

Fields

procedure: StoredProcedure

Trait Implementations

impl Clone for CatalogCommand

fn clone(&self) -> CatalogCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CatalogCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CatalogCommand

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CatalogCommand

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

where __S: Serializer,

Serialize this value into the given Serde serializer.