List of all items

Structs

• AggTable
• AnalyzeJoin
• AnalyzePlan
• AnalyzeReport
• AnalyzeSource
• AnalyzeSpec
• AnalyzeTiming
• AnalyzeTotals
• BaseColumn
• BaseTableSchema
• Cluster
• ClusterConsumer
• ClusterMutationWrite
• ClusterWriteTxn
• CommitInfo
• Db
• DdlActions
• DdlApplyReport
• DdlStep
• DerivationPool
• Drain
• DrainHandle
• Engine
• FamilyExtraction
• FamilyKey
• FamilyTemplate
• ForeignKeyAudit
• ForeignKeyViolation
• InitialSnapshotColumn
• InitialSnapshotCommit
• InitialSnapshotIdentity
• InitialSnapshotStore
• InitialSnapshotTable
• JoinPrecheckReport
• MaintenanceOptions
• MaintenanceReport
• MutationEnvelope
• MutationOutcome
• MutationReject
• MutatorRegistry
• NodeData
• NormalizeFold
• NormalizedBatch
• NormalizedHello
• NormalizedPublisher
• NormalizedSubscriber
• OpenOptions
• PoolGate
• PoolTxn
• ProgressFrame
• ProgressTracker
• PublicAuthorizerGuard
• Query
• QueryId
• ReadConn
• ReplicatedColumn
• ReplicatedTableSchema
• RoomRowConflict
• SharedQueryInfo
• SourceHead
• SqlColumn
• SqlReadRows
• SqlStatementRequest
• StatementResult
• StorageReport
• StoredSourceCheckpoint
• TableMeta
• TableNode
• TableSchema
• TableWireSchema
• TxId
• WalCheckpoint
• WriteTxn
• schema_envelope::DdlActionRecorder
• schema_envelope::DdlActions
• schema_envelope::DdlApplyReport
• schema_envelope::DdlStep
• session::CommitTail
• session::LmidAdvance
• session::ProducerWrite
• session::ReadRows
• session::SessionCommit
• session::SessionEngine
• session::SessionReply
• session::SqlStatement
• session::SqlTxn
• session::SqlTxnOutput
• sql::PublicAuthorizerGuard
• sql::SqlColumn
• sql::SqlStatementRequest
• sql::StatementResult
• writeplane::DeployMigrationRequest
• writeplane::MigrationRecord
• writeplane::ProducerCensus
• writeplane::PublicMigrateAck
• writeplane::PublicOperationCommit
• writeplane::PublicSqlRejection
• writeplane::ScriptOutcome
• writeplane::SqlAuthorizationError
• writeplane::StoredPublicOutcome
• writeplane::bookkeeping::MigrationRecord
• writeplane::bookkeeping::StoredPublicOutcome
• writeplane::oneshot::PublicMigrateAck
• writeplane::oneshot::PublicOperationCommit
• writeplane::oneshot::ScriptOutcome
• writeplane::public_http::SqlAuthorizationError
• writeplane::request::DeployMigrationRequest
• writeplane::request::PublicSqlRejection
• writeplane::storage::ProducerCensus

Enums

• ChangeEvent
• ClusterEvent
• ColType
• DdlMigrationError
• FaultCause
• ForeignKeys
• InitialSnapshotOpen
• JournalMode
• Mutation
• NormalizedApplied
• NormalizedOp
• NormalizedProtocolError
• OperatorStorage
• ReplicaError
• RoomFlushOutcome
• SqlArgs
• StatementClass
• StatementRunError
• Update
• session::ParkedNext
• session::SessionError
• session::SessionOp
• session::TxnWireId
• sql::SqlArgs
• sql::StatementClass
• sql::StatementRunError
• writeplane::BookkeepingError
• writeplane::MigrationFileKind
• writeplane::PublicReadConsistency
• writeplane::PublicSqlRequest
• writeplane::SqlIngressAuth
• writeplane::SqlOutcomeNamespace
• writeplane::WritePlaneError
• writeplane::bookkeeping::MigrationFileKind
• writeplane::bookkeeping::SqlOutcomeNamespace
• writeplane::public_http::SqlIngressAuth
• writeplane::request::PublicReadConsistency
• writeplane::request::PublicSqlRequest

Traits

• DrainSink
• MutationSql
• session::SessionBackend
• session::SessionResponder
• writeplane::MigrationSection
• writeplane::OneShotBackend
• writeplane::PublicReplayReads
• writeplane::oneshot::MigrationSection
• writeplane::oneshot::OneShotBackend
• writeplane::oneshot::PublicReplayReads

Functions

