chore: actor epoxy scoped consensus (#4502)

# Description

Please include a summary of the changes and the related issue. Please also include relevant motivation and context.

## Type of change

- [ ] Bug fix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing functionality to not work as expected)
- [ ] This change requires a documentation update

## How Has This Been Tested?

Please describe the tests that you ran to verify your changes.

## Checklist:

- [ ] My code follows the style guidelines of this project
- [ ] I have performed a self-review of my code
- [ ] I have commented my code, particularly in hard-to-understand areas
- [ ] I have made corresponding changes to the documentation
- [ ] My changes generate no new warnings
- [ ] I have added tests that prove my fix is effective or that my feature works
- [ ] New and existing unit tests pass locally with my changes

Author: NathanFlurry

Cargo.lock

@@ -108,7 +108,7 @@ members = [
   rstest = "0.26.1"
   rustls-pemfile = "2.2.0"
   rustyline = "15.0.0"
-  scc = "3.3.2"
+  scc = "3.6.12"
   semver = "1.0.27"
   serde_bare = "0.5.0"
   serde_html_form = "0.2.7"

Cargo.toml

@@ -593,6 +593,7 @@ pub async fn set_epoxy_kv(
 				}],
 			},
 			purge_cache: true,
+			target_replicas: None,
 		})
 		.await?;
 

engine/artifacts/openapi.json

@@ -146,12 +146,14 @@ pub async fn find_dc_for_actor_creation(
 	} else {
 		// Find the nearest DC with runners
 		let res = ctx
-			.op(pegboard::ops::runner::find_dc_with_runner::Input {
-				namespace_id,
-				runner_name: runner_name.into(),
-			})
+			.op(
+				pegboard::ops::runner::list_runner_config_enabled_dcs::Input {
+					namespace_id,
+					runner_name: runner_name.into(),
+				},
+			)
 			.await?;
-		if let Some(dc_label) = res.dc_label {
+		if let Some(dc_label) = res.dc_labels.into_iter().next() {
 			dc_label
 		} else {
 			return Err(pegboard::errors::Actor::NoRunnersAvailable {

engine/packages/api-peer/src/internal.rs

@@ -85,15 +85,12 @@ async fn delete_inner(ctx: ApiCtx, path: DeletePath, query: DeleteQuery) -> Resu
 		.await?
 		.ok_or_else(|| namespace::errors::Namespace::NotFound.build())?;
 
-	// Purge cache
-	ctx.cache()
-		.clone()
-		.request()
-		.purge(
-			"namespace.runner_config.get",
-			vec![(namespace.namespace_id, path.runner_name.clone())],
-		)
-		.await?;
+	pegboard::utils::purge_runner_config_caches(
+		ctx.cache(),
+		namespace.namespace_id,
+		&path.runner_name,
+	)
+	.await?;
 
 	Ok(DeleteResponse {})
 }

engine/packages/api-public/src/actors/utils.rs

@@ -184,15 +184,12 @@ async fn upsert_inner(
 		}
 	}
 
-	// Purge cache
-	ctx.cache()
-		.clone()
-		.request()
-		.purge(
-			"namespace.runner_config.get",
-			vec![(namespace.namespace_id, path.runner_name.clone())],
-		)
-		.await?;
+	pegboard::utils::purge_runner_config_caches(
+		ctx.cache(),
+		namespace.namespace_id,
+		&path.runner_name,
+	)
+	.await?;
 
 	Ok(UpsertResponse {
 		endpoint_config_changed: any_endpoint_config_changed,

engine/packages/api-public/src/runner_configs/delete.rs

@@ -324,6 +324,7 @@ fn list_runner_configs_filter_by_variant_serverless() {
 					min_runners: Some(1),
 					max_runners: 5,
 					runners_margin: Some(2),
+					metadata_poll_interval: None,
 				},
 				metadata: None,
 				drain_on_version_upgrade: true,
@@ -458,6 +459,7 @@ fn list_runner_configs_validates_returned_data() {
 					min_runners: Some(2),
 					max_runners: 10,
 					runners_margin: Some(3),
+					metadata_poll_interval: None,
 				},
 				metadata: Some(serde_json::json!({"key": "value"})),
 				drain_on_version_upgrade: true,
@@ -573,6 +575,7 @@ fn list_runner_configs_mixed_variants() {
 					min_runners: Some(1),
 					max_runners: 5,
 					runners_margin: Some(2),
+					metadata_poll_interval: None,
 				},
 				metadata: None,
 				drain_on_version_upgrade: true,

engine/packages/api-public/src/runner_configs/upsert.rs

@@ -98,6 +98,7 @@ fn upsert_runner_config_serverless() {
 					min_runners: Some(1),
 					max_runners: 5,
 					runners_margin: Some(2),
+					metadata_poll_interval: None,
 				},
 				metadata: None,
 				drain_on_version_upgrade: true,
@@ -518,6 +519,7 @@ fn upsert_runner_config_overwrites_different_variant() {
 					min_runners: Some(1),
 					max_runners: 5,
 					runners_margin: Some(2),
+					metadata_poll_interval: None,
 				},
 				metadata: None,
 				drain_on_version_upgrade: true,
@@ -617,6 +619,7 @@ fn upsert_runner_config_serverless_slots_per_runner_zero() {
 					min_runners: Some(1),
 					max_runners: 5,
 					runners_margin: Some(2),
+					metadata_poll_interval: None,
 				},
 				metadata: None,
 				drain_on_version_upgrade: true,

engine/packages/engine/tests/api_runner_configs_list.rs

@@ -328,6 +328,7 @@ async fn restart_phase1(
 		.op(crate::ops::propose::Input {
 			proposal,
 			purge_cache: false,
+			target_replicas: None,
 		})
 		.await?;