Enum mz_adapter::catalog::transact::Op

pub enum Op {
    AlterRetainHistory {
        id: CatalogItemId,
        value: Option<Value>,
        window: CompactionWindow,
    },
    AlterRole {
        id: RoleId,
        name: String,
        attributes: RoleAttributes,
        vars: RoleVars,
    },
    AlterNetworkPolicy {
        id: NetworkPolicyId,
        rules: Vec<NetworkPolicyRule>,
        name: String,
        owner_id: RoleId,
    },
    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>,
        owner_id: RoleId,
        config: ClusterConfig,
    },
    CreateClusterReplica {
        cluster_id: ClusterId,
        name: String,
        config: ReplicaConfig,
        owner_id: RoleId,
        reason: ReplicaCreateDropReason,
    },
    CreateItem {
        id: CatalogItemId,
        name: QualifiedItemName,
        item: CatalogItem,
        owner_id: RoleId,
    },
    CreateNetworkPolicy {
        rules: Vec<NetworkPolicyRule>,
        name: String,
        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: CatalogItemId,
        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: CatalogItemId,
        name: QualifiedItemName,
        to_item: CatalogItem,
    },
    UpdateSourceReferences {
        source_id: CatalogItemId,
        references: SourceReferences,
    },
    UpdateSystemConfiguration {
        name: String,
        value: OwnedVarInput,
    },
    ResetSystemConfiguration {
        name: String,
    },
    ResetAllSystemConfiguration,
    WeirdStorageUsageUpdates {
        object_id: Option<String>,
        size_bytes: u64,
        collection_timestamp: EpochMillis,
    },
    TransactionDryRun,
}

Variants

AlterRetainHistory

Fields

id: CatalogItemId

value: Option<Value>

window: CompactionWindow

AlterRole

Fields

id: RoleId

name: String

attributes: RoleAttributes

vars: RoleVars

AlterNetworkPolicy

Fields

id: NetworkPolicyId

rules: Vec<NetworkPolicyRule>

name: String

owner_id: RoleId

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>

owner_id: RoleId

config: ClusterConfig

CreateClusterReplica

Fields

cluster_id: ClusterId

name: String

config: ReplicaConfig

owner_id: RoleId

reason: ReplicaCreateDropReason

CreateItem

Fields

id: CatalogItemId

name: QualifiedItemName

item: CatalogItem

owner_id: RoleId

CreateNetworkPolicy

Fields

rules: Vec<NetworkPolicyRule>

name: String

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: CatalogItemId

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: CatalogItemId

name: QualifiedItemName

to_item: CatalogItem

UpdateSourceReferences

Fields

source_id: CatalogItemId

references: SourceReferences

UpdateSystemConfiguration

Fields

name: String

value: OwnedVarInput

ResetSystemConfiguration

Fields

name: String

ResetAllSystemConfiguration

WeirdStorageUsageUpdates

Performs updates to the storage usage table, which probably should be a builtin source.

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

Fields

object_id: Option<String>

size_bytes: u64

collection_timestamp: EpochMillis

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.