List of all items
Structs
- BuildDesc
- DataflowDescription
- DataflowGraphFormatter
- Explanation
- IndexDesc
- JsonViewFormatter
- LinearOperator
- ProtoBuildDesc
- ProtoDataflowDescription
- ProtoDataflowError
- ProtoDecodeError
- ProtoIndexDesc
- ProtoLinearOperator
- ProtoPeekResponse
- ProtoSourceError
- ProtoSourceErrorDetails
- ProtoSourceInstanceArguments
- ProtoSourceInstanceDesc
- ProtoTailBatch
- ProtoTailResponse
- SourceError
- SourceInstanceArguments
- SourceInstanceDesc
- TailBatch
- TimestampExplanation
- TimestampSource
- Update
- client::IngestSourceCommand
- client::InstanceConfig
- client::LinearizedTimestampBindingFeedback
- client::Peek
- client::ProtoAllowCompaction
- client::ProtoCompaction
- client::ProtoComputeCommand
- client::ProtoComputeResponse
- client::ProtoFrontierUppersKind
- client::ProtoIngestSourceCommand
- client::ProtoIngestSources
- client::ProtoInstanceConfig
- client::ProtoPeek
- client::ProtoStorageCommand
- client::ProtoStorageResponse
- client::ProtoTrace
- client::ProtoUpdate
- client::controller::ClusterReplicaSizeConfig
- client::controller::ClusterReplicaSizeMap
- client::controller::ComputeController
- client::controller::ComputeControllerMut
- client::controller::ComputeInstanceEvent
- client::controller::Controller
- client::controller::ControllerConfig
- client::controller::storage::CollectionDescription
- client::controller::storage::CollectionMetadata
- client::controller::storage::CollectionState
- client::controller::storage::Controller
- client::controller::storage::ProtoCollectionMetadata
- client::controller::storage::StorageControllerState
- client::partitioned::PartitionedComputeState
- client::partitioned::PartitionedStorageState
- client::proto_compute_client::ProtoComputeClient
- client::proto_compute_command::ProtoCancelPeeks
- client::proto_compute_command::ProtoCreateDataflows
- client::proto_compute_response::ProtoPeekResponseKind
- client::proto_compute_response::ProtoTailResponseKind
- client::proto_compute_server::ProtoComputeServer
- client::proto_storage_client::ProtoStorageClient
- client::proto_storage_response::ProtoLinearizedTimestampBindingFeedback
- client::proto_storage_server::ProtoStorageServer
- client::replicated::ActiveReplication
- client::replicated::PendingPeek
- connections::ConnectionContext
- connections::CsrConnection
- connections::CsrConnectionHttpAuth
- connections::CsrConnectionTlsIdentity
- connections::KafkaConnection
- connections::ProtoCsrConnection
- connections::ProtoCsrConnectionHttpAuth
- connections::ProtoCsrConnectionTlsIdentity
- connections::ProtoKafkaConnection
- connections::ProtoKafkaConnectionSaslConfig
- connections::ProtoKafkaConnectionSecurity
- connections::ProtoKafkaConnectionSslConfig
- connections::ProtoStringOrSecret
- connections::SaslConfig
- connections::SslConfig
- connections::aws::AwsAssumeRole
- connections::aws::AwsConfig
- connections::aws::AwsExternalIdPrefix
- connections::aws::ProtoAwsAssumeRole
- connections::aws::ProtoAwsConfig
- connections::aws::ProtoAwsCredentials
- connections::aws::ProtoSerdeUri
- connections::aws::SerdeUri
- connections::aws::proto_aws_credentials::ProtoStatic
- logging::LoggingConfig
- logging::ProtoActiveLog
- logging::ProtoDifferentialLog
- logging::ProtoLogVariant
- logging::ProtoLoggingConfig
- logging::ProtoMaterializedLog
- logging::ProtoTimelyLog
- plan::AvailableCollections
- plan::LirDebugInfo
- plan::ProtoAvailableCollections
- plan::ProtoGetPlan
- plan::ProtoPlan
- plan::join::JoinBuildState
- plan::join::JoinClosure
- plan::join::ProtoDeltaJoinPlan
- plan::join::ProtoDeltaPathPlan
- plan::join::ProtoDeltaStagePlan
- plan::join::ProtoJoinClosure
- plan::join::ProtoJoinClosureEquivalents
- plan::join::ProtoJoinPlan
- plan::join::ProtoLinearJoinPlan
- plan::join::ProtoLinearStagePlan
- plan::join::ProtoMirScalarVec
- plan::join::delta_join::DeltaJoinPlan
- plan::join::delta_join::DeltaPathPlan
- plan::join::delta_join::DeltaStagePlan
- plan::join::linear_join::LinearJoinPlan
- plan::join::linear_join::LinearStagePlan
- plan::proto_get_plan::ProtoGetPlanArrangement
- plan::proto_plan::ProtoPlanArrangeBy
- plan::proto_plan::ProtoPlanConstant
- plan::proto_plan::ProtoPlanFlatMap
- plan::proto_plan::ProtoPlanGet
- plan::proto_plan::ProtoPlanInputKey
- plan::proto_plan::ProtoPlanInputKeyVal
- plan::proto_plan::ProtoPlanJoin
- plan::proto_plan::ProtoPlanLet
- plan::proto_plan::ProtoPlanMfp
- plan::proto_plan::ProtoPlanReduce
- plan::proto_plan::ProtoPlanThreshold
- plan::proto_plan::ProtoPlanTopK
- plan::proto_plan::ProtoPlanUnion
- plan::proto_plan::ProtoRowDiff
- plan::proto_plan::ProtoRowDiffVec
- plan::reduce::AccumulablePlan
- plan::reduce::BucketedPlan
- plan::reduce::CollationPlan
- plan::reduce::KeyValPlan
- plan::reduce::MonotonicPlan
- plan::reduce::ProtoAccumulablePlan
- plan::reduce::ProtoBasicPlan
- plan::reduce::ProtoBucketedPlan
- plan::reduce::ProtoCollationPlan
- plan::reduce::ProtoHierarchicalPlan
- plan::reduce::ProtoKeyValPlan
- plan::reduce::ProtoMonotonicPlan
- plan::reduce::ProtoReducePlan
- plan::reduce::ProtoReductionType
- plan::reduce::proto_accumulable_plan::ProtoAggr
- plan::reduce::proto_basic_plan::ProtoMultipleBasicPlan
- plan::reduce::proto_basic_plan::ProtoSingleBasicPlan
- plan::threshold::BasicThresholdPlan
- plan::threshold::ProtoArrangement
- plan::threshold::ProtoThresholdPlan
- plan::threshold::RetractionsThresholdPlan
- plan::threshold::proto_arrangement::ProtoArrangementPermutation
- plan::top_k::BasicTopKPlan
- plan::top_k::MonotonicTop1Plan
- plan::top_k::MonotonicTopKPlan
- plan::top_k::ProtoBasicTopKPlan
- plan::top_k::ProtoMonotonicTop1Plan
- plan::top_k::ProtoMonotonicTopKPlan
- plan::top_k::ProtoTopKPlan
- proto_dataflow_description::ProtoIndex
- proto_dataflow_description::ProtoSinkExport
- proto_dataflow_description::ProtoSourceImport
- proto_peek_response::ProtoRow
- proto_peek_response::ProtoRows
- proto_tail_batch::ProtoUpdate
- reconciliation::command::ComputeCommandReconcile
- sinks::KafkaSinkConnection
- sinks::KafkaSinkConnectionBuilder
- sinks::KafkaSinkConnectionRetention
- sinks::KafkaSinkConsistencyConnection
- sinks::PersistSinkConnection
- sinks::ProtoKafkaSinkConnection
- sinks::ProtoKafkaSinkConsistencyConnection
- sinks::ProtoPersistSinkConnection
- sinks::ProtoPublishedSchemaInfo
- sinks::ProtoSinkAsOf
- sinks::ProtoSinkConnection
- sinks::ProtoSinkDesc
- sinks::ProtoSinkEnvelope
- sinks::PublishedSchemaInfo
- sinks::SinkAsOf
- sinks::SinkDesc
- sinks::TailSinkConnection
- sinks::proto_kafka_sink_connection::ProtoKeyDescAndIndices
- sinks::proto_kafka_sink_connection::ProtoRelationKeyIndicesVec
- sources::DebeziumDedupProjection
- sources::DebeziumEnvelope
- sources::DebeziumTransactionMetadata
- sources::IncludedColumnPos
- sources::IngestionDescription
- sources::KafkaOffset
- sources::KafkaSourceConnection
- sources::KinesisSourceConnection
- sources::MzOffset
- sources::NoneEnvelope
- sources::PostgresSourceConnection
- sources::PostgresSourceDetails
- sources::ProtoCompression
- sources::ProtoDebeziumDedupProjection
- sources::ProtoDebeziumEnvelope
- sources::ProtoDebeziumMode
- sources::ProtoDebeziumSourceProjection
- sources::ProtoDebeziumTransactionMetadata
- sources::ProtoIncludedColumnPos
- sources::ProtoIncludedColumnSource
- sources::ProtoIngestionDescription
- sources::ProtoKafkaSourceConnection
- sources::ProtoKeyEnvelope
- sources::ProtoKinesisSourceConnection
- sources::ProtoMzOffset
- sources::ProtoNoneEnvelope
- sources::ProtoPostgresSourceConnection
- sources::ProtoPostgresSourceDetails
- sources::ProtoPubNubSourceConnection
- sources::ProtoS3KeySource
- sources::ProtoS3SourceConnection
- sources::ProtoSourceConnection
- sources::ProtoSourceData
- sources::ProtoSourceDesc
- sources::ProtoSourceEnvelope
- sources::ProtoTimeline
- sources::ProtoUpsertEnvelope
- sources::ProtoUpsertStyle
- sources::PubNubSourceConnection
- sources::S3SourceConnection
- sources::SourceData
- sources::SourceDesc
- sources::UpsertEnvelope
- sources::encoding::AvroEncoding
- sources::encoding::CsvEncoding
- sources::encoding::DataEncoding
- sources::encoding::ProtoAvroEncoding
- sources::encoding::ProtoColumnSpec
- sources::encoding::ProtoCsvEncoding
- sources::encoding::ProtoDataEncoding
- sources::encoding::ProtoDataEncodingInner
- sources::encoding::ProtoProtobufEncoding
- sources::encoding::ProtoRegexEncoding
- sources::encoding::ProtoSourceDataEncoding
- sources::encoding::ProtobufEncoding
- sources::encoding::RegexEncoding
- sources::encoding::proto_column_spec::ProtoHeader
- sources::encoding::proto_source_data_encoding::ProtoKeyValue
- sources::proto_debezium_mode::ProtoFullInRange
- sources::proto_debezium_source_projection::ProtoMySql
- sources::proto_debezium_source_projection::ProtoPostgres
- sources::proto_debezium_source_projection::ProtoSqlServer
- sources::proto_ingestion_description::ProtoSourceMetadataImport
- sources::proto_upsert_style::ProtoDebezium
Enums
- DataflowError
- DecodeError
- PeekResponse
- SourceErrorDetails
- TailResponse
- client::ActiveReplicationResponse
- client::ComputeCommand
- client::ComputeResponse
- client::ConcreteComputeInstanceReplicaConfig
- client::ControllerResponse
- client::StorageCommand
- client::StorageResponse
- client::controller::ComputeInstanceStatus
- client::controller::ReadPolicy
- client::controller::storage::StorageError
- client::proto_compute_command::Kind
- client::proto_compute_response::Kind
- client::proto_storage_command::Kind
- client::proto_storage_response::Kind
- connections::Connection
- connections::Security
- connections::StringOrSecret
- connections::aws::AwsCredentials
- connections::aws::proto_aws_credentials::Kind
- connections::proto_kafka_connection_security::Kind
- connections::proto_string_or_secret::Kind
- logging::DifferentialLog
- logging::LogVariant
- logging::MaterializedLog
- logging::TimelyLog
- logging::proto_differential_log::Kind
- logging::proto_log_variant::Kind
- logging::proto_materialized_log::Kind
- logging::proto_timely_log::Kind
- plan::GetPlan
- plan::Plan
- plan::join::JoinPlan
- plan::join::proto_join_plan::Kind
- plan::proto_get_plan::Kind
- plan::proto_plan::Kind
- plan::proto_plan::proto_plan_constant::Result
- plan::reduce::BasicPlan
- plan::reduce::HierarchicalPlan
- plan::reduce::ReducePlan
- plan::reduce::ReductionType
- plan::reduce::proto_basic_plan::Kind
- plan::reduce::proto_hierarchical_plan::Kind
- plan::reduce::proto_reduce_plan::Kind
- plan::reduce::proto_reduction_type::Kind
- plan::threshold::ThresholdPlan
- plan::threshold::proto_threshold_plan::Kind
- plan::top_k::TopKPlan
- plan::top_k::proto_top_k_plan::Kind
- proto_dataflow_error::Kind
- proto_decode_error::Kind
- proto_peek_response::Kind
- proto_source_error_details::Kind
- proto_tail_response::Kind
- sinks::KafkaSinkFormat
- sinks::SinkConnection
- sinks::SinkConnectionBuilder
- sinks::SinkEnvelope
- sinks::proto_sink_connection::Kind
- sinks::proto_sink_envelope::Kind
- sources::Compression
- sources::DebeziumMode
- sources::DebeziumSourceProjection
- sources::IncludedColumnSource
- sources::KeyEnvelope
- sources::S3KeySource
- sources::SourceConnection
- sources::SourceEnvelope
- sources::Timeline
- sources::UnplannedSourceEnvelope
- sources::UpsertStyle
- sources::encoding::ColumnSpec
- sources::encoding::DataEncodingInner
- sources::encoding::SourceDataEncoding
- sources::encoding::SourceDataEncodingInner
- sources::encoding::proto_column_spec::Kind
- sources::encoding::proto_data_encoding_inner::Kind
- sources::encoding::proto_source_data_encoding::Kind
- sources::proto_compression::Kind
- sources::proto_debezium_mode::Kind
- sources::proto_debezium_source_projection::Kind
- sources::proto_included_column_source::Kind
- sources::proto_key_envelope::Kind
- sources::proto_s3_key_source::Kind
- sources::proto_source_connection::Kind
- sources::proto_source_data::Kind
- sources::proto_source_envelope::Kind
- sources::proto_timeline::Kind
- sources::proto_upsert_style::Kind
Traits
- PopulateClientConfig
- client::ComputeClient
- client::StorageClient
- client::controller::storage::StorageController
- client::proto_compute_server::ProtoCompute
- client::proto_storage_server::ProtoStorage
- connections::ConfigKey
Functions
- client::replicated::spawn_client_task
- plan::linear_to_mfp
- plan::reduce::convert_indexes_to_skips
- populate_client_config
- sources::encoding::included_column_desc
- sources::provide_default_metadata