docs: populate CHANGELOG for 1.2.0-1.18.0 feature history

.hermes/plans/mytheclipse-round16-spec.md

@@ -0,0 +1,33 @@
+# Implementation Spec: Round 16 — COMPLETE
+
+## Goal
+Make the round-7-15 abstractions actually usable — a single, runnable, wired
+example showing high-level primitives composing together.
+
+## New File
+
+### examples/high_level.rs (mytheclipse-core)
+`crates/mytheclipse/examples/high_level.rs`
+- One realistic flow demoing, wired together:
+  1. RuntimeConfig::auto() — auto thread/core sizing from host CPU
+  2. parallel_map — bounded fan-out + AggregateError
+  3. RetryExt — ergonomic .retry() on a Future
+  4. ShutdownGuard — RAII exactly-once cleanup
+  5. AutoReconnectPool — self-healing resource pool (dead value replaced)
+  6. AutoMetricsServiceBuilder — auto latency/outcome metrics
+- Run: `cargo run -p mytheclipse --features full --example high_level`
+
+## Verified Output (real run, 8-core host)
+```
+1. RuntimeConfig::auto() -> worker=8, blocking=12, compute=8, io=4
+2. parallel_map -> [10, 20, 30, 40, 50]
+3. RetryExt with 4 attempts -> 42
+4. ShutdownGuard fired 1x (exactly-once, even on unwind)
+5. AutoReconnectPool first acquire -> 999
+6. AutoMetrics -> 1 counters, 1 histograms
+```
+
+## Files
+- new: crates/mytheclipse/examples/high_level.rs
+
+Build: exit 0. Run: succeeds (verified above).

crates/mytheclipse/CHANGELOG.md

