From 82cdc452a53c71f76932967f63fc0d4b876525da Mon Sep 17 00:00:00 2001 From: Matteo Ferrando Date: Tue, 11 Feb 2025 01:48:39 -0400 Subject: [PATCH] feat: include external_metadata in proto (#411) --- .../src/isolate_proto/controller.proto | 2 +- .../src/isolate_proto/controller_pb2.py | 179 ++++++----- .../src/isolate_proto/controller_pb2.pyi | 290 +++++++++--------- 3 files changed, 229 insertions(+), 242 deletions(-) diff --git a/projects/isolate_proto/src/isolate_proto/controller.proto b/projects/isolate_proto/src/isolate_proto/controller.proto index bb1628dd..85313184 100644 --- a/projects/isolate_proto/src/isolate_proto/controller.proto +++ b/projects/isolate_proto/src/isolate_proto/controller.proto @@ -3,7 +3,6 @@ syntax = "proto3"; import "common.proto"; import "server.proto"; import "google/protobuf/timestamp.proto"; -import "google/protobuf/duration.proto"; import "google/protobuf/struct.proto"; package controller; @@ -317,6 +316,7 @@ message RunnerInfo { int32 in_flight_requests = 2; optional int32 expiration_countdown = 3; float uptime = 4; + optional google.protobuf.Struct external_metadata = 5; } message KillRunnerRequest { diff --git a/projects/isolate_proto/src/isolate_proto/controller_pb2.py b/projects/isolate_proto/src/isolate_proto/controller_pb2.py index 04b5c158..9a6e1126 100644 --- a/projects/isolate_proto/src/isolate_proto/controller_pb2.py +++ b/projects/isolate_proto/src/isolate_proto/controller_pb2.py @@ -15,11 +15,10 @@ from isolate.connections.grpc.definitions import common_pb2 as common__pb2 from isolate.server.definitions import server_pb2 as server__pb2 from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 -from google.protobuf import duration_pb2 as google_dot_protobuf_dot_duration__pb2 from google.protobuf import struct_pb2 as google_dot_protobuf_dot_struct__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x63ontroller.proto\x12\ncontroller\x1a\x0c\x63ommon.proto\x1a\x0cserver.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xde\x01\n\tHostedMap\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12!\n\x06inputs\x18\x04 \x03(\x0b\x32\x11.SerializedObjectB\x17\n\x15_machine_requirements\"\xf6\x01\n\tHostedRun\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_func\"\x88\x01\n\x14\x43reateUserKeyRequest\x12\x35\n\x05scope\x18\x01 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\x12\n\x05\x61lias\x18\x02 \x01(\tH\x00\x88\x01\x01\"\x1b\n\x05Scope\x12\t\n\x05\x41\x44MIN\x10\x00\x12\x07\n\x03\x41PI\x10\x01\x42\x08\n\x06_alias\";\n\x15\x43reateUserKeyResponse\x12\x12\n\nkey_secret\x18\x01 \x01(\t\x12\x0e\n\x06key_id\x18\x02 \x01(\t\"\x15\n\x13ListUserKeysRequest\"B\n\x14ListUserKeysResponse\x12*\n\tuser_keys\x18\x01 \x03(\x0b\x32\x17.controller.UserKeyInfo\"&\n\x14RevokeUserKeyRequest\x12\x0e\n\x06key_id\x18\x01 \x01(\t\"\x17\n\x15RevokeUserKeyResponse\"\x93\x01\n\x0bUserKeyInfo\x12\x0e\n\x06key_id\x18\x01 \x01(\t\x12.\n\ncreated_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x35\n\x05scope\x18\x03 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\r\n\x05\x61lias\x18\x04 \x01(\t\"\xb1\x01\n\x0fHostedRunResult\x12\x0e\n\x06run_id\x18\x01 \x01(\t\x12\x30\n\x06status\x18\x02 \x01(\x0b\x32\x1b.controller.HostedRunStatusH\x00\x88\x01\x01\x12\x12\n\x04logs\x18\x03 \x03(\x0b\x32\x04.Log\x12,\n\x0creturn_value\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\t\n\x07_statusB\x0f\n\r_return_value\"\x80\x01\n\x0fHostedRunStatus\x12\x30\n\x05state\x18\x01 \x01(\x0e\x32!.controller.HostedRunStatus.State\";\n\x05State\x12\x0f\n\x0bIN_PROGRESS\x10\x00\x12\x0b\n\x07SUCCESS\x10\x01\x12\x14\n\x10INTERNAL_FAILURE\x10\x02\"\xed\x04\n\x13MachineRequirements\x12\x1d\n\x0cmachine_type\x18\x01 \x01(\tB\x02\x18\x01H\x00\x88\x01\x01\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x01\x88\x01\x01\x12\x17\n\nbase_image\x18\x03 \x01(\tH\x02\x88\x01\x01\x12\x19\n\x0c\x65xposed_port\x18\x04 \x01(\x05H\x03\x88\x01\x01\x12\x16\n\tscheduler\x18\x05 \x01(\tH\x04\x88\x01\x01\x12\x37\n\x11scheduler_options\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x06 \x01(\x05H\x06\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\t \x01(\x05H\x07\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\n \x01(\x05H\x08\x88\x01\x01\x12\x15\n\rmachine_types\x18\x0b \x03(\t\x12\x15\n\x08num_gpus\x18\x0c \x01(\x05H\t\x88\x01\x01\x12\x1c\n\x0frequest_timeout\x18\r \x01(\x05H\n\x88\x01\x01\x12\x1c\n\x0fstartup_timeout\x18\x0e \x01(\x05H\x0b\x88\x01\x01\x42\x0f\n\r_machine_typeB\r\n\x0b_keep_aliveB\r\n\x0b_base_imageB\x0f\n\r_exposed_portB\x0c\n\n_schedulerB\x14\n\x12_scheduler_optionsB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrencyB\x0b\n\t_num_gpusB\x12\n\x10_request_timeoutB\x12\n\x10_startup_timeout\"\xed\x04\n\x1aRegisterApplicationRequest\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x12\x1d\n\x10\x61pplication_name\x18\x05 \x01(\tH\x02\x88\x01\x01\x12\x37\n\tauth_mode\x18\x06 \x01(\x0e\x32\x1f.controller.ApplicationAuthModeH\x03\x88\x01\x01\x12 \n\x0fmax_concurrency\x18\x07 \x01(\x05\x42\x02\x18\x01H\x04\x88\x01\x01\x12.\n\x08metadata\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12@\n\x13\x64\x65ployment_strategy\x18\t \x01(\x0e\x32\x1e.controller.DeploymentStrategyH\x06\x88\x01\x01\x12\x12\n\x05scale\x18\n \x01(\x08H\x07\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_funcB\x13\n\x11_application_nameB\x0c\n\n_auth_modeB\x12\n\x10_max_concurrencyB\x0b\n\t_metadataB\x16\n\x14_deployment_strategyB\x08\n\x06_scale\"7\n\x1dRegisterApplicationResultType\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"z\n\x19RegisterApplicationResult\x12\x12\n\x04logs\x18\x01 \x03(\x0b\x32\x04.Log\x12>\n\x06result\x18\x02 \x01(\x0b\x32).controller.RegisterApplicationResultTypeH\x00\x88\x01\x01\x42\t\n\x07_result\"\xa2\x02\n\x18UpdateApplicationRequest\x12\x18\n\x10\x61pplication_name\x18\x01 \x01(\t\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x00\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x03 \x01(\x05H\x01\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\x04 \x01(\x05H\x02\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\x05 \x01(\x05H\x03\x88\x01\x01\x12\x15\n\rvalid_regions\x18\x06 \x03(\t\x12\x15\n\rmachine_types\x18\x07 \x03(\tB\r\n\x0b_keep_aliveB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrency\"D\n\x17UpdateApplicationResult\x12)\n\nalias_info\x18\x01 \x01(\x0b\x32\x15.controller.AliasInfo\"\x19\n\x17ListApplicationsRequest\"\xb8\x01\n\x0f\x41pplicationInfo\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\x12\x17\n\x0fmax_concurrency\x18\x02 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x03 \x01(\x05\x12\x12\n\nkeep_alive\x18\x04 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x06 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x07 \x01(\x05\x12\x15\n\rmachine_types\x18\x08 \x03(\t\"K\n\x16ListApplicationsResult\x12\x31\n\x0c\x61pplications\x18\x01 \x03(\x0b\x32\x1b.controller.ApplicationInfo\"2\n\x18\x44\x65leteApplicationRequest\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"\x19\n\x17\x44\x65leteApplicationResult\"f\n\x0fSetAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\"\x10\n\x0eSetAliasResult\"#\n\x12\x44\x65leteAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"%\n\x11\x44\x65leteAliasResult\x12\x10\n\x08revision\x18\x01 \x01(\t\"\x14\n\x12ListAliasesRequest\";\n\x11ListAliasesResult\x12&\n\x07\x61liases\x18\x01 \x03(\x0b\x32\x15.controller.AliasInfo\"\xd8\x01\n\tAliasInfo\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\x12\x17\n\x0fmax_concurrency\x18\x04 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x05 \x01(\x05\x12\x12\n\nkeep_alive\x18\x06 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x07 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x08 \x01(\x05\">\n\x10SetSecretRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x12\n\x05value\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_value\"\x13\n\x11SetSecretResponse\"\x14\n\x12ListSecretsRequest\"^\n\x06Secret\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x35\n\x0c\x63reated_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x88\x01\x01\x42\x0f\n\r_created_time\":\n\x13ListSecretsResponse\x12#\n\x07secrets\x18\x01 \x03(\x0b\x32\x12.controller.Secret\"(\n\x17ListAliasRunnersRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"C\n\x18ListAliasRunnersResponse\x12\'\n\x07runners\x18\x01 \x03(\x0b\x32\x16.controller.RunnerInfo\"\x87\x01\n\nRunnerInfo\x12\x11\n\trunner_id\x18\x01 \x01(\t\x12\x1a\n\x12in_flight_requests\x18\x02 \x01(\x05\x12!\n\x14\x65xpiration_countdown\x18\x03 \x01(\x05H\x00\x88\x01\x01\x12\x0e\n\x06uptime\x18\x04 \x01(\x02\x42\x17\n\x15_expiration_countdown\"&\n\x11KillRunnerRequest\x12\x11\n\trunner_id\x18\x01 \x01(\t\"\x14\n\x12KillRunnerResponse*:\n\x13\x41pplicationAuthMode\x12\x0b\n\x07PRIVATE\x10\x00\x12\n\n\x06PUBLIC\x10\x01\x12\n\n\x06SHARED\x10\x02*/\n\x12\x44\x65ploymentStrategy\x12\x0c\n\x08RECREATE\x10\x00\x12\x0b\n\x07ROLLING\x10\x01\x32\xd8\n\n\x11IsolateController\x12=\n\x03Run\x12\x15.controller.HostedRun\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12=\n\x03Map\x12\x15.controller.HostedMap\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12V\n\rCreateUserKey\x12 .controller.CreateUserKeyRequest\x1a!.controller.CreateUserKeyResponse\"\x00\x12S\n\x0cListUserKeys\x12\x1f.controller.ListUserKeysRequest\x1a .controller.ListUserKeysResponse\"\x00\x12V\n\rRevokeUserKey\x12 .controller.RevokeUserKeyRequest\x1a!.controller.RevokeUserKeyResponse\"\x00\x12h\n\x13RegisterApplication\x12&.controller.RegisterApplicationRequest\x1a%.controller.RegisterApplicationResult\"\x00\x30\x01\x12`\n\x11UpdateApplication\x12$.controller.UpdateApplicationRequest\x1a#.controller.UpdateApplicationResult\"\x00\x12]\n\x10ListApplications\x12#.controller.ListApplicationsRequest\x1a\".controller.ListApplicationsResult\"\x00\x12`\n\x11\x44\x65leteApplication\x12$.controller.DeleteApplicationRequest\x1a#.controller.DeleteApplicationResult\"\x00\x12\x45\n\x08SetAlias\x12\x1b.controller.SetAliasRequest\x1a\x1a.controller.SetAliasResult\"\x00\x12N\n\x0b\x44\x65leteAlias\x12\x1e.controller.DeleteAliasRequest\x1a\x1d.controller.DeleteAliasResult\"\x00\x12N\n\x0bListAliases\x12\x1e.controller.ListAliasesRequest\x1a\x1d.controller.ListAliasesResult\"\x00\x12J\n\tSetSecret\x12\x1c.controller.SetSecretRequest\x1a\x1d.controller.SetSecretResponse\"\x00\x12P\n\x0bListSecrets\x12\x1e.controller.ListSecretsRequest\x1a\x1f.controller.ListSecretsResponse\"\x00\x12_\n\x10ListAliasRunners\x12#.controller.ListAliasRunnersRequest\x1a$.controller.ListAliasRunnersResponse\"\x00\x12M\n\nKillRunner\x12\x1d.controller.KillRunnerRequest\x1a\x1e.controller.KillRunnerResponse\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x63ontroller.proto\x12\ncontroller\x1a\x0c\x63ommon.proto\x1a\x0cserver.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xde\x01\n\tHostedMap\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12!\n\x06inputs\x18\x04 \x03(\x0b\x32\x11.SerializedObjectB\x17\n\x15_machine_requirements\"\xf6\x01\n\tHostedRun\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_func\"\x88\x01\n\x14\x43reateUserKeyRequest\x12\x35\n\x05scope\x18\x01 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\x12\n\x05\x61lias\x18\x02 \x01(\tH\x00\x88\x01\x01\"\x1b\n\x05Scope\x12\t\n\x05\x41\x44MIN\x10\x00\x12\x07\n\x03\x41PI\x10\x01\x42\x08\n\x06_alias\";\n\x15\x43reateUserKeyResponse\x12\x12\n\nkey_secret\x18\x01 \x01(\t\x12\x0e\n\x06key_id\x18\x02 \x01(\t\"\x15\n\x13ListUserKeysRequest\"B\n\x14ListUserKeysResponse\x12*\n\tuser_keys\x18\x01 \x03(\x0b\x32\x17.controller.UserKeyInfo\"&\n\x14RevokeUserKeyRequest\x12\x0e\n\x06key_id\x18\x01 \x01(\t\"\x17\n\x15RevokeUserKeyResponse\"\x93\x01\n\x0bUserKeyInfo\x12\x0e\n\x06key_id\x18\x01 \x01(\t\x12.\n\ncreated_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x35\n\x05scope\x18\x03 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\r\n\x05\x61lias\x18\x04 \x01(\t\"\xb1\x01\n\x0fHostedRunResult\x12\x0e\n\x06run_id\x18\x01 \x01(\t\x12\x30\n\x06status\x18\x02 \x01(\x0b\x32\x1b.controller.HostedRunStatusH\x00\x88\x01\x01\x12\x12\n\x04logs\x18\x03 \x03(\x0b\x32\x04.Log\x12,\n\x0creturn_value\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\t\n\x07_statusB\x0f\n\r_return_value\"\x80\x01\n\x0fHostedRunStatus\x12\x30\n\x05state\x18\x01 \x01(\x0e\x32!.controller.HostedRunStatus.State\";\n\x05State\x12\x0f\n\x0bIN_PROGRESS\x10\x00\x12\x0b\n\x07SUCCESS\x10\x01\x12\x14\n\x10INTERNAL_FAILURE\x10\x02\"\xed\x04\n\x13MachineRequirements\x12\x1d\n\x0cmachine_type\x18\x01 \x01(\tB\x02\x18\x01H\x00\x88\x01\x01\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x01\x88\x01\x01\x12\x17\n\nbase_image\x18\x03 \x01(\tH\x02\x88\x01\x01\x12\x19\n\x0c\x65xposed_port\x18\x04 \x01(\x05H\x03\x88\x01\x01\x12\x16\n\tscheduler\x18\x05 \x01(\tH\x04\x88\x01\x01\x12\x37\n\x11scheduler_options\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x06 \x01(\x05H\x06\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\t \x01(\x05H\x07\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\n \x01(\x05H\x08\x88\x01\x01\x12\x15\n\rmachine_types\x18\x0b \x03(\t\x12\x15\n\x08num_gpus\x18\x0c \x01(\x05H\t\x88\x01\x01\x12\x1c\n\x0frequest_timeout\x18\r \x01(\x05H\n\x88\x01\x01\x12\x1c\n\x0fstartup_timeout\x18\x0e \x01(\x05H\x0b\x88\x01\x01\x42\x0f\n\r_machine_typeB\r\n\x0b_keep_aliveB\r\n\x0b_base_imageB\x0f\n\r_exposed_portB\x0c\n\n_schedulerB\x14\n\x12_scheduler_optionsB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrencyB\x0b\n\t_num_gpusB\x12\n\x10_request_timeoutB\x12\n\x10_startup_timeout\"\xed\x04\n\x1aRegisterApplicationRequest\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x12\x1d\n\x10\x61pplication_name\x18\x05 \x01(\tH\x02\x88\x01\x01\x12\x37\n\tauth_mode\x18\x06 \x01(\x0e\x32\x1f.controller.ApplicationAuthModeH\x03\x88\x01\x01\x12 \n\x0fmax_concurrency\x18\x07 \x01(\x05\x42\x02\x18\x01H\x04\x88\x01\x01\x12.\n\x08metadata\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12@\n\x13\x64\x65ployment_strategy\x18\t \x01(\x0e\x32\x1e.controller.DeploymentStrategyH\x06\x88\x01\x01\x12\x12\n\x05scale\x18\n \x01(\x08H\x07\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_funcB\x13\n\x11_application_nameB\x0c\n\n_auth_modeB\x12\n\x10_max_concurrencyB\x0b\n\t_metadataB\x16\n\x14_deployment_strategyB\x08\n\x06_scale\"7\n\x1dRegisterApplicationResultType\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"z\n\x19RegisterApplicationResult\x12\x12\n\x04logs\x18\x01 \x03(\x0b\x32\x04.Log\x12>\n\x06result\x18\x02 \x01(\x0b\x32).controller.RegisterApplicationResultTypeH\x00\x88\x01\x01\x42\t\n\x07_result\"\xa2\x02\n\x18UpdateApplicationRequest\x12\x18\n\x10\x61pplication_name\x18\x01 \x01(\t\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x00\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x03 \x01(\x05H\x01\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\x04 \x01(\x05H\x02\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\x05 \x01(\x05H\x03\x88\x01\x01\x12\x15\n\rvalid_regions\x18\x06 \x03(\t\x12\x15\n\rmachine_types\x18\x07 \x03(\tB\r\n\x0b_keep_aliveB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrency\"D\n\x17UpdateApplicationResult\x12)\n\nalias_info\x18\x01 \x01(\x0b\x32\x15.controller.AliasInfo\"\x19\n\x17ListApplicationsRequest\"\xb8\x01\n\x0f\x41pplicationInfo\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\x12\x17\n\x0fmax_concurrency\x18\x02 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x03 \x01(\x05\x12\x12\n\nkeep_alive\x18\x04 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x06 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x07 \x01(\x05\x12\x15\n\rmachine_types\x18\x08 \x03(\t\"K\n\x16ListApplicationsResult\x12\x31\n\x0c\x61pplications\x18\x01 \x03(\x0b\x32\x1b.controller.ApplicationInfo\"2\n\x18\x44\x65leteApplicationRequest\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"\x19\n\x17\x44\x65leteApplicationResult\"f\n\x0fSetAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\"\x10\n\x0eSetAliasResult\"#\n\x12\x44\x65leteAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"%\n\x11\x44\x65leteAliasResult\x12\x10\n\x08revision\x18\x01 \x01(\t\"\x14\n\x12ListAliasesRequest\";\n\x11ListAliasesResult\x12&\n\x07\x61liases\x18\x01 \x03(\x0b\x32\x15.controller.AliasInfo\"\xd8\x01\n\tAliasInfo\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\x12\x17\n\x0fmax_concurrency\x18\x04 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x05 \x01(\x05\x12\x12\n\nkeep_alive\x18\x06 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x07 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x08 \x01(\x05\">\n\x10SetSecretRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x12\n\x05value\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_value\"\x13\n\x11SetSecretResponse\"\x14\n\x12ListSecretsRequest\"^\n\x06Secret\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x35\n\x0c\x63reated_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x88\x01\x01\x42\x0f\n\r_created_time\":\n\x13ListSecretsResponse\x12#\n\x07secrets\x18\x01 \x03(\x0b\x32\x12.controller.Secret\"(\n\x17ListAliasRunnersRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"C\n\x18ListAliasRunnersResponse\x12\'\n\x07runners\x18\x01 \x03(\x0b\x32\x16.controller.RunnerInfo\"\xd6\x01\n\nRunnerInfo\x12\x11\n\trunner_id\x18\x01 \x01(\t\x12\x1a\n\x12in_flight_requests\x18\x02 \x01(\x05\x12!\n\x14\x65xpiration_countdown\x18\x03 \x01(\x05H\x00\x88\x01\x01\x12\x0e\n\x06uptime\x18\x04 \x01(\x02\x12\x37\n\x11\x65xternal_metadata\x18\x05 \x01(\x0b\x32\x17.google.protobuf.StructH\x01\x88\x01\x01\x42\x17\n\x15_expiration_countdownB\x14\n\x12_external_metadata\"&\n\x11KillRunnerRequest\x12\x11\n\trunner_id\x18\x01 \x01(\t\"\x14\n\x12KillRunnerResponse*:\n\x13\x41pplicationAuthMode\x12\x0b\n\x07PRIVATE\x10\x00\x12\n\n\x06PUBLIC\x10\x01\x12\n\n\x06SHARED\x10\x02*/\n\x12\x44\x65ploymentStrategy\x12\x0c\n\x08RECREATE\x10\x00\x12\x0b\n\x07ROLLING\x10\x01\x32\xd8\n\n\x11IsolateController\x12=\n\x03Run\x12\x15.controller.HostedRun\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12=\n\x03Map\x12\x15.controller.HostedMap\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12V\n\rCreateUserKey\x12 .controller.CreateUserKeyRequest\x1a!.controller.CreateUserKeyResponse\"\x00\x12S\n\x0cListUserKeys\x12\x1f.controller.ListUserKeysRequest\x1a .controller.ListUserKeysResponse\"\x00\x12V\n\rRevokeUserKey\x12 .controller.RevokeUserKeyRequest\x1a!.controller.RevokeUserKeyResponse\"\x00\x12h\n\x13RegisterApplication\x12&.controller.RegisterApplicationRequest\x1a%.controller.RegisterApplicationResult\"\x00\x30\x01\x12`\n\x11UpdateApplication\x12$.controller.UpdateApplicationRequest\x1a#.controller.UpdateApplicationResult\"\x00\x12]\n\x10ListApplications\x12#.controller.ListApplicationsRequest\x1a\".controller.ListApplicationsResult\"\x00\x12`\n\x11\x44\x65leteApplication\x12$.controller.DeleteApplicationRequest\x1a#.controller.DeleteApplicationResult\"\x00\x12\x45\n\x08SetAlias\x12\x1b.controller.SetAliasRequest\x1a\x1a.controller.SetAliasResult\"\x00\x12N\n\x0b\x44\x65leteAlias\x12\x1e.controller.DeleteAliasRequest\x1a\x1d.controller.DeleteAliasResult\"\x00\x12N\n\x0bListAliases\x12\x1e.controller.ListAliasesRequest\x1a\x1d.controller.ListAliasesResult\"\x00\x12J\n\tSetSecret\x12\x1c.controller.SetSecretRequest\x1a\x1d.controller.SetSecretResponse\"\x00\x12P\n\x0bListSecrets\x12\x1e.controller.ListSecretsRequest\x1a\x1f.controller.ListSecretsResponse\"\x00\x12_\n\x10ListAliasRunners\x12#.controller.ListAliasRunnersRequest\x1a$.controller.ListAliasRunnersResponse\"\x00\x12M\n\nKillRunner\x12\x1d.controller.KillRunnerRequest\x1a\x1e.controller.KillRunnerResponse\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -30,92 +29,92 @@ _globals['_MACHINEREQUIREMENTS'].fields_by_name['machine_type']._serialized_options = b'\030\001' _globals['_REGISTERAPPLICATIONREQUEST'].fields_by_name['max_concurrency']._loaded_options = None _globals['_REGISTERAPPLICATIONREQUEST'].fields_by_name['max_concurrency']._serialized_options = b'\030\001' - _globals['_APPLICATIONAUTHMODE']._serialized_start=4682 - _globals['_APPLICATIONAUTHMODE']._serialized_end=4740 - _globals['_DEPLOYMENTSTRATEGY']._serialized_start=4742 - _globals['_DEPLOYMENTSTRATEGY']._serialized_end=4789 - _globals['_HOSTEDMAP']._serialized_start=156 - _globals['_HOSTEDMAP']._serialized_end=378 - _globals['_HOSTEDRUN']._serialized_start=381 - _globals['_HOSTEDRUN']._serialized_end=627 - _globals['_CREATEUSERKEYREQUEST']._serialized_start=630 - _globals['_CREATEUSERKEYREQUEST']._serialized_end=766 - _globals['_CREATEUSERKEYREQUEST_SCOPE']._serialized_start=729 - _globals['_CREATEUSERKEYREQUEST_SCOPE']._serialized_end=756 - _globals['_CREATEUSERKEYRESPONSE']._serialized_start=768 - _globals['_CREATEUSERKEYRESPONSE']._serialized_end=827 - _globals['_LISTUSERKEYSREQUEST']._serialized_start=829 - _globals['_LISTUSERKEYSREQUEST']._serialized_end=850 - _globals['_LISTUSERKEYSRESPONSE']._serialized_start=852 - _globals['_LISTUSERKEYSRESPONSE']._serialized_end=918 - _globals['_REVOKEUSERKEYREQUEST']._serialized_start=920 - _globals['_REVOKEUSERKEYREQUEST']._serialized_end=958 - _globals['_REVOKEUSERKEYRESPONSE']._serialized_start=960 - _globals['_REVOKEUSERKEYRESPONSE']._serialized_end=983 - _globals['_USERKEYINFO']._serialized_start=986 - _globals['_USERKEYINFO']._serialized_end=1133 - _globals['_HOSTEDRUNRESULT']._serialized_start=1136 - _globals['_HOSTEDRUNRESULT']._serialized_end=1313 - _globals['_HOSTEDRUNSTATUS']._serialized_start=1316 - _globals['_HOSTEDRUNSTATUS']._serialized_end=1444 - _globals['_HOSTEDRUNSTATUS_STATE']._serialized_start=1385 - _globals['_HOSTEDRUNSTATUS_STATE']._serialized_end=1444 - _globals['_MACHINEREQUIREMENTS']._serialized_start=1447 - _globals['_MACHINEREQUIREMENTS']._serialized_end=2068 - _globals['_REGISTERAPPLICATIONREQUEST']._serialized_start=2071 - _globals['_REGISTERAPPLICATIONREQUEST']._serialized_end=2692 - _globals['_REGISTERAPPLICATIONRESULTTYPE']._serialized_start=2694 - _globals['_REGISTERAPPLICATIONRESULTTYPE']._serialized_end=2749 - _globals['_REGISTERAPPLICATIONRESULT']._serialized_start=2751 - _globals['_REGISTERAPPLICATIONRESULT']._serialized_end=2873 - _globals['_UPDATEAPPLICATIONREQUEST']._serialized_start=2876 - _globals['_UPDATEAPPLICATIONREQUEST']._serialized_end=3166 - _globals['_UPDATEAPPLICATIONRESULT']._serialized_start=3168 - _globals['_UPDATEAPPLICATIONRESULT']._serialized_end=3236 - _globals['_LISTAPPLICATIONSREQUEST']._serialized_start=3238 - _globals['_LISTAPPLICATIONSREQUEST']._serialized_end=3263 - _globals['_APPLICATIONINFO']._serialized_start=3266 - _globals['_APPLICATIONINFO']._serialized_end=3450 - _globals['_LISTAPPLICATIONSRESULT']._serialized_start=3452 - _globals['_LISTAPPLICATIONSRESULT']._serialized_end=3527 - _globals['_DELETEAPPLICATIONREQUEST']._serialized_start=3529 - _globals['_DELETEAPPLICATIONREQUEST']._serialized_end=3579 - _globals['_DELETEAPPLICATIONRESULT']._serialized_start=3581 - _globals['_DELETEAPPLICATIONRESULT']._serialized_end=3606 - _globals['_SETALIASREQUEST']._serialized_start=3608 - _globals['_SETALIASREQUEST']._serialized_end=3710 - _globals['_SETALIASRESULT']._serialized_start=3712 - _globals['_SETALIASRESULT']._serialized_end=3728 - _globals['_DELETEALIASREQUEST']._serialized_start=3730 - _globals['_DELETEALIASREQUEST']._serialized_end=3765 - _globals['_DELETEALIASRESULT']._serialized_start=3767 - _globals['_DELETEALIASRESULT']._serialized_end=3804 - _globals['_LISTALIASESREQUEST']._serialized_start=3806 - _globals['_LISTALIASESREQUEST']._serialized_end=3826 - _globals['_LISTALIASESRESULT']._serialized_start=3828 - _globals['_LISTALIASESRESULT']._serialized_end=3887 - _globals['_ALIASINFO']._serialized_start=3890 - _globals['_ALIASINFO']._serialized_end=4106 - _globals['_SETSECRETREQUEST']._serialized_start=4108 - _globals['_SETSECRETREQUEST']._serialized_end=4170 - _globals['_SETSECRETRESPONSE']._serialized_start=4172 - _globals['_SETSECRETRESPONSE']._serialized_end=4191 - _globals['_LISTSECRETSREQUEST']._serialized_start=4193 - _globals['_LISTSECRETSREQUEST']._serialized_end=4213 - _globals['_SECRET']._serialized_start=4215 - _globals['_SECRET']._serialized_end=4309 - _globals['_LISTSECRETSRESPONSE']._serialized_start=4311 - _globals['_LISTSECRETSRESPONSE']._serialized_end=4369 - _globals['_LISTALIASRUNNERSREQUEST']._serialized_start=4371 - _globals['_LISTALIASRUNNERSREQUEST']._serialized_end=4411 - _globals['_LISTALIASRUNNERSRESPONSE']._serialized_start=4413 - _globals['_LISTALIASRUNNERSRESPONSE']._serialized_end=4480 - _globals['_RUNNERINFO']._serialized_start=4483 - _globals['_RUNNERINFO']._serialized_end=4618 - _globals['_KILLRUNNERREQUEST']._serialized_start=4620 - _globals['_KILLRUNNERREQUEST']._serialized_end=4658 - _globals['_KILLRUNNERRESPONSE']._serialized_start=4660 - _globals['_KILLRUNNERRESPONSE']._serialized_end=4680 - _globals['_ISOLATECONTROLLER']._serialized_start=4792 - _globals['_ISOLATECONTROLLER']._serialized_end=6160 + _globals['_APPLICATIONAUTHMODE']._serialized_start=4729 + _globals['_APPLICATIONAUTHMODE']._serialized_end=4787 + _globals['_DEPLOYMENTSTRATEGY']._serialized_start=4789 + _globals['_DEPLOYMENTSTRATEGY']._serialized_end=4836 + _globals['_HOSTEDMAP']._serialized_start=124 + _globals['_HOSTEDMAP']._serialized_end=346 + _globals['_HOSTEDRUN']._serialized_start=349 + _globals['_HOSTEDRUN']._serialized_end=595 + _globals['_CREATEUSERKEYREQUEST']._serialized_start=598 + _globals['_CREATEUSERKEYREQUEST']._serialized_end=734 + _globals['_CREATEUSERKEYREQUEST_SCOPE']._serialized_start=697 + _globals['_CREATEUSERKEYREQUEST_SCOPE']._serialized_end=724 + _globals['_CREATEUSERKEYRESPONSE']._serialized_start=736 + _globals['_CREATEUSERKEYRESPONSE']._serialized_end=795 + _globals['_LISTUSERKEYSREQUEST']._serialized_start=797 + _globals['_LISTUSERKEYSREQUEST']._serialized_end=818 + _globals['_LISTUSERKEYSRESPONSE']._serialized_start=820 + _globals['_LISTUSERKEYSRESPONSE']._serialized_end=886 + _globals['_REVOKEUSERKEYREQUEST']._serialized_start=888 + _globals['_REVOKEUSERKEYREQUEST']._serialized_end=926 + _globals['_REVOKEUSERKEYRESPONSE']._serialized_start=928 + _globals['_REVOKEUSERKEYRESPONSE']._serialized_end=951 + _globals['_USERKEYINFO']._serialized_start=954 + _globals['_USERKEYINFO']._serialized_end=1101 + _globals['_HOSTEDRUNRESULT']._serialized_start=1104 + _globals['_HOSTEDRUNRESULT']._serialized_end=1281 + _globals['_HOSTEDRUNSTATUS']._serialized_start=1284 + _globals['_HOSTEDRUNSTATUS']._serialized_end=1412 + _globals['_HOSTEDRUNSTATUS_STATE']._serialized_start=1353 + _globals['_HOSTEDRUNSTATUS_STATE']._serialized_end=1412 + _globals['_MACHINEREQUIREMENTS']._serialized_start=1415 + _globals['_MACHINEREQUIREMENTS']._serialized_end=2036 + _globals['_REGISTERAPPLICATIONREQUEST']._serialized_start=2039 + _globals['_REGISTERAPPLICATIONREQUEST']._serialized_end=2660 + _globals['_REGISTERAPPLICATIONRESULTTYPE']._serialized_start=2662 + _globals['_REGISTERAPPLICATIONRESULTTYPE']._serialized_end=2717 + _globals['_REGISTERAPPLICATIONRESULT']._serialized_start=2719 + _globals['_REGISTERAPPLICATIONRESULT']._serialized_end=2841 + _globals['_UPDATEAPPLICATIONREQUEST']._serialized_start=2844 + _globals['_UPDATEAPPLICATIONREQUEST']._serialized_end=3134 + _globals['_UPDATEAPPLICATIONRESULT']._serialized_start=3136 + _globals['_UPDATEAPPLICATIONRESULT']._serialized_end=3204 + _globals['_LISTAPPLICATIONSREQUEST']._serialized_start=3206 + _globals['_LISTAPPLICATIONSREQUEST']._serialized_end=3231 + _globals['_APPLICATIONINFO']._serialized_start=3234 + _globals['_APPLICATIONINFO']._serialized_end=3418 + _globals['_LISTAPPLICATIONSRESULT']._serialized_start=3420 + _globals['_LISTAPPLICATIONSRESULT']._serialized_end=3495 + _globals['_DELETEAPPLICATIONREQUEST']._serialized_start=3497 + _globals['_DELETEAPPLICATIONREQUEST']._serialized_end=3547 + _globals['_DELETEAPPLICATIONRESULT']._serialized_start=3549 + _globals['_DELETEAPPLICATIONRESULT']._serialized_end=3574 + _globals['_SETALIASREQUEST']._serialized_start=3576 + _globals['_SETALIASREQUEST']._serialized_end=3678 + _globals['_SETALIASRESULT']._serialized_start=3680 + _globals['_SETALIASRESULT']._serialized_end=3696 + _globals['_DELETEALIASREQUEST']._serialized_start=3698 + _globals['_DELETEALIASREQUEST']._serialized_end=3733 + _globals['_DELETEALIASRESULT']._serialized_start=3735 + _globals['_DELETEALIASRESULT']._serialized_end=3772 + _globals['_LISTALIASESREQUEST']._serialized_start=3774 + _globals['_LISTALIASESREQUEST']._serialized_end=3794 + _globals['_LISTALIASESRESULT']._serialized_start=3796 + _globals['_LISTALIASESRESULT']._serialized_end=3855 + _globals['_ALIASINFO']._serialized_start=3858 + _globals['_ALIASINFO']._serialized_end=4074 + _globals['_SETSECRETREQUEST']._serialized_start=4076 + _globals['_SETSECRETREQUEST']._serialized_end=4138 + _globals['_SETSECRETRESPONSE']._serialized_start=4140 + _globals['_SETSECRETRESPONSE']._serialized_end=4159 + _globals['_LISTSECRETSREQUEST']._serialized_start=4161 + _globals['_LISTSECRETSREQUEST']._serialized_end=4181 + _globals['_SECRET']._serialized_start=4183 + _globals['_SECRET']._serialized_end=4277 + _globals['_LISTSECRETSRESPONSE']._serialized_start=4279 + _globals['_LISTSECRETSRESPONSE']._serialized_end=4337 + _globals['_LISTALIASRUNNERSREQUEST']._serialized_start=4339 + _globals['_LISTALIASRUNNERSREQUEST']._serialized_end=4379 + _globals['_LISTALIASRUNNERSRESPONSE']._serialized_start=4381 + _globals['_LISTALIASRUNNERSRESPONSE']._serialized_end=4448 + _globals['_RUNNERINFO']._serialized_start=4451 + _globals['_RUNNERINFO']._serialized_end=4665 + _globals['_KILLRUNNERREQUEST']._serialized_start=4667 + _globals['_KILLRUNNERREQUEST']._serialized_end=4705 + _globals['_KILLRUNNERRESPONSE']._serialized_start=4707 + _globals['_KILLRUNNERRESPONSE']._serialized_end=4727 + _globals['_ISOLATECONTROLLER']._serialized_start=4839 + _globals['_ISOLATECONTROLLER']._serialized_end=6207 # @@protoc_insertion_point(module_scope) diff --git a/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi b/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi index 3c031d2f..9517d05a 100644 --- a/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi +++ b/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi @@ -2,7 +2,6 @@ @generated by mypy-protobuf. Do not edit manually! isort:skip_file """ - import builtins import collections.abc from isolate.connections.grpc.definitions import common_pb2 @@ -55,7 +54,7 @@ RECREATE: DeploymentStrategy.ValueType # 0 ROLLING: DeploymentStrategy.ValueType # 1 global___DeploymentStrategy = DeploymentStrategy -@typing.final +@typing_extensions.final class HostedMap(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -66,19 +65,15 @@ class HostedMap(google.protobuf.message.Message): @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def inputs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[common_pb2.SerializedObject]: """Inputs to the function""" - def __init__( self, *, @@ -87,13 +82,13 @@ class HostedMap(google.protobuf.message.Message): function: common_pb2.SerializedObject | None = ..., inputs: collections.abc.Iterable[common_pb2.SerializedObject] | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "function", b"function", "machine_requirements", b"machine_requirements"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "environments", b"environments", "function", b"function", "inputs", b"inputs", "machine_requirements", b"machine_requirements"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "function", b"function", "machine_requirements", b"machine_requirements"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "environments", b"environments", "function", b"function", "inputs", b"inputs", "machine_requirements", b"machine_requirements"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... global___HostedMap = HostedMap -@typing.final +@typing_extensions.final class HostedRun(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -104,19 +99,15 @@ class HostedRun(google.protobuf.message.Message): @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def setup_func(self) -> common_pb2.SerializedObject: """Optional setup function to pass as the first argument to the function.""" - def __init__( self, *, @@ -125,16 +116,16 @@ class HostedRun(google.protobuf.message.Message): function: common_pb2.SerializedObject | None = ..., setup_func: common_pb2.SerializedObject | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_setup_func", b"_setup_func"]) -> typing.Literal["setup_func"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_setup_func", b"_setup_func"]) -> typing_extensions.Literal["setup_func"] | None: ... global___HostedRun = HostedRun -@typing.final +@typing_extensions.final class CreateUserKeyRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -163,13 +154,13 @@ class CreateUserKeyRequest(google.protobuf.message.Message): scope: global___CreateUserKeyRequest.Scope.ValueType = ..., alias: builtins.str | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_alias", b"_alias", "alias", b"alias"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_alias", b"_alias", "alias", b"alias", "scope", b"scope"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_alias", b"_alias"]) -> typing.Literal["alias"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_alias", b"_alias", "alias", b"alias"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_alias", b"_alias", "alias", b"alias", "scope", b"scope"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_alias", b"_alias"]) -> typing_extensions.Literal["alias"] | None: ... global___CreateUserKeyRequest = CreateUserKeyRequest -@typing.final +@typing_extensions.final class CreateUserKeyResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -183,11 +174,11 @@ class CreateUserKeyResponse(google.protobuf.message.Message): key_secret: builtins.str = ..., key_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["key_id", b"key_id", "key_secret", b"key_secret"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["key_id", b"key_id", "key_secret", b"key_secret"]) -> None: ... global___CreateUserKeyResponse = CreateUserKeyResponse -@typing.final +@typing_extensions.final class ListUserKeysRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -199,7 +190,7 @@ class ListUserKeysRequest(google.protobuf.message.Message): global___ListUserKeysRequest = ListUserKeysRequest -@typing.final +@typing_extensions.final class ListUserKeysResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -211,11 +202,11 @@ class ListUserKeysResponse(google.protobuf.message.Message): *, user_keys: collections.abc.Iterable[global___UserKeyInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["user_keys", b"user_keys"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["user_keys", b"user_keys"]) -> None: ... global___ListUserKeysResponse = ListUserKeysResponse -@typing.final +@typing_extensions.final class RevokeUserKeyRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -226,11 +217,11 @@ class RevokeUserKeyRequest(google.protobuf.message.Message): *, key_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["key_id", b"key_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["key_id", b"key_id"]) -> None: ... global___RevokeUserKeyRequest = RevokeUserKeyRequest -@typing.final +@typing_extensions.final class RevokeUserKeyResponse(google.protobuf.message.Message): """Empty. For future use.""" @@ -242,7 +233,7 @@ class RevokeUserKeyResponse(google.protobuf.message.Message): global___RevokeUserKeyResponse = RevokeUserKeyResponse -@typing.final +@typing_extensions.final class UserKeyInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -251,10 +242,10 @@ class UserKeyInfo(google.protobuf.message.Message): SCOPE_FIELD_NUMBER: builtins.int ALIAS_FIELD_NUMBER: builtins.int key_id: builtins.str - scope: global___CreateUserKeyRequest.Scope.ValueType - alias: builtins.str @property def created_at(self) -> google.protobuf.timestamp_pb2.Timestamp: ... + scope: global___CreateUserKeyRequest.Scope.ValueType + alias: builtins.str def __init__( self, *, @@ -263,12 +254,12 @@ class UserKeyInfo(google.protobuf.message.Message): scope: global___CreateUserKeyRequest.Scope.ValueType = ..., alias: builtins.str = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["created_at", b"created_at"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias", "created_at", b"created_at", "key_id", b"key_id", "scope", b"scope"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["created_at", b"created_at"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias", "created_at", b"created_at", "key_id", b"key_id", "scope", b"scope"]) -> None: ... global___UserKeyInfo = UserKeyInfo -@typing.final +@typing_extensions.final class HostedRunResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -283,17 +274,14 @@ class HostedRunResult(google.protobuf.message.Message): """Optionally the status of the current run (in terms of fal cloud). """ - @property def logs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[common_pb2.Log]: """The most recent logs from the run.""" - @property def return_value(self) -> common_pb2.SerializedObject: """The result of the run, if it is complete (indicated by status.is_complete). """ - def __init__( self, *, @@ -302,16 +290,16 @@ class HostedRunResult(google.protobuf.message.Message): logs: collections.abc.Iterable[common_pb2.Log] | None = ..., return_value: common_pb2.SerializedObject | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_return_value", b"_return_value", "_status", b"_status", "return_value", b"return_value", "status", b"status"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_return_value", b"_return_value", "_status", b"_status", "logs", b"logs", "return_value", b"return_value", "run_id", b"run_id", "status", b"status"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_return_value", b"_return_value", "_status", b"_status", "return_value", b"return_value", "status", b"status"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_return_value", b"_return_value", "_status", b"_status", "logs", b"logs", "return_value", b"return_value", "run_id", b"run_id", "status", b"status"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_return_value", b"_return_value"]) -> typing.Literal["return_value"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_return_value", b"_return_value"]) -> typing_extensions.Literal["return_value"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_status", b"_status"]) -> typing.Literal["status"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_status", b"_status"]) -> typing_extensions.Literal["status"] | None: ... global___HostedRunResult = HostedRunResult -@typing.final +@typing_extensions.final class HostedRunStatus(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -348,11 +336,11 @@ class HostedRunStatus(google.protobuf.message.Message): *, state: global___HostedRunStatus.State.ValueType = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["state", b"state"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["state", b"state"]) -> None: ... global___HostedRunStatus = HostedRunStatus -@typing.final +@typing_extensions.final class MachineRequirements(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -381,18 +369,17 @@ class MachineRequirements(google.protobuf.message.Message): base_image: builtins.str exposed_port: builtins.int scheduler: builtins.str + @property + def scheduler_options(self) -> google.protobuf.struct_pb2.Struct: ... max_multiplexing: builtins.int max_concurrency: builtins.int min_concurrency: builtins.int - num_gpus: builtins.int - request_timeout: builtins.int - startup_timeout: builtins.int - @property - def scheduler_options(self) -> google.protobuf.struct_pb2.Struct: ... @property def machine_types(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: """machine_type alternative""" - + num_gpus: builtins.int + request_timeout: builtins.int + startup_timeout: builtins.int def __init__( self, *, @@ -410,36 +397,36 @@ class MachineRequirements(google.protobuf.message.Message): request_timeout: builtins.int | None = ..., startup_timeout: builtins.int | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "_startup_timeout", b"_startup_timeout", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options", "startup_timeout", b"startup_timeout"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "_startup_timeout", b"_startup_timeout", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options", "startup_timeout", b"startup_timeout"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "_startup_timeout", b"_startup_timeout", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options", "startup_timeout", b"startup_timeout"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "_startup_timeout", b"_startup_timeout", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options", "startup_timeout", b"startup_timeout"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_base_image", b"_base_image"]) -> typing.Literal["base_image"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_base_image", b"_base_image"]) -> typing_extensions.Literal["base_image"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_exposed_port", b"_exposed_port"]) -> typing.Literal["exposed_port"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_exposed_port", b"_exposed_port"]) -> typing_extensions.Literal["exposed_port"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_keep_alive", b"_keep_alive"]) -> typing.Literal["keep_alive"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_keep_alive", b"_keep_alive"]) -> typing_extensions.Literal["keep_alive"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_type", b"_machine_type"]) -> typing.Literal["machine_type"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_type", b"_machine_type"]) -> typing_extensions.Literal["machine_type"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing.Literal["max_multiplexing"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing_extensions.Literal["max_multiplexing"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_min_concurrency", b"_min_concurrency"]) -> typing.Literal["min_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_min_concurrency", b"_min_concurrency"]) -> typing_extensions.Literal["min_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_num_gpus", b"_num_gpus"]) -> typing.Literal["num_gpus"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_num_gpus", b"_num_gpus"]) -> typing_extensions.Literal["num_gpus"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_request_timeout", b"_request_timeout"]) -> typing.Literal["request_timeout"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_request_timeout", b"_request_timeout"]) -> typing_extensions.Literal["request_timeout"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scheduler", b"_scheduler"]) -> typing.Literal["scheduler"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scheduler", b"_scheduler"]) -> typing_extensions.Literal["scheduler"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scheduler_options", b"_scheduler_options"]) -> typing.Literal["scheduler_options"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scheduler_options", b"_scheduler_options"]) -> typing_extensions.Literal["scheduler_options"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_startup_timeout", b"_startup_timeout"]) -> typing.Literal["startup_timeout"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_startup_timeout", b"_startup_timeout"]) -> typing_extensions.Literal["startup_timeout"] | None: ... global___MachineRequirements = MachineRequirements -@typing.final +@typing_extensions.final class RegisterApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -453,35 +440,30 @@ class RegisterApplicationRequest(google.protobuf.message.Message): METADATA_FIELD_NUMBER: builtins.int DEPLOYMENT_STRATEGY_FIELD_NUMBER: builtins.int SCALE_FIELD_NUMBER: builtins.int - application_name: builtins.str - """Name of the application""" - auth_mode: global___ApplicationAuthMode.ValueType - """If application has alias: auth mode to use""" - max_concurrency: builtins.int - """Max concurrency in gateway""" - deployment_strategy: global___DeploymentStrategy.ValueType - """Deployment strategy""" - scale: builtins.bool @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def setup_func(self) -> common_pb2.SerializedObject: """Optional setup function to pass as the first argument to the function.""" - + application_name: builtins.str + """Name of the application""" + auth_mode: global___ApplicationAuthMode.ValueType + """If application has alias: auth mode to use""" + max_concurrency: builtins.int + """Max concurrency in gateway""" @property def metadata(self) -> google.protobuf.struct_pb2.Struct: """metadata to store with the application""" - + deployment_strategy: global___DeploymentStrategy.ValueType + """Deployment strategy""" + scale: builtins.bool def __init__( self, *, @@ -496,28 +478,28 @@ class RegisterApplicationRequest(google.protobuf.message.Message): deployment_strategy: global___DeploymentStrategy.ValueType | None = ..., scale: builtins.bool | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_application_name", b"_application_name"]) -> typing.Literal["application_name"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_application_name", b"_application_name"]) -> typing_extensions.Literal["application_name"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_auth_mode", b"_auth_mode"]) -> typing.Literal["auth_mode"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_auth_mode", b"_auth_mode"]) -> typing_extensions.Literal["auth_mode"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_deployment_strategy", b"_deployment_strategy"]) -> typing.Literal["deployment_strategy"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_deployment_strategy", b"_deployment_strategy"]) -> typing_extensions.Literal["deployment_strategy"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_metadata", b"_metadata"]) -> typing.Literal["metadata"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_metadata", b"_metadata"]) -> typing_extensions.Literal["metadata"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scale", b"_scale"]) -> typing.Literal["scale"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scale", b"_scale"]) -> typing_extensions.Literal["scale"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_setup_func", b"_setup_func"]) -> typing.Literal["setup_func"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_setup_func", b"_setup_func"]) -> typing_extensions.Literal["setup_func"] | None: ... global___RegisterApplicationRequest = RegisterApplicationRequest -@typing.final +@typing_extensions.final class RegisterApplicationResultType(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -528,11 +510,11 @@ class RegisterApplicationResultType(google.protobuf.message.Message): *, application_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["application_id", b"application_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["application_id", b"application_id"]) -> None: ... global___RegisterApplicationResultType = RegisterApplicationResultType -@typing.final +@typing_extensions.final class RegisterApplicationResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -548,13 +530,13 @@ class RegisterApplicationResult(google.protobuf.message.Message): logs: collections.abc.Iterable[common_pb2.Log] | None = ..., result: global___RegisterApplicationResultType | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_result", b"_result", "result", b"result"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_result", b"_result", "logs", b"logs", "result", b"result"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_result", b"_result"]) -> typing.Literal["result"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_result", b"_result", "result", b"result"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_result", b"_result", "logs", b"logs", "result", b"result"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_result", b"_result"]) -> typing_extensions.Literal["result"] | None: ... global___RegisterApplicationResult = RegisterApplicationResult -@typing.final +@typing_extensions.final class UpdateApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -585,20 +567,20 @@ class UpdateApplicationRequest(google.protobuf.message.Message): valid_regions: collections.abc.Iterable[builtins.str] | None = ..., machine_types: collections.abc.Iterable[builtins.str] | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "application_name", b"application_name", "keep_alive", b"keep_alive", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "valid_regions", b"valid_regions"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "application_name", b"application_name", "keep_alive", b"keep_alive", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "valid_regions", b"valid_regions"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_keep_alive", b"_keep_alive"]) -> typing.Literal["keep_alive"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_keep_alive", b"_keep_alive"]) -> typing_extensions.Literal["keep_alive"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing.Literal["max_multiplexing"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing_extensions.Literal["max_multiplexing"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_min_concurrency", b"_min_concurrency"]) -> typing.Literal["min_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_min_concurrency", b"_min_concurrency"]) -> typing_extensions.Literal["min_concurrency"] | None: ... global___UpdateApplicationRequest = UpdateApplicationRequest -@typing.final +@typing_extensions.final class UpdateApplicationResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -610,12 +592,12 @@ class UpdateApplicationResult(google.protobuf.message.Message): *, alias_info: global___AliasInfo | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["alias_info", b"alias_info"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["alias_info", b"alias_info"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["alias_info", b"alias_info"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["alias_info", b"alias_info"]) -> None: ... global___UpdateApplicationResult = UpdateApplicationResult -@typing.final +@typing_extensions.final class ListApplicationsRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -627,7 +609,7 @@ class ListApplicationsRequest(google.protobuf.message.Message): global___ListApplicationsRequest = ListApplicationsRequest -@typing.final +@typing_extensions.final class ApplicationInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -657,11 +639,11 @@ class ApplicationInfo(google.protobuf.message.Message): min_concurrency: builtins.int = ..., machine_types: collections.abc.Iterable[builtins.str] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["active_runners", b"active_runners", "application_id", b"application_id", "keep_alive", b"keep_alive", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["active_runners", b"active_runners", "application_id", b"application_id", "keep_alive", b"keep_alive", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... global___ApplicationInfo = ApplicationInfo -@typing.final +@typing_extensions.final class ListApplicationsResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -673,11 +655,11 @@ class ListApplicationsResult(google.protobuf.message.Message): *, applications: collections.abc.Iterable[global___ApplicationInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["applications", b"applications"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["applications", b"applications"]) -> None: ... global___ListApplicationsResult = ListApplicationsResult -@typing.final +@typing_extensions.final class DeleteApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -688,11 +670,11 @@ class DeleteApplicationRequest(google.protobuf.message.Message): *, application_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["application_id", b"application_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["application_id", b"application_id"]) -> None: ... global___DeleteApplicationRequest = DeleteApplicationRequest -@typing.final +@typing_extensions.final class DeleteApplicationResult(google.protobuf.message.Message): """Empty. For future use.""" @@ -704,7 +686,7 @@ class DeleteApplicationResult(google.protobuf.message.Message): global___DeleteApplicationResult = DeleteApplicationResult -@typing.final +@typing_extensions.final class SetAliasRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -721,11 +703,11 @@ class SetAliasRequest(google.protobuf.message.Message): revision: builtins.str = ..., auth_mode: global___ApplicationAuthMode.ValueType = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias", "auth_mode", b"auth_mode", "revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias", "auth_mode", b"auth_mode", "revision", b"revision"]) -> None: ... global___SetAliasRequest = SetAliasRequest -@typing.final +@typing_extensions.final class SetAliasResult(google.protobuf.message.Message): """Empty. For future use.""" @@ -737,7 +719,7 @@ class SetAliasResult(google.protobuf.message.Message): global___SetAliasResult = SetAliasResult -@typing.final +@typing_extensions.final class DeleteAliasRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -748,11 +730,11 @@ class DeleteAliasRequest(google.protobuf.message.Message): *, alias: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias"]) -> None: ... global___DeleteAliasRequest = DeleteAliasRequest -@typing.final +@typing_extensions.final class DeleteAliasResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -763,11 +745,11 @@ class DeleteAliasResult(google.protobuf.message.Message): *, revision: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["revision", b"revision"]) -> None: ... global___DeleteAliasResult = DeleteAliasResult -@typing.final +@typing_extensions.final class ListAliasesRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -779,7 +761,7 @@ class ListAliasesRequest(google.protobuf.message.Message): global___ListAliasesRequest = ListAliasesRequest -@typing.final +@typing_extensions.final class ListAliasesResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -791,11 +773,11 @@ class ListAliasesResult(google.protobuf.message.Message): *, aliases: collections.abc.Iterable[global___AliasInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["aliases", b"aliases"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["aliases", b"aliases"]) -> None: ... global___ListAliasesResult = ListAliasesResult -@typing.final +@typing_extensions.final class AliasInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -827,11 +809,11 @@ class AliasInfo(google.protobuf.message.Message): active_runners: builtins.int = ..., min_concurrency: builtins.int = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["active_runners", b"active_runners", "alias", b"alias", "auth_mode", b"auth_mode", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["active_runners", b"active_runners", "alias", b"alias", "auth_mode", b"auth_mode", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "revision", b"revision"]) -> None: ... global___AliasInfo = AliasInfo -@typing.final +@typing_extensions.final class SetSecretRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -845,13 +827,13 @@ class SetSecretRequest(google.protobuf.message.Message): name: builtins.str = ..., value: builtins.str | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_value", b"_value", "value", b"value"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_value", b"_value", "name", b"name", "value", b"value"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_value", b"_value"]) -> typing.Literal["value"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_value", b"_value", "value", b"value"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_value", b"_value", "name", b"name", "value", b"value"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_value", b"_value"]) -> typing_extensions.Literal["value"] | None: ... global___SetSecretRequest = SetSecretRequest -@typing.final +@typing_extensions.final class SetSecretResponse(google.protobuf.message.Message): """Empty. For future use.""" @@ -863,7 +845,7 @@ class SetSecretResponse(google.protobuf.message.Message): global___SetSecretResponse = SetSecretResponse -@typing.final +@typing_extensions.final class ListSecretsRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -875,7 +857,7 @@ class ListSecretsRequest(google.protobuf.message.Message): global___ListSecretsRequest = ListSecretsRequest -@typing.final +@typing_extensions.final class Secret(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -885,20 +867,19 @@ class Secret(google.protobuf.message.Message): @property def created_time(self) -> google.protobuf.timestamp_pb2.Timestamp: """Could also include the value/scope of the secret in the future.""" - def __init__( self, *, name: builtins.str = ..., created_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_created_time", b"_created_time", "created_time", b"created_time"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_created_time", b"_created_time", "created_time", b"created_time", "name", b"name"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_created_time", b"_created_time"]) -> typing.Literal["created_time"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_created_time", b"_created_time", "created_time", b"created_time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_created_time", b"_created_time", "created_time", b"created_time", "name", b"name"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_created_time", b"_created_time"]) -> typing_extensions.Literal["created_time"] | None: ... global___Secret = Secret -@typing.final +@typing_extensions.final class ListSecretsResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -910,11 +891,11 @@ class ListSecretsResponse(google.protobuf.message.Message): *, secrets: collections.abc.Iterable[global___Secret] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["secrets", b"secrets"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["secrets", b"secrets"]) -> None: ... global___ListSecretsResponse = ListSecretsResponse -@typing.final +@typing_extensions.final class ListAliasRunnersRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -925,11 +906,11 @@ class ListAliasRunnersRequest(google.protobuf.message.Message): *, alias: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias"]) -> None: ... global___ListAliasRunnersRequest = ListAliasRunnersRequest -@typing.final +@typing_extensions.final class ListAliasRunnersResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -941,11 +922,11 @@ class ListAliasRunnersResponse(google.protobuf.message.Message): *, runners: collections.abc.Iterable[global___RunnerInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["runners", b"runners"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["runners", b"runners"]) -> None: ... global___ListAliasRunnersResponse = ListAliasRunnersResponse -@typing.final +@typing_extensions.final class RunnerInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -953,10 +934,13 @@ class RunnerInfo(google.protobuf.message.Message): IN_FLIGHT_REQUESTS_FIELD_NUMBER: builtins.int EXPIRATION_COUNTDOWN_FIELD_NUMBER: builtins.int UPTIME_FIELD_NUMBER: builtins.int + EXTERNAL_METADATA_FIELD_NUMBER: builtins.int runner_id: builtins.str in_flight_requests: builtins.int expiration_countdown: builtins.int uptime: builtins.float + @property + def external_metadata(self) -> google.protobuf.struct_pb2.Struct: ... def __init__( self, *, @@ -964,14 +948,18 @@ class RunnerInfo(google.protobuf.message.Message): in_flight_requests: builtins.int = ..., expiration_countdown: builtins.int | None = ..., uptime: builtins.float = ..., + external_metadata: google.protobuf.struct_pb2.Struct | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_expiration_countdown", b"_expiration_countdown", "expiration_countdown", b"expiration_countdown"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_expiration_countdown", b"_expiration_countdown", "expiration_countdown", b"expiration_countdown", "in_flight_requests", b"in_flight_requests", "runner_id", b"runner_id", "uptime", b"uptime"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_expiration_countdown", b"_expiration_countdown"]) -> typing.Literal["expiration_countdown"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown", "_external_metadata", b"_external_metadata", "expiration_countdown", b"expiration_countdown", "external_metadata", b"external_metadata"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown", "_external_metadata", b"_external_metadata", "expiration_countdown", b"expiration_countdown", "external_metadata", b"external_metadata", "in_flight_requests", b"in_flight_requests", "runner_id", b"runner_id", "uptime", b"uptime"]) -> None: ... + @typing.overload + def WhichOneof(self, oneof_group: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown"]) -> typing_extensions.Literal["expiration_countdown"] | None: ... + @typing.overload + def WhichOneof(self, oneof_group: typing_extensions.Literal["_external_metadata", b"_external_metadata"]) -> typing_extensions.Literal["external_metadata"] | None: ... global___RunnerInfo = RunnerInfo -@typing.final +@typing_extensions.final class KillRunnerRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -982,11 +970,11 @@ class KillRunnerRequest(google.protobuf.message.Message): *, runner_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["runner_id", b"runner_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["runner_id", b"runner_id"]) -> None: ... global___KillRunnerRequest = KillRunnerRequest -@typing.final +@typing_extensions.final class KillRunnerResponse(google.protobuf.message.Message): """Empty. For future use."""