Skip to content

Add native celld config, KV and conditional record providers #422

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ChristianPavilonis wants to merge 18 commits into from
+9,135 −263
Open

Add native celld config, KV and conditional record providers #422

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
57374e4
feat(stores): add native celld config and KV providers
ChristianPavilonis Nov 10, 2026
d475727
Merge verified lower-stack namespace and CI fixes
ChristianPavilonis Nov 10, 2026
6a580d1
fix(axum): account for feature-disabled async preparation lints
ChristianPavilonis Nov 10, 2026
6778e01
Merge managed demo logging regression alignment
ChristianPavilonis Nov 10, 2026
b0b4df7
Merge provider-disabled asynchronous lint contract repair
ChristianPavilonis Nov 10, 2026
d08fc8f
Merge fixture failure redaction into celld provider stack
ChristianPavilonis Nov 10, 2026
0d17257
Merge native-only scaffold correction into celld provider stack
ChristianPavilonis Nov 10, 2026
48c34ed
Merge native AWS readiness fixes into celld provider stack
ChristianPavilonis Nov 10, 2026
f9b0f20
Merge SDK cohort and inherited fixture readiness fixes
ChristianPavilonis Nov 10, 2026
5b2517f
Carry authenticated head preparation through the review stack
ChristianPavilonis Nov 12, 2026
e8d72d5
Carry prepared-router installation through the review stack
ChristianPavilonis Nov 12, 2026
576f35c
Merge current parent repairs into PR 422
ChristianPavilonis Nov 12, 2026
071cb06
Retain AWS fixture lifetime repair in PR 422
ChristianPavilonis Nov 12, 2026
bb56cfe
Retain callback-scope fixture repair in PR 422
ChristianPavilonis Nov 12, 2026
ef1d4ab
Merge owned cutover follow-up through PR 422
ChristianPavilonis Nov 13, 2026
1c90b24
feat(celld): expose conditional and physical record operations
ChristianPavilonis Nov 10, 2026
4ea3199
Merge PR #414 into PR #422 for outbound compatibility stack
ChristianPavilonis Nov 13, 2026
f1d8558
Merge PR #414 into PR #422 for outbound compatibility stack
aram356 Nov 14, 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
21 changes: 19 additions & 2 deletions .github/workflows/test.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -195,6 +195,17 @@ jobs:
cargo test --offline --locked -p edgezero-store-aws --all-features --lib
scripts/run_test_nonzero.sh production_runner_loads_envelope_and_real_sdk_secret_before_serving_mixed_stores cargo test --offline --locked -p edgezero-adapter-axum --features aws-stores,test-utils --test native_aws_startup

- name: Native celld independent provider and startup contracts (loopback only)
if: matrix.suite == 'workspace'
run: |
cargo test --offline --locked -p edgezero-store-celld --no-default-features --lib
cargo test --offline --locked -p edgezero-store-celld --no-default-features --features config --lib
cargo test --offline --locked -p edgezero-store-celld --no-default-features --features kv --lib
cargo test --offline --locked -p edgezero-store-celld --all-features --lib
cargo test --offline --locked -p edgezero-adapter-axum --no-default-features --features native-bindings --lib
cargo test --offline --locked -p edgezero-adapter-axum --features celld-config,celld-kv,test-utils --test native_celld_startup
cargo test --offline --locked -p edgezero-adapter-axum --features aws-stores,aws-dynamodb,celld-config,celld-kv,test-utils --lib --test native_aws_startup --test native_celld_startup
Comment on lines +206 to +207

@aram356 aram356 Nov 11, 2026

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🔧 The new celld startup suites aren't protected against "0 passed"

The AWS step above (line 196) wraps its suite in scripts/run_test_nonzero.sh; these two lines don't. The mixed test production_runner_composes_celld_config_aws_secret_and_local_secret (native_aws_startup.rs:498) is behind #[cfg(feature = "celld-config")] and runs only from line 207. A typo in that cfg or in a feature name would compile it out, and the step would stay green. The plan lists this wrapper as an open item.

Fix:

scripts/run_test_nonzero.sh public_runner_gates_preparation_and_initializer_then_keeps_snapshot_and_live_kv cargo test --offline --locked -p edgezero-adapter-axum --features celld-config,celld-kv,test-utils --test native_celld_startup
scripts/run_test_nonzero.sh production_runner_composes_celld_config_aws_secret_and_local_secret cargo test --offline --locked -p edgezero-adapter-axum --features aws-stores,aws-dynamodb,celld-config,celld-kv,test-utils --lib --test native_aws_startup --test native_celld_startup

@prk-Jr prk-Jr Nov 12, 2026

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🔧 The same gap on the five --lib steps just above (lines 201-205)

The celld lib runs (no features, config, kv, all features) and the axum native-bindings --lib run aren't wrapped in run_test_nonzero.sh either. The celld test modules are behind feature conditions (client.rs:331 #[cfg(any(feature = "config", feature = "kv"))], config.rs:52, kv.rs:334). An accidental change to one of those conditions would quietly reduce the config-only or kv-only run to the 4 settings tests, and the step would still exit 0.

Fix: wrap each line with run_test_nonzero.sh and a test name that must run for that feature mode.


- name: Bundled demo logging and fallback TCP contracts
if: matrix.suite == 'cli'
run: |
Expand Down Expand Up @@ -248,9 +259,15 @@ jobs:
EDGEZERO_GENERATED_TEST_TARGET_DIR: ${{ github.workspace }}/target
run: scripts/run_test_nonzero.sh --ignored generated_cli_default_off_and_enabled_dynamodb_crud_list_ttl_restart cargo test --offline --locked -p edgezero-cli --test dynamodb_generated_proof

