Expand description
Core crate surface for rustcdc.
Re-exports§
pub use crate::core::RustlsClientConfig;pub use crate::core::fingerprint_event_stable;pub use crate::core::fingerprint_event_transient;pub use crate::core::AckMode;pub use crate::core::AckToken;pub use crate::core::CdcRuntime;pub use crate::core::ConnectionRetryPolicy;pub use crate::core::Error;pub use crate::core::ErrorKind;pub use crate::core::Event;pub use crate::core::EventBatch;pub use crate::core::EventIdempotencyGuard;pub use crate::core::EventTracer;pub use crate::core::FingerprintError;pub use crate::core::IdempotencyOptions;pub use crate::core::MetricsCollector;pub use crate::core::NoOpEventTracer;pub use crate::core::NoOpMetricsCollector;pub use crate::core::Offset;pub use crate::core::Operation;pub use crate::core::PostCommitSourceConfirmPolicy;pub use crate::core::Result;pub use crate::core::RuntimeAdminSnapshot;pub use crate::core::RuntimeConfig;pub use crate::core::RuntimeObservability;pub use crate::core::RuntimeOptions;pub use crate::core::RuntimeSourceConfig;pub use crate::core::RuntimeState;pub use crate::core::SecretProvider;pub use crate::core::SecretString;pub use crate::core::SnapshotMetadata;pub use crate::core::SourceErrorKind;pub use crate::core::SourceMetadata;pub use crate::core::StructuredLogger;pub use crate::core::TransactionMetadata;pub use crate::core::TransformErrorPolicy;pub use crate::core::TransportConfig;pub use crate::core::ValidationError;pub use crate::core::ValidationErrors;pub use crate::core::EVENT_ENVELOPE_VERSION;pub use crate::ddl_capture::CapturedDdl;pub use crate::ddl_capture::DdlDialect;pub use crate::ddl_capture::DdlExtractor;pub use crate::ddl_capture::DdlOperation;pub use crate::ddl_capture::ParsedDdlStatement;pub use crate::ddl_capture::SchemaDiff;pub use crate::ddl_capture::SchemaDiffOperation;pub use crate::source::IncrementalSnapshotConfig;pub use crate::source::IncrementalSnapshotHandle;pub use crate::source::ConnectorCapabilities;pub use crate::source::DatabaseAuthMode;pub use crate::source::HandoffResult;pub use crate::source::SnapshotCheckpointHelper;pub use crate::source::SnapshotEnd;pub use crate::source::SnapshotProgress;pub use crate::source::SnapshotProgressTracker;pub use crate::source::SnapshotTrackerConfig;pub use crate::source::SnapshotTrackerReport;pub use crate::source::SnapshotValidationResult;pub use crate::source::SnapshotValidator;pub use crate::source::TableProgress;pub use crate::source::PostgresConnection;pub use crate::source::PostgresSourceConfig;pub use crate::transform::FieldMappingConfig;pub use crate::transform::FieldMappingTransform;pub use crate::transform::FilterField;pub use crate::transform::FilterMode;pub use crate::transform::FilterOperator;pub use crate::transform::FilterProjectionConfig;pub use crate::transform::FilterProjectionTransform;pub use crate::transform::FilterRule;pub use crate::transform::MaskHashConfig;pub use crate::transform::MaskHashTransform;pub use crate::transform::MaskRule;pub use crate::transform::RouteConfig;pub use crate::transform::RouteTransform;pub use crate::transform::Transform;pub use crate::transform::TransformPipeline;pub use crate::transform::UnwrapConfig;pub use crate::transform::UnwrapTransform;pub use crate::codec::BoxedCodec;pub use crate::codec::Codec;pub use crate::codec::CodecOutput;pub use crate::codec::EncodedOutput;pub use crate::codec::EncoderCodec;pub use crate::codec::EventEncoder;pub use crate::codec::JsonCodec;pub use crate::codec::JsonEncoder;pub use crate::codec::JsonPrettyEncoder;pub use crate::pipeline::table_matches;pub use crate::pipeline::HeterogeneousTableRouter;pub use crate::pipeline::TableRoute;pub use crate::pipeline::TableRouter;pub use crate::pipeline::TableRouterBuilder;pub use crate::sink::BoxedSink;pub use crate::sink::FanOutSinkAdapter;pub use crate::sink::FileJsonlSink;pub use crate::sink::FileJsonlSinkConfig;pub use crate::sink::MemorySinkAdapter;pub use crate::sink::SinkAdapter;pub use crate::sink::SinkDeliveryGuarantee;pub use crate::sink::SinkDeliveryMetrics;pub use crate::sink::StdoutSink;
Modules§
- checkpoint
- Checkpoint abstractions and in-memory implementations.
- codec
- Wire-format encoders for CDC events.
- core
- Core event, error, offset, observability, and runtime primitives.
- ddl_
capture - DDL (Data Definition Language) capture and schema evolution support.
- deterministic_
replay - pipeline
- Pipeline assembly utilities for connecting CDC sources to downstream sinks.
- schema_
history - Schema history abstractions and backends.
- sink
- Sink adapter trait and built-in implementations.
- source
- Source traits, connector configuration, and feature-gated connector modules.
- transform
- Transform pipeline building blocks.