From 5dee08764219fc8dcea177ee312596f9671ca89f Mon Sep 17 00:00:00 2001 From: Zhenyu Zheng Date: Thu, 12 Dec 2024 14:05:20 +0800 Subject: [PATCH] Regenerate grpc files Regenerate grpc files Signed-off-by: Zhenyu Zheng --- .../grpcs/eulerlauncher_grpc/flavors_pb2.py | 16 +- .../eulerlauncher_grpc/flavors_pb2_grpc.py | 75 +++++- .../grpcs/eulerlauncher_grpc/images_pb2.py | 16 +- .../eulerlauncher_grpc/images_pb2_grpc.py | 93 ++++++-- .../grpcs/eulerlauncher_grpc/instances_pb2.py | 16 +- .../eulerlauncher_grpc/instances_pb2_grpc.py | 219 ++++++++++++++---- 6 files changed, 354 insertions(+), 81 deletions(-) diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2.py b/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2.py index 182a842..a8eca50 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: flavors.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.28.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 28, + 1, + '', + 'flavors.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,8 +29,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rflavors.proto\x1 _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flavors_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'\200\001\001' _globals['_FLAVOR']._serialized_start=26 _globals['_FLAVOR']._serialized_end=141 diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2_grpc.py b/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2_grpc.py index 8c4c0f3..bf98445 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2_grpc.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/flavors_pb2_grpc.py @@ -1,9 +1,29 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings import flavors_pb2 as flavors__pb2 +GRPC_GENERATED_VERSION = '1.68.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in flavors_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) + class FlavorGrpcServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,17 +38,17 @@ class FlavorGrpcServiceStub(object): '/flavors.FlavorGrpcService/list_flavor', request_serializer=flavors__pb2.ListFlavorsRequest.SerializeToString, response_deserializer=flavors__pb2.ListFlavorsResponse.FromString, - ) + _registered_method=True) self.create_flavor = channel.unary_unary( '/flavors.FlavorGrpcService/create_flavor', request_serializer=flavors__pb2.CreateFlavorRequest.SerializeToString, response_deserializer=flavors__pb2.FlavorResponse.FromString, - ) + _registered_method=True) self.delete_flavor = channel.unary_unary( '/flavors.FlavorGrpcService/delete_flavor', request_serializer=flavors__pb2.DeleteFlavorRequest.SerializeToString, response_deserializer=flavors__pb2.FlavorResponse.FromString, - ) + _registered_method=True) class FlavorGrpcServiceServicer(object): @@ -74,6 +94,7 @@ def add_FlavorGrpcServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'flavors.FlavorGrpcService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('flavors.FlavorGrpcService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -91,11 +112,21 @@ class FlavorGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/flavors.FlavorGrpcService/list_flavor', + return grpc.experimental.unary_unary( + request, + target, + '/flavors.FlavorGrpcService/list_flavor', flavors__pb2.ListFlavorsRequest.SerializeToString, flavors__pb2.ListFlavorsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def create_flavor(request, @@ -108,11 +139,21 @@ class FlavorGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/flavors.FlavorGrpcService/create_flavor', + return grpc.experimental.unary_unary( + request, + target, + '/flavors.FlavorGrpcService/create_flavor', flavors__pb2.CreateFlavorRequest.SerializeToString, flavors__pb2.FlavorResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def delete_flavor(request, @@ -125,8 +166,18 @@ class FlavorGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/flavors.FlavorGrpcService/delete_flavor', + return grpc.experimental.unary_unary( + request, + target, + '/flavors.FlavorGrpcService/delete_flavor', flavors__pb2.DeleteFlavorRequest.SerializeToString, flavors__pb2.FlavorResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2.py b/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2.py index a03ecdc..4b7a3ac 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: images.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.28.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 28, + 1, + '', + 'images.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,8 +29,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0cimages.proto\x _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'images_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'\200\001\001' _globals['_IMAGE']._serialized_start=31 _globals['_IMAGE']._serialized_end=86 diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2_grpc.py b/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2_grpc.py index af2d722..562f41a 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2_grpc.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/images_pb2_grpc.py @@ -1,9 +1,29 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings import images_pb2 as images__pb2 +GRPC_GENERATED_VERSION = '1.68.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in images_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) + class ImageGrpcServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,22 +38,22 @@ class ImageGrpcServiceStub(object): '/eulerlauncher.ImageGrpcService/list_images', request_serializer=images__pb2.ListImageRequest.SerializeToString, response_deserializer=images__pb2.ListImageResponse.FromString, - ) + _registered_method=True) self.download_image = channel.unary_unary( '/eulerlauncher.ImageGrpcService/download_image', request_serializer=images__pb2.DownloadImageRequest.SerializeToString, response_deserializer=images__pb2.GeneralImageResponse.FromString, - ) + _registered_method=True) self.load_image = channel.unary_unary( '/eulerlauncher.ImageGrpcService/load_image', request_serializer=images__pb2.LoadImageRequest.SerializeToString, response_deserializer=images__pb2.GeneralImageResponse.FromString, - ) + _registered_method=True) self.delete_image = channel.unary_unary( '/eulerlauncher.ImageGrpcService/delete_image', request_serializer=images__pb2.DeleteImageRequest.SerializeToString, response_deserializer=images__pb2.GeneralImageResponse.FromString, - ) + _registered_method=True) class ImageGrpcServiceServicer(object): @@ -90,6 +110,7 @@ def add_ImageGrpcServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'eulerlauncher.ImageGrpcService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('eulerlauncher.ImageGrpcService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -107,11 +128,21 @@ class ImageGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/eulerlauncher.ImageGrpcService/list_images', + return grpc.experimental.unary_unary( + request, + target, + '/eulerlauncher.ImageGrpcService/list_images', images__pb2.ListImageRequest.SerializeToString, images__pb2.ListImageResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def download_image(request, @@ -124,11 +155,21 @@ class ImageGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/eulerlauncher.ImageGrpcService/download_image', + return grpc.experimental.unary_unary( + request, + target, + '/eulerlauncher.ImageGrpcService/download_image', images__pb2.DownloadImageRequest.SerializeToString, images__pb2.GeneralImageResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def load_image(request, @@ -141,11 +182,21 @@ class ImageGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/eulerlauncher.ImageGrpcService/load_image', + return grpc.experimental.unary_unary( + request, + target, + '/eulerlauncher.ImageGrpcService/load_image', images__pb2.LoadImageRequest.SerializeToString, images__pb2.GeneralImageResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def delete_image(request, @@ -158,8 +209,18 @@ class ImageGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/eulerlauncher.ImageGrpcService/delete_image', + return grpc.experimental.unary_unary( + request, + target, + '/eulerlauncher.ImageGrpcService/delete_image', images__pb2.DeleteImageRequest.SerializeToString, images__pb2.GeneralImageResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2.py b/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2.py index 203a5bb..ebcd983 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: instances.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.28.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 28, + 1, + '', + 'instances.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -20,8 +30,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0finstances.prot _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'instances_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'\200\001\001' _globals['_INSTANCE']._serialized_start=45 _globals['_INSTANCE']._serialized_end=171 diff --git a/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2_grpc.py b/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2_grpc.py index 5a1ce47..e9dfdb2 100644 --- a/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2_grpc.py +++ b/eulerlauncher/grpcs/eulerlauncher_grpc/instances_pb2_grpc.py @@ -1,9 +1,29 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings import instances_pb2 as instances__pb2 +GRPC_GENERATED_VERSION = '1.68.1' +GRPC_VERSION = grpc.__version__ +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in instances_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + ) + class InstanceGrpcServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,57 +38,57 @@ class InstanceGrpcServiceStub(object): '/instances.InstanceGrpcService/list_instances', request_serializer=instances__pb2.ListInstancesRequest.SerializeToString, response_deserializer=instances__pb2.ListInstancesResponse.FromString, - ) + _registered_method=True) self.create_instance = channel.unary_unary( '/instances.InstanceGrpcService/create_instance', request_serializer=instances__pb2.CreateInstanceRequest.SerializeToString, response_deserializer=instances__pb2.CreateInstanceResponse.FromString, - ) + _registered_method=True) self.delete_instance = channel.unary_unary( '/instances.InstanceGrpcService/delete_instance', request_serializer=instances__pb2.DeleteInstanceRequest.SerializeToString, response_deserializer=instances__pb2.DeleteInstanceResponse.FromString, - ) + _registered_method=True) self.start_instance = channel.unary_unary( '/instances.InstanceGrpcService/start_instance', request_serializer=instances__pb2.StartInstanceRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.stop_instsance = channel.unary_unary( '/instances.InstanceGrpcService/stop_instsance', request_serializer=instances__pb2.StopInstanceRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.AttachDisk = channel.unary_unary( '/instances.InstanceGrpcService/AttachDisk', request_serializer=instances__pb2.AttachDiskRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.DetachDisk = channel.unary_unary( '/instances.InstanceGrpcService/DetachDisk', request_serializer=instances__pb2.DetachDiskRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.attach_disk = channel.unary_unary( '/instances.InstanceGrpcService/attach_disk', request_serializer=instances__pb2.AttachDiskRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.dettach_disk = channel.unary_unary( '/instances.InstanceGrpcService/dettach_disk', request_serializer=instances__pb2.DetachDiskRequest.SerializeToString, response_deserializer=instances__pb2.InstanceResponse.FromString, - ) + _registered_method=True) self.take_snapshot = channel.unary_unary( '/instances.InstanceGrpcService/take_snapshot', request_serializer=instances__pb2.TakeSnapshotRequest.SerializeToString, response_deserializer=instances__pb2.TakeSnapshotResponse.FromString, - ) + _registered_method=True) self.export_development_image = channel.unary_unary( '/instances.InstanceGrpcService/export_development_image', request_serializer=instances__pb2.ExportDevelopmentImageRequest.SerializeToString, response_deserializer=instances__pb2.ExportDevelopmentImageResponse.FromString, - ) + _registered_method=True) class InstanceGrpcServiceServicer(object): @@ -202,6 +222,7 @@ def add_InstanceGrpcServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'instances.InstanceGrpcService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('instances.InstanceGrpcService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -219,11 +240,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/list_instances', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/list_instances', instances__pb2.ListInstancesRequest.SerializeToString, instances__pb2.ListInstancesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def create_instance(request, @@ -236,11 +267,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/create_instance', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/create_instance', instances__pb2.CreateInstanceRequest.SerializeToString, instances__pb2.CreateInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def delete_instance(request, @@ -253,11 +294,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/delete_instance', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/delete_instance', instances__pb2.DeleteInstanceRequest.SerializeToString, instances__pb2.DeleteInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def start_instance(request, @@ -270,11 +321,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/start_instance', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/start_instance', instances__pb2.StartInstanceRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def stop_instsance(request, @@ -287,11 +348,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/stop_instsance', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/stop_instsance', instances__pb2.StopInstanceRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def AttachDisk(request, @@ -304,11 +375,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/AttachDisk', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/AttachDisk', instances__pb2.AttachDiskRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def DetachDisk(request, @@ -321,11 +402,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/DetachDisk', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/DetachDisk', instances__pb2.DetachDiskRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def attach_disk(request, @@ -338,11 +429,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/attach_disk', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/attach_disk', instances__pb2.AttachDiskRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def dettach_disk(request, @@ -355,11 +456,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/dettach_disk', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/dettach_disk', instances__pb2.DetachDiskRequest.SerializeToString, instances__pb2.InstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def take_snapshot(request, @@ -372,11 +483,21 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/take_snapshot', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/take_snapshot', instances__pb2.TakeSnapshotRequest.SerializeToString, instances__pb2.TakeSnapshotResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def export_development_image(request, @@ -389,8 +510,18 @@ class InstanceGrpcService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/instances.InstanceGrpcService/export_development_image', + return grpc.experimental.unary_unary( + request, + target, + '/instances.InstanceGrpcService/export_development_image', instances__pb2.ExportDevelopmentImageRequest.SerializeToString, instances__pb2.ExportDevelopmentImageResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) -- Gitee