• agg_table_name
• agg_table_schemas
• analyze_standalone
• build_mutation_sql
• build_query_parts
• canonical_migration_checksum
• cas_cell_matches
• classify_statement
• create_table_ddl
• decode_wire_value
• discover_table_schema
• encode_wire_value
• ensure_unique_pk_index
• extract_family
• foreign_key_check
• hello_from_parts
• install_public_authorizer
• introspect_replicated_table
• introspect_schema_envelope
• is_internal_schema_name
• normalize_migration_statements
• normalized_fp
• open_journal
• restore_bootstrap
• restore_bootstrap_with_journal
• rewrite_aggregates
• rewrite_aggregates_with_local
• run_ddl_statement
• run_statement
• schema_envelope::ensure_embedded_ddl_batch
• schema_envelope::introspect_replicated_table
• schema_envelope::introspect_schema_envelope
• schema_envelope::transactionally_apply_schema
• schema_envelope::transactionally_apply_schema_checked
• schema_envelope::validate_default_expression
• schema_envelope::validate_schema_envelope
• schema_envelope::value_type_of
• session::absorbed_reply
• session::check_read_js_safe
• session::error_reply
• session::execute_one_shot
• session::parse_session_op
• session::parse_sql_txn
• session::parse_statement_obj
• session::parse_statements
• session::public_cancel_reply
• session::public_commit_outcome_reply
• session::public_operation_sequence
• session::public_session_gone
• session::reject_one_shot
• session::session_gone
• session::session_op_id
• session::session_read_json
• session::session_read_tagged_json
• session::sql_txn_output_json
• set_foreign_keys
• split_migration_file
• split_sql_script
• split_sql_script_allow_empty
• sql::canonical_migration_checksum
• sql::classify_statement
• sql::decode_wire_value
• sql::encode_wire_value
• sql::ensure_single_statement
• sql::from_sql
• sql::install_public_authorizer
• sql::is_embedded_schema_statement
• sql::normalize_migration_statements
• sql::preflight_public_ddl_statement
• sql::run_ddl_statement
• sql::run_preflighted_ddl_statement
• sql::run_statement
• sql::split_migration_file
• sql::split_sql_script
• sql::split_sql_script_allow_empty
• sql::statement_is_insert
• sql::strip_comments_and_literals
• sql::to_value
• sql_cell_to_owned
• statement_is_insert
• table_tree
• unsafe_int_in_normalized_batch
• validate_schema_envelope
• value_type_of
• wire_json::absent_marker
• wire_json::assembled_snapshot_to_json
• wire_json::flat_changes_to_json
• wire_json::is_absent_marker
• wire_json::json_to_owned
• wire_json::mutation_from_json
• wire_json::mutation_to_json
• wire_json::nbatch_frame
• wire_json::nbatch_ops_fragment
• wire_json::normalized_batch_from_json
• wire_json::normalized_batch_to_json
• wire_json::normalized_hello_from_json
• wire_json::normalized_hello_to_json
• wire_json::normalized_op_from_json
• wire_json::normalized_op_to_json
• wire_json::owned_to_json
• wire_json::wire_row_from_json
• wire_json::wire_row_to_json
• wire_json::wire_schema_to_json
• writeplane::adopt_migration_checksums
• writeplane::append_bounded_script_results
• writeplane::authorize_sql_ingress
• writeplane::bookkeeping::adopt_migration_checksums
• writeplane::bookkeeping::append_bounded_script_results
• writeplane::bookkeeping::classify_migration_file
• writeplane::bookkeeping::data_migration_checksum
• writeplane::bookkeeping::encoded_statement_result_len
• writeplane::bookkeeping::enforce_encoded_result_array_limit
• writeplane::bookkeeping::ensure_outcome_matches_request
• writeplane::bookkeeping::insert_sql_outcome
• writeplane::bookkeeping::insert_sql_outcome_with_cursor
• writeplane::bookkeeping::journal_data_migration
• writeplane::bookkeeping::journal_migration
• writeplane::bookkeeping::journal_migration_with_cursor
• writeplane::bookkeeping::migration_content_checksum_from_record
• writeplane::bookkeeping::migration_normalized_statements_from_record
• writeplane::bookkeeping::migration_record
• writeplane::bookkeeping::parse_public_idempotency_key_at
• writeplane::bookkeeping::parse_public_or_derived_idempotency_key_at
• writeplane::bookkeeping::public_commit_outcome_on_conn
• writeplane::bookkeeping::public_idempotency_minted_at_ms
• writeplane::bookkeeping::public_transaction_minted_at_ms
• writeplane::bookkeeping::read_sql_outcome
• writeplane::bookkeeping::sql_operation_key
• writeplane::bookkeeping::sql_outcome_floor_ms
• writeplane::bookkeeping::sql_outcome_minted_at_ms
• writeplane::bookkeeping::sql_request_identity
• writeplane::bookkeeping::sql_result_limit_error
• writeplane::bookkeeping::statement_class_name
• writeplane::bookkeeping::sweep_sql_outcomes
• writeplane::budget::with_writer_statement_budget
• writeplane::budget::with_writer_statement_limits
• writeplane::classify_migration_file
• writeplane::cursor_history_lost
• writeplane::data_migration_checksum
• writeplane::ddl_only_violation_message
• writeplane::encoded_statement_result_len
• writeplane::enforce_encoded_result_array_limit
• writeplane::ensure_data_migrations_table
• writeplane::ensure_log_meta_table
• writeplane::ensure_master_migrations_table
• writeplane::ensure_master_run_id_indexes
• writeplane::ensure_migration_identity_columns
• writeplane::ensure_outcome_matches_request
• writeplane::ensure_producer_offsets_table
• writeplane::ensure_sql_outcome_identity_column
• writeplane::ensure_sql_outcomes_table
• writeplane::ensure_writeplane_tables
• writeplane::execute_public_batch
• writeplane::execute_public_ddl
• writeplane::execute_public_migration
• writeplane::execute_public_read
• writeplane::execute_public_script
• writeplane::insert_sql_outcome
• writeplane::insert_sql_outcome_with_cursor
• writeplane::journal_data_migration
• writeplane::journal_migration
• writeplane::journal_migration_with_cursor
• writeplane::migration_content_checksum_from_record
• writeplane::migration_normalized_statements_from_record
• writeplane::migration_record
• writeplane::oneshot::execute_public_batch
• writeplane::oneshot::execute_public_ddl
• writeplane::oneshot::execute_public_migration
• writeplane::oneshot::execute_public_script
• writeplane::oneshot::resolve_public_outcome_cursor
• writeplane::oneshot::resolve_replay_cursor
• writeplane::oneshot::stored_public_operation
• writeplane::oneshot::stored_public_operation_over
• writeplane::parse_public_idempotency_key_at
• writeplane::parse_public_or_derived_idempotency_key_at
• writeplane::pre_ddl_table_names
• writeplane::producer_offsets_ddl
• writeplane::producer_offsets_upsert_sql
• writeplane::public_commit_outcome_on_conn
• writeplane::public_http::authorize_sql_ingress
• writeplane::public_http::cursor_history_lost
• writeplane::public_http::execute_public_read
• writeplane::public_http::refresh_generation_bound
• writeplane::public_http::sql_success_body
• writeplane::public_http::validate_public_request_id
• writeplane::public_http::validated_request_id
• writeplane::public_idempotency_minted_at_ms
• writeplane::public_transaction_minted_at_ms
• writeplane::read_lmid
• writeplane::read_producer_seq
• writeplane::read_sql_outcome
• writeplane::refresh_generation_bound
• writeplane::refuse_broken_foreign_keys
• writeplane::render_public_script_error
• writeplane::render_public_sql_error
• writeplane::request::shape_deploy_migrations
• writeplane::request::shape_public_sql_request
• writeplane::request::take_changes
• writeplane::resolve_public_outcome_cursor
• writeplane::resolve_replay_cursor
• writeplane::shape_deploy_migrations
• writeplane::shape_public_sql_request
• writeplane::sql_error_response
• writeplane::sql_operation_key
• writeplane::sql_outcome_floor_ms
• writeplane::sql_outcome_minted_at_ms
• writeplane::sql_request_identity
• writeplane::sql_result_limit_error
• writeplane::sql_success_body
• writeplane::statement_class_name
• writeplane::statement_is_drop_table
• writeplane::statement_sql_error
• writeplane::statement_sql_error_status
• writeplane::storage::ddl_only_violation_message
• writeplane::storage::ensure_data_migrations_table
• writeplane::storage::ensure_log_meta_table
• writeplane::storage::ensure_master_migrations_table
• writeplane::storage::ensure_master_run_id_indexes
• writeplane::storage::ensure_migration_identity_columns
• writeplane::storage::ensure_producer_offsets_table
• writeplane::storage::ensure_sql_outcome_identity_column
• writeplane::storage::ensure_sql_outcomes_table
• writeplane::storage::ensure_writeplane_tables
• writeplane::storage::pre_ddl_table_names
• writeplane::storage::producer_offsets_ddl
• writeplane::storage::producer_offsets_upsert_sql
• writeplane::storage::read_lmid
• writeplane::storage::read_producer_seq
• writeplane::storage::refuse_broken_foreign_keys
• writeplane::storage::statement_is_drop_table
• writeplane::storage::upsert_lmid
• writeplane::storage::upsert_producer_seq
• writeplane::storage::validate_public_ddl_poststate
• writeplane::stored_public_operation
• writeplane::stored_public_operation_over
• writeplane::sweep_sql_outcomes
• writeplane::take_changes
• writeplane::upsert_lmid
• writeplane::upsert_producer_seq
• writeplane::validate_public_ddl_poststate
• writeplane::validate_public_request_id
• writeplane::validated_request_id
• writeplane::with_writer_statement_budget
• writeplane::with_writer_statement_limits

