List of all items[−]
Structs
- Client
- Config
- ConnClient
- Handle
- LoggingConfig
- PersistConfig
- PersistFileStorage
- PersistS3Storage
- PersisterWithConfig
- SessionClient
- StartupResponse
- catalog::BuiltinTableUpdate
- catalog::Catalog
- catalog::CatalogEntry
- catalog::CatalogState
- catalog::Config
- catalog::ConnCatalog
- catalog::Database
- catalog::Error
- catalog::Func
- catalog::Index
- catalog::Role
- catalog::Schema
- catalog::SerializedPlanContext
- catalog::SerializedSourcePersistDetails
- catalog::Sink
- catalog::Source
- catalog::Table
- catalog::Type
- catalog::View
- catalog::builtin::BUILTINS
- catalog::builtin::BUILTIN_ROLES
- catalog::builtin::BuiltinFunc
- catalog::builtin::BuiltinLog
- catalog::builtin::BuiltinRole
- catalog::builtin::BuiltinTable
- catalog::builtin::BuiltinType
- catalog::builtin::BuiltinView
- catalog::builtin::MZ_ARRAY_TYPES
- catalog::builtin::MZ_AVRO_OCF_SINKS
- catalog::builtin::MZ_BASE_TYPES
- catalog::builtin::MZ_COLUMNS
- catalog::builtin::MZ_DATABASES
- catalog::builtin::MZ_FUNCTIONS
- catalog::builtin::MZ_INDEXES
- catalog::builtin::MZ_INDEX_COLUMNS
- catalog::builtin::MZ_KAFKA_SINKS
- catalog::builtin::MZ_LIST_TYPES
- catalog::builtin::MZ_MAP_TYPES
- catalog::builtin::MZ_PROMETHEUS_HISTOGRAMS
- catalog::builtin::MZ_PROMETHEUS_METRICS
- catalog::builtin::MZ_PROMETHEUS_READINGS
- catalog::builtin::MZ_PSEUDO_TYPES
- catalog::builtin::MZ_ROLES
- catalog::builtin::MZ_SCHEMAS
- catalog::builtin::MZ_SINKS
- catalog::builtin::MZ_SOURCES
- catalog::builtin::MZ_TABLES
- catalog::builtin::MZ_TYPES
- catalog::builtin::MZ_VIEWS
- catalog::builtin::MZ_VIEW_FOREIGN_KEYS
- catalog::builtin::MZ_VIEW_KEYS
- catalog::builtin::TYPE_LIST
- catalog::builtin::TYPE_MAP
- catalog::builtin_table_updates::BuiltinTableUpdate
- catalog::config::Config
- catalog::error::Error
- catalog::migrate::VER_0_20_0
- catalog::migrate::VER_0_9_1
- catalog::migrate::VER_0_9_13
- catalog::migrate::VER_0_9_2
- catalog::storage::Connection
- catalog::storage::SqlVal
- catalog::storage::Transaction
- client::Client
- client::ConnClient
- client::Handle
- client::SessionClient
- command::Response
- command::SimpleExecuteResponse
- command::SimpleResult
- command::StartupResponse
- coord::Config
- coord::ConnMeta
- coord::Coordinator
- coord::DeferredPlan
- coord::LoggingConfig
- coord::SendDiffs
- coord::SinkConnectorReady
- coord::StatementReady
- coord::TimestampedUpdate
- coord::TxnReads
- coord::antichain::AntichainToken
- coord::arrangement_state::ArrangementFrontiers
- coord::arrangement_state::Frontiers
- coord::arrangement_state::SinkWrites
- coord::dataflow_builder::DataflowBuilder
- coord::fast_path_peek::PeekDataflowPlan
- coord::prometheus::Scraper
- id_alloc::IdAllocator
- id_alloc::IdAllocatorInner
- persistcfg::PersistConfig
- persistcfg::PersistFileStorage
- persistcfg::PersistS3Storage
- persistcfg::PersisterWithConfig
- persistcfg::TablePersistDetails
- session::InProgressRows
- session::Portal
- session::PreparedStatement
- session::Session
- session::Transaction
- session::Vars
- session::WriteOp
- session::vars::ServerVar
- session::vars::SessionVar
- session::vars::Vars
- tail::PendingTail
- util::ClientTransmitter
Enums
- Canceled
- CoordError
- ExecuteResponse
- PersistStorage
- StartupMessage
- catalog::CatalogItem
- catalog::ErrorKind
- catalog::Op
- catalog::SerializedCatalogItem
- catalog::SerializedEnvelopePersistDetails
- catalog::SinkConnectorState
- catalog::TypeInner
- catalog::Volatility
- catalog::builtin::Builtin
- catalog::error::ErrorKind
- command::Canceled
- command::Command
- command::ExecuteResponse
- command::StartupMessage
- coord::ExprPrepStyle
- coord::Message
- coord::fast_path_peek::Plan
- error::CoordError
- error::RematerializedSourceType
- persistcfg::PersistStorage
- session::EndTransactionAction
- session::PortalState
- session::TransactionOps
- session::TransactionStatus
Traits
Macros
Functions
- catalog::is_reserved_name
- catalog::migrate::ast_insert_default_confluent_wire_format_0_7_1
- catalog::migrate::ast_remove_csr_confluent_wire_format_0_19_0
- catalog::migrate::ast_rewrite_ccsr_with_options_to_compiled_0_20_0
- catalog::migrate::ast_rewrite_csv_column_aliases_0_9_2
- catalog::migrate::ast_rewrite_kafka_protobuf_source_text_to_compiled_0_9_13
- catalog::migrate::ast_rewrite_pg_catalog_char_to_text_0_9_1
- catalog::migrate::ast_rewrite_type_references_0_6_1
- catalog::migrate::ast_use_pg_catalog_0_7_1
- catalog::migrate::migrate
- catalog::migrate::rewrite_items
- catalog::migrate::semantic_use_id_for_table_format_0_7_1
- catalog::storage::is_constraint_violation
- coord::auto_generate_primary_idx
- coord::check_statement_safety
- coord::describe
- coord::duration_to_timestamp_millis
- coord::fast_path_peek::create_plan
- coord::index_sql
- coord::prometheus::add_expiring_update
- coord::prometheus::add_metadata_update
- coord::prometheus::convert_metrics_to_histogram_rows
- coord::prometheus::convert_metrics_to_value_rows
- coord::prometheus::metric_family_metadata
- coord::send_immediate_rows
- coord::serve
- persistcfg::stream_desc_from_name
- serve
- sink_connector::build
- sink_connector::build_avro_ocf
- sink_connector::build_kafka
- sink_connector::publish_kafka_schemas
- sink_connector::register_kafka_topic
Typedefs
Constants
- catalog::FIRST_USER_OID
- catalog::SYSTEM_CONN_ID
- catalog::SYSTEM_USER
- catalog::builtin::INFORMATION_SCHEMA
- catalog::builtin::INFORMATION_SCHEMA_COLUMNS
- catalog::builtin::INFORMATION_SCHEMA_TABLES
- catalog::builtin::MZ_ARRANGEMENT_BATCHES_INTERNAL
- catalog::builtin::MZ_ARRANGEMENT_RECORDS_INTERNAL
- catalog::builtin::MZ_ARRANGEMENT_SHARING
- catalog::builtin::MZ_ARRANGEMENT_SHARING_INTERNAL
- catalog::builtin::MZ_ARRANGEMENT_SIZES
- catalog::builtin::MZ_CATALOG_NAMES
- catalog::builtin::MZ_CATALOG_SCHEMA
- catalog::builtin::MZ_DATAFLOW_CHANNELS
- catalog::builtin::MZ_DATAFLOW_NAMES
- catalog::builtin::MZ_DATAFLOW_OPERATORS
- catalog::builtin::MZ_DATAFLOW_OPERATORS_ADDRESSES
- catalog::builtin::MZ_DATAFLOW_OPERATOR_DATAFLOWS
- catalog::builtin::MZ_DATAFLOW_OPERATOR_REACHABILITY
- catalog::builtin::MZ_DATAFLOW_OPERATOR_REACHABILITY_INTERNAL
- catalog::builtin::MZ_INTERNAL_SCHEMA
- catalog::builtin::MZ_KAFKA_SOURCE_STATISTICS
- catalog::builtin::MZ_MATERIALIZATIONS
- catalog::builtin::MZ_MATERIALIZATION_DEPENDENCIES
- catalog::builtin::MZ_MATERIALIZATION_FRONTIERS
- catalog::builtin::MZ_MESSAGE_COUNTS
- catalog::builtin::MZ_MESSAGE_COUNTS_RECEIVED_INTERNAL
- catalog::builtin::MZ_MESSAGE_COUNTS_SENT_INTERNAL
- catalog::builtin::MZ_OBJECTS
- catalog::builtin::MZ_PEEK_ACTIVE
- catalog::builtin::MZ_PEEK_DURATIONS
- catalog::builtin::MZ_PERF_ARRANGEMENT_RECORDS
- catalog::builtin::MZ_PERF_DEPENDENCY_FRONTIERS
- catalog::builtin::MZ_PERF_PEEK_DURATIONS_AGGREGATES
- catalog::builtin::MZ_PERF_PEEK_DURATIONS_BUCKET
- catalog::builtin::MZ_PERF_PEEK_DURATIONS_CORE
- catalog::builtin::MZ_RECORDS_PER_DATAFLOW
- catalog::builtin::MZ_RECORDS_PER_DATAFLOW_GLOBAL
- catalog::builtin::MZ_RECORDS_PER_DATAFLOW_OPERATOR
- catalog::builtin::MZ_RELATIONS
- catalog::builtin::MZ_SCHEDULING_ELAPSED
- catalog::builtin::MZ_SCHEDULING_ELAPSED_INTERNAL
- catalog::builtin::MZ_SCHEDULING_HISTOGRAM
- catalog::builtin::MZ_SCHEDULING_HISTOGRAM_INTERNAL
- catalog::builtin::MZ_SCHEDULING_PARKS
- catalog::builtin::MZ_SCHEDULING_PARKS_INTERNAL
- catalog::builtin::MZ_SOURCE_INFO
- catalog::builtin::MZ_SYSTEM
- catalog::builtin::MZ_TEMP_SCHEMA
- catalog::builtin::MZ_WORKER_MATERIALIZATION_FRONTIERS
- catalog::builtin::PG_ACCESS_METHODS
- catalog::builtin::PG_ATTRDEF
- catalog::builtin::PG_ATTRIBUTE
- catalog::builtin::PG_CATALOG_SCHEMA
- catalog::builtin::PG_CLASS
- catalog::builtin::PG_CONSTRAINT
- catalog::builtin::PG_DATABASE
- catalog::builtin::PG_DESCRIPTION
- catalog::builtin::PG_ENUM
- catalog::builtin::PG_INDEX
- catalog::builtin::PG_NAMESPACE
- catalog::builtin::PG_PROC
- catalog::builtin::PG_RANGE
- catalog::builtin::PG_ROLES
- catalog::builtin::PG_SETTINGS
- catalog::builtin::PG_TABLES
- catalog::builtin::PG_TYPE
- catalog::builtin::PG_VIEWS
- catalog::builtin::TYPE_ANY
- catalog::builtin::TYPE_ANYARRAY
- catalog::builtin::TYPE_ANYELEMENT
- catalog::builtin::TYPE_ANYNONARRAY
- catalog::builtin::TYPE_BOOL
- catalog::builtin::TYPE_BOOL_ARRAY
- catalog::builtin::TYPE_BPCHAR
- catalog::builtin::TYPE_BPCHAR_ARRAY
- catalog::builtin::TYPE_BYTEA
- catalog::builtin::TYPE_BYTEA_ARRAY
- catalog::builtin::TYPE_CHAR
- catalog::builtin::TYPE_CHAR_ARRAY
- catalog::builtin::TYPE_DATE
- catalog::builtin::TYPE_DATE_ARRAY
- catalog::builtin::TYPE_FLOAT4
- catalog::builtin::TYPE_FLOAT4_ARRAY
- catalog::builtin::TYPE_FLOAT8
- catalog::builtin::TYPE_FLOAT8_ARRAY
- catalog::builtin::TYPE_INT2
- catalog::builtin::TYPE_INT2_ARRAY
- catalog::builtin::TYPE_INT4
- catalog::builtin::TYPE_INT4_ARRAY
- catalog::builtin::TYPE_INT8
- catalog::builtin::TYPE_INT8_ARRAY
- catalog::builtin::TYPE_INTERVAL
- catalog::builtin::TYPE_INTERVAL_ARRAY
- catalog::builtin::TYPE_JSONB
- catalog::builtin::TYPE_JSONB_ARRAY
- catalog::builtin::TYPE_NUMERIC
- catalog::builtin::TYPE_NUMERIC_ARRAY
- catalog::builtin::TYPE_OID
- catalog::builtin::TYPE_OID_ARRAY
- catalog::builtin::TYPE_RECORD
- catalog::builtin::TYPE_RECORD_ARRAY
- catalog::builtin::TYPE_REGCLASS
- catalog::builtin::TYPE_REGCLASS_ARRAY
- catalog::builtin::TYPE_REGPROC
- catalog::builtin::TYPE_REGPROC_ARRAY
- catalog::builtin::TYPE_REGTYPE
- catalog::builtin::TYPE_REGTYPE_ARRAY
- catalog::builtin::TYPE_TEXT
- catalog::builtin::TYPE_TEXT_ARRAY
- catalog::builtin::TYPE_TIME
- catalog::builtin::TYPE_TIMESTAMP
- catalog::builtin::TYPE_TIMESTAMPTZ
- catalog::builtin::TYPE_TIMESTAMPTZ_ARRAY
- catalog::builtin::TYPE_TIMESTAMP_ARRAY
- catalog::builtin::TYPE_TIME_ARRAY
- catalog::builtin::TYPE_UUID
- catalog::builtin::TYPE_UUID_ARRAY
- catalog::builtin::TYPE_VARCHAR
- catalog::builtin::TYPE_VARCHAR_ARRAY
- catalog::storage::APPLICATION_ID
- catalog::storage::MIGRATIONS
- session::DUMMY_CONNECTION_ID
- session::vars::APPLICATION_NAME
- session::vars::CLIENT_ENCODING
- session::vars::DATABASE
- session::vars::DATE_STYLE
- session::vars::EXTRA_FLOAT_DIGITS
- session::vars::FAILPOINTS
- session::vars::INTEGER_DATETIMES
- session::vars::QGM_OPTIMIZATIONS
- session::vars::SEARCH_PATH
- session::vars::SERVER_VERSION
- session::vars::SERVER_VERSION_NUM
- session::vars::SQL_SAFE_UPDATES
- session::vars::STANDARD_CONFORMING_STRINGS
- session::vars::TIMEZONE
- session::vars::TRANSACTION_ISOLATION