Enum mz_adapter::catalog::transact::Op

pub enum Op {
    AlterRetainHistory {
        id: GlobalId,
        value: Option<Value>,
        window: CompactionWindow,
    },
    AlterRole {
        id: RoleId,
        name: String,
        attributes: RoleAttributes,
        vars: RoleVars,
    },
    CreateDatabase {
        name: String,
        owner_id: RoleId,
    },
    CreateSchema {
        database_id: ResolvedDatabaseSpecifier,
        schema_name: String,
        owner_id: RoleId,
    },
    CreateRole {
        name: String,
        attributes: RoleAttributes,
    },
    CreateCluster {
        id: ClusterId,
        name: String,
        introspection_sources: Vec<(&'static BuiltinLog, GlobalId)>,
        owner_id: RoleId,
        config: ClusterConfig,
    },
    CreateClusterReplica {
        cluster_id: ClusterId,
        id: ReplicaId,
        name: String,
        config: ReplicaConfig,
        owner_id: RoleId,
        reason: ReplicaCreateDropReason,
    },
    CreateItem {
        id: GlobalId,
        name: QualifiedItemName,
        item: CatalogItem,
        owner_id: RoleId,
    },
    Comment {
        object_id: CommentObjectId,
        sub_component: Option<usize>,
        comment: Option<String>,
    },
    DropObjects(Vec<DropObjectInfo>),
    GrantRole {
        role_id: RoleId,
        member_id: RoleId,
        grantor_id: RoleId,
    },
    RenameCluster {
        id: ClusterId,
        name: String,
        to_name: String,
        check_reserved_names: bool,
    },
    RenameClusterReplica {
        cluster_id: ClusterId,
        replica_id: ReplicaId,
        name: QualifiedReplica,
        to_name: String,
    },
    RenameItem {
        id: GlobalId,
        current_full_name: FullItemName,
        to_name: String,
    },
    RenameSchema {
        database_spec: ResolvedDatabaseSpecifier,
        schema_spec: SchemaSpecifier,
        new_name: String,
        check_reserved_names: bool,
    },
    UpdateOwner {
        id: ObjectId,
        new_owner: RoleId,
    },
    UpdatePrivilege {
        target_id: SystemObjectId,
        privilege: MzAclItem,
        variant: UpdatePrivilegeVariant,
    },
    UpdateDefaultPrivilege {
        privilege_object: DefaultPrivilegeObject,
        privilege_acl_item: DefaultPrivilegeAclItem,
        variant: UpdatePrivilegeVariant,
    },
    RevokeRole {
        role_id: RoleId,
        member_id: RoleId,
        grantor_id: RoleId,
    },
    UpdateClusterConfig {
        id: ClusterId,
        name: String,
        config: ClusterConfig,
    },
    UpdateClusterReplicaConfig {
        cluster_id: ClusterId,
        replica_id: ReplicaId,
        config: ReplicaConfig,
    },
    UpdateItem {
        id: GlobalId,
        name: QualifiedItemName,
        to_item: CatalogItem,
    },
    UpdateSystemConfiguration {
        name: String,
        value: OwnedVarInput,
    },
    ResetSystemConfiguration {
        name: String,
    },
    ResetAllSystemConfiguration,
    WeirdBuiltinTableUpdates {
        builtin_table_update: BuiltinTableUpdate,
        audit_log: Vec<(EventType, ObjectType, EventDetails)>,
    },
    TransactionDryRun,
}

Variants

AlterRetainHistory

Fields

id: GlobalId

value: Option<Value>

window: CompactionWindow

AlterRole

Fields

id: RoleId

name: String

attributes: RoleAttributes

vars: RoleVars

CreateDatabase

Fields

name: String

owner_id: RoleId

CreateSchema

Fields

database_id: ResolvedDatabaseSpecifier

schema_name: String

owner_id: RoleId

CreateRole

Fields

name: String

attributes: RoleAttributes

CreateCluster

Fields

id: ClusterId

name: String

introspection_sources: Vec<(&'static BuiltinLog, GlobalId)>

owner_id: RoleId

config: ClusterConfig

CreateClusterReplica

Fields

cluster_id: ClusterId

id: ReplicaId

name: String

config: ReplicaConfig

owner_id: RoleId

reason: ReplicaCreateDropReason

CreateItem

Fields

id: GlobalId

name: QualifiedItemName

item: CatalogItem

owner_id: RoleId

Comment

Fields

object_id: CommentObjectId

sub_component: Option<usize>

comment: Option<String>

DropObjects(Vec<DropObjectInfo>)

GrantRole

Fields

role_id: RoleId

member_id: RoleId

grantor_id: RoleId

RenameCluster

Fields

id: ClusterId

name: String

to_name: String

check_reserved_names: bool

RenameClusterReplica

Fields

cluster_id: ClusterId

replica_id: ReplicaId

name: QualifiedReplica

to_name: String

RenameItem

Fields

id: GlobalId

current_full_name: FullItemName

to_name: String

RenameSchema

Fields

database_spec: ResolvedDatabaseSpecifier

schema_spec: SchemaSpecifier

new_name: String

check_reserved_names: bool

UpdateOwner

Fields

id: ObjectId

new_owner: RoleId

UpdatePrivilege

Fields

target_id: SystemObjectId

privilege: MzAclItem

variant: UpdatePrivilegeVariant

UpdateDefaultPrivilege

Fields

privilege_object: DefaultPrivilegeObject

privilege_acl_item: DefaultPrivilegeAclItem

variant: UpdatePrivilegeVariant

RevokeRole

Fields

role_id: RoleId

member_id: RoleId

grantor_id: RoleId

UpdateClusterConfig

Fields

id: ClusterId

name: String

config: ClusterConfig

UpdateClusterReplicaConfig

Fields

cluster_id: ClusterId

replica_id: ReplicaId

config: ReplicaConfig

UpdateItem

Fields

id: GlobalId

name: QualifiedItemName

to_item: CatalogItem

UpdateSystemConfiguration

Fields

name: String

value: OwnedVarInput

ResetSystemConfiguration

Fields

name: String

ResetAllSystemConfiguration

WeirdBuiltinTableUpdates

Performs updates to weird builtin tables, such as mz_ssh_tunnel_connections and mz_cluster_replica_statuses. Their contents are not fully derived from catalog state. mz_ssh_tunnel_connections is derived from the secrets controller, however, it still must be kept in-sync with the catalog state. Storing the contents of the table in the durable catalog would simplify the situation, but then we’d have to somehow encode public keys the CREATE SQL of connections, which is annoying. In order to successfully balance all of these constraints, we handle all updates to the table separately. mz_cluster_replica_statuses is ephemeral state and should be a builtin source.

TODO(jkosh44) In a multi-writer or high availability catalog world, this will not work. If a process crashes after updating the durable catalog but before updating the builtin table, then another listening catalog will never know to update the builtin table.

Fields

builtin_table_update: BuiltinTableUpdate

audit_log: Vec<(EventType, ObjectType, EventDetails)>

TransactionDryRun

Performs a dry run of the commit, but errors with AdapterError::TransactionDryRun.

When using this value, it should be included only as the last element of the transaction and should not be the only value in the transaction.

Trait Implementations

impl Clone for Op

fn clone(&self) -> Op

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Op

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

Formats the value using the given formatter.