Publish quixos-protocol from e500ba880d3fb9481645d54efcf79a6389f200db

.quixos-subtree-source.json

@@ -1,7 +1,7 @@
 {
   "version": 1,
   "sourceRepo": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos.git",
-  "sourceCommit": "eb407e5a3bbd4ae2f810a0cee0d45b5c7e8d7db1",
+  "sourceCommit": "e500ba880d3fb9481645d54efcf79a6389f200db",
   "sourcePath": "quixos-protocol",
   "exportName": "quixos-protocol",
   "mirrorRemote": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"

proto/quixos/orch.proto

@@ -5,9 +5,11 @@ package quixos.orch;
 import "camino/api.proto";
 import "quixos/package.proto";
 import "quixos/refs.proto";
+import "quixos/runtime.proto";
 
 service OrchestratorRuntime {
   rpc InvokeFunction(InvokeFunctionRequest) returns (InvokeFunctionResponse);
+  rpc WatchFunction(WatchFunctionRequest) returns (stream WatchFunctionEvent);
   rpc ListPackageDescriptors(ListPackageDescriptorsRequest) returns (ListPackageDescriptorsResponse);
   rpc ListPackageRuntimes(ListPackageRuntimesRequest) returns (ListPackageRuntimesResponse);
   rpc ListActivations(ListActivationsRequest) returns (ListActivationsResponse);
@@ -28,6 +30,22 @@ message InvokeFunctionResponse {
   string error = 5;
 }
 
+message WatchFunctionRequest {
+  quixos.FunctionRef function = 1;
+  string object_id = 2;
+  map<string, camino.Value> input = 3;
+}
+
+message WatchFunctionEvent {
+  string invocation_id = 1;
+  Activation activation = 2;
+  string watch_id = 3;
+  camino.Value value = 4;
+  repeated quixos.runtime.DerivedDependency dependencies = 5;
+  string error = 6;
+  bool initial = 7;
+}
+
 message ListActivationsRequest {}
 
 message ListPackageDescriptorsRequest {}

proto/quixos/runtime.proto

@@ -8,6 +8,7 @@ import "quixos/refs.proto";
 service PackageRuntime {
   rpc Handshake(HandshakeRequest) returns (HandshakeResponse);
   rpc Invoke(InvokeRequest) returns (InvokeResponse);
+  rpc Watch(WatchRequest) returns (stream WatchEvent);
 }
 
 message HandshakeRequest {
@@ -33,3 +34,25 @@ message InvokeResponse {
   camino.Value result = 2;
   string error = 3;
 }
+
+message WatchRequest {
+  string invocation_id = 1;
+  quixos.FunctionRef function = 2;
+  string object_id = 3;
+  map<string, camino.Value> input = 4;
+}
+
+message DerivedDependency {
+  string kind = 1;
+  string object_id = 2;
+  string field_name = 3;
+  string source_field = 4;
+}
+
+message WatchEvent {
+  string watch_id = 1;
+  camino.Value value = 2;
+  repeated DerivedDependency dependencies = 3;
+  string error = 4;
+  bool initial = 5;
+}

src/gen/camino/api_pb.ts

@@ -854,3 +854,4 @@ export const CaminoService: GenService<{
   },
 }> = /*@__PURE__*/
   serviceDesc(file_camino_api, 0);
+

src/gen/camino/options_pb.ts

@@ -180,3 +180,4 @@ export const field_ops: GenExtension<FieldOptions, FieldOps> = /*@__PURE__*/
  */
 export const impl: GenExtension<MethodOptions$1, FunctionRef> = /*@__PURE__*/
   extDesc(file_camino_options, 9);
+

src/gen/camino/schema_pb.ts

@@ -695,3 +695,4 @@ export enum FieldImplementation {
  */
 export const FieldImplementationSchema: GenEnum<FieldImplementation> = /*@__PURE__*/
   enumDesc(file_camino_schema, 4);
+

src/gen/quixos/orch_pb.ts

@@ -10,13 +10,15 @@ import type { PackageDescriptor } from "./package_pb.js";
 import { file_quixos_package } from "./package_pb.js";
 import type { FunctionRef } from "./refs_pb.js";
 import { file_quixos_refs } from "./refs_pb.js";
+import type { DerivedDependency } from "./runtime_pb.js";
+import { file_quixos_runtime } from "./runtime_pb.js";
 import type { Message } from "@bufbuild/protobuf";
 
 /**
  * Describes the file quixos/orch.proto.
  */
 export const file_quixos_orch: GenFile = /*@__PURE__*/
-  fileDesc("ChFxdWl4b3Mvb3JjaC5wcm90bxILcXVpeG9zLm9yY2gizAEKFUludm9rZUZ1bmN0aW9uUmVxdWVzdBIlCghmdW5jdGlvbhgBIAEoCzITLnF1aXhvcy5GdW5jdGlvblJlZhIRCglvYmplY3RfaWQYAiABKAkSPAoFaW5wdXQYAyADKAsyLS5xdWl4b3Mub3JjaC5JbnZva2VGdW5jdGlvblJlcXVlc3QuSW5wdXRFbnRyeRo7CgpJbnB1dEVudHJ5EgsKA2tleRgBIAEoCRIcCgV2YWx1ZRgCIAEoCzINLmNhbWluby5WYWx1ZToCOAEilgEKFkludm9rZUZ1bmN0aW9uUmVzcG9uc2USFQoNaW52b2NhdGlvbl9pZBgBIAEoCRIrCgphY3RpdmF0aW9uGAIgASgLMhcucXVpeG9zLm9yY2guQWN0aXZhdGlvbhIKCgJvaxgDIAEoCBIdCgZyZXN1bHQYBCABKAsyDS5jYW1pbm8uVmFsdWUSDQoFZXJyb3IYBSABKAkiGAoWTGlzdEFjdGl2YXRpb25zUmVxdWVzdCIfCh1MaXN0UGFja2FnZURlc2NyaXB0b3JzUmVxdWVzdCJQCh5MaXN0UGFja2FnZURlc2NyaXB0b3JzUmVzcG9uc2USLgoLZGVzY3JpcHRvcnMYASADKAsyGS5xdWl4b3MuUGFja2FnZURlc2NyaXB0b3IiHAoaTGlzdFBhY2thZ2VSdW50aW1lc1JlcXVlc3QiUgobTGlzdFBhY2thZ2VSdW50aW1lc1Jlc3BvbnNlEjMKCHJ1bnRpbWVzGAEgAygLMiEucXVpeG9zLm9yY2guUGFja2FnZVJ1bnRpbWVTdGF0dXMiRwoXTGlzdEFjdGl2YXRpb25zUmVzcG9uc2USLAoLYWN0aXZhdGlvbnMYASADKAsyFy5xdWl4b3Mub3JjaC5BY3RpdmF0aW9uIj8KFkNsb3NlQWN0aXZhdGlvblJlcXVlc3QSFQoNYWN0aXZhdGlvbl9pZBgBIAEoCRIOCgZyZWFzb24YAiABKAkiRgoXQ2xvc2VBY3RpdmF0aW9uUmVzcG9uc2USKwoKYWN0aXZhdGlvbhgBIAEoCzIXLnF1aXhvcy5vcmNoLkFjdGl2YXRpb24i6AEKCkFjdGl2YXRpb24SFQoNYWN0aXZhdGlvbl9pZBgBIAEoCRIlCghmdW5jdGlvbhgCIAEoCzITLnF1aXhvcy5GdW5jdGlvblJlZhIRCglvYmplY3RfaWQYAyABKAkSDQoFc3RhdGUYBCABKAkSDgoGZGVtYW5kGAUgASgNEhEKCW9wZW5lZF9hdBgGIAEoCRIUCgxsYXN0X3VzZWRfYXQYByABKAkSGAoQaWRsZV9kZWFkbGluZV9hdBgIIAEoCRIRCgljbG9zZWRfYXQYCSABKAkSFAoMY2xvc2VfcmVhc29uGAogASgJIuMCChRQYWNrYWdlUnVudGltZVN0YXR1cxITCgtydW50aW1lX2tleRgBIAEoCRIZChFwYWNrYWdlX25hbWVzcGFjZRgCIAEoCRIUCgxwYWNrYWdlX25hbWUYAyABKAkSGgoSZGVzY3JpcHRvcl92ZXJzaW9uGAQgASgNEhMKC3NvdXJjZV9yZXBvGAUgASgJEhoKEnNlcnZlcl9pbnN0YWxsYWJsZRgGIAEoCRITCgtzb3VyY2VfcGF0aBgHIAEoCRITCgtzZXJ2ZXJfcGF0aBgIIAEoCRILCgNwaWQYCSABKA0SDQoFc3RhdGUYCiABKAkSEgoKc3RhcnRlZF9hdBgLIAEoCRIZChFsYXN0X2hhbmRzaGFrZV9hdBgMIAEoCRIgChhydW50aW1lX3Byb3RvY29sX3ZlcnNpb24YDSABKAkSIQoZYWR2ZXJ0aXNlZF9mdW5jdGlvbl9jb3VudBgOIAEoDTKJBAoTT3JjaGVzdHJhdG9yUnVudGltZRJZCg5JbnZva2VGdW5jdGlvbhIiLnF1aXhvcy5vcmNoLkludm9rZUZ1bmN0aW9uUmVxdWVzdBojLnF1aXhvcy5vcmNoLkludm9rZUZ1bmN0aW9uUmVzcG9uc2UScQoWTGlzdFBhY2thZ2VEZXNjcmlwdG9ycxIqLnF1aXhvcy5vcmNoLkxpc3RQYWNrYWdlRGVzY3JpcHRvcnNSZXF1ZXN0GisucXVpeG9zLm9yY2guTGlzdFBhY2thZ2VEZXNjcmlwdG9yc1Jlc3BvbnNlEmgKE0xpc3RQYWNrYWdlUnVudGltZXMSJy5xdWl4b3Mub3JjaC5MaXN0UGFja2FnZVJ1bnRpbWVzUmVxdWVzdBooLnF1aXhvcy5vcmNoLkxpc3RQYWNrYWdlUnVudGltZXNSZXNwb25zZRJcCg9MaXN0QWN0aXZhdGlvbnMSIy5xdWl4b3Mub3JjaC5MaXN0QWN0aXZhdGlvbnNSZXF1ZXN0GiQucXVpeG9zLm9yY2guTGlzdEFjdGl2YXRpb25zUmVzcG9uc2USXAoPQ2xvc2VBY3RpdmF0aW9uEiMucXVpeG9zLm9yY2guQ2xvc2VBY3RpdmF0aW9uUmVxdWVzdBokLnF1aXhvcy5vcmNoLkNsb3NlQWN0aXZhdGlvblJlc3BvbnNlYgZwcm90bzM", [file_camino_api, file_quixos_package, file_quixos_refs]);
+  fileDesc("ChFxdWl4b3Mvb3JjaC5wcm90bxILcXVpeG9zLm9yY2gizAEKFUludm9rZUZ1bmN0aW9uUmVxdWVzdBIlCghmdW5jdGlvbhgBIAEoCzITLnF1aXhvcy5GdW5jdGlvblJlZhIRCglvYmplY3RfaWQYAiABKAkSPAoFaW5wdXQYAyADKAsyLS5xdWl4b3Mub3JjaC5JbnZva2VGdW5jdGlvblJlcXVlc3QuSW5wdXRFbnRyeRo7CgpJbnB1dEVudHJ5EgsKA2tleRgBIAEoCRIcCgV2YWx1ZRgCIAEoCzINLmNhbWluby5WYWx1ZToCOAEilgEKFkludm9rZUZ1bmN0aW9uUmVzcG9uc2USFQoNaW52b2NhdGlvbl9pZBgBIAEoCRIrCgphY3RpdmF0aW9uGAIgASgLMhcucXVpeG9zLm9yY2guQWN0aXZhdGlvbhIKCgJvaxgDIAEoCBIdCgZyZXN1bHQYBCABKAsyDS5jYW1pbm8uVmFsdWUSDQoFZXJyb3IYBSABKAkiygEKFFdhdGNoRnVuY3Rpb25SZXF1ZXN0EiUKCGZ1bmN0aW9uGAEgASgLMhMucXVpeG9zLkZ1bmN0aW9uUmVmEhEKCW9iamVjdF9pZBgCIAEoCRI7CgVpbnB1dBgDIAMoCzIsLnF1aXhvcy5vcmNoLldhdGNoRnVuY3Rpb25SZXF1ZXN0LklucHV0RW50cnkaOwoKSW5wdXRFbnRyeRILCgNrZXkYASABKAkSHAoFdmFsdWUYAiABKAsyDS5jYW1pbm8uVmFsdWU6AjgBIuEBChJXYXRjaEZ1bmN0aW9uRXZlbnQSFQoNaW52b2NhdGlvbl9pZBgBIAEoCRIrCgphY3RpdmF0aW9uGAIgASgLMhcucXVpeG9zLm9yY2guQWN0aXZhdGlvbhIQCgh3YXRjaF9pZBgDIAEoCRIcCgV2YWx1ZRgEIAEoCzINLmNhbWluby5WYWx1ZRI3CgxkZXBlbmRlbmNpZXMYBSADKAsyIS5xdWl4b3MucnVudGltZS5EZXJpdmVkRGVwZW5kZW5jeRINCgVlcnJvchgGIAEoCRIPCgdpbml0aWFsGAcgASgIIhgKFkxpc3RBY3RpdmF0aW9uc1JlcXVlc3QiHwodTGlzdFBhY2thZ2VEZXNjcmlwdG9yc1JlcXVlc3QiUAoeTGlzdFBhY2thZ2VEZXNjcmlwdG9yc1Jlc3BvbnNlEi4KC2Rlc2NyaXB0b3JzGAEgAygLMhkucXVpeG9zLlBhY2thZ2VEZXNjcmlwdG9yIhwKGkxpc3RQYWNrYWdlUnVudGltZXNSZXF1ZXN0IlIKG0xpc3RQYWNrYWdlUnVudGltZXNSZXNwb25zZRIzCghydW50aW1lcxgBIAMoCzIhLnF1aXhvcy5vcmNoLlBhY2thZ2VSdW50aW1lU3RhdHVzIkcKF0xpc3RBY3RpdmF0aW9uc1Jlc3BvbnNlEiwKC2FjdGl2YXRpb25zGAEgAygLMhcucXVpeG9zLm9yY2guQWN0aXZhdGlvbiI/ChZDbG9zZUFjdGl2YXRpb25SZXF1ZXN0EhUKDWFjdGl2YXRpb25faWQYASABKAkSDgoGcmVhc29uGAIgASgJIkYKF0Nsb3NlQWN0aXZhdGlvblJlc3BvbnNlEisKCmFjdGl2YXRpb24YASABKAsyFy5xdWl4b3Mub3JjaC5BY3RpdmF0aW9uIugBCgpBY3RpdmF0aW9uEhUKDWFjdGl2YXRpb25faWQYASABKAkSJQoIZnVuY3Rpb24YAiABKAsyEy5xdWl4b3MuRnVuY3Rpb25SZWYSEQoJb2JqZWN0X2lkGAMgASgJEg0KBXN0YXRlGAQgASgJEg4KBmRlbWFuZBgFIAEoDRIRCglvcGVuZWRfYXQYBiABKAkSFAoMbGFzdF91c2VkX2F0GAcgASgJEhgKEGlkbGVfZGVhZGxpbmVfYXQYCCABKAkSEQoJY2xvc2VkX2F0GAkgASgJEhQKDGNsb3NlX3JlYXNvbhgKIAEoCSLjAgoUUGFja2FnZVJ1bnRpbWVTdGF0dXMSEwoLcnVudGltZV9rZXkYASABKAkSGQoRcGFja2FnZV9uYW1lc3BhY2UYAiABKAkSFAoMcGFja2FnZV9uYW1lGAMgASgJEhoKEmRlc2NyaXB0b3JfdmVyc2lvbhgEIAEoDRITCgtzb3VyY2VfcmVwbxgFIAEoCRIaChJzZXJ2ZXJfaW5zdGFsbGFibGUYBiABKAkSEwoLc291cmNlX3BhdGgYByABKAkSEwoLc2VydmVyX3BhdGgYCCABKAkSCwoDcGlkGAkgASgNEg0KBXN0YXRlGAogASgJEhIKCnN0YXJ0ZWRfYXQYCyABKAkSGQoRbGFzdF9oYW5kc2hha2VfYXQYDCABKAkSIAoYcnVudGltZV9wcm90b2NvbF92ZXJzaW9uGA0gASgJEiEKGWFkdmVydGlzZWRfZnVuY3Rpb25fY291bnQYDiABKA0y4AQKE09yY2hlc3RyYXRvclJ1bnRpbWUSWQoOSW52b2tlRnVuY3Rpb24SIi5xdWl4b3Mub3JjaC5JbnZva2VGdW5jdGlvblJlcXVlc3QaIy5xdWl4b3Mub3JjaC5JbnZva2VGdW5jdGlvblJlc3BvbnNlElUKDVdhdGNoRnVuY3Rpb24SIS5xdWl4b3Mub3JjaC5XYXRjaEZ1bmN0aW9uUmVxdWVzdBofLnF1aXhvcy5vcmNoLldhdGNoRnVuY3Rpb25FdmVudDABEnEKFkxpc3RQYWNrYWdlRGVzY3JpcHRvcnMSKi5xdWl4b3Mub3JjaC5MaXN0UGFja2FnZURlc2NyaXB0b3JzUmVxdWVzdBorLnF1aXhvcy5vcmNoLkxpc3RQYWNrYWdlRGVzY3JpcHRvcnNSZXNwb25zZRJoChNMaXN0UGFja2FnZVJ1bnRpbWVzEicucXVpeG9zLm9yY2guTGlzdFBhY2thZ2VSdW50aW1lc1JlcXVlc3QaKC5xdWl4b3Mub3JjaC5MaXN0UGFja2FnZVJ1bnRpbWVzUmVzcG9uc2USXAoPTGlzdEFjdGl2YXRpb25zEiMucXVpeG9zLm9yY2guTGlzdEFjdGl2YXRpb25zUmVxdWVzdBokLnF1aXhvcy5vcmNoLkxpc3RBY3RpdmF0aW9uc1Jlc3BvbnNlElwKD0Nsb3NlQWN0aXZhdGlvbhIjLnF1aXhvcy5vcmNoLkNsb3NlQWN0aXZhdGlvblJlcXVlc3QaJC5xdWl4b3Mub3JjaC5DbG9zZUFjdGl2YXRpb25SZXNwb25zZWIGcHJvdG8z", [file_camino_api, file_quixos_package, file_quixos_refs, file_quixos_runtime]);
 
 /**
  * @generated from message quixos.orch.InvokeFunctionRequest
@@ -82,6 +84,80 @@ export type InvokeFunctionResponse = Message<"quixos.orch.InvokeFunctionResponse
 export const InvokeFunctionResponseSchema: GenMessage<InvokeFunctionResponse> = /*@__PURE__*/
   messageDesc(file_quixos_orch, 1);
 
+/**
+ * @generated from message quixos.orch.WatchFunctionRequest
+ */
+export type WatchFunctionRequest = Message<"quixos.orch.WatchFunctionRequest"> & {
+  /**
+   * @generated from field: quixos.FunctionRef function = 1;
+   */
+  function?: FunctionRef | undefined;
+
+  /**
+   * @generated from field: string object_id = 2;
+   */
+  objectId: string;
+
+  /**
+   * @generated from field: map<string, camino.Value> input = 3;
+   */
+  input: { [key: string]: Value };
+};
+
+/**
+ * Describes the message quixos.orch.WatchFunctionRequest.
+ * Use `create(WatchFunctionRequestSchema)` to create a new message.
+ */
+export const WatchFunctionRequestSchema: GenMessage<WatchFunctionRequest> = /*@__PURE__*/
+  messageDesc(file_quixos_orch, 2);
+
+/**
+ * @generated from message quixos.orch.WatchFunctionEvent
+ */
+export type WatchFunctionEvent = Message<"quixos.orch.WatchFunctionEvent"> & {
+  /**
+   * @generated from field: string invocation_id = 1;
+   */
+  invocationId: string;
+
+  /**
+   * @generated from field: quixos.orch.Activation activation = 2;
+   */
+  activation?: Activation | undefined;
+
+  /**
+   * @generated from field: string watch_id = 3;
+   */
+  watchId: string;
+
+  /**
+   * @generated from field: camino.Value value = 4;
+   */
+  value?: Value | undefined;
+
+  /**
+   * @generated from field: repeated quixos.runtime.DerivedDependency dependencies = 5;
+   */
+  dependencies: DerivedDependency[];
+
+  /**
+   * @generated from field: string error = 6;
+   */
+  error: string;
+
+  /**
+   * @generated from field: bool initial = 7;
+   */
+  initial: boolean;
+};
+
+/**
+ * Describes the message quixos.orch.WatchFunctionEvent.
+ * Use `create(WatchFunctionEventSchema)` to create a new message.
+ */
+export const WatchFunctionEventSchema: GenMessage<WatchFunctionEvent> = /*@__PURE__*/
+  messageDesc(file_quixos_orch, 3);
+
 /**
  * @generated from message quixos.orch.ListActivationsRequest
  */
@@ -93,7 +169,7 @@ export type ListActivationsRequest = Message<"quixos.orch.ListActivationsRequest
  * Use `create(ListActivationsRequestSchema)` to create a new message.
  */
 export const ListActivationsRequestSchema: GenMessage<ListActivationsRequest> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 2);
+  messageDesc(file_quixos_orch, 4);
 
 /**
  * @generated from message quixos.orch.ListPackageDescriptorsRequest
@@ -106,7 +182,7 @@ export type ListPackageDescriptorsRequest = Message<"quixos.orch.ListPackageDesc
  * Use `create(ListPackageDescriptorsRequestSchema)` to create a new message.
  */
 export const ListPackageDescriptorsRequestSchema: GenMessage<ListPackageDescriptorsRequest> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 3);
+  messageDesc(file_quixos_orch, 5);
 
 /**
  * @generated from message quixos.orch.ListPackageDescriptorsResponse
@@ -123,7 +199,7 @@ export type ListPackageDescriptorsResponse = Message<"quixos.orch.ListPackageDes
  * Use `create(ListPackageDescriptorsResponseSchema)` to create a new message.
  */
 export const ListPackageDescriptorsResponseSchema: GenMessage<ListPackageDescriptorsResponse> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 4);
