diff --git a/.gitignore b/.gitignore index 73990b94..2d8bc944 100644 --- a/.gitignore +++ b/.gitignore @@ -24,3 +24,4 @@ tests/mock/client.properties /.vscode .coverage* coverage.xml +/src/dataclay/proto/ diff --git a/compile-protos.sh b/compile-protos.sh deleted file mode 100755 index 93c7c640..00000000 --- a/compile-protos.sh +++ /dev/null @@ -1,7 +0,0 @@ -python3 -m grpc_tools.protoc \ ---proto_path=dataclay-common \ ---python_out=src \ ---grpc_python_out=src \ -dataclay-common/dataclay/proto/common/* \ -dataclay-common/dataclay/proto/backend/* \ -dataclay-common/dataclay/proto/metadata/* diff --git a/compile_protos.py b/compile_protos.py new file mode 100755 index 00000000..4fa72081 --- /dev/null +++ b/compile_protos.py @@ -0,0 +1,41 @@ +#!/usr/bin/env python3 + +from importlib import resources +from typing import Any +import grpc_tools.protoc + +try: + from hatchling.builders.hooks.plugin.interface import BuildHookInterface +except ModuleNotFoundError: + if __name__ != "__main__": + # If we are not being run interactively, then that is an error + raise + BuildHookInterface = object + + +def run_protoc(): + grpc_tools_proto = (resources.files("grpc_tools") / "_proto").resolve() + grpc_tools.protoc.main( + [ + "grpc_tools.protoc", + "--proto_path=dataclay-common", + "--python_out=src", + "--grpc_python_out=src", + "dataclay-common/dataclay/proto/common/common.proto", + "dataclay-common/dataclay/proto/backend/backend.proto", + "dataclay-common/dataclay/proto/metadata/metadata.proto", + f"-I{grpc_tools_proto}", + ] + ) + + +class CustomBuildHook(BuildHookInterface): + def initialize(self, version: str, build_data: dict[str, Any]) -> None: + run_protoc() + + def dependencies(self): + return ["grpcio-tools==1.48.2"] + + +if __name__ == "__main__": + run_protoc() diff --git a/pyproject.toml b/pyproject.toml index 2475bb5a..1e66dc80 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [build-system] -requires = ["setuptools"] -build-backend = "setuptools.build_meta" +requires = ["hatchling"] +build-backend = "hatchling.build" [project] name = "dataclay" @@ -73,9 +73,6 @@ telemetry = [ [project.scripts] dataclayctl = "dataclay.control.ctl:run" -[tool.setuptools.dynamic] -version = {attr = "dataclay.__version__"} - [tool.isort] profile = "black" extend_skip = "src/dataclay/proto" @@ -106,3 +103,17 @@ filterwarnings = [ "error", "ignore::UserWarning", ] + +[tool.hatch.build.targets.wheel] +packages = ["src/dataclay", "src/storage"] +dependencies = ["grpcio-tools==1.48.2"] + +[tool.hatch.build.targets.sdist] +include = ["src/dataclay", "src/storage", "dataclay-common"] + +[tool.hatch.version] +path = "src/dataclay/__init__.py" + +[tool.hatch.build.hooks.custom] +path = "compile_protos.py" +dependencies = ["grpcio-tools==1.48.2"] \ No newline at end of file diff --git a/src/dataclay/proto/__init__.py b/src/dataclay/proto/__init__.py deleted file mode 100644 index e69de29b..00000000 diff --git a/src/dataclay/proto/backend/__init__.py b/src/dataclay/proto/backend/__init__.py deleted file mode 100644 index e69de29b..00000000 diff --git a/src/dataclay/proto/backend/backend_pb2.py b/src/dataclay/proto/backend/backend_pb2.py deleted file mode 100644 index 289edb8d..00000000 --- a/src/dataclay/proto/backend/backend_pb2.py +++ /dev/null @@ -1,72 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: dataclay/proto/backend/backend.proto -# Protobuf Python Version: 5.26.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 symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 -from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2 -from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n$dataclay/proto/backend/backend.proto\x12\x16\x64\x61taclay.proto.backend\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x19google/protobuf/any.proto\",\n\x15MakePersistentRequest\x12\x13\n\x0bpickled_obj\x18\x01 \x03(\x0c\"\x8d\x02\n\x17\x43\x61llActiveMethodRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x13\n\x0bmethod_name\x18\x02 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x03 \x01(\x0c\x12\x0e\n\x06kwargs\x18\x04 \x01(\x0c\x12^\n\x10\x65xec_constraints\x18\x05 \x03(\x0b\x32\x44.dataclay.proto.backend.CallActiveMethodRequest.ExecConstraintsEntry\x1aL\n\x14\x45xecConstraintsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12#\n\x05value\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any:\x02\x38\x01\"?\n\x18\x43\x61llActiveMethodResponse\x12\r\n\x05value\x18\x01 \x01(\x0c\x12\x14\n\x0cis_exception\x18\x02 \x01(\x08\"A\n\x19GetObjectAttributeRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x11\n\tattribute\x18\x02 \x01(\t\"A\n\x1aGetObjectAttributeResponse\x12\r\n\x05value\x18\x01 \x01(\x0c\x12\x14\n\x0cis_exception\x18\x02 \x01(\x08\"_\n\x19SetObjectAttributeRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x11\n\tattribute\x18\x02 \x01(\t\x12\x1c\n\x14serialized_attribute\x18\x03 \x01(\x0c\"A\n\x1aSetObjectAttributeResponse\x12\r\n\x05value\x18\x01 \x01(\x0c\x12\x14\n\x0cis_exception\x18\x02 \x01(\x08\"A\n\x19\x44\x65lObjectAttributeRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x11\n\tattribute\x18\x02 \x01(\t\"A\n\x1a\x44\x65lObjectAttributeResponse\x12\r\n\x05value\x18\x01 \x01(\x0c\x12\x14\n\x0cis_exception\x18\x02 \x01(\x08\"/\n\x1aGetObjectPropertiesRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\"Q\n\x1dUpdateObjectPropertiesRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x1d\n\x15serialized_properties\x18\x02 \x01(\x0c\"v\n\x12SendObjectsRequest\x12\x12\n\nobject_ids\x18\x01 \x03(\t\x12\x12\n\nbackend_id\x18\x02 \x01(\t\x12\x14\n\x0cmake_replica\x18\x03 \x01(\x08\x12\x11\n\trecursive\x18\x04 \x01(\x08\x12\x0f\n\x07remotes\x18\x05 \x01(\x08\"B\n\x16RegisterObjectsRequest\x12\x12\n\ndict_bytes\x18\x01 \x03(\x0c\x12\x14\n\x0cmake_replica\x18\x02 \x01(\x08\",\n\x17NewObjectVersionRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\"/\n\x18NewObjectVersionResponse\x12\x13\n\x0bobject_info\x18\x01 \x01(\t\"4\n\x1f\x43onsolidateObjectVersionRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\"@\n\x14ProxifyObjectRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x15\n\rnew_object_id\x18\x02 \x01(\t\"A\n\x15\x43hangeObjectIdRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x15\n\rnew_object_id\x18\x02 \x01(\t\"d\n\x17NewObjectReplicaRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\x12\x12\n\nbackend_id\x18\x02 \x01(\t\x12\x11\n\trecursive\x18\x03 \x01(\x08\x12\x0f\n\x07remotes\x18\x04 \x01(\x08\x32\x96\r\n\x0e\x42\x61\x63kendService\x12Y\n\x0eMakePersistent\x12-.dataclay.proto.backend.MakePersistentRequest\x1a\x16.google.protobuf.Empty\"\x00\x12w\n\x10\x43\x61llActiveMethod\x12/.dataclay.proto.backend.CallActiveMethodRequest\x1a\x30.dataclay.proto.backend.CallActiveMethodResponse\"\x00\x12}\n\x12GetObjectAttribute\x12\x31.dataclay.proto.backend.GetObjectAttributeRequest\x1a\x32.dataclay.proto.backend.GetObjectAttributeResponse\"\x00\x12}\n\x12SetObjectAttribute\x12\x31.dataclay.proto.backend.SetObjectAttributeRequest\x1a\x32.dataclay.proto.backend.SetObjectAttributeResponse\"\x00\x12}\n\x12\x44\x65lObjectAttribute\x12\x31.dataclay.proto.backend.DelObjectAttributeRequest\x1a\x32.dataclay.proto.backend.DelObjectAttributeResponse\"\x00\x12h\n\x13GetObjectProperties\x12\x32.dataclay.proto.backend.GetObjectPropertiesRequest\x1a\x1b.google.protobuf.BytesValue\"\x00\x12i\n\x16UpdateObjectProperties\x12\x35.dataclay.proto.backend.UpdateObjectPropertiesRequest\x1a\x16.google.protobuf.Empty\"\x00\x12S\n\x0bSendObjects\x12*.dataclay.proto.backend.SendObjectsRequest\x1a\x16.google.protobuf.Empty\"\x00\x12[\n\x0fRegisterObjects\x12..dataclay.proto.backend.RegisterObjectsRequest\x1a\x16.google.protobuf.Empty\"\x00\x12w\n\x10NewObjectVersion\x12/.dataclay.proto.backend.NewObjectVersionRequest\x1a\x30.dataclay.proto.backend.NewObjectVersionResponse\"\x00\x12m\n\x18\x43onsolidateObjectVersion\x12\x37.dataclay.proto.backend.ConsolidateObjectVersionRequest\x1a\x16.google.protobuf.Empty\"\x00\x12W\n\rProxifyObject\x12,.dataclay.proto.backend.ProxifyObjectRequest\x1a\x16.google.protobuf.Empty\"\x00\x12Y\n\x0e\x43hangeObjectId\x12-.dataclay.proto.backend.ChangeObjectIdRequest\x1a\x16.google.protobuf.Empty\"\x00\x12]\n\x10NewObjectReplica\x12/.dataclay.proto.backend.NewObjectReplicaRequest\x1a\x16.google.protobuf.Empty\"\x00\x12<\n\x08\x46lushAll\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00\x12\x38\n\x04Stop\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00\x12\x39\n\x05\x44rain\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00\x42!\n\x1d\x65s.bsc.dataclay.proto.backendP\x01\x62\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'dataclay.proto.backend.backend_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - _globals['DESCRIPTOR']._loaded_options = None - _globals['DESCRIPTOR']._serialized_options = b'\n\035es.bsc.dataclay.proto.backendP\001' - _globals['_CALLACTIVEMETHODREQUEST_EXECCONSTRAINTSENTRY']._loaded_options = None - _globals['_CALLACTIVEMETHODREQUEST_EXECCONSTRAINTSENTRY']._serialized_options = b'8\001' - _globals['_MAKEPERSISTENTREQUEST']._serialized_start=152 - _globals['_MAKEPERSISTENTREQUEST']._serialized_end=196 - _globals['_CALLACTIVEMETHODREQUEST']._serialized_start=199 - _globals['_CALLACTIVEMETHODREQUEST']._serialized_end=468 - _globals['_CALLACTIVEMETHODREQUEST_EXECCONSTRAINTSENTRY']._serialized_start=392 - _globals['_CALLACTIVEMETHODREQUEST_EXECCONSTRAINTSENTRY']._serialized_end=468 - _globals['_CALLACTIVEMETHODRESPONSE']._serialized_start=470 - _globals['_CALLACTIVEMETHODRESPONSE']._serialized_end=533 - _globals['_GETOBJECTATTRIBUTEREQUEST']._serialized_start=535 - _globals['_GETOBJECTATTRIBUTEREQUEST']._serialized_end=600 - _globals['_GETOBJECTATTRIBUTERESPONSE']._serialized_start=602 - _globals['_GETOBJECTATTRIBUTERESPONSE']._serialized_end=667 - _globals['_SETOBJECTATTRIBUTEREQUEST']._serialized_start=669 - _globals['_SETOBJECTATTRIBUTEREQUEST']._serialized_end=764 - _globals['_SETOBJECTATTRIBUTERESPONSE']._serialized_start=766 - _globals['_SETOBJECTATTRIBUTERESPONSE']._serialized_end=831 - _globals['_DELOBJECTATTRIBUTEREQUEST']._serialized_start=833 - _globals['_DELOBJECTATTRIBUTEREQUEST']._serialized_end=898 - _globals['_DELOBJECTATTRIBUTERESPONSE']._serialized_start=900 - _globals['_DELOBJECTATTRIBUTERESPONSE']._serialized_end=965 - _globals['_GETOBJECTPROPERTIESREQUEST']._serialized_start=967 - _globals['_GETOBJECTPROPERTIESREQUEST']._serialized_end=1014 - _globals['_UPDATEOBJECTPROPERTIESREQUEST']._serialized_start=1016 - _globals['_UPDATEOBJECTPROPERTIESREQUEST']._serialized_end=1097 - _globals['_SENDOBJECTSREQUEST']._serialized_start=1099 - _globals['_SENDOBJECTSREQUEST']._serialized_end=1217 - _globals['_REGISTEROBJECTSREQUEST']._serialized_start=1219 - _globals['_REGISTEROBJECTSREQUEST']._serialized_end=1285 - _globals['_NEWOBJECTVERSIONREQUEST']._serialized_start=1287 - _globals['_NEWOBJECTVERSIONREQUEST']._serialized_end=1331 - _globals['_NEWOBJECTVERSIONRESPONSE']._serialized_start=1333 - _globals['_NEWOBJECTVERSIONRESPONSE']._serialized_end=1380 - _globals['_CONSOLIDATEOBJECTVERSIONREQUEST']._serialized_start=1382 - _globals['_CONSOLIDATEOBJECTVERSIONREQUEST']._serialized_end=1434 - _globals['_PROXIFYOBJECTREQUEST']._serialized_start=1436 - _globals['_PROXIFYOBJECTREQUEST']._serialized_end=1500 - _globals['_CHANGEOBJECTIDREQUEST']._serialized_start=1502 - _globals['_CHANGEOBJECTIDREQUEST']._serialized_end=1567 - _globals['_NEWOBJECTREPLICAREQUEST']._serialized_start=1569 - _globals['_NEWOBJECTREPLICAREQUEST']._serialized_end=1669 - _globals['_BACKENDSERVICE']._serialized_start=1672 - _globals['_BACKENDSERVICE']._serialized_end=3358 -# @@protoc_insertion_point(module_scope) diff --git a/src/dataclay/proto/backend/backend_pb2_grpc.py b/src/dataclay/proto/backend/backend_pb2_grpc.py deleted file mode 100644 index 41ba796c..00000000 --- a/src/dataclay/proto/backend/backend_pb2_grpc.py +++ /dev/null @@ -1,792 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc -import warnings - -from dataclay.proto.backend import backend_pb2 as dataclay_dot_proto_dot_backend_dot_backend__pb2 -from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 -from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2 - -GRPC_GENERATED_VERSION = '1.64.1' -GRPC_VERSION = grpc.__version__ -EXPECTED_ERROR_RELEASE = '1.65.0' -SCHEDULED_RELEASE_DATE = 'June 25, 2024' -_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: - warnings.warn( - f'The grpc package installed is at version {GRPC_VERSION},' - + f' but the generated code in dataclay/proto/backend/backend_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}.' - + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' - + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', - RuntimeWarning - ) - - -class BackendServiceStub(object): - """Missing associated documentation comment in .proto file.""" - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.MakePersistent = channel.unary_unary( - '/dataclay.proto.backend.BackendService/MakePersistent', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.MakePersistentRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.CallActiveMethod = channel.unary_unary( - '/dataclay.proto.backend.BackendService/CallActiveMethod', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodResponse.FromString, - _registered_method=True) - self.GetObjectAttribute = channel.unary_unary( - '/dataclay.proto.backend.BackendService/GetObjectAttribute', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeResponse.FromString, - _registered_method=True) - self.SetObjectAttribute = channel.unary_unary( - '/dataclay.proto.backend.BackendService/SetObjectAttribute', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeResponse.FromString, - _registered_method=True) - self.DelObjectAttribute = channel.unary_unary( - '/dataclay.proto.backend.BackendService/DelObjectAttribute', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeResponse.FromString, - _registered_method=True) - self.GetObjectProperties = channel.unary_unary( - '/dataclay.proto.backend.BackendService/GetObjectProperties', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectPropertiesRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_wrappers__pb2.BytesValue.FromString, - _registered_method=True) - self.UpdateObjectProperties = channel.unary_unary( - '/dataclay.proto.backend.BackendService/UpdateObjectProperties', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.UpdateObjectPropertiesRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.SendObjects = channel.unary_unary( - '/dataclay.proto.backend.BackendService/SendObjects', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SendObjectsRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.RegisterObjects = channel.unary_unary( - '/dataclay.proto.backend.BackendService/RegisterObjects', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.RegisterObjectsRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.NewObjectVersion = channel.unary_unary( - '/dataclay.proto.backend.BackendService/NewObjectVersion', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionResponse.FromString, - _registered_method=True) - self.ConsolidateObjectVersion = channel.unary_unary( - '/dataclay.proto.backend.BackendService/ConsolidateObjectVersion', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ConsolidateObjectVersionRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.ProxifyObject = channel.unary_unary( - '/dataclay.proto.backend.BackendService/ProxifyObject', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ProxifyObjectRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.ChangeObjectId = channel.unary_unary( - '/dataclay.proto.backend.BackendService/ChangeObjectId', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ChangeObjectIdRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.NewObjectReplica = channel.unary_unary( - '/dataclay.proto.backend.BackendService/NewObjectReplica', - request_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectReplicaRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.FlushAll = channel.unary_unary( - '/dataclay.proto.backend.BackendService/FlushAll', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.Stop = channel.unary_unary( - '/dataclay.proto.backend.BackendService/Stop', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.Drain = channel.unary_unary( - '/dataclay.proto.backend.BackendService/Drain', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - - -class BackendServiceServicer(object): - """Missing associated documentation comment in .proto file.""" - - def MakePersistent(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def CallActiveMethod(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetObjectAttribute(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def SetObjectAttribute(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def DelObjectAttribute(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetObjectProperties(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def UpdateObjectProperties(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def SendObjects(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def RegisterObjects(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def NewObjectVersion(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def ConsolidateObjectVersion(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def ProxifyObject(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def ChangeObjectId(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def NewObjectReplica(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def FlushAll(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Stop(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Drain(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_BackendServiceServicer_to_server(servicer, server): - rpc_method_handlers = { - 'MakePersistent': grpc.unary_unary_rpc_method_handler( - servicer.MakePersistent, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.MakePersistentRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'CallActiveMethod': grpc.unary_unary_rpc_method_handler( - servicer.CallActiveMethod, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodRequest.FromString, - response_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodResponse.SerializeToString, - ), - 'GetObjectAttribute': grpc.unary_unary_rpc_method_handler( - servicer.GetObjectAttribute, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeRequest.FromString, - response_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeResponse.SerializeToString, - ), - 'SetObjectAttribute': grpc.unary_unary_rpc_method_handler( - servicer.SetObjectAttribute, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeRequest.FromString, - response_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeResponse.SerializeToString, - ), - 'DelObjectAttribute': grpc.unary_unary_rpc_method_handler( - servicer.DelObjectAttribute, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeRequest.FromString, - response_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeResponse.SerializeToString, - ), - 'GetObjectProperties': grpc.unary_unary_rpc_method_handler( - servicer.GetObjectProperties, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectPropertiesRequest.FromString, - response_serializer=google_dot_protobuf_dot_wrappers__pb2.BytesValue.SerializeToString, - ), - 'UpdateObjectProperties': grpc.unary_unary_rpc_method_handler( - servicer.UpdateObjectProperties, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.UpdateObjectPropertiesRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'SendObjects': grpc.unary_unary_rpc_method_handler( - servicer.SendObjects, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.SendObjectsRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'RegisterObjects': grpc.unary_unary_rpc_method_handler( - servicer.RegisterObjects, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.RegisterObjectsRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'NewObjectVersion': grpc.unary_unary_rpc_method_handler( - servicer.NewObjectVersion, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionRequest.FromString, - response_serializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionResponse.SerializeToString, - ), - 'ConsolidateObjectVersion': grpc.unary_unary_rpc_method_handler( - servicer.ConsolidateObjectVersion, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ConsolidateObjectVersionRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'ProxifyObject': grpc.unary_unary_rpc_method_handler( - servicer.ProxifyObject, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ProxifyObjectRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'ChangeObjectId': grpc.unary_unary_rpc_method_handler( - servicer.ChangeObjectId, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.ChangeObjectIdRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'NewObjectReplica': grpc.unary_unary_rpc_method_handler( - servicer.NewObjectReplica, - request_deserializer=dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectReplicaRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'FlushAll': grpc.unary_unary_rpc_method_handler( - servicer.FlushAll, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'Stop': grpc.unary_unary_rpc_method_handler( - servicer.Stop, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'Drain': grpc.unary_unary_rpc_method_handler( - servicer.Drain, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'dataclay.proto.backend.BackendService', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - server.add_registered_method_handlers('dataclay.proto.backend.BackendService', rpc_method_handlers) - - - # This class is part of an EXPERIMENTAL API. -class BackendService(object): - """Missing associated documentation comment in .proto file.""" - - @staticmethod - def MakePersistent(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/MakePersistent', - dataclay_dot_proto_dot_backend_dot_backend__pb2.MakePersistentRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def CallActiveMethod(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/CallActiveMethod', - dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodRequest.SerializeToString, - dataclay_dot_proto_dot_backend_dot_backend__pb2.CallActiveMethodResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetObjectAttribute(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/GetObjectAttribute', - dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeRequest.SerializeToString, - dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectAttributeResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def SetObjectAttribute(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/SetObjectAttribute', - dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeRequest.SerializeToString, - dataclay_dot_proto_dot_backend_dot_backend__pb2.SetObjectAttributeResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def DelObjectAttribute(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/DelObjectAttribute', - dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeRequest.SerializeToString, - dataclay_dot_proto_dot_backend_dot_backend__pb2.DelObjectAttributeResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetObjectProperties(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/GetObjectProperties', - dataclay_dot_proto_dot_backend_dot_backend__pb2.GetObjectPropertiesRequest.SerializeToString, - google_dot_protobuf_dot_wrappers__pb2.BytesValue.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def UpdateObjectProperties(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/UpdateObjectProperties', - dataclay_dot_proto_dot_backend_dot_backend__pb2.UpdateObjectPropertiesRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def SendObjects(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/SendObjects', - dataclay_dot_proto_dot_backend_dot_backend__pb2.SendObjectsRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def RegisterObjects(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/RegisterObjects', - dataclay_dot_proto_dot_backend_dot_backend__pb2.RegisterObjectsRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def NewObjectVersion(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/NewObjectVersion', - dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionRequest.SerializeToString, - dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectVersionResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def ConsolidateObjectVersion(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/ConsolidateObjectVersion', - dataclay_dot_proto_dot_backend_dot_backend__pb2.ConsolidateObjectVersionRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def ProxifyObject(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/ProxifyObject', - dataclay_dot_proto_dot_backend_dot_backend__pb2.ProxifyObjectRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def ChangeObjectId(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/ChangeObjectId', - dataclay_dot_proto_dot_backend_dot_backend__pb2.ChangeObjectIdRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def NewObjectReplica(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/NewObjectReplica', - dataclay_dot_proto_dot_backend_dot_backend__pb2.NewObjectReplicaRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def FlushAll(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/FlushAll', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def Stop(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/Stop', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def Drain(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.backend.BackendService/Drain', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) diff --git a/src/dataclay/proto/common/__init__.py b/src/dataclay/proto/common/__init__.py deleted file mode 100644 index e69de29b..00000000 diff --git a/src/dataclay/proto/common/common_pb2.py b/src/dataclay/proto/common/common_pb2.py deleted file mode 100644 index e51b3e51..00000000 --- a/src/dataclay/proto/common/common_pb2.py +++ /dev/null @@ -1,33 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: dataclay/proto/common/common.proto -# Protobuf Python Version: 5.26.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 symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"dataclay/proto/common/common.proto\x12\x15\x64\x61taclay.proto.common\"F\n\x07\x42\x61\x63kend\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0c\n\x04host\x18\x02 \x01(\t\x12\x0c\n\x04port\x18\x03 \x01(\x05\x12\x13\n\x0b\x64\x61taclay_id\x18\x04 \x01(\t\"\xcd\x01\n\x0eObjectMetadata\x12\n\n\x02id\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\x12\x12\n\nclass_name\x18\x03 \x01(\t\x12\x19\n\x11master_backend_id\x18\x04 \x01(\t\x12\x1b\n\x13replica_backend_ids\x18\x05 \x03(\t\x12\x14\n\x0cis_read_only\x18\x06 \x01(\x08\x12\x1a\n\x12original_object_id\x18\x07 \x01(\t\x12\x1b\n\x13versions_object_ids\x18\x08 \x03(\t\"C\n\x08\x44\x61taclay\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0c\n\x04host\x18\x02 \x01(\t\x12\x0c\n\x04port\x18\x03 \x01(\x05\x12\x0f\n\x07is_this\x18\x04 \x01(\x08\">\n\x05\x41lias\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\x12\x11\n\tobject_id\x18\x03 \x01(\tB \n\x1c\x65s.bsc.dataclay.proto.commonP\x01\x62\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'dataclay.proto.common.common_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - _globals['DESCRIPTOR']._loaded_options = None - _globals['DESCRIPTOR']._serialized_options = b'\n\034es.bsc.dataclay.proto.commonP\001' - _globals['_BACKEND']._serialized_start=61 - _globals['_BACKEND']._serialized_end=131 - _globals['_OBJECTMETADATA']._serialized_start=134 - _globals['_OBJECTMETADATA']._serialized_end=339 - _globals['_DATACLAY']._serialized_start=341 - _globals['_DATACLAY']._serialized_end=408 - _globals['_ALIAS']._serialized_start=410 - _globals['_ALIAS']._serialized_end=472 -# @@protoc_insertion_point(module_scope) diff --git a/src/dataclay/proto/common/common_pb2_grpc.py b/src/dataclay/proto/common/common_pb2_grpc.py deleted file mode 100644 index 08618285..00000000 --- a/src/dataclay/proto/common/common_pb2_grpc.py +++ /dev/null @@ -1,29 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc -import warnings - - -GRPC_GENERATED_VERSION = '1.64.1' -GRPC_VERSION = grpc.__version__ -EXPECTED_ERROR_RELEASE = '1.65.0' -SCHEDULED_RELEASE_DATE = 'June 25, 2024' -_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: - warnings.warn( - f'The grpc package installed is at version {GRPC_VERSION},' - + f' but the generated code in dataclay/proto/common/common_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}.' - + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' - + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', - RuntimeWarning - ) diff --git a/src/dataclay/proto/metadata/__init__.py b/src/dataclay/proto/metadata/__init__.py deleted file mode 100644 index e69de29b..00000000 diff --git a/src/dataclay/proto/metadata/metadata_pb2.py b/src/dataclay/proto/metadata/metadata_pb2.py deleted file mode 100644 index 368c060f..00000000 --- a/src/dataclay/proto/metadata/metadata_pb2.py +++ /dev/null @@ -1,69 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: dataclay/proto/metadata/metadata.proto -# Protobuf Python Version: 5.26.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 symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 -from dataclay.proto.common import common_pb2 as dataclay_dot_proto_dot_common_dot_common__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n&dataclay/proto/metadata/metadata.proto\x12\x17\x64\x61taclay.proto.metadata\x1a\x1bgoogle/protobuf/empty.proto\x1a\"dataclay/proto/common/common.proto\"7\n\x11NewAccountRequest\x12\x10\n\x08username\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"%\n\x11GetAccountRequest\x12\x10\n\x08username\x18\x01 \x01(\t\"\x14\n\x12GetAccountResponse\"H\n\x11NewDatasetRequest\x12\x10\n\x08username\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\x12\x0f\n\x07\x64\x61taset\x18\x03 \x01(\t\"<\n\x15GetAllBackendsRequest\x12\x14\n\x0c\x66rom_backend\x18\x01 \x01(\x08\x12\r\n\x05\x66orce\x18\x02 \x01(\x08\"\xba\x01\n\x16GetAllBackendsResponse\x12O\n\x08\x62\x61\x63kends\x18\x01 \x03(\x0b\x32=.dataclay.proto.metadata.GetAllBackendsResponse.BackendsEntry\x1aO\n\rBackendsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12-\n\x05value\x18\x02 \x01(\x0b\x32\x1e.dataclay.proto.common.Backend:\x02\x38\x01\")\n\x12GetDataclayRequest\x12\x13\n\x0b\x64\x61taclay_id\x18\x01 \x01(\t\"+\n\x16GetObjectMDByIdRequest\x12\x11\n\tobject_id\x18\x01 \x01(\t\"E\n\x19GetObjectMDByAliasRequest\x12\x12\n\nalias_name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\"\xbc\x01\n\x15GetAllObjectsResponse\x12L\n\x07objects\x18\x01 \x03(\x0b\x32;.dataclay.proto.metadata.GetAllObjectsResponse.ObjectsEntry\x1aU\n\x0cObjectsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x34\n\x05value\x18\x02 \x01(\x0b\x32%.dataclay.proto.common.ObjectMetadata:\x02\x38\x01\">\n\x12\x44\x65leteAliasRequest\x12\x12\n\nalias_name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\"=\n\x12GetAllAliasRequest\x12\x14\n\x0c\x64\x61taset_name\x18\x01 \x01(\t\x12\x11\n\tobject_id\x18\x02 \x01(\t\"\xaf\x01\n\x13GetAllAliasResponse\x12J\n\x07\x61liases\x18\x01 \x03(\x0b\x32\x39.dataclay.proto.metadata.GetAllAliasResponse.AliasesEntry\x1aL\n\x0c\x41liasesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12+\n\x05value\x18\x02 \x01(\x0b\x32\x1c.dataclay.proto.common.Alias:\x02\x38\x01\"N\n\x0fNewAliasRequest\x12\x12\n\nalias_name\x18\x01 \x01(\t\x12\x14\n\x0c\x64\x61taset_name\x18\x02 \x01(\t\x12\x11\n\tobject_id\x18\x03 \x01(\t2\xfd\x08\n\x0fMetadataService\x12R\n\nNewAccount\x12*.dataclay.proto.metadata.NewAccountRequest\x1a\x16.google.protobuf.Empty\"\x00\x12g\n\nGetAccount\x12*.dataclay.proto.metadata.GetAccountRequest\x1a+.dataclay.proto.metadata.GetAccountResponse\"\x00\x12R\n\nNewDataset\x12*.dataclay.proto.metadata.NewDatasetRequest\x1a\x16.google.protobuf.Empty\"\x00\x12s\n\x0eGetAllBackends\x12..dataclay.proto.metadata.GetAllBackendsRequest\x1a/.dataclay.proto.metadata.GetAllBackendsResponse\"\x00\x12]\n\x0bGetDataclay\x12+.dataclay.proto.metadata.GetDataclayRequest\x1a\x1f.dataclay.proto.common.Dataclay\"\x00\x12k\n\x0fGetObjectMDById\x12/.dataclay.proto.metadata.GetObjectMDByIdRequest\x1a%.dataclay.proto.common.ObjectMetadata\"\x00\x12q\n\x12GetObjectMDByAlias\x12\x32.dataclay.proto.metadata.GetObjectMDByAliasRequest\x1a%.dataclay.proto.common.ObjectMetadata\"\x00\x12Y\n\rGetAllObjects\x12\x16.google.protobuf.Empty\x1a..dataclay.proto.metadata.GetAllObjectsResponse\"\x00\x12T\n\x0b\x44\x65leteAlias\x12+.dataclay.proto.metadata.DeleteAliasRequest\x1a\x16.google.protobuf.Empty\"\x00\x12N\n\x08NewAlias\x12(.dataclay.proto.metadata.NewAliasRequest\x1a\x16.google.protobuf.Empty\"\x00\x12j\n\x0bGetAllAlias\x12+.dataclay.proto.metadata.GetAllAliasRequest\x1a,.dataclay.proto.metadata.GetAllAliasResponse\"\x00\x12\x38\n\x04Stop\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00\x42\"\n\x1e\x65s.bsc.dataclay.proto.metadataP\x01\x62\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'dataclay.proto.metadata.metadata_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - _globals['DESCRIPTOR']._loaded_options = None - _globals['DESCRIPTOR']._serialized_options = b'\n\036es.bsc.dataclay.proto.metadataP\001' - _globals['_GETALLBACKENDSRESPONSE_BACKENDSENTRY']._loaded_options = None - _globals['_GETALLBACKENDSRESPONSE_BACKENDSENTRY']._serialized_options = b'8\001' - _globals['_GETALLOBJECTSRESPONSE_OBJECTSENTRY']._loaded_options = None - _globals['_GETALLOBJECTSRESPONSE_OBJECTSENTRY']._serialized_options = b'8\001' - _globals['_GETALLALIASRESPONSE_ALIASESENTRY']._loaded_options = None - _globals['_GETALLALIASRESPONSE_ALIASESENTRY']._serialized_options = b'8\001' - _globals['_NEWACCOUNTREQUEST']._serialized_start=132 - _globals['_NEWACCOUNTREQUEST']._serialized_end=187 - _globals['_GETACCOUNTREQUEST']._serialized_start=189 - _globals['_GETACCOUNTREQUEST']._serialized_end=226 - _globals['_GETACCOUNTRESPONSE']._serialized_start=228 - _globals['_GETACCOUNTRESPONSE']._serialized_end=248 - _globals['_NEWDATASETREQUEST']._serialized_start=250 - _globals['_NEWDATASETREQUEST']._serialized_end=322 - _globals['_GETALLBACKENDSREQUEST']._serialized_start=324 - _globals['_GETALLBACKENDSREQUEST']._serialized_end=384 - _globals['_GETALLBACKENDSRESPONSE']._serialized_start=387 - _globals['_GETALLBACKENDSRESPONSE']._serialized_end=573 - _globals['_GETALLBACKENDSRESPONSE_BACKENDSENTRY']._serialized_start=494 - _globals['_GETALLBACKENDSRESPONSE_BACKENDSENTRY']._serialized_end=573 - _globals['_GETDATACLAYREQUEST']._serialized_start=575 - _globals['_GETDATACLAYREQUEST']._serialized_end=616 - _globals['_GETOBJECTMDBYIDREQUEST']._serialized_start=618 - _globals['_GETOBJECTMDBYIDREQUEST']._serialized_end=661 - _globals['_GETOBJECTMDBYALIASREQUEST']._serialized_start=663 - _globals['_GETOBJECTMDBYALIASREQUEST']._serialized_end=732 - _globals['_GETALLOBJECTSRESPONSE']._serialized_start=735 - _globals['_GETALLOBJECTSRESPONSE']._serialized_end=923 - _globals['_GETALLOBJECTSRESPONSE_OBJECTSENTRY']._serialized_start=838 - _globals['_GETALLOBJECTSRESPONSE_OBJECTSENTRY']._serialized_end=923 - _globals['_DELETEALIASREQUEST']._serialized_start=925 - _globals['_DELETEALIASREQUEST']._serialized_end=987 - _globals['_GETALLALIASREQUEST']._serialized_start=989 - _globals['_GETALLALIASREQUEST']._serialized_end=1050 - _globals['_GETALLALIASRESPONSE']._serialized_start=1053 - _globals['_GETALLALIASRESPONSE']._serialized_end=1228 - _globals['_GETALLALIASRESPONSE_ALIASESENTRY']._serialized_start=1152 - _globals['_GETALLALIASRESPONSE_ALIASESENTRY']._serialized_end=1228 - _globals['_NEWALIASREQUEST']._serialized_start=1230 - _globals['_NEWALIASREQUEST']._serialized_end=1308 - _globals['_METADATASERVICE']._serialized_start=1311 - _globals['_METADATASERVICE']._serialized_end=2460 -# @@protoc_insertion_point(module_scope) diff --git a/src/dataclay/proto/metadata/metadata_pb2_grpc.py b/src/dataclay/proto/metadata/metadata_pb2_grpc.py deleted file mode 100644 index 1d69f8d3..00000000 --- a/src/dataclay/proto/metadata/metadata_pb2_grpc.py +++ /dev/null @@ -1,583 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc -import warnings - -from dataclay.proto.common import common_pb2 as dataclay_dot_proto_dot_common_dot_common__pb2 -from dataclay.proto.metadata import metadata_pb2 as dataclay_dot_proto_dot_metadata_dot_metadata__pb2 -from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 - -GRPC_GENERATED_VERSION = '1.64.1' -GRPC_VERSION = grpc.__version__ -EXPECTED_ERROR_RELEASE = '1.65.0' -SCHEDULED_RELEASE_DATE = 'June 25, 2024' -_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: - warnings.warn( - f'The grpc package installed is at version {GRPC_VERSION},' - + f' but the generated code in dataclay/proto/metadata/metadata_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}.' - + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' - + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', - RuntimeWarning - ) - - -class MetadataServiceStub(object): - """Missing associated documentation comment in .proto file.""" - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.NewAccount = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/NewAccount', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAccountRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.GetAccount = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetAccount', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountResponse.FromString, - _registered_method=True) - self.NewDataset = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/NewDataset', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewDatasetRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.GetAllBackends = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetAllBackends', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsResponse.FromString, - _registered_method=True) - self.GetDataclay = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetDataclay', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetDataclayRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_common_dot_common__pb2.Dataclay.FromString, - _registered_method=True) - self.GetObjectMDById = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetObjectMDById', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByIdRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.FromString, - _registered_method=True) - self.GetObjectMDByAlias = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetObjectMDByAlias', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByAliasRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.FromString, - _registered_method=True) - self.GetAllObjects = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetAllObjects', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllObjectsResponse.FromString, - _registered_method=True) - self.DeleteAlias = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/DeleteAlias', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.DeleteAliasRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.NewAlias = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/NewAlias', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAliasRequest.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - self.GetAllAlias = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/GetAllAlias', - request_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasRequest.SerializeToString, - response_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasResponse.FromString, - _registered_method=True) - self.Stop = channel.unary_unary( - '/dataclay.proto.metadata.MetadataService/Stop', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) - - -class MetadataServiceServicer(object): - """Missing associated documentation comment in .proto file.""" - - def NewAccount(self, request, context): - """Account Manager - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetAccount(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def NewDataset(self, request, context): - """Dataset Manager - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetAllBackends(self, request, context): - """EE-SL information - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetDataclay(self, request, context): - """Federation - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetObjectMDById(self, request, context): - """Object Metadata - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetObjectMDByAlias(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetAllObjects(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def DeleteAlias(self, request, context): - """Alias - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def NewAlias(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetAllAlias(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Stop(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_MetadataServiceServicer_to_server(servicer, server): - rpc_method_handlers = { - 'NewAccount': grpc.unary_unary_rpc_method_handler( - servicer.NewAccount, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAccountRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'GetAccount': grpc.unary_unary_rpc_method_handler( - servicer.GetAccount, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountRequest.FromString, - response_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountResponse.SerializeToString, - ), - 'NewDataset': grpc.unary_unary_rpc_method_handler( - servicer.NewDataset, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewDatasetRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'GetAllBackends': grpc.unary_unary_rpc_method_handler( - servicer.GetAllBackends, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsRequest.FromString, - response_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsResponse.SerializeToString, - ), - 'GetDataclay': grpc.unary_unary_rpc_method_handler( - servicer.GetDataclay, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetDataclayRequest.FromString, - response_serializer=dataclay_dot_proto_dot_common_dot_common__pb2.Dataclay.SerializeToString, - ), - 'GetObjectMDById': grpc.unary_unary_rpc_method_handler( - servicer.GetObjectMDById, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByIdRequest.FromString, - response_serializer=dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.SerializeToString, - ), - 'GetObjectMDByAlias': grpc.unary_unary_rpc_method_handler( - servicer.GetObjectMDByAlias, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByAliasRequest.FromString, - response_serializer=dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.SerializeToString, - ), - 'GetAllObjects': grpc.unary_unary_rpc_method_handler( - servicer.GetAllObjects, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllObjectsResponse.SerializeToString, - ), - 'DeleteAlias': grpc.unary_unary_rpc_method_handler( - servicer.DeleteAlias, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.DeleteAliasRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'NewAlias': grpc.unary_unary_rpc_method_handler( - servicer.NewAlias, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAliasRequest.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'GetAllAlias': grpc.unary_unary_rpc_method_handler( - servicer.GetAllAlias, - request_deserializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasRequest.FromString, - response_serializer=dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasResponse.SerializeToString, - ), - 'Stop': grpc.unary_unary_rpc_method_handler( - servicer.Stop, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'dataclay.proto.metadata.MetadataService', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - server.add_registered_method_handlers('dataclay.proto.metadata.MetadataService', rpc_method_handlers) - - - # This class is part of an EXPERIMENTAL API. -class MetadataService(object): - """Missing associated documentation comment in .proto file.""" - - @staticmethod - def NewAccount(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/NewAccount', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAccountRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetAccount(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetAccount', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountRequest.SerializeToString, - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAccountResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def NewDataset(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/NewDataset', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewDatasetRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetAllBackends(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetAllBackends', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsRequest.SerializeToString, - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllBackendsResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetDataclay(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetDataclay', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetDataclayRequest.SerializeToString, - dataclay_dot_proto_dot_common_dot_common__pb2.Dataclay.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetObjectMDById(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetObjectMDById', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByIdRequest.SerializeToString, - dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetObjectMDByAlias(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetObjectMDByAlias', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetObjectMDByAliasRequest.SerializeToString, - dataclay_dot_proto_dot_common_dot_common__pb2.ObjectMetadata.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetAllObjects(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetAllObjects', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllObjectsResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def DeleteAlias(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/DeleteAlias', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.DeleteAliasRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def NewAlias(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/NewAlias', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.NewAliasRequest.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetAllAlias(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/GetAllAlias', - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasRequest.SerializeToString, - dataclay_dot_proto_dot_metadata_dot_metadata__pb2.GetAllAliasResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def Stop(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/dataclay.proto.metadata.MetadataService/Stop', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True)