feat: introduce seatbelt crate

.spelling

@@ -111,6 +111,7 @@ fn
 foldhash
 footguns
 formatter
+frontend
 fundle
 Fundle
 Fundle's
@@ -137,6 +138,7 @@ interop
 Interop
 interoperability
 interoperate
+jitter
 IOCP
 IP
 Kubernetes
@@ -181,6 +183,7 @@ non-mockable
 ns
 nuget
 NUMA
+observability
 ohno
 ok
 Ok
@@ -212,6 +215,7 @@ repo
 repos
 Reqwest
 Reusability
+RPC
 runtime
 runtimes
 rustc

CHANGELOG.md

@@ -14,6 +14,7 @@ Please see each crate's change log below:
 - [`ohno`](./crates/ohno/CHANGELOG.md)
 - [`ohno_macros`](./crates/ohno_macros/CHANGELOG.md)
 - [`recoverable`](./crates/recoverable/CHANGELOG.md)
+- [`seatbelt`](./crates/seatbelt/CHANGELOG.md)
 - [`thread_aware`](./crates/thread_aware/CHANGELOG.md)
 - [`thread_aware_macros`](./crates/thread_aware_macros/CHANGELOG.md)
 - [`thread_aware_macros_impl`](./crates/thread_aware_macros_impl/CHANGELOG.md)

Cargo.toml

