Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

emaballarin / ray python

Repository URL to install this package:

Version: 
3.0.0.dev0  ▾
Details    
ray / core / generated / autoscaler_pb2.py
Size: Mime: 
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: src/ray/protobuf/autoscaler.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()


from . import common_pb2 as src_dot_ray_dot_protobuf_dot_common__pb2


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n!src/ray/protobuf/autoscaler.proto\x12\x12ray.rpc.autoscaler\x1a\x1dsrc/ray/protobuf/common.proto\"X\n\x16\x41ntiAffinityConstraint\x12\x1d\n\nlabel_name\x18\x01 \x01(\tR\tlabelName\x12\x1f\n\x0blabel_value\x18\x02 \x01(\tR\nlabelValue\"T\n\x12\x41\x66\x66inityConstraint\x12\x1d\n\nlabel_name\x18\x01 \x01(\tR\tlabelName\x12\x1f\n\x0blabel_value\x18\x02 \x01(\tR\nlabelValue\"\xd3\x01\n\x13PlacementConstraint\x12T\n\ranti_affinity\x18\x01 \x01(\x0b\x32*.ray.rpc.autoscaler.AntiAffinityConstraintH\x00R\x0c\x61ntiAffinity\x88\x01\x01\x12G\n\x08\x61\x66\x66inity\x18\x02 \x01(\x0b\x32&.ray.rpc.autoscaler.AffinityConstraintH\x01R\x08\x61\x66\x66inity\x88\x01\x01\x42\x10\n\x0e_anti_affinityB\x0b\n\t_affinity\"\xd9\x02\n\x0fResourceRequest\x12\x63\n\x10resources_bundle\x18\x01 \x03(\x0b\x32\x38.ray.rpc.autoscaler.ResourceRequest.ResourcesBundleEntryR\x0fresourcesBundle\x12\\\n\x15placement_constraints\x18\x02 \x03(\x0b\x32\'.ray.rpc.autoscaler.PlacementConstraintR\x14placementConstraints\x12?\n\x0flabel_selectors\x18\x03 \x03(\x0b\x32\x16.ray.rpc.LabelSelectorR\x0elabelSelectors\x1a\x42\n\x14ResourcesBundleEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"m\n\x16ResourceRequestByCount\x12=\n\x07request\x18\x01 \x01(\x0b\x32#.ray.rpc.autoscaler.ResourceRequestR\x07request\x12\x14\n\x05\x63ount\x18\x02 \x01(\x03R\x05\x63ount\"b\n\x0e\x42undleSelector\x12P\n\x11resource_requests\x18\x01 \x03(\x0b\x32#.ray.rpc.autoscaler.ResourceRequestR\x10resourceRequests\"\xbf\x01\n\x13GangResourceRequest\x12?\n\x08requests\x18\x01 \x03(\x0b\x32#.ray.rpc.autoscaler.ResourceRequestR\x08requests\x12\x18\n\x07\x64\x65tails\x18\x02 \x01(\tR\x07\x64\x65tails\x12M\n\x10\x62undle_selectors\x18\x03 \x03(\x0b\x32\".ray.rpc.autoscaler.BundleSelectorR\x0f\x62undleSelectors\"t\n\x19\x43lusterResourceConstraint\x12W\n\x11resource_requests\x18\x01 \x03(\x0b\x32*.ray.rpc.autoscaler.ResourceRequestByCountR\x10resourceRequests\"\xe4\x07\n\tNodeState\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x1f\n\x0binstance_id\x18\x02 \x01(\tR\ninstanceId\x12+\n\x12ray_node_type_name\x18\x03 \x01(\tR\x0frayNodeTypeName\x12\x66\n\x13\x61vailable_resources\x18\x04 \x03(\x0b\x32\x35.ray.rpc.autoscaler.NodeState.AvailableResourcesEntryR\x12\x61vailableResources\x12Z\n\x0ftotal_resources\x18\x05 \x03(\x0b\x32\x31.ray.rpc.autoscaler.NodeState.TotalResourcesEntryR\x0etotalResources\x12W\n\x0e\x64ynamic_labels\x18\x06 \x03(\x0b\x32\x30.ray.rpc.autoscaler.NodeState.DynamicLabelsEntryR\rdynamicLabels\x12,\n\x12node_state_version\x18\x07 \x01(\x03R\x10nodeStateVersion\x12\x36\n\x06status\x18\x08 \x01(\x0e\x32\x1e.ray.rpc.autoscaler.NodeStatusR\x06status\x12(\n\x10idle_duration_ms\x18\t \x01(\x03R\x0eidleDurationMs\x12&\n\x0fnode_ip_address\x18\n \x01(\tR\rnodeIpAddress\x12,\n\x12instance_type_name\x18\x0b \x01(\tR\x10instanceTypeName\x12#\n\rnode_activity\x18\x0c \x03(\tR\x0cnodeActivity\x12\x41\n\x06labels\x18\r \x03(\x0b\x32).ray.rpc.autoscaler.NodeState.LabelsEntryR\x06labels\x1a\x45\n\x17\x41vailableResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\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@\n\x12\x44ynamicLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"w\n\x1eGetClusterResourceStateRequest\x12U\n(last_seen_cluster_resource_state_version\x18\x01 \x01(\x03R#lastSeenClusterResourceStateVersion\"\xe0\x04\n\x14\x43lusterResourceState\x12\x43\n\x1e\x63luster_resource_state_version\x18\x01 \x01(\x03R\x1b\x63lusterResourceStateVersion\x12J\n\"last_seen_autoscaler_state_version\x18\x02 \x01(\x03R\x1elastSeenAutoscalerStateVersion\x12>\n\x0bnode_states\x18\x03 \x03(\x0b\x32\x1d.ray.rpc.autoscaler.NodeStateR\nnodeStates\x12\x66\n\x19pending_resource_requests\x18\x04 \x03(\x0b\x32*.ray.rpc.autoscaler.ResourceRequestByCountR\x17pendingResourceRequests\x12l\n\x1epending_gang_resource_requests\x18\x05 \x03(\x0b\x32\'.ray.rpc.autoscaler.GangResourceRequestR\x1bpendingGangResourceRequests\x12o\n\x1c\x63luster_resource_constraints\x18\x06 \x03(\x0b\x32-.ray.rpc.autoscaler.ClusterResourceConstraintR\x1a\x63lusterResourceConstraints\x12\x30\n\x14\x63luster_session_name\x18\x07 \x01(\tR\x12\x63lusterSessionName\"~\n\x1cGetClusterResourceStateReply\x12^\n\x16\x63luster_resource_state\x18\x01 \x01(\x0b\x32(.ray.rpc.autoscaler.ClusterResourceStateR\x14\x63lusterResourceState\"\xa8\x01\n\x16PendingInstanceRequest\x12,\n\x12instance_type_name\x18\x01 \x01(\tR\x10instanceTypeName\x12+\n\x12ray_node_type_name\x18\x02 \x01(\tR\x0frayNodeTypeName\x12\x14\n\x05\x63ount\x18\x03 \x01(\x05R\x05\x63ount\x12\x1d\n\nrequest_ts\x18\x04 \x01(\x03R\trequestTs\"\xd8\x01\n\x15\x46\x61iledInstanceRequest\x12,\n\x12instance_type_name\x18\x01 \x01(\tR\x10instanceTypeName\x12+\n\x12ray_node_type_name\x18\x02 \x01(\tR\x0frayNodeTypeName\x12\x14\n\x05\x63ount\x18\x03 \x01(\x05R\x05\x63ount\x12\x16\n\x06reason\x18\x04 \x01(\tR\x06reason\x12\x19\n\x08start_ts\x18\x05 \x01(\x03R\x07startTs\x12\x1b\n\tfailed_ts\x18\x06 \x01(\x03R\x08\x66\x61iledTs\"\xc6\x01\n\x0fPendingInstance\x12,\n\x12instance_type_name\x18\x01 \x01(\tR\x10instanceTypeName\x12+\n\x12ray_node_type_name\x18\x02 \x01(\tR\x0frayNodeTypeName\x12\x1f\n\x0binstance_id\x18\x03 \x01(\tR\ninstanceId\x12\x1d\n\nip_address\x18\x04 \x01(\tR\tipAddress\x12\x18\n\x07\x64\x65tails\x18\x05 \x01(\tR\x07\x64\x65tails\"\xa4\x06\n\x10\x41utoscalingState\x12U\n(last_seen_cluster_resource_state_version\x18\x01 \x01(\x03R#lastSeenClusterResourceStateVersion\x12\x38\n\x18\x61utoscaler_state_version\x18\x02 \x01(\x03R\x16\x61utoscalerStateVersion\x12\x66\n\x19pending_instance_requests\x18\x03 \x03(\x0b\x32*.ray.rpc.autoscaler.PendingInstanceRequestR\x17pendingInstanceRequests\x12\x65\n\x1cinfeasible_resource_requests\x18\x04 \x03(\x0b\x32#.ray.rpc.autoscaler.ResourceRequestR\x1ainfeasibleResourceRequests\x12r\n!infeasible_gang_resource_requests\x18\x05 \x03(\x0b\x32\'.ray.rpc.autoscaler.GangResourceRequestR\x1einfeasibleGangResourceRequests\x12\x84\x01\n\'infeasible_cluster_resource_constraints\x18\x06 \x03(\x0b\x32-.ray.rpc.autoscaler.ClusterResourceConstraintR$infeasibleClusterResourceConstraints\x12P\n\x11pending_instances\x18\x07 \x03(\x0b\x32#.ray.rpc.autoscaler.PendingInstanceR\x10pendingInstances\x12\x63\n\x18\x66\x61iled_instance_requests\x18\x08 \x03(\x0b\x32).ray.rpc.autoscaler.FailedInstanceRequestR\x16\x66\x61iledInstanceRequests\"r\n\x1dReportAutoscalingStateRequest\x12Q\n\x11\x61utoscaling_state\x18\x01 \x01(\x0b\x32$.ray.rpc.autoscaler.AutoscalingStateR\x10\x61utoscalingState\"\x1d\n\x1bReportAutoscalingStateReply\"\x98\x01\n\'RequestClusterResourceConstraintRequest\x12m\n\x1b\x63luster_resource_constraint\x18\x01 \x01(\x0b\x32-.ray.rpc.autoscaler.ClusterResourceConstraintR\x19\x63lusterResourceConstraint\"\'\n%RequestClusterResourceConstraintReply\"\x19\n\x17GetClusterStatusRequest\"\xca\x01\n\x15GetClusterStatusReply\x12Q\n\x11\x61utoscaling_state\x18\x01 \x01(\x0b\x32$.ray.rpc.autoscaler.AutoscalingStateR\x10\x61utoscalingState\x12^\n\x16\x63luster_resource_state\x18\x02 \x01(\x0b\x32(.ray.rpc.autoscaler.ClusterResourceStateR\x14\x63lusterResourceState\"\xc3\x01\n\x10\x44rainNodeRequest\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12;\n\x06reason\x18\x02 \x01(\x0e\x32#.ray.rpc.autoscaler.DrainNodeReasonR\x06reason\x12%\n\x0ereason_message\x18\x03 \x01(\tR\rreasonMessage\x12\x32\n\x15\x64\x65\x61\x64line_timestamp_ms\x18\x04 \x01(\x03R\x13\x64\x65\x61\x64lineTimestampMs\"k\n\x0e\x44rainNodeReply\x12\x1f\n\x0bis_accepted\x18\x01 \x01(\x08R\nisAccepted\x12\x38\n\x18rejection_reason_message\x18\x02 \x01(\tR\x16rejectionReasonMessage\"\xef\x01\n\x0fNodeGroupConfig\x12P\n\tresources\x18\x01 \x03(\x0b\x32\x32.ray.rpc.autoscaler.NodeGroupConfig.ResourcesEntryR\tresources\x12\x1b\n\tmin_count\x18\x02 \x01(\rR\x08minCount\x12\x1b\n\tmax_count\x18\x03 \x01(\x05R\x08maxCount\x12\x12\n\x04name\x18\x04 \x01(\tR\x04name\x1a<\n\x0eResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x04R\x05value:\x02\x38\x01\"\x98\x03\n\rClusterConfig\x12X\n\rmin_resources\x18\x01 \x03(\x0b\x32\x33.ray.rpc.autoscaler.ClusterConfig.MinResourcesEntryR\x0cminResources\x12X\n\rmax_resources\x18\x02 \x03(\x0b\x32\x33.ray.rpc.autoscaler.ClusterConfig.MaxResourcesEntryR\x0cmaxResources\x12Q\n\x12node_group_configs\x18\x03 \x03(\x0b\x32#.ray.rpc.autoscaler.NodeGroupConfigR\x10nodeGroupConfigs\x1a?\n\x11MinResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x04R\x05value:\x02\x38\x01\x1a?\n\x11MaxResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x04R\x05value:\x02\x38\x01\"f\n\x1aReportClusterConfigRequest\x12H\n\x0e\x63luster_config\x18\x01 \x01(\x0b\x32!.ray.rpc.autoscaler.ClusterConfigR\rclusterConfig\"\x1a\n\x18ReportClusterConfigReply*L\n\nNodeStatus\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\x0b\n\x07RUNNING\x10\x01\x12\x08\n\x04\x44\x45\x41\x44\x10\x02\x12\x08\n\x04IDLE\x10\x03\x12\x0c\n\x08\x44RAINING\x10\x04*~\n\x0f\x44rainNodeReason\x12!\n\x1d\x44RAIN_NODE_REASON_UNSPECIFIED\x10\x00\x12&\n\"DRAIN_NODE_REASON_IDLE_TERMINATION\x10\x01\x12 \n\x1c\x44RAIN_NODE_REASON_PREEMPTION\x10\x02\x32\xec\x05\n\x16\x41utoscalerStateService\x12\x7f\n\x17GetClusterResourceState\x12\x32.ray.rpc.autoscaler.GetClusterResourceStateRequest\x1a\x30.ray.rpc.autoscaler.GetClusterResourceStateReply\x12|\n\x16ReportAutoscalingState\x12\x31.ray.rpc.autoscaler.ReportAutoscalingStateRequest\x1a/.ray.rpc.autoscaler.ReportAutoscalingStateReply\x12s\n\x13ReportClusterConfig\x12..ray.rpc.autoscaler.ReportClusterConfigRequest\x1a,.ray.rpc.autoscaler.ReportClusterConfigReply\x12\x9a\x01\n RequestClusterResourceConstraint\x12;.ray.rpc.autoscaler.RequestClusterResourceConstraintRequest\x1a\x39.ray.rpc.autoscaler.RequestClusterResourceConstraintReply\x12j\n\x10GetClusterStatus\x12+.ray.rpc.autoscaler.GetClusterStatusRequest\x1a).ray.rpc.autoscaler.GetClusterStatusReply\x12U\n\tDrainNode\x12$.ray.rpc.autoscaler.DrainNodeRequest\x1a\".ray.rpc.autoscaler.DrainNodeReplyb\x06proto3')

_NODESTATUS = DESCRIPTOR.enum_types_by_name['NodeStatus']
NodeStatus = enum_type_wrapper.EnumTypeWrapper(_NODESTATUS)
_DRAINNODEREASON = DESCRIPTOR.enum_types_by_name['DrainNodeReason']
DrainNodeReason = enum_type_wrapper.EnumTypeWrapper(_DRAINNODEREASON)
UNSPECIFIED = 0
RUNNING = 1
DEAD = 2
IDLE = 3
DRAINING = 4
DRAIN_NODE_REASON_UNSPECIFIED = 0
DRAIN_NODE_REASON_IDLE_TERMINATION = 1
DRAIN_NODE_REASON_PREEMPTION = 2


_ANTIAFFINITYCONSTRAINT = DESCRIPTOR.message_types_by_name['AntiAffinityConstraint']
_AFFINITYCONSTRAINT = DESCRIPTOR.message_types_by_name['AffinityConstraint']
_PLACEMENTCONSTRAINT = DESCRIPTOR.message_types_by_name['PlacementConstraint']
_RESOURCEREQUEST = DESCRIPTOR.message_types_by_name['ResourceRequest']
_RESOURCEREQUEST_RESOURCESBUNDLEENTRY = _RESOURCEREQUEST.nested_types_by_name['ResourcesBundleEntry']
_RESOURCEREQUESTBYCOUNT = DESCRIPTOR.message_types_by_name['ResourceRequestByCount']
_BUNDLESELECTOR = DESCRIPTOR.message_types_by_name['BundleSelector']
_GANGRESOURCEREQUEST = DESCRIPTOR.message_types_by_name['GangResourceRequest']
_CLUSTERRESOURCECONSTRAINT = DESCRIPTOR.message_types_by_name['ClusterResourceConstraint']
_NODESTATE = DESCRIPTOR.message_types_by_name['NodeState']
_NODESTATE_AVAILABLERESOURCESENTRY = _NODESTATE.nested_types_by_name['AvailableResourcesEntry']
_NODESTATE_TOTALRESOURCESENTRY = _NODESTATE.nested_types_by_name['TotalResourcesEntry']
_NODESTATE_DYNAMICLABELSENTRY = _NODESTATE.nested_types_by_name['DynamicLabelsEntry']
_NODESTATE_LABELSENTRY = _NODESTATE.nested_types_by_name['LabelsEntry']
_GETCLUSTERRESOURCESTATEREQUEST = DESCRIPTOR.message_types_by_name['GetClusterResourceStateRequest']
_CLUSTERRESOURCESTATE = DESCRIPTOR.message_types_by_name['ClusterResourceState']
_GETCLUSTERRESOURCESTATEREPLY = DESCRIPTOR.message_types_by_name['GetClusterResourceStateReply']
_PENDINGINSTANCEREQUEST = DESCRIPTOR.message_types_by_name['PendingInstanceRequest']
_FAILEDINSTANCEREQUEST = DESCRIPTOR.message_types_by_name['FailedInstanceRequest']
_PENDINGINSTANCE = DESCRIPTOR.message_types_by_name['PendingInstance']
_AUTOSCALINGSTATE = DESCRIPTOR.message_types_by_name['AutoscalingState']
_REPORTAUTOSCALINGSTATEREQUEST = DESCRIPTOR.message_types_by_name['ReportAutoscalingStateRequest']
_REPORTAUTOSCALINGSTATEREPLY = DESCRIPTOR.message_types_by_name['ReportAutoscalingStateReply']
_REQUESTCLUSTERRESOURCECONSTRAINTREQUEST = DESCRIPTOR.message_types_by_name['RequestClusterResourceConstraintRequest']
_REQUESTCLUSTERRESOURCECONSTRAINTREPLY = DESCRIPTOR.message_types_by_name['RequestClusterResourceConstraintReply']
_GETCLUSTERSTATUSREQUEST = DESCRIPTOR.message_types_by_name['GetClusterStatusRequest']
_GETCLUSTERSTATUSREPLY = DESCRIPTOR.message_types_by_name['GetClusterStatusReply']
_DRAINNODEREQUEST = DESCRIPTOR.message_types_by_name['DrainNodeRequest']
_DRAINNODEREPLY = DESCRIPTOR.message_types_by_name['DrainNodeReply']
_NODEGROUPCONFIG = DESCRIPTOR.message_types_by_name['NodeGroupConfig']
_NODEGROUPCONFIG_RESOURCESENTRY = _NODEGROUPCONFIG.nested_types_by_name['ResourcesEntry']
_CLUSTERCONFIG = DESCRIPTOR.message_types_by_name['ClusterConfig']
_CLUSTERCONFIG_MINRESOURCESENTRY = _CLUSTERCONFIG.nested_types_by_name['MinResourcesEntry']
_CLUSTERCONFIG_MAXRESOURCESENTRY = _CLUSTERCONFIG.nested_types_by_name['MaxResourcesEntry']
_REPORTCLUSTERCONFIGREQUEST = DESCRIPTOR.message_types_by_name['ReportClusterConfigRequest']
_REPORTCLUSTERCONFIGREPLY = DESCRIPTOR.message_types_by_name['ReportClusterConfigReply']
AntiAffinityConstraint = _reflection.GeneratedProtocolMessageType('AntiAffinityConstraint', (_message.Message,), {
  'DESCRIPTOR' : _ANTIAFFINITYCONSTRAINT,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.AntiAffinityConstraint)
  })
