List of all items

Structs

• checkpoint::CheckpointFailure
• checkpoint::CheckpointMetadata
• checkpoint::CheckpointResponse
• checkpoint::CheckpointStatus
• checkpoint::CheckpointSyncFailure
• checkpoint::CheckpointSyncResponse
• checkpoint::CheckpointSyncStatus
• checkpoint::PSpineBatches
• completion_token::CompletionStatusArgs
• completion_token::CompletionStatusResponse
• completion_token::CompletionTokenResponse
• config::ConnectorConfig
• config::FileBackendConfig
• config::FormatConfig
• config::FtConfig
• config::FtModelUnknown
• config::InputEndpointConfig
• config::ObjectStorageConfig
• config::OutputBufferConfig
• config::OutputEndpointConfig
• config::PipelineConfig
• config::ResourceConfig
• config::RuntimeConfig
• config::StorageConfig
• config::StorageOptions
• config::SyncConfig
• error::ErrorResponse
• format::avro::AvroEncoderConfig
• format::avro::AvroParserConfig
• format::avro::AvroSchemaRegistryConfig
• format::csv::CsvDelimiter
• format::csv::CsvEncoderConfig
• format::csv::CsvParserConfig
• format::json::JsonEncoderConfig
• format::json::JsonParserConfig
• format::parquet::ParquetEncoderConfig
• format::parquet::ParquetParserConfig
• format::raw::RawParserConfig
• program_schema::ColumnType
• program_schema::Field
• program_schema::ProgramSchema
• program_schema::PropertyValue
• program_schema::Relation
• program_schema::SourcePosition
• program_schema::SqlIdentifier
• query::AdhocQueryArgs
• query_params::MetricsParameters
• serde_with_context::deserialize::FieldParseError
• serde_with_context::serde_config::SqlSerdeConfig
• serde_with_context::serialize::SerializeFieldsWithContextWrapper
• serde_with_context::serialize::SerializeWithContextWrapper
• suspend::SuspendableResponse
• transport::adhoc::AdHocInputConfig
• transport::clock::ClockConfig
• transport::datagen::DatagenInputConfig
• transport::datagen::GenerationPlan
• transport::datagen::RngFieldSettings
• transport::delta_table::DeltaTableReaderConfig
• transport::delta_table::DeltaTableWriterConfig
• transport::file::FileInputConfig
• transport::file::FileOutputConfig
• transport::http::Chunk
• transport::http::HttpInputConfig
• transport::iceberg::GlueCatalogConfig
• transport::iceberg::IcebergReaderConfig
• transport::iceberg::RestCatalogConfig
• transport::kafka::Chunk
• transport::kafka::KafkaHeader
• transport::kafka::KafkaHeaderValue
• transport::kafka::KafkaInputConfig
• transport::kafka::KafkaOutputConfig
• transport::kafka::KafkaOutputFtConfig
• transport::nexmark::NexmarkInputConfig
• transport::nexmark::NexmarkInputOptions
• transport::postgres::PostgresReaderConfig
• transport::postgres::PostgresWriterConfig
• transport::pubsub::PubSubInputConfig
• transport::redis::RedisOutputConfig
• transport::s3::S3InputConfig
• transport::url::UrlInputConfig

Enums

• completion_token::CompletionStatus
• config::FtModel
• config::StartFromCheckpoint
• config::StorageBackendConfig
• config::StorageCacheConfig
• config::StorageCompression
• config::TransportConfig
• format::avro::AvroEncoderKeyMode
• format::avro::AvroUpdateFormat
• format::avro::SubjectNameStrategy
• format::json::JsonFlavor
• format::json::JsonLines
• format::json::JsonUpdateFormat
• format::raw::RawParserMode
• program_schema::IntervalUnit
• program_schema::SqlType
• query::AdHocResultFormat
• query_params::MetricsFormat
• secret_ref::KubernetesSecretDataKeyParseError
• secret_ref::KubernetesSecretNameParseError
• secret_ref::MaybeSecretRef
• secret_ref::MaybeSecretRefParseError
• secret_ref::SecretRef
• secret_resolver::SecretRefDiscoveryError
• secret_resolver::SecretRefResolutionError
• serde_with_context::serde_config::BinaryFormat
• serde_with_context::serde_config::DateFormat
• serde_with_context::serde_config::DecimalFormat
• serde_with_context::serde_config::TimeFormat
• serde_with_context::serde_config::TimestampFormat
• serde_with_context::serde_config::UuidFormat
• serde_with_context::serde_config::VariantFormat
• suspend::PermanentSuspendError
• suspend::SuspendError
• suspend::TemporarySuspendError
• transport::datagen::DatagenStrategy
• transport::delta_table::DeltaTableIngestMode
• transport::delta_table::DeltaTableWriteMode
• transport::iceberg::IcebergCatalogType
• transport::iceberg::IcebergIngestMode
• transport::kafka::KafkaLogLevel
• transport::kafka::KafkaStartFromConfig
• transport::nexmark::NexmarkTable

Traits

• error::DetailedError
• serde_with_context::deserialize::DeserializeWithContext
• serde_with_context::deserialize::ErasedDeserializeWithContext
• serde_with_context::serialize::SerializeWithContext

Macros

• deserialize_struct
• deserialize_table_record
• deserialize_tuple
• deserialize_without_context
• serialize_struct
• serialize_table_record
• serialize_without_context

Functions

• config::default_checkpoint_interval_secs
• config::default_max_batch_size
• config::default_max_queued_records
• program_schema::canonical_identifier
• secret_ref::validate_kubernetes_secret_data_key
• secret_ref::validate_kubernetes_secret_name
• secret_resolver::discover_secret_references_in_connector_config
• secret_resolver::resolve_secret_references_in_connector_config
• serde_with_context::deserialize::field_parse_error
• serde_with_context::deserialize::invalid_length_error
• serde_with_context::deserialize::missing_field_error
• transport::kafka::default_group_join_timeout_secs
• transport::kafka::default_redpanda_server

Constants

• config::DEFAULT_CLOCK_RESOLUTION_USECS
• constants::CHECKPOINT_DEPENDENCIES
• constants::CHECKPOINT_FILE_NAME
• constants::STATE_FILE
• constants::STEPS_FILE
• error::MAX_REPORTED_PARSE_ERRORS
• query::MAX_WS_FRAME_SIZE
• secret_ref::PATTERN_RFC_1123_DNS_LABEL
• secret_resolver::DEFAULT_SECRETS_DIRECTORY_PATH
• transport::http::SERVER_PORT_FILE