@@ -36,6 +36,7 @@ layered = { path = "crates/layered", default-features = false, version = "0.3.0"
 ohno = { path = "crates/ohno", default-features = false, version = "0.3.0" }
 ohno_macros = { path = "crates/ohno_macros", default-features = false, version = "0.3.0" }
 recoverable = { path = "crates/recoverable", default-features = false, version = "0.1.0" }
+seatbelt = { path = "crates/seatbelt", default-features = false, version = "0.2.0" }
 testing_aids = { path = "crates/testing_aids", default-features = false }
 thread_aware = { path = "crates/thread_aware", default-features = false, version = "0.6.1" }
 thread_aware_macros = { path = "crates/thread_aware_macros", default-features = false, version = "0.6.1" }
@@ -51,9 +52,11 @@ criterion = { version = "0.8.1", default-features = false }
 derive_more = { version = "2.0.1", default-features = false }
 duct = { version = "1.1.1", default-features = false }
 dynosaur = { version = "0.3.0", default-features = false }
+fastrand = { version = "2.3.0", default-features = false, features = ["std"] }
 futures = { version = "0.3.31", default-features = false }
 futures-core = { version = "0.3.31", default-features = false }
 futures-util = { version = "0.3.31", default-features = false }
+http = { version = "1.2.0", default-features = false, features = ["std"] }
 infinity_pool = { version = "0.8.1", default-features = false }
 insta = { version = "1.44.1", default-features = false }
 jiff = { version = "0.2.16", default-features = false }
@@ -65,6 +68,9 @@ new_zealand = { version = "1.0.1", default-features = false }
 nm = { version = "0.1.21", default-features = false }
 num-traits = { version = "0.2.19", default-features = false }
 once_cell = { version = "1.21.3", default-features = false }
+opentelemetry = { version = "0.31.0", default-features = false }
+opentelemetry-stdout = { version = "0.31.0", default-features = false }
+opentelemetry_sdk = { version = "0.31.0", default-features = false }
 pin-project-lite = { version = "0.2.13", default-features = false }
 pretty_assertions = { version = "1.4.1", default-features = false }
 prettyplease = { version = "0.2.37", default-features = false }

README.md

@@ -32,6 +32,7 @@ These are the primary crates built out of this repo:
 - [`layered`](./crates/layered/README.md) - A foundational service abstraction for building composable, middleware-driven systems.
 - [`ohno`](./crates/ohno/README.md) - High-quality Rust error handling.
 - [`recoverable`](./crates/recoverable/README.md) - Recovery information and classification for resilience patterns.
+- [`seatbelt`](./crates/seatbelt/README.md) - Resilience and recovery mechanisms for fallible operations.
 - [`thread_aware`](./crates/thread_aware/README.md) - Facilities to support thread-isolated state.
 - [`tick`](./crates/tick/README.md) - Provides primitives to interact with and manipulate machine time.
 

crates/seatbelt/CHANGELOG.md

@@ -0,0 +1,14 @@
+# Changelog
+
+## [0.2.0] - 2026-01-20
+
+Initial release.
+
+- ✨ Features
+
+  - Timeout middleware for canceling long-running operations
+  - Retry middleware with constant, linear, and exponential backoff strategies
+  - Circuit breaker middleware with health-based failure detection and gradual recovery
+  - OpenTelemetry metrics integration (`metrics` feature)
+  - Structured logging via tracing (`logs` feature)
+  - Shared `Context` for clock and telemetry configuration

crates/seatbelt/Cargo.toml

@@ -0,0 +1,118 @@
+# Copyright (c) Microsoft Corporation.
+# Licensed under the MIT License.
+
+[package]
+name = "seatbelt"
+description = "Resilience and recovery mechanisms for fallible operations."
+version = "0.2.0"
+readme = "README.md"
+keywords = ["oxidizer", "resilience", "layered", "recovery", "retry", "breaker"]
+categories = ["data-structures"]
+
+edition.workspace = true
+rust-version.workspace = true
+authors.workspace = true
+license.workspace = true
+homepage.workspace = true
+repository.workspace = true
+
+[package.metadata.cargo_check_external_types]
+allowed_external_types = [
+    "layered::layer::stack::Stack",
+    "layered::service::Service",
+    "opentelemetry::metrics::meter::MeterProvider",
+    "recoverable::Recovery",
+    "recoverable::RecoveryInfo",
+    "recoverable::RecoveryKind",
+    "tick::clock::Clock",
+    "tower_layer::Layer",
+]
+
+[package.metadata.docs.rs]
+all-features = true
+
+[features]
+default = ["timeout", "retry", "breaker"]
+timeout = []
+retry = ["dep:fastrand"]
+breaker = ["dep:fastrand"]
+metrics = ["dep:opentelemetry", "opentelemetry/metrics"]
+logs = ["dep:tracing"]
+
+[dependencies]
+fastrand = { workspace = true, optional = true }
+futures = { workspace = true }
+layered = { workspace = true }
+opentelemetry = { workspace = true, optional = true }
+recoverable = { workspace = true }
+tick = { workspace = true }
+tracing = { workspace = true, optional = true }
+
+[dev-dependencies]
+alloc_tracker.workspace = true
+criterion.workspace = true
+fastrand.workspace = true
+futures = { workspace = true, features = ["executor"] }
+http.workspace = true
+layered = { workspace = true }
+mutants.workspace = true
+ohno = { workspace = true, features = ["app-err"] }
+opentelemetry = { workspace = true, default-features = false, features = ["metrics"] }
+opentelemetry-stdout = { workspace = true, default-features = false, features = ["metrics", "logs"] }
+opentelemetry_sdk = { workspace = true, default-features = false, features = ["metrics", "testing", "experimental_metrics_custom_reader"] }
+static_assertions.workspace = true
+tick = { workspace = true, features = ["test-util", "tokio"] }
+tokio = { workspace = true, features = ["rt", "macros"] }
+tracing.workspace = true
+tracing-subscriber = { workspace = true, features = ["fmt", "std"] }
+
+[[example]]
+name = "timeout"
+required-features = ["timeout"]
+
+[[example]]
+name = "timeout_advanced"
+required-features = ["timeout"]
+
+[[example]]
+name = "retry"
+required-features = ["retry"]
+
+[[example]]
+name = "retry_advanced"
+required-features = ["retry"]
+
+[[example]]
+name = "retry_outage"
+required-features = ["retry"]
+
+[[example]]
+name = "resilience_pipeline"
+required-features = ["retry", "timeout"]
+
+[[example]]
+name = "breaker"
+required-features = ["breaker", "metrics"]
+
+[[bench]]
+name = "observability"
+harness = false
+required-features = ["retry", "logs", "metrics"]
+
+[[bench]]
+name = "timeout"
+harness = false
+required-features = ["timeout"]
+
+[[bench]]
+name = "retry"
+harness = false
+required-features = ["retry"]
+
+[[bench]]
+name = "breaker"
+harness = false
+required-features = ["breaker"]
+
+[lints]
+workspace = true