_sym_db.RegisterMessage(AntiAffinityConstraint)

AffinityConstraint = _reflection.GeneratedProtocolMessageType('AffinityConstraint', (_message.Message,), {
  'DESCRIPTOR' : _AFFINITYCONSTRAINT,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.AffinityConstraint)
  })
_sym_db.RegisterMessage(AffinityConstraint)

PlacementConstraint = _reflection.GeneratedProtocolMessageType('PlacementConstraint', (_message.Message,), {
  'DESCRIPTOR' : _PLACEMENTCONSTRAINT,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.PlacementConstraint)
  })
_sym_db.RegisterMessage(PlacementConstraint)

ResourceRequest = _reflection.GeneratedProtocolMessageType('ResourceRequest', (_message.Message,), {

  'ResourcesBundleEntry' : _reflection.GeneratedProtocolMessageType('ResourcesBundleEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCEREQUEST_RESOURCESBUNDLEENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ResourceRequest.ResourcesBundleEntry)
    })
  ,
  'DESCRIPTOR' : _RESOURCEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ResourceRequest)
  })
_sym_db.RegisterMessage(ResourceRequest)
_sym_db.RegisterMessage(ResourceRequest.ResourcesBundleEntry)

ResourceRequestByCount = _reflection.GeneratedProtocolMessageType('ResourceRequestByCount', (_message.Message,), {
  'DESCRIPTOR' : _RESOURCEREQUESTBYCOUNT,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ResourceRequestByCount)
  })
