# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

import sea_generator_rpcdesign_pb2 as sea__generator__rpcdesign__pb2


class SEAOnlineTrainingStub(object):
    """Missing associated documentation comment in .proto file."""

    def __init__(self, channel):
        """Constructor.

        Args:
            channel: A grpc.Channel.
        """
        self.test_connection = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/test_connection',
                request_serializer=sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.testConnectString.FromString,
                )
        self.learn_one = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/learn_one',
                request_serializer=sea__generator__rpcdesign__pb2.learnOneRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.learnOneReply.FromString,
                )
        self.predict_one = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/predict_one',
                request_serializer=sea__generator__rpcdesign__pb2.predictOneRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.predictOneReply.FromString,
                )
        self.flush_model = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/flush_model',
                request_serializer=sea__generator__rpcdesign__pb2.flushModelRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.flushModelReply.FromString,
                )
        self.extract_model = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/extract_model',
                request_serializer=sea__generator__rpcdesign__pb2.extractModelRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.extractModelReply.FromString,
                )


class SEAOnlineTrainingServicer(object):
    """Missing associated documentation comment in .proto file."""

    def test_connection(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 learn_one(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 predict_one(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 flush_model(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 extract_model(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_SEAOnlineTrainingServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'test_connection': grpc.unary_unary_rpc_method_handler(
                    servicer.test_connection,
                    request_deserializer=sea__generator__rpcdesign__pb2.testConnectString.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
            ),
            'learn_one': grpc.unary_unary_rpc_method_handler(
                    servicer.learn_one,
                    request_deserializer=sea__generator__rpcdesign__pb2.learnOneRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.learnOneReply.SerializeToString,
            ),
            'predict_one': grpc.unary_unary_rpc_method_handler(
                    servicer.predict_one,
                    request_deserializer=sea__generator__rpcdesign__pb2.predictOneRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.predictOneReply.SerializeToString,
            ),
            'flush_model': grpc.unary_unary_rpc_method_handler(
                    servicer.flush_model,
                    request_deserializer=sea__generator__rpcdesign__pb2.flushModelRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.flushModelReply.SerializeToString,
            ),
            'extract_model': grpc.unary_unary_rpc_method_handler(
                    servicer.extract_model,
                    request_deserializer=sea__generator__rpcdesign__pb2.extractModelRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.extractModelReply.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'seagenerator.SEAOnlineTraining', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class SEAOnlineTraining(object):
    """Missing associated documentation comment in .proto file."""

    @staticmethod
    def test_connection(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, '/seagenerator.SEAOnlineTraining/test_connection',
            sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
            sea__generator__rpcdesign__pb2.testConnectString.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def learn_one(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, '/seagenerator.SEAOnlineTraining/learn_one',
            sea__generator__rpcdesign__pb2.learnOneRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.learnOneReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def predict_one(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, '/seagenerator.SEAOnlineTraining/predict_one',
            sea__generator__rpcdesign__pb2.predictOneRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.predictOneReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def flush_model(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, '/seagenerator.SEAOnlineTraining/flush_model',
            sea__generator__rpcdesign__pb2.flushModelRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.flushModelReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def extract_model(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, '/seagenerator.SEAOnlineTraining/extract_model',
            sea__generator__rpcdesign__pb2.extractModelRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.extractModelReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

import sea_generator_rpcdesign_pb2 as sea__generator__rpcdesign__pb2


class SEAOnlineTrainingStub(object):
    """Missing associated documentation comment in .proto file."""

    def __init__(self, channel):
        """Constructor.

        Args:
            channel: A grpc.Channel.
        """
        self.test_connection = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/test_connection',
                request_serializer=sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.testConnectString.FromString,
                )
        self.learn_one = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/learn_one',
                request_serializer=sea__generator__rpcdesign__pb2.learnOneRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.learnOneReply.FromString,
                )
        self.predict_one = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/predict_one',
                request_serializer=sea__generator__rpcdesign__pb2.predictOneRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.predictOneReply.FromString,
                )
        self.flush_model = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/flush_model',
                request_serializer=sea__generator__rpcdesign__pb2.flushModelRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.flushModelReply.FromString,
                )
        self.extract_model = channel.unary_unary(
                '/seagenerator.SEAOnlineTraining/extract_model',
                request_serializer=sea__generator__rpcdesign__pb2.extractModelRequest.SerializeToString,
                response_deserializer=sea__generator__rpcdesign__pb2.extractModelReply.FromString,
                )


class SEAOnlineTrainingServicer(object):
    """Missing associated documentation comment in .proto file."""

    def test_connection(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 learn_one(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 predict_one(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 flush_model(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 extract_model(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_SEAOnlineTrainingServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'test_connection': grpc.unary_unary_rpc_method_handler(
                    servicer.test_connection,
                    request_deserializer=sea__generator__rpcdesign__pb2.testConnectString.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
            ),
            'learn_one': grpc.unary_unary_rpc_method_handler(
                    servicer.learn_one,
                    request_deserializer=sea__generator__rpcdesign__pb2.learnOneRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.learnOneReply.SerializeToString,
            ),
            'predict_one': grpc.unary_unary_rpc_method_handler(
                    servicer.predict_one,
                    request_deserializer=sea__generator__rpcdesign__pb2.predictOneRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.predictOneReply.SerializeToString,
            ),
            'flush_model': grpc.unary_unary_rpc_method_handler(
                    servicer.flush_model,
                    request_deserializer=sea__generator__rpcdesign__pb2.flushModelRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.flushModelReply.SerializeToString,
            ),
            'extract_model': grpc.unary_unary_rpc_method_handler(
                    servicer.extract_model,
                    request_deserializer=sea__generator__rpcdesign__pb2.extractModelRequest.FromString,
                    response_serializer=sea__generator__rpcdesign__pb2.extractModelReply.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'seagenerator.SEAOnlineTraining', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class SEAOnlineTraining(object):
    """Missing associated documentation comment in .proto file."""

    @staticmethod
    def test_connection(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, '/seagenerator.SEAOnlineTraining/test_connection',
            sea__generator__rpcdesign__pb2.testConnectString.SerializeToString,
            sea__generator__rpcdesign__pb2.testConnectString.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def learn_one(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, '/seagenerator.SEAOnlineTraining/learn_one',
            sea__generator__rpcdesign__pb2.learnOneRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.learnOneReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def predict_one(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, '/seagenerator.SEAOnlineTraining/predict_one',
            sea__generator__rpcdesign__pb2.predictOneRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.predictOneReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def flush_model(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, '/seagenerator.SEAOnlineTraining/flush_model',
            sea__generator__rpcdesign__pb2.flushModelRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.flushModelReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def extract_model(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, '/seagenerator.SEAOnlineTraining/extract_model',
            sea__generator__rpcdesign__pb2.extractModelRequest.SerializeToString,
            sea__generator__rpcdesign__pb2.extractModelReply.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! Client and server classes corresponding to protobuf-defined services. Missing associated documentation comment in .proto file. Constructor.          Args:             channel: A grpc.Channel. Missing associated documentation comment in .proto file. Missing associated documentation comment in .proto file. Missing associated documentation comment in .proto file. Missing associated documentation comment in .proto file. Missing associated documentation comment in .proto file. Missing associated documentation comment in .proto file. # This class is part of an EXPERIMENTAL API. Missing associated documentation comment in .proto file.