+  messageDesc(file_quixos_orch, 6);
 
 /**
  * @generated from message quixos.orch.ListPackageRuntimesRequest
@@ -136,7 +212,7 @@ export type ListPackageRuntimesRequest = Message<"quixos.orch.ListPackageRuntime
  * Use `create(ListPackageRuntimesRequestSchema)` to create a new message.
  */
 export const ListPackageRuntimesRequestSchema: GenMessage<ListPackageRuntimesRequest> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 5);
+  messageDesc(file_quixos_orch, 7);
 
 /**
  * @generated from message quixos.orch.ListPackageRuntimesResponse
@@ -153,7 +229,7 @@ export type ListPackageRuntimesResponse = Message<"quixos.orch.ListPackageRuntim
  * Use `create(ListPackageRuntimesResponseSchema)` to create a new message.
  */
 export const ListPackageRuntimesResponseSchema: GenMessage<ListPackageRuntimesResponse> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 6);
+  messageDesc(file_quixos_orch, 8);
 
 /**
  * @generated from message quixos.orch.ListActivationsResponse
@@ -170,7 +246,7 @@ export type ListActivationsResponse = Message<"quixos.orch.ListActivationsRespon
  * Use `create(ListActivationsResponseSchema)` to create a new message.
  */
 export const ListActivationsResponseSchema: GenMessage<ListActivationsResponse> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 7);