_sym_db.RegisterMessage(ResourceRequestByCount)

BundleSelector = _reflection.GeneratedProtocolMessageType('BundleSelector', (_message.Message,), {
  'DESCRIPTOR' : _BUNDLESELECTOR,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.BundleSelector)
  })
_sym_db.RegisterMessage(BundleSelector)

GangResourceRequest = _reflection.GeneratedProtocolMessageType('GangResourceRequest', (_message.Message,), {
  'DESCRIPTOR' : _GANGRESOURCEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.GangResourceRequest)
  })
_sym_db.RegisterMessage(GangResourceRequest)

ClusterResourceConstraint = _reflection.GeneratedProtocolMessageType('ClusterResourceConstraint', (_message.Message,), {
  'DESCRIPTOR' : _CLUSTERRESOURCECONSTRAINT,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ClusterResourceConstraint)
  })
_sym_db.RegisterMessage(ClusterResourceConstraint)

NodeState = _reflection.GeneratedProtocolMessageType('NodeState', (_message.Message,), {

  'AvailableResourcesEntry' : _reflection.GeneratedProtocolMessageType('AvailableResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODESTATE_AVAILABLERESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeState.AvailableResourcesEntry)
    })
  ,

  'TotalResourcesEntry' : _reflection.GeneratedProtocolMessageType('TotalResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODESTATE_TOTALRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeState.TotalResourcesEntry)
    })
  ,

  'DynamicLabelsEntry' : _reflection.GeneratedProtocolMessageType('DynamicLabelsEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODESTATE_DYNAMICLABELSENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeState.DynamicLabelsEntry)
    })
  ,

  'LabelsEntry' : _reflection.GeneratedProtocolMessageType('LabelsEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODESTATE_LABELSENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeState.LabelsEntry)
    })
  ,
  'DESCRIPTOR' : _NODESTATE,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeState)
  })
