diff --git a/proto/quixos/orch.proto b/proto/quixos/orch.proto index b0f746e..4a4f32d 100644 --- a/proto/quixos/orch.proto +++ b/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 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 {} diff --git a/proto/quixos/runtime.proto b/proto/quixos/runtime.proto index 241db00..cb86b70 100644 --- a/proto/quixos/runtime.proto +++ b/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 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; +} diff --git a/src/gen/camino/api_pb.ts b/src/gen/camino/api_pb.ts index c545abd..ef23474 100644 --- a/src/gen/camino/api_pb.ts +++ b/src/gen/camino/api_pb.ts @@ -854,3 +854,4 @@ export const CaminoService: GenService<{ }, }> = /*@__PURE__*/ serviceDesc(file_camino_api, 0); + diff --git a/src/gen/camino/options_pb.ts b/src/gen/camino/options_pb.ts index a06d4fe..b039a4a 100644 --- a/src/gen/camino/options_pb.ts +++ b/src/gen/camino/options_pb.ts @@ -180,3 +180,4 @@ export const field_ops: GenExtension = /*@__PURE__*/ */ export const impl: GenExtension = /*@__PURE__*/ extDesc(file_camino_options, 9); + diff --git a/src/gen/camino/schema_pb.ts b/src/gen/camino/schema_pb.ts index c9729b2..09e6ea0 100644 --- a/src/gen/camino/schema_pb.ts +++ b/src/gen/camino/schema_pb.ts @@ -695,3 +695,4 @@ export enum FieldImplementation { */ export const FieldImplementationSchema: GenEnum = /*@__PURE__*/ enumDesc(file_camino_schema, 4); + diff --git a/src/gen/quixos/orch_pb.ts b/src/gen/quixos/orch_pb.ts index a48f708..b9dbc80 100644 --- a/src/gen/quixos/orch_pb.ts +++ b/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 = /*@__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 input = 3; + */ + input: { [key: string]: Value }; +}; + +/** + * Describes the message quixos.orch.WatchFunctionRequest. + * Use `create(WatchFunctionRequestSchema)` to create a new message. + */ +export const WatchFunctionRequestSchema: GenMessage = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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 = /*@__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); + diff --git a/src/gen/quixos/package_pb.ts b/src/gen/quixos/package_pb.ts index e8fc067..dfeb9bb 100644 --- a/src/gen/quixos/package_pb.ts +++ b/src/gen/quixos/package_pb.ts @@ -310,3 +310,4 @@ export enum FunctionCapabilityKind { */ export const FunctionCapabilityKindSchema: GenEnum = /*@__PURE__*/ enumDesc(file_quixos_package, 0); + diff --git a/src/gen/quixos/refs_pb.ts b/src/gen/quixos/refs_pb.ts index ee3f89e..f320aa2 100644 --- a/src/gen/quixos/refs_pb.ts +++ b/src/gen/quixos/refs_pb.ts @@ -48,3 +48,4 @@ export type FunctionRef = Message<"quixos.FunctionRef"> & { */ export const FunctionRefSchema: GenMessage = /*@__PURE__*/ messageDesc(file_quixos_refs, 0); + diff --git a/src/gen/quixos/runtime_pb.ts b/src/gen/quixos/runtime_pb.ts index 8ffc7fe..6574d7d 100644 --- a/src/gen/quixos/runtime_pb.ts +++ b/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 = /*@__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 input = 4; + */ + input: { [key: string]: Value }; +}; + +/** + * Describes the message quixos.runtime.WatchRequest. + * Use `create(WatchRequestSchema)` to create a new message. + */ +export const WatchRequestSchema: GenMessage = /*@__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 = /*@__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 = /*@__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); +