feat(v2): add native cloud controller

Author: Michael Eichelbeck

AGENTS.md

@@ -104,6 +104,8 @@ Destructive commands (need permission): `zeroshot kill`, `zeroshot clear`, `zero
 | Native product construction           | `zeroshot-rust/`                                                                                                                 |
 | Native foreground agents              | `zeroshot-rust/src/native_execution/{agent,pi}/`, `native_execution/program/foreground.rs`                                       |
 | Native admission composition          | `zeroshot-rust/src/native_admission.rs`, `zeroshot-rust/src/main.rs`                                                             |
+| Native v2 cloud controller/OECP backend | `zeroshot-rust/src/native_v2_cloud.rs`, `native_v2_cloud/`                                                                      |
+| Native v2 private capsule runner       | `zeroshot-rust/src/native_v2_capsule.rs`, `native_v2_capsule/`                                                                  |
 | Native release targets                | `distribution/zeroshot-rust-targets.json`                                                                                        |
 | Native npm binary shim                | `npm/zeroshot-rust/`                                                                                                             |
 | Native distribution tooling           | `scripts/rust-distribution.js`                                                                                                   |
@@ -146,6 +148,9 @@ Destructive commands (need permission): `zeroshot kill`, `zeroshot clear`, `zero
 | Watch observation port                | `crates/openengine-cluster-server/src/watch/ports.rs`                                                                            |
 | Watch minimal test fixture            | `crates/openengine-cluster-server/src/watch/fixtures.rs`                                                                         |
 | Watch wire types/framing              | `crates/openengine-cluster-protocol/src/watch.rs`                                                                                |
+| Native v2 run method wire values      | `crates/openengine-cluster-protocol/src/native_v2_{run,observation}.rs`                                                          |
+| Native v2 server routes/stream seam    | `crates/openengine-cluster-server/src/native_v2.rs`, `connection/native_v2.rs`                                                   |
+| Native v2 typed protocol client        | `crates/openengine-cluster-client/src/native_v2.rs`                                                                              |
 | Client watch/reconnect                | `crates/openengine-cluster-client/src/watch.rs`                                                                                  |
 | NDJSON stdio binding                  | `crates/openengine-cluster-server/src/stdio.rs`                                                                                  |
 | NDJSON watch client                   | `crates/openengine-cluster-client/src/ndjson_watch.rs`                                                                           |

crates/openengine-cluster-client/src/lib.rs

@@ -6,6 +6,7 @@ mod ndjson_subscription;
 
 pub mod agent_attach;
 pub mod logs;
+pub mod native_v2;
 pub mod ndjson_agent_attach;
 pub mod ndjson_logs;
 pub mod ndjson_watch;
@@ -16,6 +17,7 @@ pub use logs::*;
 pub use ndjson_agent_attach::*;
 pub use ndjson_logs::*;
 pub use ndjson_watch::*;
+pub use native_v2::*;
 pub use watch::*;
 pub use websocket::*;
 
@@ -29,8 +31,10 @@ use openengine_cluster_protocol::{
     ApplyParams, ApplyResult, DeleteParams, DeleteResult, GetParams, GetResult, InitializeParams,
     InitializeResult, JsonRpcError, JsonRpcErrorResponse, JsonRpcRequest, JsonRpcSuccess,
     PlanParams, PlanResult, RequestId, ResubmitParams, ResubmitResult, RetryParams, RetryResult,
-    StopParams, StopResult, SubscriptionId, UpdateParams, UpdateResult, JSON_RPC_VERSION,
-    PROTOCOL_VERSION,
+    RunForceParams, RunForceResult, RunListParams, RunListResult, RunStatusParams, RunStatusResult,
+    RunSubmitParams, RunSubmitResult, StopParams, StopResult, SubscriptionId, UpdateParams,
+    UpdateResult, JSON_RPC_VERSION, PROTOCOL_VERSION, RUN_FORCE_METHOD, RUN_LIST_METHOD,
+    RUN_STATUS_METHOD, RUN_SUBMIT_METHOD,
 };
 use openengine_cluster_server::{ClusterBackend, Dispatcher};
 use serde::de::DeserializeOwned;
@@ -337,6 +341,28 @@ where
         self.call("delete", params).await
     }
 
+    pub async fn run_submit(
+        &self,
+        params: RunSubmitParams,
+    ) -> Result<RunSubmitResult, ClientError> {
+        self.call(RUN_SUBMIT_METHOD, params).await
+    }
+
+    pub async fn run_list(&self, params: RunListParams) -> Result<RunListResult, ClientError> {
+        self.call(RUN_LIST_METHOD, params).await
+    }
+
+    pub async fn run_status(
+        &self,
+        params: RunStatusParams,
+    ) -> Result<RunStatusResult, ClientError> {
+        self.call(RUN_STATUS_METHOD, params).await
+    }
+
+    pub async fn run_force(&self, params: RunForceParams) -> Result<RunForceResult, ClientError> {
+        self.call(RUN_FORCE_METHOD, params).await
+    }
+
     async fn call<P, R>(&self, method: &str, params: P) -> Result<R, ClientError>
     where
         P: Serialize + Send,