_sym_db.RegisterMessage(NodeState)
_sym_db.RegisterMessage(NodeState.AvailableResourcesEntry)
_sym_db.RegisterMessage(NodeState.TotalResourcesEntry)
_sym_db.RegisterMessage(NodeState.DynamicLabelsEntry)
_sym_db.RegisterMessage(NodeState.LabelsEntry)

GetClusterResourceStateRequest = _reflection.GeneratedProtocolMessageType('GetClusterResourceStateRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETCLUSTERRESOURCESTATEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.GetClusterResourceStateRequest)
  })
_sym_db.RegisterMessage(GetClusterResourceStateRequest)

ClusterResourceState = _reflection.GeneratedProtocolMessageType('ClusterResourceState', (_message.Message,), {
  'DESCRIPTOR' : _CLUSTERRESOURCESTATE,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ClusterResourceState)
  })
_sym_db.RegisterMessage(ClusterResourceState)

GetClusterResourceStateReply = _reflection.GeneratedProtocolMessageType('GetClusterResourceStateReply', (_message.Message,), {
  'DESCRIPTOR' : _GETCLUSTERRESOURCESTATEREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.GetClusterResourceStateReply)
  })
_sym_db.RegisterMessage(GetClusterResourceStateReply)

PendingInstanceRequest = _reflection.GeneratedProtocolMessageType('PendingInstanceRequest', (_message.Message,), {
  'DESCRIPTOR' : _PENDINGINSTANCEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.PendingInstanceRequest)
  })