Type Aliases

• Binding
• ConnId
• PkMap
• ProjMap
• ServerMutator
• SubId

Constants

• APPLIED_DDL_TABLE
• CDC_BOOTSTRAP_TABLE
• CLIENT_MUTATIONS_TABLE
• FOREIGN_KEY_AUDIT_ROW_CAP
• OUTCOME_RETENTION_LMIDS
• READ_ROW_CAP
• READ_TIME_BUDGET
• READ_VM_BUDGET
• ROOM_CLIENT_MUTATIONS_TABLE
• ROOM_MUTATION_OUTCOMES_TABLE
• ROOM_PLACEMENT_TABLE
• ROOM_WATERMARK_TABLE
• SCOPE_SESSIONS_TABLE
• SOURCE_OFFSETS_TABLE
• SOURCE_OFFSET_WHOLE_RUN
• SQL_BIND_LIMIT
• SQL_BIND_VALUE_BYTE_LIMIT
• SQL_RESULT_BYTE_LIMIT
• SQL_RESULT_ROW_LIMIT
• SQL_TEXT_LIMIT
• session::DEFAULT_SESSION_DEADLINE
• sql::SQL_BIND_LIMIT
• sql::SQL_BIND_VALUE_BYTE_LIMIT
• sql::SQL_RESULT_BYTE_LIMIT
• sql::SQL_RESULT_ROW_LIMIT
• sql::SQL_TEXT_LIMIT
• wire_json::ABSENT_WIRE_KEY
• writeplane::CLIENT_MUTATIONS_TABLE
• writeplane::DATA_MIGRATIONS_TABLE
• writeplane::LOG_META_TABLE
• writeplane::MIGRATIONS_JOURNAL_TABLE
• writeplane::OUTCOME_RETENTION_LMIDS
• writeplane::PRODUCER_OFFSETS_TABLE
• writeplane::RINDLE_REQUEST_ID_HEADER
• writeplane::ROOM_CLIENT_MUTATIONS_TABLE
• writeplane::ROOM_MUTATION_OUTCOMES_TABLE
• writeplane::ROOM_PLACEMENT_TABLE
• writeplane::ROOM_WATERMARK_TABLE
• writeplane::SCOPE_SESSIONS_TABLE
• writeplane::SOURCE_OFFSETS_TABLE
• writeplane::SOURCE_OFFSET_WHOLE_RUN
• writeplane::SQL_IDEMPOTENCY_MAX_FUTURE_SKEW_MS
• writeplane::SQL_IDEMPOTENCY_PREFIX
• writeplane::SQL_OUTCOMES_TABLE
• writeplane::SQL_OUTCOME_MAX_RECORDS
• writeplane::SQL_OUTCOME_RETENTION_MS
• writeplane::WRITE_DDL_TIME_BUDGET
• writeplane::WRITE_STATEMENT_TIME_BUDGET
• writeplane::bookkeeping::CLIENT_MUTATIONS_TABLE
• writeplane::bookkeeping::DATA_MIGRATIONS_TABLE
• writeplane::bookkeeping::LOG_META_TABLE
• writeplane::bookkeeping::MIGRATIONS_JOURNAL_TABLE
• writeplane::bookkeeping::OUTCOME_RETENTION_LMIDS
• writeplane::bookkeeping::ROOM_CLIENT_MUTATIONS_TABLE
• writeplane::bookkeeping::ROOM_MUTATION_OUTCOMES_TABLE
• writeplane::bookkeeping::ROOM_PLACEMENT_TABLE
• writeplane::bookkeeping::ROOM_WATERMARK_TABLE
• writeplane::bookkeeping::SCOPE_SESSIONS_TABLE
• writeplane::bookkeeping::SOURCE_OFFSETS_TABLE
• writeplane::bookkeeping::SOURCE_OFFSET_WHOLE_RUN
• writeplane::bookkeeping::SQL_IDEMPOTENCY_MAX_FUTURE_SKEW_MS
• writeplane::bookkeeping::SQL_IDEMPOTENCY_PREFIX
• writeplane::bookkeeping::SQL_OUTCOMES_TABLE
• writeplane::bookkeeping::SQL_OUTCOME_MAX_RECORDS
• writeplane::bookkeeping::SQL_OUTCOME_RETENTION_MS
• writeplane::budget::WRITE_DDL_TIME_BUDGET
• writeplane::budget::WRITE_STATEMENT_TIME_BUDGET
• writeplane::public_http::RINDLE_REQUEST_ID_HEADER
• writeplane::storage::PRODUCER_OFFSETS_TABLE