docs(actors): sync from rivet-dev/actors@89c31e9

Author: rivet-docs-sync[bot]

vendor/actors/docs/content/docs/general/environment-variables.mdx

@@ -38,6 +38,8 @@ These variables configure how clients connect to your actors.
 | `RIVET_RUN_ENGINE_HOST` | Host to bind the spawned local engine process to. Defaults to `127.0.0.1`. |
 | `RIVET_RUN_ENGINE_PORT` | Port to bind the spawned local engine process to. Defaults to `6420`. |
 | `RIVET_RUN_ENGINE_VERSION` | Version of engine to download |
+| `RIVET_RUN_SERVICES` | Set to `1` to run Services with a local Engine, or `0` to disable it. By default, Services follows RivetKit's local-Engine decision. |
+| `RIVET_SERVICES_BINARY` | Path to a local `rivet-services` binary. |
 
 ## Inspector
 

vendor/actors/docs/content/docs/limits.mdx

@@ -53,14 +53,9 @@ These limits affect actions that do not use `.connect()` and [low-level HTTP req
 | Name | Soft Limit | Hard Limit | Description |
 |------|------------|------------|-------------|
 | Max request body size | — | 20 MiB | Maximum size of HTTP request bodies. |
-| Max response body size | — | 20 MiB | Maximum size of HTTP response bodies. |
-| Request timeout | 60 seconds | — | Maximum time for an `onRequest` handler to complete. Defaults to `actionTimeout`; configure with `actionTimeout`. |
-
-### Actions
-
-| Name | Soft Limit | Hard Limit | Description |
-|------|------------|------------|-------------|
-| Max actions per actor | 128 | None | Maximum number of action handlers defined on one actor. Nested action groups count each leaf handler. Configurable via `maxActions`. |
+| Max buffered response body size | — | 20 MiB | Maximum size of a non-streaming HTTP response. Streaming responses may transfer more than 20 MiB over their lifetime and are flow controlled instead of buffered in full. |
+| Response start timeout | — | 5 minutes by default | Maximum time for `onRequest` to return response headers. It does not limit the lifetime of a response stream after the headers arrive. Self-hosted operators can configure `pegboard.gateway_response_start_timeout_ms`. |
+| Streaming response idle timeout | — | None by default | Rivet does not close an otherwise healthy stream because no body chunk was produced. Other proxies and hosting platforms may impose their own idle timeouts, so SSE handlers should send periodic comment heartbeats. |
 
 ### Networking
 
@@ -145,7 +140,8 @@ See [Actor Input](/actors/docs/input) for details.
 | Name | Soft Limit | Hard Limit | Description |
 |------|------------|------------|-------------|
 | Action timeout | 60 seconds | — | Timeout for RPC actions. Configurable via `actionTimeout`. |
-| On request timeout | 60 seconds | — | Timeout for raw `onRequest` handlers. Defaults to `actionTimeout`; configure with `actionTimeout`. |
+| Raw HTTP response start timeout | — | 5 minutes by default | Time allowed for a raw `onRequest` handler to return response headers. `actionTimeout` does not apply to raw HTTP handlers, and a streaming response has no fixed total-duration timeout after it starts. Self-hosted operators can configure `pegboard.gateway_response_start_timeout_ms`. |
+| Raw HTTP stream idle timeout | — | None by default | Time allowed between response chunks. Self-hosted operators can configure `pegboard.gateway_response_chunk_idle_timeout_ms`; send SSE heartbeats more frequently than that value when enabled. |
 | On before connect timeout | 5 seconds | — | Timeout for the `onBeforeConnect` hook. Configurable via `onBeforeConnectTimeout`. |
 | Create vars timeout | 5 seconds | — | Timeout for `createVars` hook. Configurable via `createVarsTimeout`. |
 | Create conn state timeout | 5 seconds | — | Timeout for `createConnState` hook. Configurable via `createConnStateTimeout`. |

vendor/actors/docs/content/docs/request-handler.mdx

@@ -26,6 +26,17 @@ The `onRequest` handler processes HTTP requests sent to your actor. It receives
 
 See also the [raw fetch handler example](https://github.com/rivet-dev/rivet/tree/main/examples/raw-fetch-handler).
 
+## Streaming Responses & Server-Sent Events
+
+Return a `Response` with a `ReadableStream` body to stream data as it becomes available. For server-sent events (SSE), set `Content-Type` to `text/event-stream` and format each event as one or more fields followed by a blank line.
+
+<CodeGroup>
+<CodeSnippet file="examples/docs/actors-request-handler/sse.ts" title="actor.ts" />
+<CodeSnippet file="examples/docs/actors-request-handler/sse-client.ts" title="client.ts" />
+</CodeGroup>
+
+Rivet keeps the actor and request lifecycle active until the response stream closes, errors, or the client disconnects. The request's `AbortSignal` is aborted when the downstream client disconnects, so stop producers and release request-scoped resources when `request.signal` fires. Also implement the stream's `cancel()` callback for cleanup.
+
 ## Sending Requests To Actors
 
 ### Via RivetKit Client
@@ -87,7 +98,6 @@ The `onRequest` handler is WinterTC compliant and will work with existing librar
 
 ## Limitations
 
-- Does not support streaming responses & server-sent events at the moment. See the [tracking issue](https://github.com/rivet-dev/rivet/issues/3529).
 - `OPTIONS` requests currently are handled by Rivet and are not passed to `onRequest`
 
 ## Advanced

vendor/actors/docs/content/integrations/durable-streams.mdx

@@ -0,0 +1,70 @@
+---
+title: "Durable Streams"
+description: "Run the Durable Streams protocol locally and deploy it with Rivet."
+---
+
+[Durable Streams](https://github.com/durable-streams/durable-streams) is a protocol for append-only streams with catch-up reads, live updates, and resumable offsets. Rivet provides an implementation backed by Rivet Actors.
+
+## Quickstart
+
+<Steps>
+
+<Step title="Run locally">
+
+Start the local Rivet control plane and Services:
+
+```sh
+npx @rivet-dev/services dev
+```
+
+The command prints the local URL when it is ready. Durable Streams is available at `http://127.0.0.1:8642/durable-streams/v1/stream/<path>`.
+
+</Step>
+
+<Step title="Connect to a stream">
+
+<Tabs>
+
+<Tab title="TypeScript client">
+
+Install the official client:
+
+```sh
+npm install @durable-streams/client
+```
+
+<CodeSnippet file="examples/docs/actors-integrations-durable-streams/client.ts" title="client.ts" />
+
+</Tab>
+
+<Tab title="HTTP">
+
+Create a stream, append a record, and read its contents:
+
+```sh
+curl -i -X PUT \
+  -H 'content-type: application/json' \
+  --data '[{"message":"hello"}]' \
+  http://127.0.0.1:8642/durable-streams/v1/stream/demo
+
+curl -i -X POST \
+  -H 'content-type: application/json' \
+  --data '{"message":"world"}' \
+  http://127.0.0.1:8642/durable-streams/v1/stream/demo
+
+curl 'http://127.0.0.1:8642/durable-streams/v1/stream/demo?offset=-1'
+```
+
+</Tab>
+
+</Tabs>
+
+</Step>
+
+<Step title="Deploy">
+
+Set up the `services` pool in [Rivet Cloud](https://dashboard.rivet.dev/), or follow the [self-hosting guide in the Durable Streams README](https://github.com/rivet-dev/rivet-durable-streams#self-hosted).
+
+</Step>
+
+</Steps>

vendor/actors/docs/sidebar.json

@@ -423,6 +423,10 @@
 		{
 			"title": "Integrations",
 			"pages": [
+				{
+					"title": "Durable Streams",
+					"href": "/actors/integrations/durable-streams"
+				},
 				{
 					"title": "Flue",
 					"href": "/actors/integrations/flue"

vendor/actors/engine/artifacts/config-schema.json

@@ -73,6 +73,17 @@
         }
       ]
     },
+    "features": {
+      "default": null,
+      "anyOf": [
+        {
+          "$ref": "#/definitions/Features"
+        },
+        {
+          "type": "null"
+        }
+      ]
+    },
     "guard": {
       "default": null,
       "anyOf": [
@@ -465,6 +476,24 @@
         }
       ]
     },
+    "Features": {
+      "type": "object",
+      "properties": {
+        "guard_gateway_v3": {
+          "description": "Controls routing to the streaming Guard Gateway V3 implementation.",
+          "default": null,
+          "anyOf": [
+            {
+              "$ref": "#/definitions/GuardGatewayV3"
+            },
+            {
+              "type": "null"
+            }
+          ]
+        }
+      },
+      "additionalProperties": false
+    },
     "FileSystem": {
       "type": "object",
       "required": [
@@ -675,6 +704,35 @@
       },
       "additionalProperties": false
     },
+    "GuardGatewayV3": {
+      "type": "object",
+      "properties": {
+        "mode": {
+          "default": "off",
+          "allOf": [
+            {
+              "$ref": "#/definitions/GuardGatewayV3Mode"
+            }
+          ]
+        },
+        "percentage": {
+          "default": 0,
+          "type": "integer",
+          "format": "uint8",
+          "maximum": 100.0,
+          "minimum": 0.0
+        }
+      },
+      "additionalProperties": false
+    },
+    "GuardGatewayV3Mode": {
+      "type": "string",
+      "enum": [
+        "off",
+        "opportunistic",
+        "on"
+      ]
+    },
     "Https": {
       "type": "object",
       "required": [
@@ -1008,6 +1066,24 @@
           "format": "uint",
           "minimum": 0.0
         },
+        "gateway_http_response_body_channel_capacity": {
+          "description": "Number of body chunks buffered between a streaming response handler and its HTTP client.",
+          "type": [
+            "integer",
+            "null"
+          ],
+          "format": "uint",
+          "minimum": 0.0
+        },
+        "gateway_http_response_queue_max_messages": {
+          "description": "Maximum number of envoy response messages buffered per HTTP request.",
+          "type": [
+            "integer",
+            "null"
+          ],
+          "format": "uint",
+          "minimum": 0.0
+        },
         "gateway_hws_max_pending_size": {
           "description": "Max pending message buffer size for hibernating WebSockets in bytes.",
           "type": [
@@ -1026,6 +1102,15 @@
           "format": "uint64",
           "minimum": 0.0
         },
+        "gateway_response_chunk_idle_timeout_ms": {
+          "description": "Timeout between streaming HTTP response chunks in milliseconds.\n\nDisabled when unset so long-lived streams such as SSE may remain idle.",
+          "type": [
+            "integer",
+            "null"
+          ],
+          "format": "uint64",
+          "minimum": 0.0
+        },
         "gateway_response_start_timeout_ms": {
           "description": "Timeout for response to start in milliseconds.",
           "type": [
@@ -1035,6 +1120,15 @@
           "format": "uint64",
           "minimum": 0.0
         },
+        "gateway_streaming_http_response_queue_max_bytes": {
+          "description": "Maximum streaming response bytes buffered per HTTP request.",
+          "type": [
+            "integer",
+            "null"
+          ],
+          "format": "uint",
+          "minimum": 0.0
+        },
         "gateway_tunnel_ping_timeout_ms": {
           "description": "Tunnel ping timeout in milliseconds.",
           "type": [

vendor/actors/examples/docs/actors-integrations-durable-streams/client.ts

@@ -0,0 +1,8 @@
+import { DurableStream } from "@durable-streams/client";
+
+const stream = await DurableStream.create({
+	url: "http://127.0.0.1:8642/durable-streams/v1/stream/demo",
+	contentType: "application/json",
+});
+
+await stream.append(JSON.stringify({ message: "hello" }));

vendor/actors/examples/docs/actors-limits/actor-options.ts

@@ -2,7 +2,6 @@ import { actor } from "rivetkit";
 
 const myActor = actor({
   options: {
-    maxActions: 128,
     maxQueueSize: 1000,
     actionTimeout: 60_000,
     stateSaveInterval: 1_000,

vendor/actors/examples/docs/actors-request-handler/sse-client.ts

@@ -0,0 +1,30 @@
+import { createClient } from "rivetkit/client";
+import type { registry } from "./sse-server";
+
+const client = createClient<typeof registry>("http://localhost:6420");
+const notifications = client.notifications.getOrCreate(["status"]);
+const response = await notifications.fetch("/", {
+	headers: { Accept: "text/event-stream" },
+});
+
+if (!response.ok || !response.body) {
+	throw new Error(`SSE request failed with status ${response.status}`);
+}
+
+const reader = response.body.getReader();
+const decoder = new TextDecoder();
+let pending = "";
+
+for (;;) {
+	const chunk = await reader.read();
+	if (chunk.done) break;
+
+	pending += decoder.decode(chunk.value, { stream: true });
+	for (;;) {
+		const boundary = pending.indexOf("\n\n");
+		if (boundary === -1) break;
+		const event = pending.slice(0, boundary);
+		pending = pending.slice(boundary + 2);
+		console.log(event);
+	}
+}

vendor/actors/examples/docs/actors-request-handler/sse-server.ts

@@ -0,0 +1,8 @@
+import { setup } from "rivetkit";
+import { notificationsActor } from "./sse";
+
+export const registry = setup({
+	use: { notifications: notificationsActor },
+});
+
+registry.start();