_sym_db.RegisterMessage(PendingInstanceRequest)

FailedInstanceRequest = _reflection.GeneratedProtocolMessageType('FailedInstanceRequest', (_message.Message,), {
  'DESCRIPTOR' : _FAILEDINSTANCEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.FailedInstanceRequest)
  })
_sym_db.RegisterMessage(FailedInstanceRequest)

PendingInstance = _reflection.GeneratedProtocolMessageType('PendingInstance', (_message.Message,), {
  'DESCRIPTOR' : _PENDINGINSTANCE,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.PendingInstance)
  })
_sym_db.RegisterMessage(PendingInstance)

AutoscalingState = _reflection.GeneratedProtocolMessageType('AutoscalingState', (_message.Message,), {
  'DESCRIPTOR' : _AUTOSCALINGSTATE,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.AutoscalingState)
  })
_sym_db.RegisterMessage(AutoscalingState)

ReportAutoscalingStateRequest = _reflection.GeneratedProtocolMessageType('ReportAutoscalingStateRequest', (_message.Message,), {
  'DESCRIPTOR' : _REPORTAUTOSCALINGSTATEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ReportAutoscalingStateRequest)
  })
_sym_db.RegisterMessage(ReportAutoscalingStateRequest)

ReportAutoscalingStateReply = _reflection.GeneratedProtocolMessageType('ReportAutoscalingStateReply', (_message.Message,), {
  'DESCRIPTOR' : _REPORTAUTOSCALINGSTATEREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ReportAutoscalingStateReply)
  })