@@ -1,3 +1,119 @@
+# [1.18.0](https://github.com/asepharyana/mytheclipse/compare/v1.17.0...v1.18.0) (2026-08-29)
+
+### Documentation
+
+* add `high_level` example wiring round-7-15 abstractions (RuntimeConfig, parallel_map, RetryExt, ShutdownGuard, AutoReconnectPool, AutoMetricsServiceBuilder)
+
+# [1.17.0](https://github.com/asepharyana/mytheclipse/compare/v1.16.0...v1.17.0) (2026-08-29)
+
+### Features
+
+* **parallel_map:** add `parallel_for_each` streaming bounded fan-out (no full input materialization)
+
+# [1.16.0](https://github.com/asepharyana/mytheclipse/compare/v1.15.0...v1.16.0) (2026-08-29)
+
+### Features
+
+* **parallel_map:** add `parallel_map` / `parallel_map_unordered` bounded fan-out with AggregateError
+
+# [1.15.0](https://github.com/asepharyana/mytheclipse/compare/v1.14.0...v1.15.0) (2026-08-29)
+
+### Features
+
+* **aggregate_error:** add `AggregateError` for parallel/fan-out error aggregation
+
+# [1.14.0](https://github.com/asepharyana/mytheclipse/compare/v1.13.0...v1.14.0) (2026-08-29)
+
+### Features
+
+* **pool:** add `AutoReconnectPool` + `Reconnectable` self-healing resource pool
+
+# [1.13.0](https://github.com/asepharyana/mytheclipse/compare/v1.12.0...v1.13.0) (2026-08-29)
+
+### Features
+
+* **runtime_auto:** add `RuntimeConfig` auto thread/core allocation + `ShutdownGuard` RAII
+
+# [1.12.0](https://github.com/asepharyana/mytheclipse/compare/v1.11.0...v1.12.0) (2026-08-29)
+
+### Features
+
+* **auto_metrics:** add `AutoMetricsServiceBuilder` (metrics + [mytheclipse-queue](crates/mytheclipse-queue) `RateLimitedWorkerPool`)
+
+# [1.11.0](https://github.com/asepharyana/mytheclipse/compare/v1.10.0...v1.11.0) (2026-08-29)
+
+### Features
+
+* **retry_ext:** add ergonomic `RetryExt` Future extension — also covers ResilientHttpClient from [mytheclipse-http](crates/mytheclipse-http)
+
+# [1.10.0](https://github.com/asepharyana/mytheclipse/compare/v1.9.0...v1.10.0) (2026-08-29)
+
+### Features
+
+* **http:** add `ResilientHttpClient` ([mytheclipse-http](crates/mytheclipse-http)) with retry + circuit breaker + timeout
+* **middleware:** add composable `MiddlewarePipeline`
+* **bg_join:** add `BgJoiner` graceful task joiner
+
+# [1.9.0](https://github.com/asepharyana/mytheclipse/compare/v1.8.0...v1.9.0) (2026-08-28)
+
+### Features
+
+* **bg_join:** add `BgJoiner` graceful task joiner
+* **middleware:** add composable `MiddlewarePipeline`
+* **queue:** add `RateLimitedQueue` ([mytheclipse-queue](crates/mytheclipse-queue))
+
+# [1.8.0](https://github.com/asepharyana/mytheclipse/compare/v1.7.0...v1.8.0) (2026-08-28)
+
+### Features
+
+* **pool_health:** add `HealthCheckedPool`
+* **crypto:** add `HkdfKeyDeriver` ([mytheclipse-crypto](crates/mytheclipse-crypto))
+* **queue:** add `BackpressureEnforcer` / `enqueue_with_backpressure`
+
+# [1.7.0](https://github.com/asepharyana/mytheclipse/compare/v1.6.0...v1.7.0) (2026-08-28)
+
+### Features
+
+* **batch:** add `BatchProcessor` & `BatchJobHandler`
+* **health:** add `CircuitBreakerHealthCheck` / `MetricsHealthCheck`
+* **crypto:** add `TypedKeyRegistry`
+* **http:** add `MetricsHttpHandler`
+
+# [1.6.0](https://github.com/asepharyana/mytheclipse/compare/v1.5.0...v1.6.0) (2026-08-28)
+
+### Features
+
+* **circuit_breaker:** add snapshot metrics
+* **retry:** add `RetryStats`
+* lifecycle fixes
+
+# [1.5.0](https://github.com/asepharyana/mytheclipse/compare/v1.4.1...v1.5.0) (2026-08-28)
+
+### Features
+
+* **validation:** add `ConfigValidator`
+* **lifecycle:** add `AsyncLifecycleManager`
+* **metrics:** add `MetricsBridge`
+* **ratelimit:** rate limiter pre-acquire
+
+# [1.4.0](https://github.com/asepharyana/mytheclipse/compare/v1.3.5...v1.4.0) (2026-08-28)
+
+### Features
+
+* add 4 new crates: [mytheclipse-queue](crates/mytheclipse-queue), [mytheclipse-tracing](crates/mytheclipse-tracing), [mytheclipse-http](crates/mytheclipse-http), [mytheclipse-cli](crates/mytheclipse-cli)
+
+# [1.3.0](https://github.com/asepharyana/mytheclipse/compare/v1.2.0...v1.3.0) (2026-08-28)
+
+### Features
+
+* add [mytheclipse-storage](crates/mytheclipse-storage) crate for unified storage abstraction
+
+# [1.2.0](https://github.com/asepharyana/mytheclipse/compare/v1.1.0...v1.2.0) (2026-08-28)
+
+### Features
+
+* add panic tracking and logging with `PanicTracker`
+
 # [1.1.0](https://github.com/asepharyana/mytheclipse/compare/v1.0.0...v1.1.0) (2026-08-28)
 
 

crates/mytheclipse/examples/high_level.rs

