diff --git a/immudb/grpc/schema_pb2.py b/immudb/grpc/schema_pb2.py index d1b69d2..150f55a 100644 --- a/immudb/grpc/schema_pb2.py +++ b/immudb/grpc/schema_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: schema.proto -# Protobuf Python Version: 5.26.1 +# Protobuf Python Version: 4.25.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -22,132 +22,132 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'schema_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - _globals['DESCRIPTOR']._loaded_options = None +if _descriptor._USE_C_DESCRIPTORS == False: + _globals['DESCRIPTOR']._options = None _globals['DESCRIPTOR']._serialized_options = b'Z+github.com/codenotary/immudb/pkg/api/schema' - _globals['_VERIFIABLESQLENTRY_COLNAMESBYIDENTRY']._loaded_options = None + _globals['_VERIFIABLESQLENTRY_COLNAMESBYIDENTRY']._options = None _globals['_VERIFIABLESQLENTRY_COLNAMESBYIDENTRY']._serialized_options = b'8\001' - _globals['_VERIFIABLESQLENTRY_COLIDSBYNAMEENTRY']._loaded_options = None + _globals['_VERIFIABLESQLENTRY_COLIDSBYNAMEENTRY']._options = None _globals['_VERIFIABLESQLENTRY_COLIDSBYNAMEENTRY']._serialized_options = b'8\001' - _globals['_VERIFIABLESQLENTRY_COLTYPESBYIDENTRY']._loaded_options = None + _globals['_VERIFIABLESQLENTRY_COLTYPESBYIDENTRY']._options = None _globals['_VERIFIABLESQLENTRY_COLTYPESBYIDENTRY']._serialized_options = b'8\001' - _globals['_VERIFIABLESQLENTRY_COLLENBYIDENTRY']._loaded_options = None + _globals['_VERIFIABLESQLENTRY_COLLENBYIDENTRY']._options = None _globals['_VERIFIABLESQLENTRY_COLLENBYIDENTRY']._serialized_options = b'8\001' - _globals['_CHUNK_METADATAENTRY']._loaded_options = None + _globals['_CHUNK_METADATAENTRY']._options = None _globals['_CHUNK_METADATAENTRY']._serialized_options = b'8\001' - _globals['_SQLQUERYREQUEST'].fields_by_name['reuseSnapshot']._loaded_options = None + _globals['_SQLQUERYREQUEST'].fields_by_name['reuseSnapshot']._options = None _globals['_SQLQUERYREQUEST'].fields_by_name['reuseSnapshot']._serialized_options = b'\030\001' - _globals['_COMMITTEDSQLTX_LASTINSERTEDPKSENTRY']._loaded_options = None + _globals['_COMMITTEDSQLTX_LASTINSERTEDPKSENTRY']._options = None _globals['_COMMITTEDSQLTX_LASTINSERTEDPKSENTRY']._serialized_options = b'8\001' - _globals['_COMMITTEDSQLTX_FIRSTINSERTEDPKSENTRY']._loaded_options = None + _globals['_COMMITTEDSQLTX_FIRSTINSERTEDPKSENTRY']._options = None _globals['_COMMITTEDSQLTX_FIRSTINSERTEDPKSENTRY']._serialized_options = b'8\001' - _globals['_IMMUSERVICE'].methods_by_name['ListUsers']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ListUsers']._options = None _globals['_IMMUSERVICE'].methods_by_name['ListUsers']._serialized_options = b'\202\323\344\223\002\014\022\n/user/list' - _globals['_IMMUSERVICE'].methods_by_name['CreateUser']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CreateUser']._options = None _globals['_IMMUSERVICE'].methods_by_name['CreateUser']._serialized_options = b'\202\323\344\223\002\n\"\005/user:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ChangePassword']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ChangePassword']._options = None _globals['_IMMUSERVICE'].methods_by_name['ChangePassword']._serialized_options = b'\202\323\344\223\002\032\"\025/user/password/change:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ChangePermission']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ChangePermission']._options = None _globals['_IMMUSERVICE'].methods_by_name['ChangePermission']._serialized_options = b'\202\323\344\223\002\033\"\026/user/changepermission:\001*' - _globals['_IMMUSERVICE'].methods_by_name['SetActiveUser']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['SetActiveUser']._options = None _globals['_IMMUSERVICE'].methods_by_name['SetActiveUser']._serialized_options = b'\202\323\344\223\002\030\"\023/user/setactiveUser:\001*' - _globals['_IMMUSERVICE'].methods_by_name['UpdateAuthConfig']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UpdateAuthConfig']._options = None _globals['_IMMUSERVICE'].methods_by_name['UpdateAuthConfig']._serialized_options = b'\210\002\001' - _globals['_IMMUSERVICE'].methods_by_name['UpdateMTLSConfig']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UpdateMTLSConfig']._options = None _globals['_IMMUSERVICE'].methods_by_name['UpdateMTLSConfig']._serialized_options = b'\210\002\001' - _globals['_IMMUSERVICE'].methods_by_name['Login']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Login']._options = None _globals['_IMMUSERVICE'].methods_by_name['Login']._serialized_options = b'\210\002\001\202\323\344\223\002\013\"\006/login:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Logout']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Logout']._options = None _globals['_IMMUSERVICE'].methods_by_name['Logout']._serialized_options = b'\210\002\001\202\323\344\223\002\014\"\007/logout:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Set']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Set']._options = None _globals['_IMMUSERVICE'].methods_by_name['Set']._serialized_options = b'\202\323\344\223\002\014\"\007/db/set:\001*' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableSet']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableSet']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableSet']._serialized_options = b'\202\323\344\223\002\027\"\022/db/verifiable/set:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Get']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Get']._options = None _globals['_IMMUSERVICE'].methods_by_name['Get']._serialized_options = b'\202\323\344\223\002\017\022\r/db/get/{key}' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableGet']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableGet']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableGet']._serialized_options = b'\202\323\344\223\002\027\"\022/db/verifiable/get:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Delete']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Delete']._options = None _globals['_IMMUSERVICE'].methods_by_name['Delete']._serialized_options = b'\202\323\344\223\002\022\"\r/db/deletekey:\001*' - _globals['_IMMUSERVICE'].methods_by_name['GetAll']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['GetAll']._options = None _globals['_IMMUSERVICE'].methods_by_name['GetAll']._serialized_options = b'\202\323\344\223\002\017\"\n/db/getall:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ExecAll']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ExecAll']._options = None _globals['_IMMUSERVICE'].methods_by_name['ExecAll']._serialized_options = b'\202\323\344\223\002\020\"\013/db/execall:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Scan']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Scan']._options = None _globals['_IMMUSERVICE'].methods_by_name['Scan']._serialized_options = b'\202\323\344\223\002\r\"\010/db/scan:\001*' - _globals['_IMMUSERVICE'].methods_by_name['Count']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Count']._options = None _globals['_IMMUSERVICE'].methods_by_name['Count']._serialized_options = b'\202\323\344\223\002\024\022\022/db/count/{prefix}' - _globals['_IMMUSERVICE'].methods_by_name['CountAll']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CountAll']._options = None _globals['_IMMUSERVICE'].methods_by_name['CountAll']._serialized_options = b'\202\323\344\223\002\016\022\014/db/countall' - _globals['_IMMUSERVICE'].methods_by_name['TxById']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['TxById']._options = None _globals['_IMMUSERVICE'].methods_by_name['TxById']._serialized_options = b'\202\323\344\223\002\r\022\013/db/tx/{tx}' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableTxById']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableTxById']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableTxById']._serialized_options = b'\202\323\344\223\002\030\022\026/db/verifiable/tx/{tx}' - _globals['_IMMUSERVICE'].methods_by_name['TxScan']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['TxScan']._options = None _globals['_IMMUSERVICE'].methods_by_name['TxScan']._serialized_options = b'\202\323\344\223\002\013\"\006/db/tx:\001*' - _globals['_IMMUSERVICE'].methods_by_name['History']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['History']._options = None _globals['_IMMUSERVICE'].methods_by_name['History']._serialized_options = b'\202\323\344\223\002\020\"\013/db/history:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ServerInfo']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ServerInfo']._options = None _globals['_IMMUSERVICE'].methods_by_name['ServerInfo']._serialized_options = b'\202\323\344\223\002\r\022\013/serverinfo' - _globals['_IMMUSERVICE'].methods_by_name['Health']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['Health']._options = None _globals['_IMMUSERVICE'].methods_by_name['Health']._serialized_options = b'\202\323\344\223\002\t\022\007/health' - _globals['_IMMUSERVICE'].methods_by_name['DatabaseHealth']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['DatabaseHealth']._options = None _globals['_IMMUSERVICE'].methods_by_name['DatabaseHealth']._serialized_options = b'\202\323\344\223\002\014\022\n/db/health' - _globals['_IMMUSERVICE'].methods_by_name['CurrentState']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CurrentState']._options = None _globals['_IMMUSERVICE'].methods_by_name['CurrentState']._serialized_options = b'\202\323\344\223\002\013\022\t/db/state' - _globals['_IMMUSERVICE'].methods_by_name['SetReference']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['SetReference']._options = None _globals['_IMMUSERVICE'].methods_by_name['SetReference']._serialized_options = b'\202\323\344\223\002\025\"\020/db/setreference:\001*' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableSetReference']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableSetReference']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableSetReference']._serialized_options = b'\202\323\344\223\002 \"\033/db/verifiable/setreference:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ZAdd']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ZAdd']._options = None _globals['_IMMUSERVICE'].methods_by_name['ZAdd']._serialized_options = b'\202\323\344\223\002\r\"\010/db/zadd:\001*' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableZAdd']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableZAdd']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableZAdd']._serialized_options = b'\202\323\344\223\002\030\"\023/db/verifiable/zadd:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ZScan']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ZScan']._options = None _globals['_IMMUSERVICE'].methods_by_name['ZScan']._serialized_options = b'\202\323\344\223\002\016\"\t/db/zscan:\001*' - _globals['_IMMUSERVICE'].methods_by_name['CreateDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CreateDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['CreateDatabase']._serialized_options = b'\210\002\001\202\323\344\223\002\017\"\n/db/create:\001*' - _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseWith']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseWith']._options = None _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseWith']._serialized_options = b'\210\002\001\202\323\344\223\002\023\"\016/db/createwith:\001*' - _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseV2']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseV2']._options = None _globals['_IMMUSERVICE'].methods_by_name['CreateDatabaseV2']._serialized_options = b'\202\323\344\223\002\022\"\r/db/create/v2:\001*' - _globals['_IMMUSERVICE'].methods_by_name['LoadDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['LoadDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['LoadDatabase']._serialized_options = b'\202\323\344\223\002\r\"\010/db/load:\001*' - _globals['_IMMUSERVICE'].methods_by_name['UnloadDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UnloadDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['UnloadDatabase']._serialized_options = b'\202\323\344\223\002\017\"\n/db/unload:\001*' - _globals['_IMMUSERVICE'].methods_by_name['DeleteDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['DeleteDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['DeleteDatabase']._serialized_options = b'\202\323\344\223\002\017\"\n/db/delete:\001*' - _globals['_IMMUSERVICE'].methods_by_name['DatabaseList']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['DatabaseList']._options = None _globals['_IMMUSERVICE'].methods_by_name['DatabaseList']._serialized_options = b'\210\002\001\202\323\344\223\002\r\"\010/db/list:\001*' - _globals['_IMMUSERVICE'].methods_by_name['DatabaseListV2']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['DatabaseListV2']._options = None _globals['_IMMUSERVICE'].methods_by_name['DatabaseListV2']._serialized_options = b'\202\323\344\223\002\020\"\013/db/list/v2:\001*' - _globals['_IMMUSERVICE'].methods_by_name['UseDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UseDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['UseDatabase']._serialized_options = b'\202\323\344\223\002\030\022\026/db/use/{databaseName}' - _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabase']._serialized_options = b'\210\002\001\202\323\344\223\002\017\"\n/db/update:\001*' - _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabaseV2']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabaseV2']._options = None _globals['_IMMUSERVICE'].methods_by_name['UpdateDatabaseV2']._serialized_options = b'\202\323\344\223\002\022\"\r/db/update/v2:\001*' - _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettings']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettings']._options = None _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettings']._serialized_options = b'\210\002\001\202\323\344\223\002\021\"\014/db/settings:\001*' - _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettingsV2']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettingsV2']._options = None _globals['_IMMUSERVICE'].methods_by_name['GetDatabaseSettingsV2']._serialized_options = b'\202\323\344\223\002\024\"\017/db/settings/v2:\001*' - _globals['_IMMUSERVICE'].methods_by_name['FlushIndex']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['FlushIndex']._options = None _globals['_IMMUSERVICE'].methods_by_name['FlushIndex']._serialized_options = b'\202\323\344\223\002\020\022\016/db/flushindex' - _globals['_IMMUSERVICE'].methods_by_name['CompactIndex']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['CompactIndex']._options = None _globals['_IMMUSERVICE'].methods_by_name['CompactIndex']._serialized_options = b'\202\323\344\223\002\022\022\020/db/compactindex' - _globals['_IMMUSERVICE'].methods_by_name['SQLExec']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['SQLExec']._options = None _globals['_IMMUSERVICE'].methods_by_name['SQLExec']._serialized_options = b'\202\323\344\223\002\020\"\013/db/sqlexec:\001*' - _globals['_IMMUSERVICE'].methods_by_name['UnarySQLQuery']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['UnarySQLQuery']._options = None _globals['_IMMUSERVICE'].methods_by_name['UnarySQLQuery']._serialized_options = b'\202\323\344\223\002\021\"\014/db/sqlquery:\001*' - _globals['_IMMUSERVICE'].methods_by_name['SQLQuery']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['SQLQuery']._options = None _globals['_IMMUSERVICE'].methods_by_name['SQLQuery']._serialized_options = b'\202\323\344\223\002\021\"\014/db/sqlquery:\001*' - _globals['_IMMUSERVICE'].methods_by_name['ListTables']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['ListTables']._options = None _globals['_IMMUSERVICE'].methods_by_name['ListTables']._serialized_options = b'\202\323\344\223\002\020\022\016/db/table/list' - _globals['_IMMUSERVICE'].methods_by_name['DescribeTable']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['DescribeTable']._options = None _globals['_IMMUSERVICE'].methods_by_name['DescribeTable']._serialized_options = b'\202\323\344\223\002\017\"\n/db/tables:\001*' - _globals['_IMMUSERVICE'].methods_by_name['VerifiableSQLGet']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['VerifiableSQLGet']._options = None _globals['_IMMUSERVICE'].methods_by_name['VerifiableSQLGet']._serialized_options = b'\202\323\344\223\002\032\"\025/db/verifiable/sqlget:\001*' - _globals['_IMMUSERVICE'].methods_by_name['TruncateDatabase']._loaded_options = None + _globals['_IMMUSERVICE'].methods_by_name['TruncateDatabase']._options = None _globals['_IMMUSERVICE'].methods_by_name['TruncateDatabase']._serialized_options = b'\202\323\344\223\002\021\"\014/db/truncate:\001*' _globals['_ENTRYTYPEACTION']._serialized_start=15343 _globals['_ENTRYTYPEACTION']._serialized_end=15418 diff --git a/immudb/grpc/schema_pb2_grpc.py b/immudb/grpc/schema_pb2_grpc.py index 336b964..11456b2 100644 --- a/immudb/grpc/schema_pb2_grpc.py +++ b/immudb/grpc/schema_pb2_grpc.py @@ -1,35 +1,10 @@ # 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 google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 from . import schema_pb2 as schema__pb2 -GRPC_GENERATED_VERSION = '1.63.0' -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 schema_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 ImmuServiceStub(object): """immudb gRPC & REST service @@ -45,367 +20,367 @@ def __init__(self, channel): '/immudb.schema.ImmuService/ListUsers', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.UserList.FromString, - _registered_method=True) + ) self.CreateUser = channel.unary_unary( '/immudb.schema.ImmuService/CreateUser', request_serializer=schema__pb2.CreateUserRequest.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.ChangePassword = channel.unary_unary( '/immudb.schema.ImmuService/ChangePassword', request_serializer=schema__pb2.ChangePasswordRequest.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.ChangePermission = channel.unary_unary( '/immudb.schema.ImmuService/ChangePermission', request_serializer=schema__pb2.ChangePermissionRequest.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.SetActiveUser = channel.unary_unary( '/immudb.schema.ImmuService/SetActiveUser', request_serializer=schema__pb2.SetActiveUserRequest.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.UpdateAuthConfig = channel.unary_unary( '/immudb.schema.ImmuService/UpdateAuthConfig', request_serializer=schema__pb2.AuthConfig.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.UpdateMTLSConfig = channel.unary_unary( '/immudb.schema.ImmuService/UpdateMTLSConfig', request_serializer=schema__pb2.MTLSConfig.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.OpenSession = channel.unary_unary( '/immudb.schema.ImmuService/OpenSession', request_serializer=schema__pb2.OpenSessionRequest.SerializeToString, response_deserializer=schema__pb2.OpenSessionResponse.FromString, - _registered_method=True) + ) self.CloseSession = channel.unary_unary( '/immudb.schema.ImmuService/CloseSession', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.KeepAlive = channel.unary_unary( '/immudb.schema.ImmuService/KeepAlive', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.NewTx = channel.unary_unary( '/immudb.schema.ImmuService/NewTx', request_serializer=schema__pb2.NewTxRequest.SerializeToString, response_deserializer=schema__pb2.NewTxResponse.FromString, - _registered_method=True) + ) self.Commit = channel.unary_unary( '/immudb.schema.ImmuService/Commit', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.CommittedSQLTx.FromString, - _registered_method=True) + ) self.Rollback = channel.unary_unary( '/immudb.schema.ImmuService/Rollback', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.TxSQLExec = channel.unary_unary( '/immudb.schema.ImmuService/TxSQLExec', request_serializer=schema__pb2.SQLExecRequest.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.TxSQLQuery = channel.unary_stream( '/immudb.schema.ImmuService/TxSQLQuery', request_serializer=schema__pb2.SQLQueryRequest.SerializeToString, response_deserializer=schema__pb2.SQLQueryResult.FromString, - _registered_method=True) + ) self.Login = channel.unary_unary( '/immudb.schema.ImmuService/Login', request_serializer=schema__pb2.LoginRequest.SerializeToString, response_deserializer=schema__pb2.LoginResponse.FromString, - _registered_method=True) + ) self.Logout = channel.unary_unary( '/immudb.schema.ImmuService/Logout', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.Set = channel.unary_unary( '/immudb.schema.ImmuService/Set', request_serializer=schema__pb2.SetRequest.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.VerifiableSet = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableSet', request_serializer=schema__pb2.VerifiableSetRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableTx.FromString, - _registered_method=True) + ) self.Get = channel.unary_unary( '/immudb.schema.ImmuService/Get', request_serializer=schema__pb2.KeyRequest.SerializeToString, response_deserializer=schema__pb2.Entry.FromString, - _registered_method=True) + ) self.VerifiableGet = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableGet', request_serializer=schema__pb2.VerifiableGetRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableEntry.FromString, - _registered_method=True) + ) self.Delete = channel.unary_unary( '/immudb.schema.ImmuService/Delete', request_serializer=schema__pb2.DeleteKeysRequest.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.GetAll = channel.unary_unary( '/immudb.schema.ImmuService/GetAll', request_serializer=schema__pb2.KeyListRequest.SerializeToString, response_deserializer=schema__pb2.Entries.FromString, - _registered_method=True) + ) self.ExecAll = channel.unary_unary( '/immudb.schema.ImmuService/ExecAll', request_serializer=schema__pb2.ExecAllRequest.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.Scan = channel.unary_unary( '/immudb.schema.ImmuService/Scan', request_serializer=schema__pb2.ScanRequest.SerializeToString, response_deserializer=schema__pb2.Entries.FromString, - _registered_method=True) + ) self.Count = channel.unary_unary( '/immudb.schema.ImmuService/Count', request_serializer=schema__pb2.KeyPrefix.SerializeToString, response_deserializer=schema__pb2.EntryCount.FromString, - _registered_method=True) + ) self.CountAll = channel.unary_unary( '/immudb.schema.ImmuService/CountAll', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.EntryCount.FromString, - _registered_method=True) + ) self.TxById = channel.unary_unary( '/immudb.schema.ImmuService/TxById', request_serializer=schema__pb2.TxRequest.SerializeToString, response_deserializer=schema__pb2.Tx.FromString, - _registered_method=True) + ) self.VerifiableTxById = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableTxById', request_serializer=schema__pb2.VerifiableTxRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableTx.FromString, - _registered_method=True) + ) self.TxScan = channel.unary_unary( '/immudb.schema.ImmuService/TxScan', request_serializer=schema__pb2.TxScanRequest.SerializeToString, response_deserializer=schema__pb2.TxList.FromString, - _registered_method=True) + ) self.History = channel.unary_unary( '/immudb.schema.ImmuService/History', request_serializer=schema__pb2.HistoryRequest.SerializeToString, response_deserializer=schema__pb2.Entries.FromString, - _registered_method=True) + ) self.ServerInfo = channel.unary_unary( '/immudb.schema.ImmuService/ServerInfo', request_serializer=schema__pb2.ServerInfoRequest.SerializeToString, response_deserializer=schema__pb2.ServerInfoResponse.FromString, - _registered_method=True) + ) self.Health = channel.unary_unary( '/immudb.schema.ImmuService/Health', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.HealthResponse.FromString, - _registered_method=True) + ) self.DatabaseHealth = channel.unary_unary( '/immudb.schema.ImmuService/DatabaseHealth', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.DatabaseHealthResponse.FromString, - _registered_method=True) + ) self.CurrentState = channel.unary_unary( '/immudb.schema.ImmuService/CurrentState', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.ImmutableState.FromString, - _registered_method=True) + ) self.SetReference = channel.unary_unary( '/immudb.schema.ImmuService/SetReference', request_serializer=schema__pb2.ReferenceRequest.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.VerifiableSetReference = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableSetReference', request_serializer=schema__pb2.VerifiableReferenceRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableTx.FromString, - _registered_method=True) + ) self.ZAdd = channel.unary_unary( '/immudb.schema.ImmuService/ZAdd', request_serializer=schema__pb2.ZAddRequest.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.VerifiableZAdd = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableZAdd', request_serializer=schema__pb2.VerifiableZAddRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableTx.FromString, - _registered_method=True) + ) self.ZScan = channel.unary_unary( '/immudb.schema.ImmuService/ZScan', request_serializer=schema__pb2.ZScanRequest.SerializeToString, response_deserializer=schema__pb2.ZEntries.FromString, - _registered_method=True) + ) self.CreateDatabase = channel.unary_unary( '/immudb.schema.ImmuService/CreateDatabase', request_serializer=schema__pb2.Database.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.CreateDatabaseWith = channel.unary_unary( '/immudb.schema.ImmuService/CreateDatabaseWith', request_serializer=schema__pb2.DatabaseSettings.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.CreateDatabaseV2 = channel.unary_unary( '/immudb.schema.ImmuService/CreateDatabaseV2', request_serializer=schema__pb2.CreateDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.CreateDatabaseResponse.FromString, - _registered_method=True) + ) self.LoadDatabase = channel.unary_unary( '/immudb.schema.ImmuService/LoadDatabase', request_serializer=schema__pb2.LoadDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.LoadDatabaseResponse.FromString, - _registered_method=True) + ) self.UnloadDatabase = channel.unary_unary( '/immudb.schema.ImmuService/UnloadDatabase', request_serializer=schema__pb2.UnloadDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.UnloadDatabaseResponse.FromString, - _registered_method=True) + ) self.DeleteDatabase = channel.unary_unary( '/immudb.schema.ImmuService/DeleteDatabase', request_serializer=schema__pb2.DeleteDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.DeleteDatabaseResponse.FromString, - _registered_method=True) + ) self.DatabaseList = channel.unary_unary( '/immudb.schema.ImmuService/DatabaseList', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.DatabaseListResponse.FromString, - _registered_method=True) + ) self.DatabaseListV2 = channel.unary_unary( '/immudb.schema.ImmuService/DatabaseListV2', request_serializer=schema__pb2.DatabaseListRequestV2.SerializeToString, response_deserializer=schema__pb2.DatabaseListResponseV2.FromString, - _registered_method=True) + ) self.UseDatabase = channel.unary_unary( '/immudb.schema.ImmuService/UseDatabase', request_serializer=schema__pb2.Database.SerializeToString, response_deserializer=schema__pb2.UseDatabaseReply.FromString, - _registered_method=True) + ) self.UpdateDatabase = channel.unary_unary( '/immudb.schema.ImmuService/UpdateDatabase', request_serializer=schema__pb2.DatabaseSettings.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.UpdateDatabaseV2 = channel.unary_unary( '/immudb.schema.ImmuService/UpdateDatabaseV2', request_serializer=schema__pb2.UpdateDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.UpdateDatabaseResponse.FromString, - _registered_method=True) + ) self.GetDatabaseSettings = channel.unary_unary( '/immudb.schema.ImmuService/GetDatabaseSettings', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.DatabaseSettings.FromString, - _registered_method=True) + ) self.GetDatabaseSettingsV2 = channel.unary_unary( '/immudb.schema.ImmuService/GetDatabaseSettingsV2', request_serializer=schema__pb2.DatabaseSettingsRequest.SerializeToString, response_deserializer=schema__pb2.DatabaseSettingsResponse.FromString, - _registered_method=True) + ) self.FlushIndex = channel.unary_unary( '/immudb.schema.ImmuService/FlushIndex', request_serializer=schema__pb2.FlushIndexRequest.SerializeToString, response_deserializer=schema__pb2.FlushIndexResponse.FromString, - _registered_method=True) + ) self.CompactIndex = channel.unary_unary( '/immudb.schema.ImmuService/CompactIndex', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.streamGet = channel.unary_stream( '/immudb.schema.ImmuService/streamGet', request_serializer=schema__pb2.KeyRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.streamSet = channel.stream_unary( '/immudb.schema.ImmuService/streamSet', request_serializer=schema__pb2.Chunk.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.streamVerifiableGet = channel.unary_stream( '/immudb.schema.ImmuService/streamVerifiableGet', request_serializer=schema__pb2.VerifiableGetRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.streamVerifiableSet = channel.stream_unary( '/immudb.schema.ImmuService/streamVerifiableSet', request_serializer=schema__pb2.Chunk.SerializeToString, response_deserializer=schema__pb2.VerifiableTx.FromString, - _registered_method=True) + ) self.streamScan = channel.unary_stream( '/immudb.schema.ImmuService/streamScan', request_serializer=schema__pb2.ScanRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.streamZScan = channel.unary_stream( '/immudb.schema.ImmuService/streamZScan', request_serializer=schema__pb2.ZScanRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.streamHistory = channel.unary_stream( '/immudb.schema.ImmuService/streamHistory', request_serializer=schema__pb2.HistoryRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.streamExecAll = channel.stream_unary( '/immudb.schema.ImmuService/streamExecAll', request_serializer=schema__pb2.Chunk.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.exportTx = channel.unary_stream( '/immudb.schema.ImmuService/exportTx', request_serializer=schema__pb2.ExportTxRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.replicateTx = channel.stream_unary( '/immudb.schema.ImmuService/replicateTx', request_serializer=schema__pb2.Chunk.SerializeToString, response_deserializer=schema__pb2.TxHeader.FromString, - _registered_method=True) + ) self.streamExportTx = channel.stream_stream( '/immudb.schema.ImmuService/streamExportTx', request_serializer=schema__pb2.ExportTxRequest.SerializeToString, response_deserializer=schema__pb2.Chunk.FromString, - _registered_method=True) + ) self.SQLExec = channel.unary_unary( '/immudb.schema.ImmuService/SQLExec', request_serializer=schema__pb2.SQLExecRequest.SerializeToString, response_deserializer=schema__pb2.SQLExecResult.FromString, - _registered_method=True) + ) self.UnarySQLQuery = channel.unary_unary( '/immudb.schema.ImmuService/UnarySQLQuery', request_serializer=schema__pb2.SQLQueryRequest.SerializeToString, response_deserializer=schema__pb2.SQLQueryResult.FromString, - _registered_method=True) + ) self.SQLQuery = channel.unary_stream( '/immudb.schema.ImmuService/SQLQuery', request_serializer=schema__pb2.SQLQueryRequest.SerializeToString, response_deserializer=schema__pb2.SQLQueryResult.FromString, - _registered_method=True) + ) self.ListTables = channel.unary_unary( '/immudb.schema.ImmuService/ListTables', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=schema__pb2.SQLQueryResult.FromString, - _registered_method=True) + ) self.DescribeTable = channel.unary_unary( '/immudb.schema.ImmuService/DescribeTable', request_serializer=schema__pb2.Table.SerializeToString, response_deserializer=schema__pb2.SQLQueryResult.FromString, - _registered_method=True) + ) self.VerifiableSQLGet = channel.unary_unary( '/immudb.schema.ImmuService/VerifiableSQLGet', request_serializer=schema__pb2.VerifiableSQLGetRequest.SerializeToString, response_deserializer=schema__pb2.VerifiableSQLEntry.FromString, - _registered_method=True) + ) self.TruncateDatabase = channel.unary_unary( '/immudb.schema.ImmuService/TruncateDatabase', request_serializer=schema__pb2.TruncateDatabaseRequest.SerializeToString, response_deserializer=schema__pb2.TruncateDatabaseResponse.FromString, - _registered_method=True) + ) class ImmuServiceServicer(object): @@ -1253,21 +1228,11 @@ def ListUsers(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ListUsers', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ListUsers', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.UserList.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateUser(request, @@ -1280,21 +1245,11 @@ def CreateUser(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CreateUser', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CreateUser', schema__pb2.CreateUserRequest.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ChangePassword(request, @@ -1307,21 +1262,11 @@ def ChangePassword(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ChangePassword', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ChangePassword', schema__pb2.ChangePasswordRequest.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ChangePermission(request, @@ -1334,21 +1279,11 @@ def ChangePermission(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ChangePermission', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ChangePermission', schema__pb2.ChangePermissionRequest.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SetActiveUser(request, @@ -1361,21 +1296,11 @@ def SetActiveUser(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/SetActiveUser', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/SetActiveUser', schema__pb2.SetActiveUserRequest.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UpdateAuthConfig(request, @@ -1388,21 +1313,11 @@ def UpdateAuthConfig(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UpdateAuthConfig', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UpdateAuthConfig', schema__pb2.AuthConfig.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UpdateMTLSConfig(request, @@ -1415,21 +1330,11 @@ def UpdateMTLSConfig(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UpdateMTLSConfig', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UpdateMTLSConfig', schema__pb2.MTLSConfig.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def OpenSession(request, @@ -1442,21 +1347,11 @@ def OpenSession(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/OpenSession', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/OpenSession', schema__pb2.OpenSessionRequest.SerializeToString, schema__pb2.OpenSessionResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CloseSession(request, @@ -1469,21 +1364,11 @@ def CloseSession(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CloseSession', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CloseSession', 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) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def KeepAlive(request, @@ -1496,21 +1381,11 @@ def KeepAlive(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/KeepAlive', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/KeepAlive', 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) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def NewTx(request, @@ -1523,21 +1398,11 @@ def NewTx(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/NewTx', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/NewTx', schema__pb2.NewTxRequest.SerializeToString, schema__pb2.NewTxResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Commit(request, @@ -1550,21 +1415,11 @@ def Commit(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Commit', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Commit', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.CommittedSQLTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Rollback(request, @@ -1577,21 +1432,11 @@ def Rollback(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Rollback', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Rollback', 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) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TxSQLExec(request, @@ -1604,21 +1449,11 @@ def TxSQLExec(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/TxSQLExec', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/TxSQLExec', schema__pb2.SQLExecRequest.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TxSQLQuery(request, @@ -1631,21 +1466,11 @@ def TxSQLQuery(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/TxSQLQuery', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/TxSQLQuery', schema__pb2.SQLQueryRequest.SerializeToString, schema__pb2.SQLQueryResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Login(request, @@ -1658,21 +1483,11 @@ def Login(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Login', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Login', schema__pb2.LoginRequest.SerializeToString, schema__pb2.LoginResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Logout(request, @@ -1685,21 +1500,11 @@ def Logout(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Logout', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Logout', 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) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Set(request, @@ -1712,21 +1517,11 @@ def Set(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Set', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Set', schema__pb2.SetRequest.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableSet(request, @@ -1739,21 +1534,11 @@ def VerifiableSet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableSet', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableSet', schema__pb2.VerifiableSetRequest.SerializeToString, schema__pb2.VerifiableTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Get(request, @@ -1766,21 +1551,11 @@ def Get(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Get', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Get', schema__pb2.KeyRequest.SerializeToString, schema__pb2.Entry.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableGet(request, @@ -1793,21 +1568,11 @@ def VerifiableGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableGet', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableGet', schema__pb2.VerifiableGetRequest.SerializeToString, schema__pb2.VerifiableEntry.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Delete(request, @@ -1820,21 +1585,11 @@ def Delete(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Delete', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Delete', schema__pb2.DeleteKeysRequest.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetAll(request, @@ -1847,21 +1602,11 @@ def GetAll(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/GetAll', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/GetAll', schema__pb2.KeyListRequest.SerializeToString, schema__pb2.Entries.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ExecAll(request, @@ -1874,21 +1619,11 @@ def ExecAll(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ExecAll', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ExecAll', schema__pb2.ExecAllRequest.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Scan(request, @@ -1901,21 +1636,11 @@ def Scan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Scan', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Scan', schema__pb2.ScanRequest.SerializeToString, schema__pb2.Entries.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Count(request, @@ -1928,21 +1653,11 @@ def Count(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Count', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Count', schema__pb2.KeyPrefix.SerializeToString, schema__pb2.EntryCount.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CountAll(request, @@ -1955,21 +1670,11 @@ def CountAll(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CountAll', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CountAll', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.EntryCount.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TxById(request, @@ -1982,21 +1687,11 @@ def TxById(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/TxById', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/TxById', schema__pb2.TxRequest.SerializeToString, schema__pb2.Tx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableTxById(request, @@ -2009,21 +1704,11 @@ def VerifiableTxById(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableTxById', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableTxById', schema__pb2.VerifiableTxRequest.SerializeToString, schema__pb2.VerifiableTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TxScan(request, @@ -2036,21 +1721,11 @@ def TxScan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/TxScan', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/TxScan', schema__pb2.TxScanRequest.SerializeToString, schema__pb2.TxList.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def History(request, @@ -2063,21 +1738,11 @@ def History(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/History', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/History', schema__pb2.HistoryRequest.SerializeToString, schema__pb2.Entries.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ServerInfo(request, @@ -2090,21 +1755,11 @@ def ServerInfo(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ServerInfo', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ServerInfo', schema__pb2.ServerInfoRequest.SerializeToString, schema__pb2.ServerInfoResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def Health(request, @@ -2117,21 +1772,11 @@ def Health(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/Health', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/Health', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.HealthResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DatabaseHealth(request, @@ -2144,21 +1789,11 @@ def DatabaseHealth(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/DatabaseHealth', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/DatabaseHealth', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.DatabaseHealthResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CurrentState(request, @@ -2171,21 +1806,11 @@ def CurrentState(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CurrentState', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CurrentState', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.ImmutableState.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SetReference(request, @@ -2198,21 +1823,11 @@ def SetReference(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/SetReference', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/SetReference', schema__pb2.ReferenceRequest.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableSetReference(request, @@ -2225,21 +1840,11 @@ def VerifiableSetReference(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableSetReference', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableSetReference', schema__pb2.VerifiableReferenceRequest.SerializeToString, schema__pb2.VerifiableTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ZAdd(request, @@ -2252,21 +1857,11 @@ def ZAdd(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ZAdd', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ZAdd', schema__pb2.ZAddRequest.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableZAdd(request, @@ -2279,21 +1874,11 @@ def VerifiableZAdd(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableZAdd', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableZAdd', schema__pb2.VerifiableZAddRequest.SerializeToString, schema__pb2.VerifiableTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ZScan(request, @@ -2306,21 +1891,11 @@ def ZScan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ZScan', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ZScan', schema__pb2.ZScanRequest.SerializeToString, schema__pb2.ZEntries.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateDatabase(request, @@ -2333,21 +1908,11 @@ def CreateDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CreateDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CreateDatabase', schema__pb2.Database.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateDatabaseWith(request, @@ -2360,21 +1925,11 @@ def CreateDatabaseWith(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CreateDatabaseWith', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CreateDatabaseWith', schema__pb2.DatabaseSettings.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateDatabaseV2(request, @@ -2387,21 +1942,11 @@ def CreateDatabaseV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CreateDatabaseV2', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CreateDatabaseV2', schema__pb2.CreateDatabaseRequest.SerializeToString, schema__pb2.CreateDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def LoadDatabase(request, @@ -2414,21 +1959,11 @@ def LoadDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/LoadDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/LoadDatabase', schema__pb2.LoadDatabaseRequest.SerializeToString, schema__pb2.LoadDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UnloadDatabase(request, @@ -2441,21 +1976,11 @@ def UnloadDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UnloadDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UnloadDatabase', schema__pb2.UnloadDatabaseRequest.SerializeToString, schema__pb2.UnloadDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DeleteDatabase(request, @@ -2468,21 +1993,11 @@ def DeleteDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/DeleteDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/DeleteDatabase', schema__pb2.DeleteDatabaseRequest.SerializeToString, schema__pb2.DeleteDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DatabaseList(request, @@ -2495,21 +2010,11 @@ def DatabaseList(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/DatabaseList', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/DatabaseList', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.DatabaseListResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DatabaseListV2(request, @@ -2522,21 +2027,11 @@ def DatabaseListV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/DatabaseListV2', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/DatabaseListV2', schema__pb2.DatabaseListRequestV2.SerializeToString, schema__pb2.DatabaseListResponseV2.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UseDatabase(request, @@ -2549,21 +2044,11 @@ def UseDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UseDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UseDatabase', schema__pb2.Database.SerializeToString, schema__pb2.UseDatabaseReply.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UpdateDatabase(request, @@ -2576,21 +2061,11 @@ def UpdateDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UpdateDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UpdateDatabase', schema__pb2.DatabaseSettings.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UpdateDatabaseV2(request, @@ -2603,21 +2078,11 @@ def UpdateDatabaseV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UpdateDatabaseV2', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UpdateDatabaseV2', schema__pb2.UpdateDatabaseRequest.SerializeToString, schema__pb2.UpdateDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetDatabaseSettings(request, @@ -2630,21 +2095,11 @@ def GetDatabaseSettings(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/GetDatabaseSettings', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/GetDatabaseSettings', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.DatabaseSettings.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetDatabaseSettingsV2(request, @@ -2657,21 +2112,11 @@ def GetDatabaseSettingsV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/GetDatabaseSettingsV2', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/GetDatabaseSettingsV2', schema__pb2.DatabaseSettingsRequest.SerializeToString, schema__pb2.DatabaseSettingsResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def FlushIndex(request, @@ -2684,21 +2129,11 @@ def FlushIndex(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/FlushIndex', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/FlushIndex', schema__pb2.FlushIndexRequest.SerializeToString, schema__pb2.FlushIndexResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompactIndex(request, @@ -2711,21 +2146,11 @@ def CompactIndex(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/CompactIndex', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/CompactIndex', 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) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamGet(request, @@ -2738,21 +2163,11 @@ def streamGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/streamGet', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/streamGet', schema__pb2.KeyRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamSet(request_iterator, @@ -2765,21 +2180,11 @@ def streamSet(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary( - request_iterator, - target, - '/immudb.schema.ImmuService/streamSet', + return grpc.experimental.stream_unary(request_iterator, target, '/immudb.schema.ImmuService/streamSet', schema__pb2.Chunk.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamVerifiableGet(request, @@ -2792,21 +2197,11 @@ def streamVerifiableGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/streamVerifiableGet', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/streamVerifiableGet', schema__pb2.VerifiableGetRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamVerifiableSet(request_iterator, @@ -2819,21 +2214,11 @@ def streamVerifiableSet(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary( - request_iterator, - target, - '/immudb.schema.ImmuService/streamVerifiableSet', + return grpc.experimental.stream_unary(request_iterator, target, '/immudb.schema.ImmuService/streamVerifiableSet', schema__pb2.Chunk.SerializeToString, schema__pb2.VerifiableTx.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamScan(request, @@ -2846,21 +2231,11 @@ def streamScan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/streamScan', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/streamScan', schema__pb2.ScanRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamZScan(request, @@ -2873,21 +2248,11 @@ def streamZScan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/streamZScan', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/streamZScan', schema__pb2.ZScanRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamHistory(request, @@ -2900,21 +2265,11 @@ def streamHistory(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/streamHistory', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/streamHistory', schema__pb2.HistoryRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamExecAll(request_iterator, @@ -2927,21 +2282,11 @@ def streamExecAll(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary( - request_iterator, - target, - '/immudb.schema.ImmuService/streamExecAll', + return grpc.experimental.stream_unary(request_iterator, target, '/immudb.schema.ImmuService/streamExecAll', schema__pb2.Chunk.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def exportTx(request, @@ -2954,21 +2299,11 @@ def exportTx(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/exportTx', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/exportTx', schema__pb2.ExportTxRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def replicateTx(request_iterator, @@ -2981,21 +2316,11 @@ def replicateTx(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary( - request_iterator, - target, - '/immudb.schema.ImmuService/replicateTx', + return grpc.experimental.stream_unary(request_iterator, target, '/immudb.schema.ImmuService/replicateTx', schema__pb2.Chunk.SerializeToString, schema__pb2.TxHeader.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def streamExportTx(request_iterator, @@ -3008,21 +2333,11 @@ def streamExportTx(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_stream( - request_iterator, - target, - '/immudb.schema.ImmuService/streamExportTx', + return grpc.experimental.stream_stream(request_iterator, target, '/immudb.schema.ImmuService/streamExportTx', schema__pb2.ExportTxRequest.SerializeToString, schema__pb2.Chunk.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SQLExec(request, @@ -3035,21 +2350,11 @@ def SQLExec(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/SQLExec', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/SQLExec', schema__pb2.SQLExecRequest.SerializeToString, schema__pb2.SQLExecResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def UnarySQLQuery(request, @@ -3062,21 +2367,11 @@ def UnarySQLQuery(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/UnarySQLQuery', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/UnarySQLQuery', schema__pb2.SQLQueryRequest.SerializeToString, schema__pb2.SQLQueryResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SQLQuery(request, @@ -3089,21 +2384,11 @@ def SQLQuery(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream( - request, - target, - '/immudb.schema.ImmuService/SQLQuery', + return grpc.experimental.unary_stream(request, target, '/immudb.schema.ImmuService/SQLQuery', schema__pb2.SQLQueryRequest.SerializeToString, schema__pb2.SQLQueryResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ListTables(request, @@ -3116,21 +2401,11 @@ def ListTables(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/ListTables', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/ListTables', google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, schema__pb2.SQLQueryResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DescribeTable(request, @@ -3143,21 +2418,11 @@ def DescribeTable(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/DescribeTable', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/DescribeTable', schema__pb2.Table.SerializeToString, schema__pb2.SQLQueryResult.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def VerifiableSQLGet(request, @@ -3170,21 +2435,11 @@ def VerifiableSQLGet(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/VerifiableSQLGet', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/VerifiableSQLGet', schema__pb2.VerifiableSQLGetRequest.SerializeToString, schema__pb2.VerifiableSQLEntry.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TruncateDatabase(request, @@ -3197,18 +2452,8 @@ def TruncateDatabase(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/immudb.schema.ImmuService/TruncateDatabase', + return grpc.experimental.unary_unary(request, target, '/immudb.schema.ImmuService/TruncateDatabase', schema__pb2.TruncateDatabaseRequest.SerializeToString, schema__pb2.TruncateDatabaseResponse.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata)