Reproduce Azure failed-fill egress across four real workers

.github/styles/config/vocabularies/TraceMachina/accept.txt

@@ -492,3 +492,4 @@ Flybody
 MuJoCo
 connectome
 simulatable
+Zipf

Cargo.toml

@@ -82,6 +82,33 @@ tonic = { version = "0.14.0", features = [
 tower = { version = "0.5.2", default-features = false }
 tracing = { version = "0.1.41", default-features = false }
 
+[dev-dependencies]
+axum = { version = "0.8.3", default-features = false, features = [
+  "http1",
+  "query",
+  "tokio",
+] }
+azure_core = { version = "1", default-features = false, features = [
+  "reqwest",
+  "tokio",
+] }
+azure_storage_blob = { version = "1", default-features = false, features = [
+  "tokio",
+] }
+libc = { version = "0.2.183", default-features = false }
+prost = { version = "0.14.4", default-features = false }
+prost-types = { version = "0.14.4", default-features = false }
+reqwest = { version = "0.13", default-features = false, features = ["stream"] }
+serde = { version = "1.0.219", default-features = false, features = ["derive"] }
+serde_json = { version = "1.0.140", default-features = false, features = [
+  "std",
+] }
+tokio = { version = "1.52.2", default-features = false, features = ["io-std"] }
+tracing-subscriber = { version = "0.3.19", default-features = false, features = [
+  "env-filter",
+  "fmt",
+] }
+
 [workspace.cargo-features-manager.keep]
 async-lock = ["std"]
 aws-sdk-s3 = ["rt-tokio"]

examples/azure_fleet/BUILD.bazel

@@ -0,0 +1,61 @@
+load("@rules_rust//rust:defs.bzl", "rust_binary", "rust_test")
+
+_SOURCES = [
+    "account.rs",
+    "main.rs",
+    "node.rs",
+    "workload.rs",
+]
+
+_COMPILE_DATA = ["//nativelink-store:tests/fixtures/azure_download_response.json"]
+
+_DEPS = [
+    "//nativelink-config",
+    "//nativelink-proto",
+    "//nativelink-scheduler",
+    "//nativelink-service",
+    "//nativelink-store",
+    "//nativelink-util",
+    "//nativelink-worker",
+    "@crates//:axum",
+    "@crates//:azure_core",
+    "@crates//:azure_storage_blob",
+    "@crates//:bytes",
+    "@crates//:clap",
+    "@crates//:futures",
+    "@crates//:hex",
+    "@crates//:libc",
+    "@crates//:prost",
+    "@crates//:prost-types",
+    "@crates//:reqwest",
+    "@crates//:serde",
+    "@crates//:serde_json",
+    "@crates//:sha2",
+    "@crates//:tokio",
+    "@crates//:tokio-rustls",
+    "@crates//:tonic",
+    "@crates//:tracing-subscriber",
+]
+
+# The complete experiment runs explicitly: it needs unshare, mount, taskset,
+# and a writable output directory. Ordinary tests exercise the account's real
+# SDK transport and disk accounting without mounting filesystems or running a fleet.
+rust_binary(
+    name = "azure_fleet",
+    srcs = _SOURCES,
+    compile_data = _COMPILE_DATA,
+    crate_root = "main.rs",
+    target_compatible_with = ["@platforms//os:linux"],
+    deps = _DEPS,
+)
+
+rust_test(
+    name = "azure_fleet_test",
+    size = "small",
+    timeout = "short",
+    srcs = _SOURCES,
+    compile_data = _COMPILE_DATA,
+    crate_root = "main.rs",
+    target_compatible_with = ["@platforms//os:linux"],
+    deps = _DEPS,
+)