Worker event stream

Cargo.toml

@@ -114,6 +114,7 @@ reqwest = { version = "0.13", default-features = false, features = [
     "rustls",
     "stream",
 ] }
+rustls = { version = "0.23", features = ["ring"] }
 schemars = "1.0.4"
 semver = { version = "1.0.18", features = ["serde"] }
 serde = { version = "1.0", features = ["derive"] }
@@ -142,6 +143,7 @@ url = { version = "2.5.0", features = ["serde"] }
 uuid = { version = "1.11.0", features = ["v7"] }
 nix = { version = "0.30.1", default-features = false, features = ["signal"] }
 percent-encoding = "2.3"
+webpki-roots = "0.26"
 which = "8.0.0"
 zstd = "0.13.3"
 

crates/bin/ampd/Cargo.toml

@@ -26,6 +26,7 @@ amp-providers-registry = { path = "../../core/providers-registry" }
 metadata-db = { path = "../../core/metadata-db" }
 metadata-db-postgres = { path = "../../services/metadata-db-postgres" }
 monitoring = { path = "../../core/monitoring" }
+rustls.workspace = true
 server = { path = "../../services/server" }
 snmalloc-rs = { version = "0.3.4", optional = true }
 thiserror.workspace = true

crates/bin/ampd/src/main.rs

@@ -77,6 +77,12 @@ async fn main() {
 }
 
 async fn main_inner() -> Result<(), Error> {
+    // Install rustls crypto provider before any TLS operations.
+    // Required when both ring and aws-lc-rs are available in the dependency tree.
+    rustls::crypto::ring::default_provider()
+        .install_default()
+        .expect("Failed to install default crypto provider");
+
     // Initialize tokio-console subscriber if feature is enabled
     #[cfg(feature = "console-subscriber")]
     {

crates/bin/ampd/src/solo_cmd.rs

@@ -186,6 +186,7 @@ pub async fn run(
         dataset_store,
         meter,
         worker_id,
+        None, // Use config-based event emitter
     )
     .await
     .map_err(Error::WorkerInit)?;

crates/bin/ampd/src/worker_cmd.rs

@@ -66,6 +66,7 @@ pub async fn run(
         dataset_store,
         meter,
         node_id,
+        None, // Use config-based event emitter
     )
     .await
     .map_err(Error::Init)?;
@@ -126,5 +127,6 @@ pub(crate) fn config_from_common(config: &Config) -> worker::config::Config {
         query_max_mem_mb: config.query_max_mem_mb,
         spill_location: config.spill_location.clone(),
         parquet: config.parquet.clone(),
+        events_config: config.worker_events.clone(),
     }
 }

crates/config/src/config_file.rs

@@ -193,9 +193,17 @@ pub struct ConfigFile {
     // Writer/Parquet configuration
     #[serde(default)]
     pub writer: ParquetConfig,
+
+    // Worker event streaming configuration
+    #[serde(default)]
+    pub worker_events: crate::WorkerEventsConfig,
 }
 
 impl ConfigFile {
+    /// Returns the worker events configuration.
+    pub fn worker_events(&self) -> &crate::WorkerEventsConfig {
+        &self.worker_events
+    }
     /// Returns the data directory path where Parquet files are stored.
     pub fn data_dir(&self) -> &str {
         &self.data_dir