Skip to content
Open
Show file tree
Hide file tree
Changes from 18 commits
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
b1a7ab1
x
chenquan Jan 24, 2026
174f7a1
feat(transaction): Add transaction coordinator, WAL, and idempotency …
chenquan Mar 28, 2026
97775fa
feat(config): Add exactly-once configuration support
chenquan Mar 28, 2026
72f6026
feat(stream): Integrate 2PC protocol into stream output
chenquan Mar 28, 2026
3964ef8
feat(output): Extend Output trait with 2PC support
chenquan Mar 28, 2026
f150cf8
feat(output): Implement 2PC support in Kafka, HTTP, and SQL outputs
chenquan Mar 28, 2026
5dc74d0
feat(engine): Integrate transaction coordinator with engine
chenquan Mar 28, 2026
8bb0799
test(exactly-once): Add comprehensive integration tests
chenquan Mar 28, 2026
0863c2c
docs(exactly-once): Add comprehensive documentation and examples
chenquan Mar 28, 2026
e878be1
chore: Update Cargo.toml dependencies for exactly-once support
chenquan Mar 28, 2026
3ed3274
chore: Apply code formatting and minor fixes
chenquan Mar 28, 2026
30b4cf7
chore(plugin): Apply code formatting and minor fixes
chenquan Mar 28, 2026
5e5d2e3
test(e2e): Add comprehensive end-to-end testing framework
chenquan Mar 28, 2026
5ad83f3
fix(e2e): Fix configuration files for proper schema alignment
chenquan Mar 28, 2026
998552e
test(e2e): Add end-to-end test results report
chenquan Mar 28, 2026
9ff47eb
docs(e2e): Add comprehensive E2E testing summary report
chenquan Mar 28, 2026
d923d33
feat(e2e): Fix configuration issues and enable Exactly-Once semantics
chenquan Mar 28, 2026
5049d4c
docs(p0): Add P0 task completion report
chenquan Mar 28, 2026
7976f9e
test: fix exactly-once config duration format
chenquan Mar 28, 2026
8f358be
x
chenquan Mar 28, 2026
2a8ab23
x
chenquan Mar 29, 2026
d34fe35
x
chenquan Mar 29, 2026
e68b750
x
chenquan Mar 29, 2026
38dddb6
x
chenquan Apr 1, 2026
fc8867a
x
chenquan Apr 1, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
84 changes: 81 additions & 3 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

8 changes: 8 additions & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ serde = { version = "1", features = ["derive"] }
serde_json = "1.0"
serde_yaml = "0.9"
humantime = "2.3.0"
humantime-serde = "1.1"
thiserror = "2.0"
anyhow = "1.0"
tracing = "0.1"
Expand All @@ -37,11 +38,18 @@ protobuf-parse = "3.7.2"
protobuf = "3.7.2"
toml = "0.9"
lazy_static = "1.4"
once_cell = "1.19"
axum = "0.8"
reqwest = { version = "0.12", features = ["json"] }
clap = { version = "4.5", features = ["derive"] }
lru = "0.12"
bincode = "1.3"
colored = "3.0"
flume = "=0.11"
chrono = { version = "0.4", features = ["serde"] }
rmp-serde = "1.1"
zstd = "0.13"
uuid = "1.6"

# Sql
sqlx = { version = "0.8", features = ["mysql", "postgres", "runtime-tokio", "tls-native-tls"] }
Expand Down
Loading
Loading