_sym_db.RegisterMessage(ReportAutoscalingStateReply)

RequestClusterResourceConstraintRequest = _reflection.GeneratedProtocolMessageType('RequestClusterResourceConstraintRequest', (_message.Message,), {
  'DESCRIPTOR' : _REQUESTCLUSTERRESOURCECONSTRAINTREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.RequestClusterResourceConstraintRequest)
  })
_sym_db.RegisterMessage(RequestClusterResourceConstraintRequest)

RequestClusterResourceConstraintReply = _reflection.GeneratedProtocolMessageType('RequestClusterResourceConstraintReply', (_message.Message,), {
  'DESCRIPTOR' : _REQUESTCLUSTERRESOURCECONSTRAINTREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.RequestClusterResourceConstraintReply)
  })
_sym_db.RegisterMessage(RequestClusterResourceConstraintReply)

GetClusterStatusRequest = _reflection.GeneratedProtocolMessageType('GetClusterStatusRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETCLUSTERSTATUSREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.GetClusterStatusRequest)
  })
_sym_db.RegisterMessage(GetClusterStatusRequest)

GetClusterStatusReply = _reflection.GeneratedProtocolMessageType('GetClusterStatusReply', (_message.Message,), {
  'DESCRIPTOR' : _GETCLUSTERSTATUSREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.GetClusterStatusReply)
  })
_sym_db.RegisterMessage(GetClusterStatusReply)

DrainNodeRequest = _reflection.GeneratedProtocolMessageType('DrainNodeRequest', (_message.Message,), {
  'DESCRIPTOR' : _DRAINNODEREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.DrainNodeRequest)
  })
_sym_db.RegisterMessage(DrainNodeRequest)