@@ -0,0 +1,134 @@
+//! End-to-end demo of the high-level (round 7-15) abstractions in `mytheclipse`.
+//!
+//! Run with: `cargo run -p mytheclipse --features full --example high_level`
+//!
+//! Demonstrates, wired together in one realistic flow:
+//!   - `RuntimeConfig::auto()`  — auto thread/core sizing from the host CPU
+//!   - `parallel_map`           — bounded fan-out with AggregateError
+//!   - `RetryExt`               — ergonomic `.retry()` on a Future
+//!   - `ShutdownGuard`          — RAII cleanup guaranteed even on panic
+//!   - `AutoReconnectPool`      — self-healing resource pool
+//!   - `AutoMetricsServiceBuilder` — service calls that auto-record metrics
+
+use std::sync::atomic::{AtomicU32, Ordering};
+use std::sync::Arc;
+use std::time::Duration;
+
+use mytheclipse::{
+    aggregate_error::AggregateError,
+    auto_metrics_service::AutoMetricsServiceBuilder,
+    parallel_map::parallel_map,
+    pool::{AutoReconnectPool, Pool, Reconnectable, SemaphorePool},
+    retry_ext::RetryExt,
+    runtime_auto::RuntimeConfig,
+    shutdown_guard::ShutdownGuard,
+    service_builder::ServiceConfig,
+};
+
+#[tokio::main]
+async fn main() {
+    println!("== mytheclipse high-level abstractions demo ==");
+
+    // 1. Auto thread/core allocation from host CPU topology.
+    let cfg = RuntimeConfig::auto();
+    println!(
+        "1. RuntimeConfig::auto() -> worker={}, blocking={}, compute={}, io={}",
+        cfg.worker_threads, cfg.max_blocking_threads, cfg.compute_threads, cfg.io_threads
+    );
+
+    // 2. Bounded parallel fan-out with automatic error aggregation.
+    let results: Result<Vec<i32>, AggregateError> =
+        parallel_map(vec![1, 2, 3, 4, 5], 2, |x| async move {
+            tokio::time::sleep(Duration::from_millis(10)).await;
+            Ok::<_, std::io::Error>(x * 10)
+        })
+        .await;
+    println!("2. parallel_map -> {:?}", results.unwrap());
+
+    // 3. Ergonomic retry on a Future.
+    let attempts = Arc::new(AtomicU32::new(0));
+    let a = Arc::clone(&attempts);
+    let cfg = mytheclipse::retry::RetryConfig {
+        max_attempts: 4,
+        base_delay: Duration::from_millis(1),
+        ..Default::default()
+    };
+    let fut = async { Err::<u32, String>("boom".into()) };
+    let op = move || {
+        let a = Arc::clone(&a);
+        async move {
+            let n = a.fetch_add(1, Ordering::SeqCst);
+            if n < 3 {
+                Err::<u32, String>("transient".into())
+            } else {
+                Ok(42u32)
+            }
+        }
+    };
+    let value = fut.retry(cfg, |_: &String| true, op).await.unwrap();
+    println!("3. RetryExt with {} attempts -> {value}", attempts.load(Ordering::SeqCst));
+
+    // 4. RAII ShutdownGuard — callback runs exactly once on drop, panic-safe.
+    let fired = Arc::new(AtomicU32::new(0));
+    let f = Arc::clone(&fired);
+    {
+        let _guard = ShutdownGuard::new(move || {
+            f.fetch_add(1, Ordering::SeqCst);
+        });
+    } // guard dropped -> callback fires
+    println!(
+        "4. ShutdownGuard fired {}x (exactly-once, even on unwind)",
+        fired.load(Ordering::SeqCst)
+    );
+
+    // 5. AutoReconnectPool — transparently replaces dead resources.
+    let auto = AutoReconnectPool::new(SemaphorePool::new(vec![1u32, 2u32]), Probe { dead: 1 });
+    let first = auto.acquire().await.unwrap().resource;
+    // Never the dead value (1) once the probe rejects it.
+    println!("5. AutoReconnectPool first acquire -> {first}");
+
+    // 6. AutoMetricsServiceBuilder — auto records latency + outcome counters.
+    let mut svc_cfg = ServiceConfig::default();
+    svc_cfg.max_attempts = 2;
+    let svc = AutoMetricsServiceBuilder::new("demo_op", svc_cfg);
+    let n = Arc::new(AtomicU32::new(0));
+    let n2 = Arc::clone(&n);
+    let _: Result<u32, mytheclipse::service_builder::RunError<()>> = svc.run(|| {
+        let n2 = Arc::clone(&n2);
+        Box::pin(async move {
+            tokio::time::sleep(Duration::from_millis(5)).await;
+            let v = n2.fetch_add(1, Ordering::SeqCst);
+            if v < 1 {
+                Err(())
+            } else {
+                Ok(7u32)
+            }
+        })
+    }).await;
+    let snap = svc.collector().snapshot();
+    println!(
+        "6. AutoMetrics -> {} counters, {} histograms",
+        snap.counters.len(),
+        snap.histograms.len()
+    );
+
+    println!("== demo complete ==");
+}
+
+/// A [`Reconnectable`] probe that rejects any value matching `dead`.
+struct Probe {
+    dead: u32,
+}
+
+#[async_trait::async_trait]
+impl Reconnectable for Probe {
+    type Item = u32;
+
+    fn is_healthy(&self, item: &Self::Item) -> bool {
+        *item != self.dead
+    }
+
+    async fn reconnect(&self) -> Result<Self::Item, Box<dyn std::error::Error + Send + Sync>> {
+        Ok(999)
+    }
+}