+  messageDesc(file_quixos_orch, 9);
 
 /**
  * @generated from message quixos.orch.CloseActivationRequest
@@ -192,7 +268,7 @@ export type CloseActivationRequest = Message<"quixos.orch.CloseActivationRequest
  * Use `create(CloseActivationRequestSchema)` to create a new message.
  */
 export const CloseActivationRequestSchema: GenMessage<CloseActivationRequest> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 8);
+  messageDesc(file_quixos_orch, 10);
 
 /**
  * @generated from message quixos.orch.CloseActivationResponse
@@ -209,7 +285,7 @@ export type CloseActivationResponse = Message<"quixos.orch.CloseActivationRespon
  * Use `create(CloseActivationResponseSchema)` to create a new message.
  */
 export const CloseActivationResponseSchema: GenMessage<CloseActivationResponse> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 9);
+  messageDesc(file_quixos_orch, 11);
 
 /**
  * @generated from message quixos.orch.Activation
@@ -271,7 +347,7 @@ export type Activation = Message<"quixos.orch.Activation"> & {
  * Use `create(ActivationSchema)` to create a new message.
  */
 export const ActivationSchema: GenMessage<Activation> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 10);
+  messageDesc(file_quixos_orch, 12);
 
 /**
  * @generated from message quixos.orch.PackageRuntimeStatus
@@ -353,7 +429,7 @@ export type PackageRuntimeStatus = Message<"quixos.orch.PackageRuntimeStatus"> &
  * Use `create(PackageRuntimeStatusSchema)` to create a new message.
  */
 export const PackageRuntimeStatusSchema: GenMessage<PackageRuntimeStatus> = /*@__PURE__*/