DrainNodeReply = _reflection.GeneratedProtocolMessageType('DrainNodeReply', (_message.Message,), {
  'DESCRIPTOR' : _DRAINNODEREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.DrainNodeReply)
  })
_sym_db.RegisterMessage(DrainNodeReply)

NodeGroupConfig = _reflection.GeneratedProtocolMessageType('NodeGroupConfig', (_message.Message,), {

  'ResourcesEntry' : _reflection.GeneratedProtocolMessageType('ResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODEGROUPCONFIG_RESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeGroupConfig.ResourcesEntry)
    })
  ,
  'DESCRIPTOR' : _NODEGROUPCONFIG,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.NodeGroupConfig)
  })
_sym_db.RegisterMessage(NodeGroupConfig)
_sym_db.RegisterMessage(NodeGroupConfig.ResourcesEntry)

ClusterConfig = _reflection.GeneratedProtocolMessageType('ClusterConfig', (_message.Message,), {

  'MinResourcesEntry' : _reflection.GeneratedProtocolMessageType('MinResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _CLUSTERCONFIG_MINRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ClusterConfig.MinResourcesEntry)
    })
  ,

  'MaxResourcesEntry' : _reflection.GeneratedProtocolMessageType('MaxResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _CLUSTERCONFIG_MAXRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.autoscaler_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ClusterConfig.MaxResourcesEntry)
    })
  ,
  'DESCRIPTOR' : _CLUSTERCONFIG,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ClusterConfig)
  })
_sym_db.RegisterMessage(ClusterConfig)
_sym_db.RegisterMessage(ClusterConfig.MinResourcesEntry)
_sym_db.RegisterMessage(ClusterConfig.MaxResourcesEntry)

ReportClusterConfigRequest = _reflection.GeneratedProtocolMessageType('ReportClusterConfigRequest', (_message.Message,), {
  'DESCRIPTOR' : _REPORTCLUSTERCONFIGREQUEST,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ReportClusterConfigRequest)
  })
_sym_db.RegisterMessage(ReportClusterConfigRequest)

ReportClusterConfigReply = _reflection.GeneratedProtocolMessageType('ReportClusterConfigReply', (_message.Message,), {
  'DESCRIPTOR' : _REPORTCLUSTERCONFIGREPLY,
  '__module__' : 'src.ray.protobuf.autoscaler_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.autoscaler.ReportClusterConfigReply)
  })
_sym_db.RegisterMessage(ReportClusterConfigReply)

