Merge commit '0a2f4c9ab5468834bf3fcf5b20c052161415519c'

Author: slinkydeveloper

sdk-core/src/main/service-protocol/deployment_manifest_schema.json

@@ -0,0 +1,59 @@
+{
+  "$id": "https://restate.dev/deployment.manifest.json",
+  "$schema": "https://json-schema.org/draft/2020-12/schema",
+  "type": "object",
+  "title": "Deployment",
+  "description": "Restate deployment manifest",
+  "properties": {
+    "protocolMode": {
+      "title": "ProtocolMode",
+      "enum": ["BIDI_STREAM", "REQUEST_RESPONSE"]
+    },
+    "minProtocolVersion": {
+      "type": "integer",
+      "minimum": 0
+    },
+    "maxProtocolVersion": {
+      "type": "integer",
+      "maximum": 0
+    },
+    "components": {
+      "type": "array",
+      "items": {
+        "type": "object",
+        "title": "Component",
+        "properties": {
+          "fullyQualifiedComponentName": {
+            "type": "string",
+            "pattern": "^([a-zA-Z]|_[a-zA-Z0-9])[a-zA-Z0-9._-]*$"
+          },
+          "componentType": {
+            "title": "ComponentType",
+            "enum": ["VIRTUAL_OBJECT", "SERVICE"]
+          },
+          "handlers": {
+            "type": "array",
+            "items": {
+              "type": "object",
+              "title": "Handler",
+              "properties": {
+                "name": {
+                  "type": "string",
+                  "pattern": "^([a-zA-Z]|_[a-zA-Z0-9])[a-zA-Z0-9_]*$"
+                },
+                "inputSchema": {},
+                "outputSchema": {}
+              },
+              "required": [ "name" ],
+              "additionalProperties": false
+            }
+          }
+        },
+        "required": [ "fullyQualifiedComponentName","componentType", "handlers" ],
+        "additionalProperties": false
+      }
+    }
+  },
+  "required": [ "minProtocolVersion", "maxProtocolVersion", "components" ],
+  "additionalProperties": false
+}

sdk-core/src/main/service-protocol/dev/restate/service/protocol.proto

@@ -39,6 +39,11 @@ message StartMessage {
   // protolint:disable:next REPEATED_FIELD_NAMES_PLURALIZED
   repeated StateEntry state_map = 4;
   bool partial_state = 5;
+
+  repeated Header headers = 6;
+
+  // If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
+  string key = 7;
 }
 
 // Type: 0x0000 + 1
@@ -196,6 +201,11 @@ message InvokeEntryMessage {
 
   bytes parameter = 3;
 
+  repeated Header headers = 4;
+
+  // If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
+  string key = 5;
+
   oneof result {
     bytes value = 14;
     Failure failure = 15;
@@ -216,6 +226,11 @@ message BackgroundInvokeEntryMessage {
   // If this value is not set, equal to 0, or past in time,
   // the runtime will execute this BackgroundInvoke as soon as possible.
   uint64 invoke_time = 4;
+
+  repeated Header headers = 5;
+
+  // If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
+  string key = 6;
 }
 
 // Completable: Yes
@@ -255,3 +270,8 @@ message Failure {
   // Contains a concise error message, e.g. Throwable#getMessage() in Java.
   string message = 2;
 }
+
+message Header {
+  string key = 1;
+  string value = 2;
+}