feat(rust/engine-runner): minimal rust engine runner (#4289)

# 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

CLAUDE.md

@@ -211,6 +211,11 @@ When the user asks to track something in a note, store it in `.agent/notes/` by
 - **Shared Libraries** (`shared/{language}/{package}/`) - Libraries shared between the engine and rivetkit (e.g., `shared/typescript/virtual-websocket/`)
 - **Service Infrastructure** - Distributed services communicate via NATS messaging with service discovery
 
+### Engine Runner Parity
+- Keep `engine/sdks/typescript/runner` and `engine/sdks/rust/engine-runner` at feature parity.
+- Any behavior, protocol handling, or test coverage added to one runner should be mirrored in the other runner in the same change whenever possible.
+- When parity cannot be completed in the same change, explicitly document the gap and add a follow-up task.
+
 ### Important Patterns
 
 **Error Handling**

engine/packages/engine/tests/runner/actors_alarm.rs

@@ -140,7 +140,7 @@ impl AlarmAndSleepActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmAndSleepActor {
+impl Actor for AlarmAndSleepActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm actor starting");
@@ -195,7 +195,7 @@ impl AlarmAndSleepOnceActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmAndSleepOnceActor {
+impl Actor for AlarmAndSleepOnceActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm once actor starting");
@@ -250,7 +250,7 @@ impl AlarmSleepThenClearActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmSleepThenClearActor {
+impl Actor for AlarmSleepThenClearActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm actor starting");
@@ -311,7 +311,7 @@ impl AlarmSleepThenReplaceActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmSleepThenReplaceActor {
+impl Actor for AlarmSleepThenReplaceActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm actor starting");
@@ -374,7 +374,7 @@ impl MultipleAlarmSetActor {
 }
 
 #[async_trait]
-impl TestActor for MultipleAlarmSetActor {
+impl Actor for MultipleAlarmSetActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "multi alarm actor starting");
@@ -429,7 +429,7 @@ impl MultiCycleAlarmActor {
 }
 
 #[async_trait]
-impl TestActor for MultiCycleAlarmActor {
+impl Actor for MultiCycleAlarmActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "multi cycle alarm actor starting");
@@ -481,7 +481,7 @@ impl AlarmOnceActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmOnceActor {
+impl Actor for AlarmOnceActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm once actor starting");
@@ -536,7 +536,7 @@ impl AlarmSleepThenCrashActor {
 }
 
 #[async_trait]
-impl TestActor for AlarmSleepThenCrashActor {
+impl Actor for AlarmSleepThenCrashActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm crash actor starting");
@@ -599,7 +599,7 @@ impl RapidAlarmCycleActor {
 }
 
 #[async_trait]
-impl TestActor for RapidAlarmCycleActor {
+impl Actor for RapidAlarmCycleActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "rapid alarm cycle actor starting");
@@ -647,7 +647,7 @@ impl SetClearAlarmAndSleepActor {
 }
 
 #[async_trait]
-impl TestActor for SetClearAlarmAndSleepActor {
+impl Actor for SetClearAlarmAndSleepActor {
 	async fn on_start(&mut self, config: ActorConfig) -> anyhow::Result<ActorStartResult> {
 		let generation = config.generation;
 		tracing::info!(?config.actor_id, generation, "alarm actor starting");

engine/packages/engine/tests/runner/actors_kv_crud.rs

@@ -38,7 +38,7 @@ impl PutAndGetActor {
 }
 
 #[async_trait]
-impl TestActor for PutAndGetActor {
+impl Actor for PutAndGetActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "put and get actor starting");
 
@@ -116,7 +116,7 @@ impl GetNonexistentKeyActor {
 }
 
 #[async_trait]
-impl TestActor for GetNonexistentKeyActor {
+impl Actor for GetNonexistentKeyActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "get nonexistent key actor starting");
 
@@ -191,7 +191,7 @@ impl PutOverwriteActor {
 }
 
 #[async_trait]
-impl TestActor for PutOverwriteActor {
+impl Actor for PutOverwriteActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "put overwrite actor starting");
 
@@ -295,7 +295,7 @@ impl DeleteKeyActor {
 }
 
 #[async_trait]
-impl TestActor for DeleteKeyActor {
+impl Actor for DeleteKeyActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "delete key actor starting");
 
@@ -383,7 +383,7 @@ impl DeleteNonexistentKeyActor {
 }
 
 #[async_trait]
-impl TestActor for DeleteNonexistentKeyActor {
+impl Actor for DeleteNonexistentKeyActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "delete nonexistent key actor starting");
 
@@ -638,7 +638,7 @@ impl BatchPutActor {
 }
 
 #[async_trait]
-impl TestActor for BatchPutActor {
+impl Actor for BatchPutActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "batch put actor starting");
 
@@ -721,7 +721,7 @@ impl BatchGetActor {
 }
 
 #[async_trait]
-impl TestActor for BatchGetActor {
+impl Actor for BatchGetActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "batch get actor starting");
 
@@ -808,7 +808,7 @@ impl BatchDeleteActor {
 }
 
 #[async_trait]
-impl TestActor for BatchDeleteActor {
+impl Actor for BatchDeleteActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "batch delete actor starting");
 

engine/packages/engine/tests/runner/actors_kv_drop.rs

@@ -39,7 +39,7 @@ impl DropClearsAllActor {
 }
 
 #[async_trait]
-impl TestActor for DropClearsAllActor {
+impl Actor for DropClearsAllActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "drop clears all actor starting");
 
@@ -137,7 +137,7 @@ impl DropEmptyActor {
 }
 
 #[async_trait]
-impl TestActor for DropEmptyActor {
+impl Actor for DropEmptyActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "drop empty actor starting");
 

engine/packages/engine/tests/runner/actors_kv_list.rs

@@ -39,7 +39,7 @@ impl ListAllEmptyActor {
 }
 
 #[async_trait]
-impl TestActor for ListAllEmptyActor {
+impl Actor for ListAllEmptyActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list all empty actor starting");
 
@@ -102,7 +102,7 @@ impl ListAllKeysActor {
 }
 
 #[async_trait]
-impl TestActor for ListAllKeysActor {
+impl Actor for ListAllKeysActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list all keys actor starting");
 
@@ -199,7 +199,7 @@ impl ListAllLimitActor {
 }
 
 #[async_trait]
-impl TestActor for ListAllLimitActor {
+impl Actor for ListAllLimitActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list all limit actor starting");
 
@@ -277,7 +277,7 @@ impl ListAllReverseActor {
 }
 
 #[async_trait]
-impl TestActor for ListAllReverseActor {
+impl Actor for ListAllReverseActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list all reverse actor starting");
 
@@ -368,7 +368,7 @@ impl ListRangeInclusiveActor {
 }
 
 #[async_trait]
-impl TestActor for ListRangeInclusiveActor {
+impl Actor for ListRangeInclusiveActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list range inclusive actor starting");
 
@@ -467,7 +467,7 @@ impl ListRangeExclusiveActor {
 }
 
 #[async_trait]
-impl TestActor for ListRangeExclusiveActor {
+impl Actor for ListRangeExclusiveActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list range exclusive actor starting");
 
@@ -566,7 +566,7 @@ impl ListPrefixActor {
 }
 
 #[async_trait]
-impl TestActor for ListPrefixActor {
+impl Actor for ListPrefixActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list prefix actor starting");
 
@@ -669,7 +669,7 @@ impl ListPrefixNoMatchActor {
 }
 
 #[async_trait]
-impl TestActor for ListPrefixNoMatchActor {
+impl Actor for ListPrefixNoMatchActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list prefix no match actor starting");
 

engine/packages/engine/tests/runner/actors_kv_misc.rs

@@ -39,7 +39,7 @@ impl BinaryDataActor {
 }
 
 #[async_trait]
-impl TestActor for BinaryDataActor {
+impl Actor for BinaryDataActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "binary data actor starting");
 
@@ -114,7 +114,7 @@ impl EmptyValueActor {
 }
 
 #[async_trait]
-impl TestActor for EmptyValueActor {
+impl Actor for EmptyValueActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "empty value actor starting");
 
@@ -203,7 +203,7 @@ impl LargeValueActor {
 }
 
 #[async_trait]
-impl TestActor for LargeValueActor {
+impl Actor for LargeValueActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "large value actor starting");
 
@@ -286,7 +286,7 @@ impl GetEmptyKeysActor {
 }
 
 #[async_trait]
-impl TestActor for GetEmptyKeysActor {
+impl Actor for GetEmptyKeysActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "get empty keys actor starting");
 
@@ -350,7 +350,7 @@ impl ListLimitZeroActor {
 }
 
 #[async_trait]
-impl TestActor for ListLimitZeroActor {
+impl Actor for ListLimitZeroActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "list limit zero actor starting");
 
@@ -429,7 +429,7 @@ impl KeyOrderingActor {
 }
 
 #[async_trait]
-impl TestActor for KeyOrderingActor {
+impl Actor for KeyOrderingActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "key ordering actor starting");
 
@@ -520,7 +520,7 @@ impl ManyKeysActor {
 }
 
 #[async_trait]
-impl TestActor for ManyKeysActor {
+impl Actor for ManyKeysActor {
 	async fn on_start(&mut self, config: ActorConfig) -> Result<ActorStartResult> {
 		tracing::info!(actor_id = ?config.actor_id, generation = config.generation, "many keys actor starting");
 

engine/packages/engine/tests/runner/actors_lifecycle.rs

@@ -42,7 +42,7 @@ fn actor_basic_create() {
 			"runner should have the actor allocated"
 		);
 
-		tracing::info!(?actor_id, runner_id = ?runner.runner_id, "actor allocated to runner");
+		tracing::info!(?actor_id, "actor allocated to runner");
 	});
 }