# 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 grpcServer.protobuf import igapi_pb2 as igapi__pb2 GRPC_GENERATED_VERSION = '1.68.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False try: from grpc._utilities import first_version_is_lower _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) except ImportError: _version_not_supported = True if _version_not_supported: raise RuntimeError( f'The grpc package installed is at version {GRPC_VERSION},' + f' but the generated code in igapi_pb2_grpc.py depends on' + f' grpcio>={GRPC_GENERATED_VERSION}.' + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' ) class IGAPIStub(object): """Missing associated documentation comment in .proto file.""" def __init__(self, channel): """Constructor. Args: channel: A grpc.Channel. """ self.login = channel.unary_unary( '/IGAPI/login', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) self.account_info = channel.unary_unary( '/IGAPI/account_info', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) self.upload = channel.unary_unary( '/IGAPI/upload', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) self.delete = channel.unary_unary( '/IGAPI/delete', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) self.setting = channel.unary_unary( '/IGAPI/setting', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) self.queue = channel.unary_unary( '/IGAPI/queue', request_serializer=igapi__pb2.Request.SerializeToString, response_deserializer=igapi__pb2.Reply.FromString, _registered_method=True) class IGAPIServicer(object): """Missing associated documentation comment in .proto file.""" def login(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 account_info(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 upload(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 delete(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 setting(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 queue(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_IGAPIServicer_to_server(servicer, server): rpc_method_handlers = { 'login': grpc.unary_unary_rpc_method_handler( servicer.login, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), 'account_info': grpc.unary_unary_rpc_method_handler( servicer.account_info, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), 'upload': grpc.unary_unary_rpc_method_handler( servicer.upload, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), 'delete': grpc.unary_unary_rpc_method_handler( servicer.delete, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), 'setting': grpc.unary_unary_rpc_method_handler( servicer.setting, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), 'queue': grpc.unary_unary_rpc_method_handler( servicer.queue, request_deserializer=igapi__pb2.Request.FromString, response_serializer=igapi__pb2.Reply.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'IGAPI', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) server.add_registered_method_handlers('IGAPI', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. class IGAPI(object): """Missing associated documentation comment in .proto file.""" @staticmethod def login(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, '/IGAPI/login', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True) @staticmethod def account_info(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, '/IGAPI/account_info', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True) @staticmethod def upload(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, '/IGAPI/upload', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True) @staticmethod def delete(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, '/IGAPI/delete', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True) @staticmethod def setting(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, '/IGAPI/setting', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True) @staticmethod def queue(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, '/IGAPI/queue', igapi__pb2.Request.SerializeToString, igapi__pb2.Reply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata, _registered_method=True)