- name: Native AWS integration runner tests
- name: Generated native celld startup and KV (deterministic loopback fixture)
if: matrix.suite == 'cli'
env:
EDGEZERO_GENERATED_TEST_TARGET_DIR: ${{ github.workspace }}/target
run: scripts/run_test_nonzero.sh --ignored generated_celld_default_off_kv_and_config_restart cargo test --offline --locked -p edgezero-cli --no-default-features --features cli,edgezero-adapter-axum --test celld_generated_proof generated_celld_default_off_kv_and_config_restart

- name: Native provider integration runner tests
if: matrix.suite == 'cli'
run: node --test scripts/native_aws_test_admin.test.mjs scripts/run_native_aws_integration.test.mjs
run: node --test scripts/native_aws_test_admin.test.mjs scripts/run_native_aws_integration.test.mjs scripts/run_native_celld_integration.test.mjs

- name: Generated native AWS independent service contracts
if: matrix.suite == 'cli'
Expand Down
22 changes: 22 additions & 0 deletions Cargo.lock
View file
Open in desktop

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

2 changes: 2 additions & 0 deletions Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ members = [
"crates/edgezero-core",
"crates/edgezero-macros",
"crates/edgezero-store-aws",
"crates/edgezero-store-celld",
]
exclude = ["examples/app-demo", "crates/edgezero-test-harness"]
resolver = "2"
Expand Down Expand Up @@ -65,6 +66,7 @@ edgezero-adapter-fastly = { path = "crates/edgezero-adapter-fastly", default-fea
edgezero-adapter-spin = { path = "crates/edgezero-adapter-spin", default-features = false }
edgezero-core = { path = "crates/edgezero-core", default-features = false }
edgezero-store-aws = { path = "crates/edgezero-store-aws", default-features = false }
edgezero-store-celld = { path = "crates/edgezero-store-celld", default-features = false }
edgezero-cli = { path = "crates/edgezero-cli", default-features = false }
fastly = "=0.13.1"
fastly-shared = "=0.13.1"
Expand Down
16 changes: 15 additions & 1 deletion crates/edgezero-adapter-axum/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,11 +28,13 @@ axum = [
"dep:reqwest",
"dep:redb",
]
native-bindings = ["dep:toml", "dep:edgezero-store-aws"]
native-bindings = ["dep:toml", "dep:edgezero-store-aws", "dep:edgezero-store-celld"]
aws-appconfig-agent = ["axum", "edgezero-store-aws/appconfig-agent"]
aws-secrets-manager = ["axum", "edgezero-store-aws/secrets-manager"]
aws-stores = ["aws-appconfig-agent", "aws-secrets-manager"]
aws-dynamodb = ["axum", "edgezero-store-aws/dynamodb-kv"]
celld-config = ["axum", "edgezero-store-celld/config"]
celld-kv = ["axum", "edgezero-store-celld/kv"]
cli = [
"native-bindings",
"dep:edgezero-adapter",
Expand Down Expand Up @@ -78,6 +80,7 @@ walkdir = { workspace = true, optional = true }

[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
edgezero-store-aws = { workspace = true, optional = true }
edgezero-store-celld = { workspace = true, optional = true }

[target.'cfg(unix)'.dependencies]
libc = { workspace = true }
Expand All @@ -99,6 +102,17 @@ name = "native_aws_startup"
path = "tests/native_aws_startup.rs"
required-features = ["aws-stores", "test-utils"]

[[bin]]
name = "edgezero-native-celld-host"
path = "tests/fixtures/native_celld_host.rs"
required-features = ["celld-config", "celld-kv", "test-utils"]
test = false

[[test]]
name = "native_celld_startup"
path = "tests/native_celld_startup.rs"
required-features = ["celld-config", "celld-kv", "test-utils"]

[dev-dependencies]
async-trait = { workspace = true }
axum = { workspace = true, features = ["macros"] }
Expand Down
14 changes: 4 additions & 10 deletions crates/edgezero-adapter-axum/src/dev_server.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1373,12 +1373,10 @@ async fn build_production_stores(
let mut kv = BTreeMap::new();
let mut secrets = BTreeMap::new();
let mut resident = 0_usize;
let mut aws = sources.session()?;
let mut sessions = sources.sessions()?;
for (id, source) in sources.config {
let binding = match source {
NativeStoreSource::BuiltIn(builtin) => {
native_stores::prepare_aws_config(builtin, &mut aws, id).await?
}
NativeStoreSource::BuiltIn(builtin) => sessions.prepare_config(builtin, id).await?,
local @ (NativeStoreSource::Local
| NativeStoreSource::Ready(_)
| NativeStoreSource::Prepare(_)) => {
Expand Down Expand Up @@ -1439,9 +1437,7 @@ async fn build_production_stores(
}
for (id, source) in sources.kv {
let handle = match source {
NativeStoreSource::BuiltIn(builtin) => {
native_stores::prepare_aws_kv(builtin, &mut aws, id).await?
}
NativeStoreSource::BuiltIn(builtin) => sessions.prepare_kv(builtin, id).await?,
local @ (NativeStoreSource::Local
| NativeStoreSource::Ready(_)
| NativeStoreSource::Prepare(_)) => {
Expand All @@ -1467,9 +1463,7 @@ async fn build_production_stores(
let environment_secrets = SecretHandle::new(Arc::new(EnvSecretStore::new()));
for (id, source) in sources.secrets {
let binding = match source {
NativeStoreSource::BuiltIn(builtin) => {
native_stores::prepare_aws_secrets(builtin, &mut aws, id).await?
}
NativeStoreSource::BuiltIn(builtin) => sessions.prepare_secrets(builtin, id).await?,
local @ (NativeStoreSource::Local
| NativeStoreSource::Ready(_)
| NativeStoreSource::Prepare(_)) => {
Expand Down
Loading
Loading