-  messageDesc(file_quixos_orch, 11);
+  messageDesc(file_quixos_orch, 13);
 
 /**
  * @generated from service quixos.orch.OrchestratorRuntime
@@ -367,6 +443,14 @@ export const OrchestratorRuntime: GenService<{
     input: typeof InvokeFunctionRequestSchema;
     output: typeof InvokeFunctionResponseSchema;
   },
+  /**
+   * @generated from rpc quixos.orch.OrchestratorRuntime.WatchFunction
+   */
+  watchFunction: {
+    methodKind: "server_streaming";
+    input: typeof WatchFunctionRequestSchema;
+    output: typeof WatchFunctionEventSchema;
+  },
   /**
    * @generated from rpc quixos.orch.OrchestratorRuntime.ListPackageDescriptors
    */
@@ -401,3 +485,4 @@ export const OrchestratorRuntime: GenService<{
   },
 }> = /*@__PURE__*/
   serviceDesc(file_quixos_orch, 0);
+

src/gen/quixos/package_pb.ts

@@ -310,3 +310,4 @@ export enum FunctionCapabilityKind {
  */
 export const FunctionCapabilityKindSchema: GenEnum<FunctionCapabilityKind> = /*@__PURE__*/
   enumDesc(file_quixos_package, 0);
+

src/gen/quixos/refs_pb.ts

@@ -48,3 +48,4 @@ export type FunctionRef = Message<"quixos.FunctionRef"> & {
  */
 export const FunctionRefSchema: GenMessage<FunctionRef> = /*@__PURE__*/
   messageDesc(file_quixos_refs, 0);
+

src/gen/quixos/runtime_pb.ts

@@ -14,7 +14,7 @@ import type { Message } from "@bufbuild/protobuf";
  * Describes the file quixos/runtime.proto.
  */
 export const file_quixos_runtime: GenFile = /*@__PURE__*/
-  fileDesc("ChRxdWl4b3MvcnVudGltZS5wcm90bxIOcXVpeG9zLnJ1bnRpbWUiMQoQSGFuZHNoYWtlUmVxdWVzdBIdChVvcmNoX3Byb3RvY29sX3ZlcnNpb24YASABKAkijgEKEUhhbmRzaGFrZVJlc3BvbnNlEhkKEXBhY2thZ2VfbmFtZXNwYWNlGAEgASgJEhQKDHBhY2thZ2VfbmFtZRgCIAEoCRIgChhydW50aW1lX3Byb3RvY29sX3ZlcnNpb24YAyABKAkSJgoJZnVuY3Rpb25zGAQgAygLMhMucXVpeG9zLkZ1bmN0aW9uUmVmItYBCg1JbnZva2VSZXF1ZXN0EhUKDWludm9jYXRpb25faWQYASABKAkSJQoIZnVuY3Rpb24YAiABKAsyEy5xdWl4b3MuRnVuY3Rpb25SZWYSEQoJb2JqZWN0X2lkGAMgASgJEjcKBWlucHV0GAQgAygLMigucXVpeG9zLnJ1bnRpbWUuSW52b2tlUmVxdWVzdC5JbnB1dEVudHJ5GjsKCklucHV0RW50cnkSCwoDa2V5GAEgASgJEhwKBXZhbHVlGAIgASgLMg0uY2FtaW5vLlZhbHVlOgI4ASJKCg5JbnZva2VSZXNwb25zZRIKCgJvaxgBIAEoCBIdCgZyZXN1bHQYAiABKAsyDS5jYW1pbm8uVmFsdWUSDQoFZXJyb3IYAyABKAkyqwEKDlBhY2thZ2VSdW50aW1lElAKCUhhbmRzaGFrZRIgLnF1aXhvcy5ydW50aW1lLkhhbmRzaGFrZVJlcXVlc3QaIS5xdWl4b3MucnVudGltZS5IYW5kc2hha2VSZXNwb25zZRJHCgZJbnZva2USHS5xdWl4b3MucnVudGltZS5JbnZva2VSZXF1ZXN0Gh4ucXVpeG9zLnJ1bnRpbWUuSW52b2tlUmVzcG9uc2ViBnByb3RvMw", [file_camino_api, file_quixos_refs]);
+  fileDesc("ChRxdWl4b3MvcnVudGltZS5wcm90bxIOcXVpeG9zLnJ1bnRpbWUiMQoQSGFuZHNoYWtlUmVxdWVzdBIdChVvcmNoX3Byb3RvY29sX3ZlcnNpb24YASABKAkijgEKEUhhbmRzaGFrZVJlc3BvbnNlEhkKEXBhY2thZ2VfbmFtZXNwYWNlGAEgASgJEhQKDHBhY2thZ2VfbmFtZRgCIAEoCRIgChhydW50aW1lX3Byb3RvY29sX3ZlcnNpb24YAyABKAkSJgoJZnVuY3Rpb25zGAQgAygLMhMucXVpeG9zLkZ1bmN0aW9uUmVmItYBCg1JbnZva2VSZXF1ZXN0EhUKDWludm9jYXRpb25faWQYASABKAkSJQoIZnVuY3Rpb24YAiABKAsyEy5xdWl4b3MuRnVuY3Rpb25SZWYSEQoJb2JqZWN0X2lkGAMgASgJEjcKBWlucHV0GAQgAygLMigucXVpeG9zLnJ1bnRpbWUuSW52b2tlUmVxdWVzdC5JbnB1dEVudHJ5GjsKCklucHV0RW50cnkSCwoDa2V5GAEgASgJEhwKBXZhbHVlGAIgASgLMg0uY2FtaW5vLlZhbHVlOgI4ASJKCg5JbnZva2VSZXNwb25zZRIKCgJvaxgBIAEoCBIdCgZyZXN1bHQYAiABKAsyDS5jYW1pbm8uVmFsdWUSDQoFZXJyb3IYAyABKAki1AEKDFdhdGNoUmVxdWVzdBIVCg1pbnZvY2F0aW9uX2lkGAEgASgJEiUKCGZ1bmN0aW9uGAIgASgLMhMucXVpeG9zLkZ1bmN0aW9uUmVmEhEKCW9iamVjdF9pZBgDIAEoCRI2CgVpbnB1dBgEIAMoCzInLnF1aXhvcy5ydW50aW1lLldhdGNoUmVxdWVzdC5JbnB1dEVudHJ5GjsKCklucHV0RW50cnkSCwoDa2V5GAEgASgJEhwKBXZhbHVlGAIgASgLMg0uY2FtaW5vLlZhbHVlOgI4ASJeChFEZXJpdmVkRGVwZW5kZW5jeRIMCgRraW5kGAEgASgJEhEKCW9iamVjdF9pZBgCIAEoCRISCgpmaWVsZF9uYW1lGAMgASgJEhQKDHNvdXJjZV9maWVsZBgEIAEoCSKVAQoKV2F0Y2hFdmVudBIQCgh3YXRjaF9pZBgBIAEoCRIcCgV2YWx1ZRgCIAEoCzINLmNhbWluby5WYWx1ZRI3CgxkZXBlbmRlbmNpZXMYAyADKAsyIS5xdWl4b3MucnVudGltZS5EZXJpdmVkRGVwZW5kZW5jeRINCgVlcnJvchgEIAEoCRIPCgdpbml0aWFsGAUgASgIMvABCg5QYWNrYWdlUnVudGltZRJQCglIYW5kc2hha2USIC5xdWl4b3MucnVudGltZS5IYW5kc2hha2VSZXF1ZXN0GiEucXVpeG9zLnJ1bnRpbWUuSGFuZHNoYWtlUmVzcG9uc2USRwoGSW52b2tlEh0ucXVpeG9zLnJ1bnRpbWUuSW52b2tlUmVxdWVzdBoeLnF1aXhvcy5ydW50aW1lLkludm9rZVJlc3BvbnNlEkMKBVdhdGNoEhwucXVpeG9zLnJ1bnRpbWUuV2F0Y2hSZXF1ZXN0GhoucXVpeG9zLnJ1bnRpbWUuV2F0Y2hFdmVudDABYgZwcm90bzM", [file_camino_api, file_quixos_refs]);
 
 /**
  * @generated from message quixos.runtime.HandshakeRequest
@@ -124,6 +124,107 @@ export type InvokeResponse = Message<"quixos.runtime.InvokeResponse"> & {
 export const InvokeResponseSchema: GenMessage<InvokeResponse> = /*@__PURE__*/
   messageDesc(file_quixos_runtime, 3);
 
+/**
+ * @generated from message quixos.runtime.WatchRequest
+ */
+export type WatchRequest = Message<"quixos.runtime.WatchRequest"> & {
+  /**
+   * @generated from field: string invocation_id = 1;
+   */
+  invocationId: string;
+
+  /**
+   * @generated from field: quixos.FunctionRef function = 2;
+   */
+  function?: FunctionRef | undefined;
+
+  /**
+   * @generated from field: string object_id = 3;
+   */
+  objectId: string;
+
+  /**
+   * @generated from field: map<string, camino.Value> input = 4;
+   */
+  input: { [key: string]: Value };
+};
+
+/**
+ * Describes the message quixos.runtime.WatchRequest.
+ * Use `create(WatchRequestSchema)` to create a new message.
+ */
+export const WatchRequestSchema: GenMessage<WatchRequest> = /*@__PURE__*/
+  messageDesc(file_quixos_runtime, 4);
+
+/**
+ * @generated from message quixos.runtime.DerivedDependency
+ */
+export type DerivedDependency = Message<"quixos.runtime.DerivedDependency"> & {
+  /**
+   * @generated from field: string kind = 1;
+   */
+  kind: string;
+
+  /**
+   * @generated from field: string object_id = 2;
+   */
+  objectId: string;
+
+  /**
+   * @generated from field: string field_name = 3;
+   */
+  fieldName: string;
+
+  /**
+   * @generated from field: string source_field = 4;
+   */
+  sourceField: string;
+};
+
+/**
+ * Describes the message quixos.runtime.DerivedDependency.
+ * Use `create(DerivedDependencySchema)` to create a new message.
+ */
+export const DerivedDependencySchema: GenMessage<DerivedDependency> = /*@__PURE__*/
+  messageDesc(file_quixos_runtime, 5);
+
+/**
+ * @generated from message quixos.runtime.WatchEvent
+ */
+export type WatchEvent = Message<"quixos.runtime.WatchEvent"> & {
+  /**
+   * @generated from field: string watch_id = 1;
+   */
+  watchId: string;
+
+  /**
+   * @generated from field: camino.Value value = 2;
+   */
+  value?: Value | undefined;
+
+  /**
+   * @generated from field: repeated quixos.runtime.DerivedDependency dependencies = 3;
+   */
+  dependencies: DerivedDependency[];
+
+  /**
+   * @generated from field: string error = 4;
+   */
+  error: string;
+
+  /**
+   * @generated from field: bool initial = 5;
+   */
+  initial: boolean;
+};
+
+/**
+ * Describes the message quixos.runtime.WatchEvent.
+ * Use `create(WatchEventSchema)` to create a new message.
+ */
+export const WatchEventSchema: GenMessage<WatchEvent> = /*@__PURE__*/
+  messageDesc(file_quixos_runtime, 6);
+
 /**
  * @generated from service quixos.runtime.PackageRuntime
  */
@@ -144,5 +245,14 @@ export const PackageRuntime: GenService<{
     input: typeof InvokeRequestSchema;
     output: typeof InvokeResponseSchema;
   },
+  /**
+   * @generated from rpc quixos.runtime.PackageRuntime.Watch
+   */
+  watch: {
+    methodKind: "server_streaming";
+    input: typeof WatchRequestSchema;
+    output: typeof WatchEventSchema;
+  },
 }> = /*@__PURE__*/
   serviceDesc(file_quixos_runtime, 0);
+