Implement compaction

Compaction routine is now well-tested. Woot woot! Operator has been updated to pass along retention policy config to stream. Updated deps across all components. closes #99
hadron-project · Nov 5, 2021 · ad08d59 · ad08d59
1 parent ca035e0
commit ad08d59
Show file tree

Hide file tree

Showing 39 changed files with 1,133 additions and 822 deletions.
diff --git a/examples/pipeline-transactional-processing/Cargo.lock b/examples/pipeline-transactional-processing/Cargo.lock
diff --git a/examples/pipeline-transactional-processing/Cargo.toml b/examples/pipeline-transactional-processing/Cargo.toml
@@ -1,16 +1,16 @@
 [package]
 name = "pipeline-txp"
 version = "0.1.0"
-edition = "2018"
+edition = "2021"
 authors = ["Anthony Dodd <dodd.anthonyjosiah@gmail.com>"]
 
 [dependencies]
-anyhow = "1.0.44"
+anyhow = "1"
 hadron = { package = "hadron-client", version = "0.1.0-beta.1" }
 sqlx = { version = "0.5", features = [ "runtime-tokio-rustls", "postgres", "offline", "time" ] }
 tokio = { version = "1", default-features = false, features = [
     # See https://docs.rs/tokio/latest/tokio/#feature-flags
     "rt", "macros", "sync", "signal",
 ]}
 tracing = { version = "0.1", features = ["attributes"] }
-tracing-subscriber = "0.2"
+tracing-subscriber = { version = "0.3", features = ["env-filter", "registry"] }
diff --git a/examples/pipeline-transactional-processing/Dockerfile b/examples/pipeline-transactional-processing/Dockerfile
@@ -1,7 +1,7 @@
 ## Dockerfile for pipeline-transactional-processing (txp) demo app.
 
 # syntax=docker/dockerfile:1.3
-ARG RUST_TAG=1.56.0
+ARG RUST_TAG=1.56.1
 ARG ALPINE_TAG=3.14
 FROM rust:${RUST_TAG}-alpine${ALPINE_TAG} as builder