Created
August 11, 2020 07:28
-
-
Save simon-mo/2d2c412102c0d6347aad9a6bd20f59b1 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # @generated by mypy-protobuf. Do not edit manually! | |
| import sys | |
| from google.protobuf.descriptor import ( | |
| Descriptor as google___protobuf___descriptor___Descriptor, | |
| EnumDescriptor as google___protobuf___descriptor___EnumDescriptor, | |
| FileDescriptor as google___protobuf___descriptor___FileDescriptor, | |
| ) | |
| from google.protobuf.internal.containers import ( | |
| RepeatedCompositeFieldContainer as google___protobuf___internal___containers___RepeatedCompositeFieldContainer, | |
| RepeatedScalarFieldContainer as google___protobuf___internal___containers___RepeatedScalarFieldContainer, | |
| ) | |
| from google.protobuf.internal.enum_type_wrapper import ( | |
| _EnumTypeWrapper as google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper, | |
| ) | |
| from google.protobuf.message import ( | |
| Message as google___protobuf___message___Message, | |
| ) | |
| from typing import ( | |
| Iterable as typing___Iterable, | |
| Mapping as typing___Mapping, | |
| MutableMapping as typing___MutableMapping, | |
| NewType as typing___NewType, | |
| Optional as typing___Optional, | |
| Text as typing___Text, | |
| cast as typing___cast, | |
| ) | |
| from typing_extensions import ( | |
| Literal as typing_extensions___Literal, | |
| ) | |
| builtin___bool = bool | |
| builtin___bytes = bytes | |
| builtin___float = float | |
| builtin___int = int | |
| DESCRIPTOR: google___protobuf___descriptor___FileDescriptor = ... | |
| LanguageValue = typing___NewType('LanguageValue', builtin___int) | |
| type___LanguageValue = LanguageValue | |
| Language: _Language | |
| class _Language(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[LanguageValue]): | |
| DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ... | |
| PYTHON = typing___cast(LanguageValue, 0) | |
| JAVA = typing___cast(LanguageValue, 1) | |
| CPP = typing___cast(LanguageValue, 2) | |
| PYTHON = typing___cast(LanguageValue, 0) | |
| JAVA = typing___cast(LanguageValue, 1) | |
| CPP = typing___cast(LanguageValue, 2) | |
| type___Language = Language | |
| WorkerTypeValue = typing___NewType('WorkerTypeValue', builtin___int) | |
| type___WorkerTypeValue = WorkerTypeValue | |
| WorkerType: _WorkerType | |
| class _WorkerType(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[WorkerTypeValue]): | |
| DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ... | |
| WORKER = typing___cast(WorkerTypeValue, 0) | |
| DRIVER = typing___cast(WorkerTypeValue, 1) | |
| WORKER = typing___cast(WorkerTypeValue, 0) | |
| DRIVER = typing___cast(WorkerTypeValue, 1) | |
| type___WorkerType = WorkerType | |
| TaskTypeValue = typing___NewType('TaskTypeValue', builtin___int) | |
| type___TaskTypeValue = TaskTypeValue | |
| TaskType: _TaskType | |
| class _TaskType(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[TaskTypeValue]): | |
| DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ... | |
| NORMAL_TASK = typing___cast(TaskTypeValue, 0) | |
| ACTOR_CREATION_TASK = typing___cast(TaskTypeValue, 1) | |
| ACTOR_TASK = typing___cast(TaskTypeValue, 2) | |
| DRIVER_TASK = typing___cast(TaskTypeValue, 3) | |
| NORMAL_TASK = typing___cast(TaskTypeValue, 0) | |
| ACTOR_CREATION_TASK = typing___cast(TaskTypeValue, 1) | |
| ACTOR_TASK = typing___cast(TaskTypeValue, 2) | |
| DRIVER_TASK = typing___cast(TaskTypeValue, 3) | |
| type___TaskType = TaskType | |
| PlacementStrategyValue = typing___NewType('PlacementStrategyValue', builtin___int) | |
| type___PlacementStrategyValue = PlacementStrategyValue | |
| PlacementStrategy: _PlacementStrategy | |
| class _PlacementStrategy(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[PlacementStrategyValue]): | |
| DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ... | |
| PACK = typing___cast(PlacementStrategyValue, 0) | |
| SPREAD = typing___cast(PlacementStrategyValue, 1) | |
| PACK = typing___cast(PlacementStrategyValue, 0) | |
| SPREAD = typing___cast(PlacementStrategyValue, 1) | |
| type___PlacementStrategy = PlacementStrategy | |
| class Address(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| raylet_id: builtin___bytes = ... | |
| ip_address: typing___Text = ... | |
| port: builtin___int = ... | |
| worker_id: builtin___bytes = ... | |
| def __init__(self, | |
| *, | |
| raylet_id : typing___Optional[builtin___bytes] = None, | |
| ip_address : typing___Optional[typing___Text] = None, | |
| port : typing___Optional[builtin___int] = None, | |
| worker_id : typing___Optional[builtin___bytes] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"ip_address",b"ip_address",u"port",b"port",u"raylet_id",b"raylet_id",u"worker_id",b"worker_id"]) -> None: ... | |
| type___Address = Address | |
| class JavaFunctionDescriptor(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class_name: typing___Text = ... | |
| function_name: typing___Text = ... | |
| signature: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| class_name : typing___Optional[typing___Text] = None, | |
| function_name : typing___Optional[typing___Text] = None, | |
| signature : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"class_name",b"class_name",u"function_name",b"function_name",u"signature",b"signature"]) -> None: ... | |
| type___JavaFunctionDescriptor = JavaFunctionDescriptor | |
| class PythonFunctionDescriptor(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| module_name: typing___Text = ... | |
| class_name: typing___Text = ... | |
| function_name: typing___Text = ... | |
| function_hash: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| module_name : typing___Optional[typing___Text] = None, | |
| class_name : typing___Optional[typing___Text] = None, | |
| function_name : typing___Optional[typing___Text] = None, | |
| function_hash : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"class_name",b"class_name",u"function_hash",b"function_hash",u"function_name",b"function_name",u"module_name",b"module_name"]) -> None: ... | |
| type___PythonFunctionDescriptor = PythonFunctionDescriptor | |
| class CppFunctionDescriptor(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| lib_name: typing___Text = ... | |
| function_offset: typing___Text = ... | |
| exec_function_offset: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| lib_name : typing___Optional[typing___Text] = None, | |
| function_offset : typing___Optional[typing___Text] = None, | |
| exec_function_offset : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"exec_function_offset",b"exec_function_offset",u"function_offset",b"function_offset",u"lib_name",b"lib_name"]) -> None: ... | |
| type___CppFunctionDescriptor = CppFunctionDescriptor | |
| class FunctionDescriptor(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| @property | |
| def java_function_descriptor(self) -> type___JavaFunctionDescriptor: ... | |
| @property | |
| def python_function_descriptor(self) -> type___PythonFunctionDescriptor: ... | |
| @property | |
| def cpp_function_descriptor(self) -> type___CppFunctionDescriptor: ... | |
| def __init__(self, | |
| *, | |
| java_function_descriptor : typing___Optional[type___JavaFunctionDescriptor] = None, | |
| python_function_descriptor : typing___Optional[type___PythonFunctionDescriptor] = None, | |
| cpp_function_descriptor : typing___Optional[type___CppFunctionDescriptor] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"cpp_function_descriptor",b"cpp_function_descriptor",u"function_descriptor",b"function_descriptor",u"java_function_descriptor",b"java_function_descriptor",u"python_function_descriptor",b"python_function_descriptor"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"cpp_function_descriptor",b"cpp_function_descriptor",u"function_descriptor",b"function_descriptor",u"java_function_descriptor",b"java_function_descriptor",u"python_function_descriptor",b"python_function_descriptor"]) -> None: ... | |
| def WhichOneof(self, oneof_group: typing_extensions___Literal[u"function_descriptor",b"function_descriptor"]) -> typing_extensions___Literal["java_function_descriptor","python_function_descriptor","cpp_function_descriptor"]: ... | |
| type___FunctionDescriptor = FunctionDescriptor | |
| class TaskSpec(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class RequiredResourcesEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| value: builtin___float = ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[builtin___float] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___RequiredResourcesEntry = RequiredResourcesEntry | |
| class RequiredPlacementResourcesEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| value: builtin___float = ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[builtin___float] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___RequiredPlacementResourcesEntry = RequiredPlacementResourcesEntry | |
| type: type___TaskTypeValue = ... | |
| language: type___LanguageValue = ... | |
| job_id: builtin___bytes = ... | |
| task_id: builtin___bytes = ... | |
| parent_task_id: builtin___bytes = ... | |
| parent_counter: builtin___int = ... | |
| caller_id: builtin___bytes = ... | |
| num_returns: builtin___int = ... | |
| max_retries: builtin___int = ... | |
| @property | |
| def function_descriptor(self) -> type___FunctionDescriptor: ... | |
| @property | |
| def caller_address(self) -> type___Address: ... | |
| @property | |
| def args(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___TaskArg]: ... | |
| @property | |
| def required_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ... | |
| @property | |
| def required_placement_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ... | |
| @property | |
| def actor_creation_task_spec(self) -> type___ActorCreationTaskSpec: ... | |
| @property | |
| def actor_task_spec(self) -> type___ActorTaskSpec: ... | |
| def __init__(self, | |
| *, | |
| type : typing___Optional[type___TaskTypeValue] = None, | |
| language : typing___Optional[type___LanguageValue] = None, | |
| function_descriptor : typing___Optional[type___FunctionDescriptor] = None, | |
| job_id : typing___Optional[builtin___bytes] = None, | |
| task_id : typing___Optional[builtin___bytes] = None, | |
| parent_task_id : typing___Optional[builtin___bytes] = None, | |
| parent_counter : typing___Optional[builtin___int] = None, | |
| caller_id : typing___Optional[builtin___bytes] = None, | |
| caller_address : typing___Optional[type___Address] = None, | |
| args : typing___Optional[typing___Iterable[type___TaskArg]] = None, | |
| num_returns : typing___Optional[builtin___int] = None, | |
| required_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None, | |
| required_placement_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None, | |
| actor_creation_task_spec : typing___Optional[type___ActorCreationTaskSpec] = None, | |
| actor_task_spec : typing___Optional[type___ActorTaskSpec] = None, | |
| max_retries : typing___Optional[builtin___int] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"actor_creation_task_spec",b"actor_creation_task_spec",u"actor_task_spec",b"actor_task_spec",u"caller_address",b"caller_address",u"function_descriptor",b"function_descriptor"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"actor_creation_task_spec",b"actor_creation_task_spec",u"actor_task_spec",b"actor_task_spec",u"args",b"args",u"caller_address",b"caller_address",u"caller_id",b"caller_id",u"function_descriptor",b"function_descriptor",u"job_id",b"job_id",u"language",b"language",u"max_retries",b"max_retries",u"num_returns",b"num_returns",u"parent_counter",b"parent_counter",u"parent_task_id",b"parent_task_id",u"required_placement_resources",b"required_placement_resources",u"required_resources",b"required_resources",u"task_id",b"task_id",u"type",b"type"]) -> None: ... | |
| type___TaskSpec = TaskSpec | |
| class Bundle(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class BundleIdentifier(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| placement_group_id: builtin___bytes = ... | |
| bundle_index: builtin___int = ... | |
| def __init__(self, | |
| *, | |
| placement_group_id : typing___Optional[builtin___bytes] = None, | |
| bundle_index : typing___Optional[builtin___int] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"bundle_index",b"bundle_index",u"placement_group_id",b"placement_group_id"]) -> None: ... | |
| type___BundleIdentifier = BundleIdentifier | |
| class UnitResourcesEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| value: builtin___float = ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[builtin___float] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___UnitResourcesEntry = UnitResourcesEntry | |
| @property | |
| def bundle_id(self) -> type___Bundle.BundleIdentifier: ... | |
| @property | |
| def unit_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ... | |
| def __init__(self, | |
| *, | |
| bundle_id : typing___Optional[type___Bundle.BundleIdentifier] = None, | |
| unit_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"bundle_id",b"bundle_id"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"bundle_id",b"bundle_id",u"unit_resources",b"unit_resources"]) -> None: ... | |
| type___Bundle = Bundle | |
| class PlacementGroupSpec(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| placement_group_id: builtin___bytes = ... | |
| name: typing___Text = ... | |
| strategy: type___PlacementStrategyValue = ... | |
| @property | |
| def bundles(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___Bundle]: ... | |
| def __init__(self, | |
| *, | |
| placement_group_id : typing___Optional[builtin___bytes] = None, | |
| name : typing___Optional[typing___Text] = None, | |
| bundles : typing___Optional[typing___Iterable[type___Bundle]] = None, | |
| strategy : typing___Optional[type___PlacementStrategyValue] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"bundles",b"bundles",u"name",b"name",u"placement_group_id",b"placement_group_id",u"strategy",b"strategy"]) -> None: ... | |
| type___PlacementGroupSpec = PlacementGroupSpec | |
| class ObjectReference(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| object_id: builtin___bytes = ... | |
| @property | |
| def owner_address(self) -> type___Address: ... | |
| def __init__(self, | |
| *, | |
| object_id : typing___Optional[builtin___bytes] = None, | |
| owner_address : typing___Optional[type___Address] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"owner_address",b"owner_address"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"object_id",b"object_id",u"owner_address",b"owner_address"]) -> None: ... | |
| type___ObjectReference = ObjectReference | |
| class TaskArg(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| data: builtin___bytes = ... | |
| metadata: builtin___bytes = ... | |
| nested_inlined_ids: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___bytes] = ... | |
| @property | |
| def object_ref(self) -> type___ObjectReference: ... | |
| def __init__(self, | |
| *, | |
| object_ref : typing___Optional[type___ObjectReference] = None, | |
| data : typing___Optional[builtin___bytes] = None, | |
| metadata : typing___Optional[builtin___bytes] = None, | |
| nested_inlined_ids : typing___Optional[typing___Iterable[builtin___bytes]] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"object_ref",b"object_ref"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"data",b"data",u"metadata",b"metadata",u"nested_inlined_ids",b"nested_inlined_ids",u"object_ref",b"object_ref"]) -> None: ... | |
| type___TaskArg = TaskArg | |
| class ActorCreationTaskSpec(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| actor_id: builtin___bytes = ... | |
| max_actor_restarts: builtin___int = ... | |
| dynamic_worker_options: google___protobuf___internal___containers___RepeatedScalarFieldContainer[typing___Text] = ... | |
| max_concurrency: builtin___int = ... | |
| is_detached: builtin___bool = ... | |
| name: typing___Text = ... | |
| is_asyncio: builtin___bool = ... | |
| extension_data: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| actor_id : typing___Optional[builtin___bytes] = None, | |
| max_actor_restarts : typing___Optional[builtin___int] = None, | |
| dynamic_worker_options : typing___Optional[typing___Iterable[typing___Text]] = None, | |
| max_concurrency : typing___Optional[builtin___int] = None, | |
| is_detached : typing___Optional[builtin___bool] = None, | |
| name : typing___Optional[typing___Text] = None, | |
| is_asyncio : typing___Optional[builtin___bool] = None, | |
| extension_data : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"actor_id",b"actor_id",u"dynamic_worker_options",b"dynamic_worker_options",u"extension_data",b"extension_data",u"is_asyncio",b"is_asyncio",u"is_detached",b"is_detached",u"max_actor_restarts",b"max_actor_restarts",u"max_concurrency",b"max_concurrency",u"name",b"name"]) -> None: ... | |
| type___ActorCreationTaskSpec = ActorCreationTaskSpec | |
| class ActorTaskSpec(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| actor_id: builtin___bytes = ... | |
| actor_creation_dummy_object_id: builtin___bytes = ... | |
| actor_counter: builtin___int = ... | |
| previous_actor_task_dummy_object_id: builtin___bytes = ... | |
| def __init__(self, | |
| *, | |
| actor_id : typing___Optional[builtin___bytes] = None, | |
| actor_creation_dummy_object_id : typing___Optional[builtin___bytes] = None, | |
| actor_counter : typing___Optional[builtin___int] = None, | |
| previous_actor_task_dummy_object_id : typing___Optional[builtin___bytes] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"actor_counter",b"actor_counter",u"actor_creation_dummy_object_id",b"actor_creation_dummy_object_id",u"actor_id",b"actor_id",u"previous_actor_task_dummy_object_id",b"previous_actor_task_dummy_object_id"]) -> None: ... | |
| type___ActorTaskSpec = ActorTaskSpec | |
| class TaskExecutionSpec(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| last_timestamp: builtin___float = ... | |
| num_forwards: builtin___int = ... | |
| def __init__(self, | |
| *, | |
| last_timestamp : typing___Optional[builtin___float] = None, | |
| num_forwards : typing___Optional[builtin___int] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"last_timestamp",b"last_timestamp",u"num_forwards",b"num_forwards"]) -> None: ... | |
| type___TaskExecutionSpec = TaskExecutionSpec | |
| class Task(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| @property | |
| def task_spec(self) -> type___TaskSpec: ... | |
| @property | |
| def task_execution_spec(self) -> type___TaskExecutionSpec: ... | |
| def __init__(self, | |
| *, | |
| task_spec : typing___Optional[type___TaskSpec] = None, | |
| task_execution_spec : typing___Optional[type___TaskExecutionSpec] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"task_execution_spec",b"task_execution_spec",u"task_spec",b"task_spec"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"task_execution_spec",b"task_execution_spec",u"task_spec",b"task_spec"]) -> None: ... | |
| type___Task = Task | |
| class ResourceId(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| index: builtin___int = ... | |
| quantity: builtin___float = ... | |
| def __init__(self, | |
| *, | |
| index : typing___Optional[builtin___int] = None, | |
| quantity : typing___Optional[builtin___float] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"index",b"index",u"quantity",b"quantity"]) -> None: ... | |
| type___ResourceId = ResourceId | |
| class ResourceMapEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| name: typing___Text = ... | |
| @property | |
| def resource_ids(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ResourceId]: ... | |
| def __init__(self, | |
| *, | |
| name : typing___Optional[typing___Text] = None, | |
| resource_ids : typing___Optional[typing___Iterable[type___ResourceId]] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"name",b"name",u"resource_ids",b"resource_ids"]) -> None: ... | |
| type___ResourceMapEntry = ResourceMapEntry | |
| class ViewData(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class Measure(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| tags: typing___Text = ... | |
| int_value: builtin___int = ... | |
| double_value: builtin___float = ... | |
| distribution_min: builtin___float = ... | |
| distribution_mean: builtin___float = ... | |
| distribution_max: builtin___float = ... | |
| distribution_count: builtin___float = ... | |
| distribution_bucket_boundaries: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___float] = ... | |
| distribution_bucket_counts: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___float] = ... | |
| def __init__(self, | |
| *, | |
| tags : typing___Optional[typing___Text] = None, | |
| int_value : typing___Optional[builtin___int] = None, | |
| double_value : typing___Optional[builtin___float] = None, | |
| distribution_min : typing___Optional[builtin___float] = None, | |
| distribution_mean : typing___Optional[builtin___float] = None, | |
| distribution_max : typing___Optional[builtin___float] = None, | |
| distribution_count : typing___Optional[builtin___float] = None, | |
| distribution_bucket_boundaries : typing___Optional[typing___Iterable[builtin___float]] = None, | |
| distribution_bucket_counts : typing___Optional[typing___Iterable[builtin___float]] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"distribution_bucket_boundaries",b"distribution_bucket_boundaries",u"distribution_bucket_counts",b"distribution_bucket_counts",u"distribution_count",b"distribution_count",u"distribution_max",b"distribution_max",u"distribution_mean",b"distribution_mean",u"distribution_min",b"distribution_min",u"double_value",b"double_value",u"int_value",b"int_value",u"tags",b"tags"]) -> None: ... | |
| type___Measure = Measure | |
| view_name: typing___Text = ... | |
| @property | |
| def measures(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ViewData.Measure]: ... | |
| def __init__(self, | |
| *, | |
| view_name : typing___Optional[typing___Text] = None, | |
| measures : typing___Optional[typing___Iterable[type___ViewData.Measure]] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"measures",b"measures",u"view_name",b"view_name"]) -> None: ... | |
| type___ViewData = ViewData | |
| class ObjectRefInfo(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| object_id: builtin___bytes = ... | |
| call_site: typing___Text = ... | |
| object_size: builtin___int = ... | |
| local_ref_count: builtin___int = ... | |
| submitted_task_ref_count: builtin___int = ... | |
| contained_in_owned: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___bytes] = ... | |
| pinned_in_memory: builtin___bool = ... | |
| def __init__(self, | |
| *, | |
| object_id : typing___Optional[builtin___bytes] = None, | |
| call_site : typing___Optional[typing___Text] = None, | |
| object_size : typing___Optional[builtin___int] = None, | |
| local_ref_count : typing___Optional[builtin___int] = None, | |
| submitted_task_ref_count : typing___Optional[builtin___int] = None, | |
| contained_in_owned : typing___Optional[typing___Iterable[builtin___bytes]] = None, | |
| pinned_in_memory : typing___Optional[builtin___bool] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"call_site",b"call_site",u"contained_in_owned",b"contained_in_owned",u"local_ref_count",b"local_ref_count",u"object_id",b"object_id",u"object_size",b"object_size",u"pinned_in_memory",b"pinned_in_memory",u"submitted_task_ref_count",b"submitted_task_ref_count"]) -> None: ... | |
| type___ObjectRefInfo = ObjectRefInfo | |
| class ResourceAllocations(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class ResourceSlot(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| slot: builtin___int = ... | |
| allocation: builtin___float = ... | |
| def __init__(self, | |
| *, | |
| slot : typing___Optional[builtin___int] = None, | |
| allocation : typing___Optional[builtin___float] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"allocation",b"allocation",u"slot",b"slot"]) -> None: ... | |
| type___ResourceSlot = ResourceSlot | |
| @property | |
| def resource_slots(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ResourceAllocations.ResourceSlot]: ... | |
| def __init__(self, | |
| *, | |
| resource_slots : typing___Optional[typing___Iterable[type___ResourceAllocations.ResourceSlot]] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"resource_slots",b"resource_slots"]) -> None: ... | |
| type___ResourceAllocations = ResourceAllocations | |
| class CoreWorkerStats(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class UsedResourcesEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| @property | |
| def value(self) -> type___ResourceAllocations: ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[type___ResourceAllocations] = None, | |
| ) -> None: ... | |
| def HasField(self, field_name: typing_extensions___Literal[u"value",b"value"]) -> builtin___bool: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___UsedResourcesEntry = UsedResourcesEntry | |
| class WebuiDisplayEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| value: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___WebuiDisplayEntry = WebuiDisplayEntry | |
| current_task_desc: typing___Text = ... | |
| num_pending_tasks: builtin___int = ... | |
| num_object_refs_in_scope: builtin___int = ... | |
| current_task_func_desc: typing___Text = ... | |
| ip_address: typing___Text = ... | |
| port: builtin___int = ... | |
| actor_id: builtin___bytes = ... | |
| num_in_plasma: builtin___int = ... | |
| num_local_objects: builtin___int = ... | |
| used_object_store_memory: builtin___int = ... | |
| task_queue_length: builtin___int = ... | |
| num_executed_tasks: builtin___int = ... | |
| actor_title: typing___Text = ... | |
| @property | |
| def used_resources(self) -> typing___MutableMapping[typing___Text, type___ResourceAllocations]: ... | |
| @property | |
| def webui_display(self) -> typing___MutableMapping[typing___Text, typing___Text]: ... | |
| @property | |
| def object_refs(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ObjectRefInfo]: ... | |
| def __init__(self, | |
| *, | |
| current_task_desc : typing___Optional[typing___Text] = None, | |
| num_pending_tasks : typing___Optional[builtin___int] = None, | |
| num_object_refs_in_scope : typing___Optional[builtin___int] = None, | |
| current_task_func_desc : typing___Optional[typing___Text] = None, | |
| ip_address : typing___Optional[typing___Text] = None, | |
| port : typing___Optional[builtin___int] = None, | |
| actor_id : typing___Optional[builtin___bytes] = None, | |
| used_resources : typing___Optional[typing___Mapping[typing___Text, type___ResourceAllocations]] = None, | |
| webui_display : typing___Optional[typing___Mapping[typing___Text, typing___Text]] = None, | |
| num_in_plasma : typing___Optional[builtin___int] = None, | |
| num_local_objects : typing___Optional[builtin___int] = None, | |
| used_object_store_memory : typing___Optional[builtin___int] = None, | |
| task_queue_length : typing___Optional[builtin___int] = None, | |
| num_executed_tasks : typing___Optional[builtin___int] = None, | |
| actor_title : typing___Optional[typing___Text] = None, | |
| object_refs : typing___Optional[typing___Iterable[type___ObjectRefInfo]] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"actor_id",b"actor_id",u"actor_title",b"actor_title",u"current_task_desc",b"current_task_desc",u"current_task_func_desc",b"current_task_func_desc",u"ip_address",b"ip_address",u"num_executed_tasks",b"num_executed_tasks",u"num_in_plasma",b"num_in_plasma",u"num_local_objects",b"num_local_objects",u"num_object_refs_in_scope",b"num_object_refs_in_scope",u"num_pending_tasks",b"num_pending_tasks",u"object_refs",b"object_refs",u"port",b"port",u"task_queue_length",b"task_queue_length",u"used_object_store_memory",b"used_object_store_memory",u"used_resources",b"used_resources",u"webui_display",b"webui_display"]) -> None: ... | |
| type___CoreWorkerStats = CoreWorkerStats | |
| class MetricPoint(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| class TagsEntry(google___protobuf___message___Message): | |
| DESCRIPTOR: google___protobuf___descriptor___Descriptor = ... | |
| key: typing___Text = ... | |
| value: typing___Text = ... | |
| def __init__(self, | |
| *, | |
| key : typing___Optional[typing___Text] = None, | |
| value : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ... | |
| type___TagsEntry = TagsEntry | |
| metric_name: typing___Text = ... | |
| timestamp: builtin___int = ... | |
| value: builtin___float = ... | |
| description: typing___Text = ... | |
| units: typing___Text = ... | |
| @property | |
| def tags(self) -> typing___MutableMapping[typing___Text, typing___Text]: ... | |
| def __init__(self, | |
| *, | |
| metric_name : typing___Optional[typing___Text] = None, | |
| timestamp : typing___Optional[builtin___int] = None, | |
| value : typing___Optional[builtin___float] = None, | |
| tags : typing___Optional[typing___Mapping[typing___Text, typing___Text]] = None, | |
| description : typing___Optional[typing___Text] = None, | |
| units : typing___Optional[typing___Text] = None, | |
| ) -> None: ... | |
| def ClearField(self, field_name: typing_extensions___Literal[u"description",b"description",u"metric_name",b"metric_name",u"tags",b"tags",u"timestamp",b"timestamp",u"units",b"units",u"value",b"value"]) -> None: ... | |
| type___MetricPoint = MetricPoint |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment