rustcdc 0.1.3

Embeddable Rust CDC library focused on correctness-first capture primitives
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

[package]
name = "rustcdc"
version = "0.1.3"
edition = "2021"
rust-version = "1.88"
description = "Embeddable Rust CDC library focused on correctness-first capture primitives"
authors      = ["hupe1980"]
license = "MIT OR Apache-2.0"
repository   = "https://github.com/hupe1980/rustcdc"
homepage     = "https://github.com/hupe1980/rustcdc"
documentation = "https://docs.rs/rustcdc"
readme       = "README.md"
keywords     = ["cdc", "change-data-capture"]
categories   = ["database", "asynchronous", "data-structures"]

[workspace]
members = [".", "xtask"]
default-members = ["."]
resolver = "2"

[features]
# Default production profile with PostgreSQL source support and TLS transport enabled.
default = ["postgres", "tls"]
# Enable PostgreSQL-specific source implementations.
postgres = ["dep:tokio-postgres", "dep:tokio-postgres-rustls", "tls"]
# Enable MySQL-specific source implementations.
mysql = ["dep:mysql_async", "dep:mysql_common", "mysql_async/rustls-tls", "tls"]
# Enable MariaDB CDC support (thin facade over the MySQL connector).
mariadb = ["mysql"]
# Enable SQL Server-specific source implementations.
sqlserver = ["dep:tiberius", "dep:tokio-util", "tls"]
# Enable TLS-related transport support for source connectors.
tls = ["dep:rustls", "dep:rustls-pemfile", "dep:rustls-native-certs", "dep:tokio-rustls"]
# Enable outbox helpers and transforms.
outbox = []
# Enable encryption-oriented transforms and helpers.
encryption = ["dep:aes-gcm", "dep:base64", "dep:hkdf", "dep:hmac"]
# Enable metrics and instrumentation integrations.
metrics = ["dep:opentelemetry", "dep:opentelemetry_sdk", "dep:opentelemetry-otlp"]
# Enable explicit test-only insecure transport/TLS overrides behind env toggles.
# Never enable this feature for production builds.
insecure-test-overrides = []
# Enable fault-injection and chaos-testing primitives (FaultInjectingSource, FaultInjectingCheckpoint,
# CrashSimulationValidator, DataLossValidator). Must NOT be enabled in production builds.
test-harnesses = []
# Enable CloudEvents 1.0 structured JSON encoding (no additional dependencies).
cloudevents = []
# Enable Protocol Buffer binary encoding via prost.
protobuf = ["dep:prost"]
# Enable Apache Avro binary encoding via apache-avro.
avro = ["dep:apache-avro"]

[dependencies]
async-trait = "0.1.89"
ahash = { version = "0.8.11", features = ["serde"] }
futures-util = "0.3.31"
serde = { version = "1.0.228", features = ["derive"] }
serde_json = "1.0.145"
sha2 = "0.10.9"
thiserror = "2.0.17"
tokio = { version = "1.48.0", features = ["macros", "rt", "signal", "sync", "time"] }
tracing = "0.1.41"
regex = "1.11.1"
wasmparser = "0.240.0"
wasmtime = "24.0.2"
aes-gcm = { version = "0.10.3", optional = true }
base64 = { version = "0.22.1", optional = true }
hkdf = { version = "0.12", optional = true }
hmac = { version = "0.12", optional = true }
opentelemetry = { version = "0.27", features = ["trace", "metrics"], optional = true }
opentelemetry_sdk = { version = "0.27", features = ["trace", "metrics", "rt-tokio"], optional = true }
opentelemetry-otlp = { version = "0.27", features = ["trace", "metrics", "grpc-tonic"], optional = true }
tokio-postgres = { version = "0.7.15", optional = true }
tokio-postgres-rustls = { version = "0.13", optional = true }
zeroize = { version = "1", features = ["alloc"] }
mysql_async = { version = "0.36.2", default-features = false, features = ["minimal", "binlog"], optional = true }
mysql_common = { version = "0.35.5", default-features = false, features = ["binlog"], optional = true }
tiberius = { version = "0.12.3", default-features = false, features = ["tds73", "tokio", "rustls"], optional = true }
tokio-util = { version = "0.7.16", features = ["compat"], optional = true }
rustls = { version = "0.23.19", default-features = false, features = ["std", "ring"], optional = true }
rustls-pemfile = { version = "2.0", optional = true }
rustls-native-certs = { version = "0.8", optional = true }
tokio-rustls = { version = "0.25", optional = true }
prost = { version = "0.13", optional = true }
apache-avro = { version = "0.17", optional = true }

[dev-dependencies]
criterion = "0.7.0"
sqlx = { version = "0.8.6", default-features = false, features = ["runtime-tokio-rustls", "postgres", "mysql", "json"] }
tempfile = "3.23.0"
testcontainers = "0.25.2"
tokio-test = "0.4.4"
tracing-subscriber = { version = "0.3.20", features = ["fmt", "std", "json"] }
reqwest = { version = "0.12.5", default-features = false, features = ["json", "rustls-tls"] }
wasm-bindgen = "0.2.105"
wat = "1.240.0"

[[bench]]
name = "quality_perf"
harness = false

[[bench]]
name = "cdc_perf"
harness = false

[[test]]
name = "fault_injection_soak_matrix"
required-features = ["test-harnesses"]

[[test]]
name = "crash_simulation_integration"
required-features = ["test-harnesses"]

[[test]]
name = "data_loss_detection"
required-features = ["test-harnesses"]