Skip to content

Commit c07bec7

Browse files
Create an interface for consuming data that fixes #5.
Create Consumer and ConsumerFactory traits. Implement CDCRow struct that represents data passed to the consumer. Implement CDCRowSchema that contains info about column order in the CDC table. Create tests for Consumer module.
1 parent cbb8776 commit c07bec7

File tree

3 files changed

+488
-0
lines changed

3 files changed

+488
-0
lines changed

scylla-cdc/Cargo.toml

+2
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,8 @@ scylla = "0.3.0"
1111
tokio = { version = "1.1.0", features = ["rt", "io-util", "net", "time", "macros", "sync"] }
1212
chrono = "0.4.19"
1313
futures = "0.3.17"
14+
uuid = "0.8.2"
15+
num_enum = "0.5.4"
1416

1517
[dev-dependencies]
1618
hex = "0.4.3"

0 commit comments

Comments
 (0)