# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: src/ray/protobuf/instance_manager.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import message as _message from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\'src/ray/protobuf/instance_manager.proto\x12\x15ray.rpc.autoscaler.im\"Y\n\x06Status\x12\x35\n\x04\x63ode\x18\x01 \x01(\x0e\x32!.ray.rpc.autoscaler.im.StatusCodeR\x04\x63ode\x12\x18\n\x07message\x18\x02 \x01(\tR\x07message\"\xe9\t\n\x08Instance\x12\x1f\n\x0binstance_id\x18\x01 \x01(\tR\ninstanceId\x12/\n\x11\x63loud_instance_id\x18\x02 \x01(\tH\x00R\x0f\x63loudInstanceId\x88\x01\x01\x12\x1c\n\x07node_id\x18\x03 \x01(\tH\x01R\x06nodeId\x88\x01\x01\x12\x46\n\x06status\x18\x04 \x01(\x0e\x32..ray.rpc.autoscaler.im.Instance.InstanceStatusR\x06status\x12#\n\rinstance_type\x18\x05 \x01(\tR\x0cinstanceType\x12\\\n\x0ftotal_resources\x18\x06 \x03(\x0b\x32\x33.ray.rpc.autoscaler.im.Instance.TotalResourcesEntryR\x0etotalResources\x12\x1f\n\x0binternal_ip\x18\x07 \x01(\tR\ninternalIp\x12\x1f\n\x0b\x65xternal_ip\x18\x08 \x01(\tR\nexternalIp\x12\x18\n\x07version\x18\t \x01(\x03R\x07version\x12T\n\x0estatus_history\x18\n \x03(\x0b\x32-.ray.rpc.autoscaler.im.Instance.StatusHistoryR\rstatusHistory\x12*\n\x11launch_request_id\x18\x0b \x01(\tR\x0flaunchRequestId\x12!\n\x0c\x65xit_details\x18\x0c \x01(\tR\x0b\x65xitDetails\x12,\n\x12launch_config_hash\x18\r \x01(\tR\x10launchConfigHash\x12<\n\tnode_kind\x18\x0e \x01(\x0e\x32\x1f.ray.rpc.autoscaler.im.NodeKindR\x08nodeKind\x1a\x41\n\x13TotalResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\xa5\x01\n\rStatusHistory\x12W\n\x0finstance_status\x18\x01 \x01(\x0e\x32..ray.rpc.autoscaler.im.Instance.InstanceStatusR\x0einstanceStatus\x12!\n\x0ctimestamp_ns\x18\x02 \x01(\x03R\x0btimestampNs\x12\x18\n\x07\x64\x65tails\x18\x03 \x01(\tR\x07\x64\x65tails\"\xa7\x02\n\x0eInstanceStatus\x12\x0b\n\x07UNKNOWN\x10\x00\x12\n\n\x06QUEUED\x10\x01\x12\r\n\tREQUESTED\x10\x02\x12\r\n\tALLOCATED\x10\x03\x12\x12\n\x0eRAY_INSTALLING\x10\x04\x12\x0f\n\x0bRAY_RUNNING\x10\x05\x12\x16\n\x12RAY_STOP_REQUESTED\x10\x06\x12\x10\n\x0cRAY_STOPPING\x10\x07\x12\x0f\n\x0bRAY_STOPPED\x10\x08\x12\x0f\n\x0bTERMINATING\x10\t\x12\x0e\n\nTERMINATED\x10\n\x12\x15\n\x11\x41LLOCATION_FAILED\x10\x0b\x12\x16\n\x12RAY_INSTALL_FAILED\x10\x0c\x12\x16\n\x12TERMINATION_FAILED\x10\r\x12\x16\n\x12\x41LLOCATION_TIMEOUT\x10\x0e\x42\x14\n\x12_cloud_instance_idB\n\n\x08_node_id\"\x91\x05\n\x13InstanceUpdateEvent\x12\x1f\n\x0binstance_id\x18\x01 \x01(\tR\ninstanceId\x12^\n\x13new_instance_status\x18\x02 \x01(\x0e\x32..ray.rpc.autoscaler.im.Instance.InstanceStatusR\x11newInstanceStatus\x12\x18\n\x07\x64\x65tails\x18\x03 \x01(\tR\x07\x64\x65tails\x12\x16\n\x06upsert\x18\x04 \x01(\x08R\x06upsert\x12(\n\rinstance_type\x18\x05 \x01(\tH\x00R\x0cinstanceType\x88\x01\x01\x12/\n\x11\x63loud_instance_id\x18\x06 \x01(\tH\x01R\x0f\x63loudInstanceId\x88\x01\x01\x12\x41\n\tnode_kind\x18\x07 \x01(\x0e\x32\x1f.ray.rpc.autoscaler.im.NodeKindH\x02R\x08nodeKind\x88\x01\x01\x12#\n\x0bray_node_id\x18\x08 \x01(\tH\x03R\trayNodeId\x88\x01\x01\x12/\n\x11launch_request_id\x18\t \x01(\tH\x04R\x0flaunchRequestId\x88\x01\x01\x12_\n\x13termination_request\x18\n \x01(\x0b\x32).ray.rpc.autoscaler.im.TerminationRequestH\x05R\x12terminationRequest\x88\x01\x01\x42\x10\n\x0e_instance_typeB\x14\n\x12_cloud_instance_idB\x0c\n\n_node_kindB\x0e\n\x0c_ray_node_idB\x14\n\x12_launch_request_idB\x16\n\x14_termination_request\"~\n\rLaunchRequest\x12#\n\rinstance_type\x18\x01 \x01(\tR\x0cinstanceType\x12\x14\n\x05\x63ount\x18\x02 \x01(\x05R\x05\x63ount\x12\x0e\n\x02id\x18\x03 \x01(\tR\x02id\x12\"\n\rrequest_ts_ms\x18\x04 \x01(\x03R\x0brequestTsMs\"\xf3\x04\n\x12TerminationRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x1e\n\x0bray_node_id\x18\x02 \x01(\tR\trayNodeId\x12\x1f\n\x0binstance_id\x18\x03 \x01(\tR\ninstanceId\x12\x45\n\x05\x63\x61use\x18\x04 \x01(\x0e\x32/.ray.rpc.autoscaler.im.TerminationRequest.CauseR\x05\x63\x61use\x12#\n\rinstance_type\x18\x05 \x01(\tR\x0cinstanceType\x12-\n\x10idle_duration_ms\x18\x06 \x01(\x04H\x00R\x0eidleDurationMs\x88\x01\x01\x12\x37\n\x16max_num_nodes_per_type\x18\x07 \x01(\rH\x01R\x12maxNumNodesPerType\x88\x01\x01\x12\'\n\rmax_num_nodes\x18\x08 \x01(\rH\x02R\x0bmaxNumNodes\x88\x01\x01\x12\x18\n\x07\x64\x65tails\x18\t \x01(\tR\x07\x64\x65tails\x12W\n\x0finstance_status\x18\n \x01(\x0e\x32..ray.rpc.autoscaler.im.Instance.InstanceStatusR\x0einstanceStatus\"Z\n\x05\x43\x61use\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x08\n\x04IDLE\x10\x01\x12\x19\n\x15MAX_NUM_NODE_PER_TYPE\x10\x02\x12\x11\n\rMAX_NUM_NODES\x10\x03\x12\x0c\n\x08OUTDATED\x10\x04\x42\x13\n\x11_idle_duration_msB\x19\n\x17_max_num_nodes_per_typeB\x10\n\x0e_max_num_nodes\"\x94\x01\n!UpdateInstanceManagerStateRequest\x12)\n\x10\x65xpected_version\x18\x01 \x01(\x03R\x0f\x65xpectedVersion\x12\x44\n\x07updates\x18\x02 \x03(\x0b\x32*.ray.rpc.autoscaler.im.InstanceUpdateEventR\x07updates\"r\n\x1fUpdateInstanceManagerStateReply\x12\x35\n\x06status\x18\x01 \x01(\x0b\x32\x1d.ray.rpc.autoscaler.im.StatusR\x06status\x12\x18\n\x07version\x18\x02 \x01(\x03R\x07version\"o\n\x14InstanceManagerState\x12\x18\n\x07version\x18\x01 \x01(\x03R\x07version\x12=\n\tinstances\x18\x02 \x03(\x0b\x32\x1f.ray.rpc.autoscaler.im.InstanceR\tinstances\" \n\x1eGetInstanceManagerStateRequest\"\x98\x01\n\x1cGetInstanceManagerStateReply\x12\x35\n\x06status\x18\x01 \x01(\x0b\x32\x1d.ray.rpc.autoscaler.im.StatusR\x06status\x12\x41\n\x05state\x18\x02 \x01(\x0b\x32+.ray.rpc.autoscaler.im.InstanceManagerStateR\x05state*`\n\nStatusCode\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\x06\n\x02OK\x10\x01\x12\x14\n\x10VERSION_MISMATCH\x10\x02\x12\x12\n\x0eUNKNOWN_ERRORS\x10\x03\x12\x0f\n\x0bUNAVAILABLE\x10\x04*/\n\x08NodeKind\x12\r\n\tUNMANAGED\x10\x00\x12\x08\n\x04HEAD\x10\x01\x12\n\n\x06WORKER\x10\x02\x32\xb1\x02\n\x16InstanceManagerService\x12\x85\x01\n\x17GetInstanceManagerState\x12\x35.ray.rpc.autoscaler.im.GetInstanceManagerStateRequest\x1a\x33.ray.rpc.autoscaler.im.GetInstanceManagerStateReply\x12\x8e\x01\n\x1aUpdateInstanceManagerState\x12\x38.ray.rpc.autoscaler.im.UpdateInstanceManagerStateRequest\x1a\x36.ray.rpc.autoscaler.im.UpdateInstanceManagerStateReplyb\x06proto3') _STATUSCODE = DESCRIPTOR.enum_types_by_name['StatusCode'] StatusCode = enum_type_wrapper.EnumTypeWrapper(_STATUSCODE) _NODEKIND = DESCRIPTOR.enum_types_by_name['NodeKind'] NodeKind = enum_type_wrapper.EnumTypeWrapper(_NODEKIND) UNSPECIFIED = 0 OK = 1 VERSION_MISMATCH = 2 UNKNOWN_ERRORS = 3 UNAVAILABLE = 4 UNMANAGED = 0 HEAD = 1 WORKER = 2 _STATUS = DESCRIPTOR.message_types_by_name['Status'] _INSTANCE = DESCRIPTOR.message_types_by_name['Instance'] _INSTANCE_TOTALRESOURCESENTRY = _INSTANCE.nested_types_by_name['TotalResourcesEntry'] _INSTANCE_STATUSHISTORY = _INSTANCE.nested_types_by_name['StatusHistory'] _INSTANCEUPDATEEVENT = DESCRIPTOR.message_types_by_name['InstanceUpdateEvent'] _LAUNCHREQUEST = DESCRIPTOR.message_types_by_name['LaunchRequest'] _TERMINATIONREQUEST = DESCRIPTOR.message_types_by_name['TerminationRequest'] _UPDATEINSTANCEMANAGERSTATEREQUEST = DESCRIPTOR.message_types_by_name['UpdateInstanceManagerStateRequest'] _UPDATEINSTANCEMANAGERSTATEREPLY = DESCRIPTOR.message_types_by_name['UpdateInstanceManagerStateReply'] _INSTANCEMANAGERSTATE = DESCRIPTOR.message_types_by_name['InstanceManagerState'] _GETINSTANCEMANAGERSTATEREQUEST = DESCRIPTOR.message_types_by_name['GetInstanceManagerStateRequest'] _GETINSTANCEMANAGERSTATEREPLY = DESCRIPTOR.message_types_by_name['GetInstanceManagerStateReply'] _INSTANCE_INSTANCESTATUS = _INSTANCE.enum_types_by_name['InstanceStatus'] _TERMINATIONREQUEST_CAUSE = _TERMINATIONREQUEST.enum_types_by_name['Cause'] Status = _reflection.GeneratedProtocolMessageType('Status', (_message.Message,), { 'DESCRIPTOR' : _STATUS, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.Status) }) _sym_db.RegisterMessage(Status) Instance = _reflection.GeneratedProtocolMessageType('Instance', (_message.Message,), { 'TotalResourcesEntry' : _reflection.GeneratedProtocolMessageType('TotalResourcesEntry', (_message.Message,), { 'DESCRIPTOR' : _INSTANCE_TOTALRESOURCESENTRY, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.Instance.TotalResourcesEntry) }) , 'StatusHistory' : _reflection.GeneratedProtocolMessageType('StatusHistory', (_message.Message,), { 'DESCRIPTOR' : _INSTANCE_STATUSHISTORY, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.Instance.StatusHistory) }) , 'DESCRIPTOR' : _INSTANCE, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.Instance) }) _sym_db.RegisterMessage(Instance) _sym_db.RegisterMessage(Instance.TotalResourcesEntry) _sym_db.RegisterMessage(Instance.StatusHistory) InstanceUpdateEvent = _reflection.GeneratedProtocolMessageType('InstanceUpdateEvent', (_message.Message,), { 'DESCRIPTOR' : _INSTANCEUPDATEEVENT, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.InstanceUpdateEvent) }) _sym_db.RegisterMessage(InstanceUpdateEvent) LaunchRequest = _reflection.GeneratedProtocolMessageType('LaunchRequest', (_message.Message,), { 'DESCRIPTOR' : _LAUNCHREQUEST, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.LaunchRequest) }) _sym_db.RegisterMessage(LaunchRequest) TerminationRequest = _reflection.GeneratedProtocolMessageType('TerminationRequest', (_message.Message,), { 'DESCRIPTOR' : _TERMINATIONREQUEST, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.TerminationRequest) }) _sym_db.RegisterMessage(TerminationRequest) UpdateInstanceManagerStateRequest = _reflection.GeneratedProtocolMessageType('UpdateInstanceManagerStateRequest', (_message.Message,), { 'DESCRIPTOR' : _UPDATEINSTANCEMANAGERSTATEREQUEST, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.UpdateInstanceManagerStateRequest) }) _sym_db.RegisterMessage(UpdateInstanceManagerStateRequest) UpdateInstanceManagerStateReply = _reflection.GeneratedProtocolMessageType('UpdateInstanceManagerStateReply', (_message.Message,), { 'DESCRIPTOR' : _UPDATEINSTANCEMANAGERSTATEREPLY, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.UpdateInstanceManagerStateReply) }) _sym_db.RegisterMessage(UpdateInstanceManagerStateReply) InstanceManagerState = _reflection.GeneratedProtocolMessageType('InstanceManagerState', (_message.Message,), { 'DESCRIPTOR' : _INSTANCEMANAGERSTATE, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.InstanceManagerState) }) _sym_db.RegisterMessage(InstanceManagerState) GetInstanceManagerStateRequest = _reflection.GeneratedProtocolMessageType('GetInstanceManagerStateRequest', (_message.Message,), { 'DESCRIPTOR' : _GETINSTANCEMANAGERSTATEREQUEST, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.GetInstanceManagerStateRequest) }) _sym_db.RegisterMessage(GetInstanceManagerStateRequest) GetInstanceManagerStateReply = _reflection.GeneratedProtocolMessageType('GetInstanceManagerStateReply', (_message.Message,), { 'DESCRIPTOR' : _GETINSTANCEMANAGERSTATEREPLY, '__module__' : 'src.ray.protobuf.instance_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.im.GetInstanceManagerStateReply) }) _sym_db.RegisterMessage(GetInstanceManagerStateReply) _INSTANCEMANAGERSERVICE = DESCRIPTOR.services_by_name['InstanceManagerService'] if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _INSTANCE_TOTALRESOURCESENTRY._options = None _INSTANCE_TOTALRESOURCESENTRY._serialized_options = b'8\001' _STATUSCODE._serialized_start=3404 _STATUSCODE._serialized_end=3500 _NODEKIND._serialized_start=3502 _NODEKIND._serialized_end=3549 _STATUS._serialized_start=66 _STATUS._serialized_end=155 _INSTANCE._serialized_start=158 _INSTANCE._serialized_end=1415 _INSTANCE_TOTALRESOURCESENTRY._serialized_start=850 _INSTANCE_TOTALRESOURCESENTRY._serialized_end=915 _INSTANCE_STATUSHISTORY._serialized_start=918 _INSTANCE_STATUSHISTORY._serialized_end=1083 _INSTANCE_INSTANCESTATUS._serialized_start=1086 _INSTANCE_INSTANCESTATUS._serialized_end=1381 _INSTANCEUPDATEEVENT._serialized_start=1418 _INSTANCEUPDATEEVENT._serialized_end=2075 _LAUNCHREQUEST._serialized_start=2077 _LAUNCHREQUEST._serialized_end=2203 _TERMINATIONREQUEST._serialized_start=2206 _TERMINATIONREQUEST._serialized_end=2833 _TERMINATIONREQUEST_CAUSE._serialized_start=2677 _TERMINATIONREQUEST_CAUSE._serialized_end=2767 _UPDATEINSTANCEMANAGERSTATEREQUEST._serialized_start=2836 _UPDATEINSTANCEMANAGERSTATEREQUEST._serialized_end=2984 _UPDATEINSTANCEMANAGERSTATEREPLY._serialized_start=2986 _UPDATEINSTANCEMANAGERSTATEREPLY._serialized_end=3100 _INSTANCEMANAGERSTATE._serialized_start=3102 _INSTANCEMANAGERSTATE._serialized_end=3213 _GETINSTANCEMANAGERSTATEREQUEST._serialized_start=3215 _GETINSTANCEMANAGERSTATEREQUEST._serialized_end=3247 _GETINSTANCEMANAGERSTATEREPLY._serialized_start=3250 _GETINSTANCEMANAGERSTATEREPLY._serialized_end=3402 _INSTANCEMANAGERSERVICE._serialized_start=3552 _INSTANCEMANAGERSERVICE._serialized_end=3857 # @@protoc_insertion_point(module_scope)