_AUTOSCALERSTATESERVICE = DESCRIPTOR.services_by_name['AutoscalerStateService']
if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  _RESOURCEREQUEST_RESOURCESBUNDLEENTRY._options = None
  _RESOURCEREQUEST_RESOURCESBUNDLEENTRY._serialized_options = b'8\001'
  _NODESTATE_AVAILABLERESOURCESENTRY._options = None
  _NODESTATE_AVAILABLERESOURCESENTRY._serialized_options = b'8\001'
  _NODESTATE_TOTALRESOURCESENTRY._options = None
  _NODESTATE_TOTALRESOURCESENTRY._serialized_options = b'8\001'
  _NODESTATE_DYNAMICLABELSENTRY._options = None
  _NODESTATE_DYNAMICLABELSENTRY._serialized_options = b'8\001'
  _NODESTATE_LABELSENTRY._options = None
  _NODESTATE_LABELSENTRY._serialized_options = b'8\001'
  _NODEGROUPCONFIG_RESOURCESENTRY._options = None
  _NODEGROUPCONFIG_RESOURCESENTRY._serialized_options = b'8\001'
  _CLUSTERCONFIG_MINRESOURCESENTRY._options = None
  _CLUSTERCONFIG_MINRESOURCESENTRY._serialized_options = b'8\001'
  _CLUSTERCONFIG_MAXRESOURCESENTRY._options = None
  _CLUSTERCONFIG_MAXRESOURCESENTRY._serialized_options = b'8\001'
  _NODESTATUS._serialized_start=6273
  _NODESTATUS._serialized_end=6349
  _DRAINNODEREASON._serialized_start=6351
  _DRAINNODEREASON._serialized_end=6477
  _ANTIAFFINITYCONSTRAINT._serialized_start=88
  _ANTIAFFINITYCONSTRAINT._serialized_end=176
  _AFFINITYCONSTRAINT._serialized_start=178
  _AFFINITYCONSTRAINT._serialized_end=262
  _PLACEMENTCONSTRAINT._serialized_start=265
  _PLACEMENTCONSTRAINT._serialized_end=476
  _RESOURCEREQUEST._serialized_start=479
  _RESOURCEREQUEST._serialized_end=824
  _RESOURCEREQUEST_RESOURCESBUNDLEENTRY._serialized_start=758
  _RESOURCEREQUEST_RESOURCESBUNDLEENTRY._serialized_end=824
  _RESOURCEREQUESTBYCOUNT._serialized_start=826
  _RESOURCEREQUESTBYCOUNT._serialized_end=935
  _BUNDLESELECTOR._serialized_start=937
  _BUNDLESELECTOR._serialized_end=1035
  _GANGRESOURCEREQUEST._serialized_start=1038
  _GANGRESOURCEREQUEST._serialized_end=1229
  _CLUSTERRESOURCECONSTRAINT._serialized_start=1231
  _CLUSTERRESOURCECONSTRAINT._serialized_end=1347
  _NODESTATE._serialized_start=1350
  _NODESTATE._serialized_end=2346
  _NODESTATE_AVAILABLERESOURCESENTRY._serialized_start=2085
  _NODESTATE_AVAILABLERESOURCESENTRY._serialized_end=2154
  _NODESTATE_TOTALRESOURCESENTRY._serialized_start=2156
  _NODESTATE_TOTALRESOURCESENTRY._serialized_end=2221
  _NODESTATE_DYNAMICLABELSENTRY._serialized_start=2223
  _NODESTATE_DYNAMICLABELSENTRY._serialized_end=2287
  _NODESTATE_LABELSENTRY._serialized_start=2289
  _NODESTATE_LABELSENTRY._serialized_end=2346
  _GETCLUSTERRESOURCESTATEREQUEST._serialized_start=2348
  _GETCLUSTERRESOURCESTATEREQUEST._serialized_end=2467
  _CLUSTERRESOURCESTATE._serialized_start=2470
  _CLUSTERRESOURCESTATE._serialized_end=3078
  _GETCLUSTERRESOURCESTATEREPLY._serialized_start=3080
  _GETCLUSTERRESOURCESTATEREPLY._serialized_end=3206
  _PENDINGINSTANCEREQUEST._serialized_start=3209
  _PENDINGINSTANCEREQUEST._serialized_end=3377
  _FAILEDINSTANCEREQUEST._serialized_start=3380
  _FAILEDINSTANCEREQUEST._serialized_end=3596
  _PENDINGINSTANCE._serialized_start=3599
  _PENDINGINSTANCE._serialized_end=3797
  _AUTOSCALINGSTATE._serialized_start=3800
  _AUTOSCALINGSTATE._serialized_end=4604
  _REPORTAUTOSCALINGSTATEREQUEST._serialized_start=4606
  _REPORTAUTOSCALINGSTATEREQUEST._serialized_end=4720
  _REPORTAUTOSCALINGSTATEREPLY._serialized_start=4722
  _REPORTAUTOSCALINGSTATEREPLY._serialized_end=4751
  _REQUESTCLUSTERRESOURCECONSTRAINTREQUEST._serialized_start=4754
  _REQUESTCLUSTERRESOURCECONSTRAINTREQUEST._serialized_end=4906
  _REQUESTCLUSTERRESOURCECONSTRAINTREPLY._serialized_start=4908
  _REQUESTCLUSTERRESOURCECONSTRAINTREPLY._serialized_end=4947
  _GETCLUSTERSTATUSREQUEST._serialized_start=4949
  _GETCLUSTERSTATUSREQUEST._serialized_end=4974
  _GETCLUSTERSTATUSREPLY._serialized_start=4977
  _GETCLUSTERSTATUSREPLY._serialized_end=5179
  _DRAINNODEREQUEST._serialized_start=5182
  _DRAINNODEREQUEST._serialized_end=5377
  _DRAINNODEREPLY._serialized_start=5379
  _DRAINNODEREPLY._serialized_end=5486
  _NODEGROUPCONFIG._serialized_start=5489
  _NODEGROUPCONFIG._serialized_end=5728
  _NODEGROUPCONFIG_RESOURCESENTRY._serialized_start=5668
  _NODEGROUPCONFIG_RESOURCESENTRY._serialized_end=5728
  _CLUSTERCONFIG._serialized_start=5731
  _CLUSTERCONFIG._serialized_end=6139
  _CLUSTERCONFIG_MINRESOURCESENTRY._serialized_start=6011
  _CLUSTERCONFIG_MINRESOURCESENTRY._serialized_end=6074
  _CLUSTERCONFIG_MAXRESOURCESENTRY._serialized_start=6076
  _CLUSTERCONFIG_MAXRESOURCESENTRY._serialized_end=6139
  _REPORTCLUSTERCONFIGREQUEST._serialized_start=6141
  _REPORTCLUSTERCONFIGREQUEST._serialized_end=6243
  _REPORTCLUSTERCONFIGREPLY._serialized_start=6245
  _REPORTCLUSTERCONFIGREPLY._serialized_end=6271
  _AUTOSCALERSTATESERVICE._serialized_start=6480
  _AUTOSCALERSTATESERVICE._serialized_end=7228
# @@protoc_insertion_point(module_scope)

Products

About

Resources

Contact Gemfury