# 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 . import validator_pb2 as validator__pb2

GRPC_GENERATED_VERSION = '1.74.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 validator_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 ValidatorMapfixServiceStub(object):
    """Missing associated documentation comment in .proto file."""

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

        Args:
            channel: A grpc.Channel.
        """
        self.Create = channel.unary_unary(
                '/validator.ValidatorMapfixService/Create',
                request_serializer=validator__pb2.MapfixCreate.SerializeToString,
                response_deserializer=validator__pb2.MapfixID.FromString,
                _registered_method=True)
        self.CreateAuditError = channel.unary_unary(
                '/validator.ValidatorMapfixService/CreateAuditError',
                request_serializer=validator__pb2.AuditErrorRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.CreateAuditChecklist = channel.unary_unary(
                '/validator.ValidatorMapfixService/CreateAuditChecklist',
                request_serializer=validator__pb2.AuditChecklistRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetValidatedModel = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetValidatedModel',
                request_serializer=validator__pb2.ValidatedModelRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusSubmitted = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusSubmitted',
                request_serializer=validator__pb2.SubmittedRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusRequestChanges = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusRequestChanges',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusValidated = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusValidated',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusNotValidated = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusNotValidated',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusUploaded = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusUploaded',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusNotUploaded = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusNotUploaded',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusReleased = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusReleased',
                request_serializer=validator__pb2.MapfixReleaseRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusNotReleased = channel.unary_unary(
                '/validator.ValidatorMapfixService/SetStatusNotReleased',
                request_serializer=validator__pb2.MapfixID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)


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

    def Create(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 CreateAuditError(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 CreateAuditChecklist(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 SetValidatedModel(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 SetStatusSubmitted(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 SetStatusRequestChanges(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 SetStatusValidated(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 SetStatusNotValidated(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 SetStatusUploaded(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 SetStatusNotUploaded(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 SetStatusReleased(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 SetStatusNotReleased(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_ValidatorMapfixServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Create': grpc.unary_unary_rpc_method_handler(
                    servicer.Create,
                    request_deserializer=validator__pb2.MapfixCreate.FromString,
                    response_serializer=validator__pb2.MapfixID.SerializeToString,
            ),
            'CreateAuditError': grpc.unary_unary_rpc_method_handler(
                    servicer.CreateAuditError,
                    request_deserializer=validator__pb2.AuditErrorRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'CreateAuditChecklist': grpc.unary_unary_rpc_method_handler(
                    servicer.CreateAuditChecklist,
                    request_deserializer=validator__pb2.AuditChecklistRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetValidatedModel': grpc.unary_unary_rpc_method_handler(
                    servicer.SetValidatedModel,
                    request_deserializer=validator__pb2.ValidatedModelRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusSubmitted': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusSubmitted,
                    request_deserializer=validator__pb2.SubmittedRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusRequestChanges': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusRequestChanges,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusValidated': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusValidated,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusNotValidated': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusNotValidated,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusUploaded': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusUploaded,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusNotUploaded': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusNotUploaded,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusReleased': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusReleased,
                    request_deserializer=validator__pb2.MapfixReleaseRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusNotReleased': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusNotReleased,
                    request_deserializer=validator__pb2.MapfixID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'validator.ValidatorMapfixService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('validator.ValidatorMapfixService', rpc_method_handlers)


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

    @staticmethod
    def Create(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,
            '/validator.ValidatorMapfixService/Create',
            validator__pb2.MapfixCreate.SerializeToString,
            validator__pb2.MapfixID.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def CreateAuditError(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,
            '/validator.ValidatorMapfixService/CreateAuditError',
            validator__pb2.AuditErrorRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def CreateAuditChecklist(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,
            '/validator.ValidatorMapfixService/CreateAuditChecklist',
            validator__pb2.AuditChecklistRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetValidatedModel(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,
            '/validator.ValidatorMapfixService/SetValidatedModel',
            validator__pb2.ValidatedModelRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusSubmitted(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,
            '/validator.ValidatorMapfixService/SetStatusSubmitted',
            validator__pb2.SubmittedRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusRequestChanges(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,
            '/validator.ValidatorMapfixService/SetStatusRequestChanges',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusValidated(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,
            '/validator.ValidatorMapfixService/SetStatusValidated',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusNotValidated(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,
            '/validator.ValidatorMapfixService/SetStatusNotValidated',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusUploaded(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,
            '/validator.ValidatorMapfixService/SetStatusUploaded',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusNotUploaded(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,
            '/validator.ValidatorMapfixService/SetStatusNotUploaded',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusReleased(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,
            '/validator.ValidatorMapfixService/SetStatusReleased',
            validator__pb2.MapfixReleaseRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusNotReleased(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,
            '/validator.ValidatorMapfixService/SetStatusNotReleased',
            validator__pb2.MapfixID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)


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

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

        Args:
            channel: A grpc.Channel.
        """
        self.Create = channel.unary_unary(
                '/validator.ValidatorSubmissionService/Create',
                request_serializer=validator__pb2.SubmissionCreate.SerializeToString,
                response_deserializer=validator__pb2.SubmissionID.FromString,
                _registered_method=True)
        self.CreateAuditError = channel.unary_unary(
                '/validator.ValidatorSubmissionService/CreateAuditError',
                request_serializer=validator__pb2.AuditErrorRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.CreateAuditChecklist = channel.unary_unary(
                '/validator.ValidatorSubmissionService/CreateAuditChecklist',
                request_serializer=validator__pb2.AuditChecklistRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetValidatedModel = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetValidatedModel',
                request_serializer=validator__pb2.ValidatedModelRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusSubmitted = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusSubmitted',
                request_serializer=validator__pb2.SubmittedRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusRequestChanges = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusRequestChanges',
                request_serializer=validator__pb2.SubmissionID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusValidated = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusValidated',
                request_serializer=validator__pb2.SubmissionID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusNotValidated = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusNotValidated',
                request_serializer=validator__pb2.SubmissionID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusUploaded = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusUploaded',
                request_serializer=validator__pb2.StatusUploadedRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusNotUploaded = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusNotUploaded',
                request_serializer=validator__pb2.SubmissionID.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.SetStatusReleased = channel.unary_unary(
                '/validator.ValidatorSubmissionService/SetStatusReleased',
                request_serializer=validator__pb2.SubmissionReleaseRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)


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

    def Create(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 CreateAuditError(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 CreateAuditChecklist(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 SetValidatedModel(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 SetStatusSubmitted(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 SetStatusRequestChanges(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 SetStatusValidated(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 SetStatusNotValidated(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 SetStatusUploaded(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 SetStatusNotUploaded(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 SetStatusReleased(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_ValidatorSubmissionServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Create': grpc.unary_unary_rpc_method_handler(
                    servicer.Create,
                    request_deserializer=validator__pb2.SubmissionCreate.FromString,
                    response_serializer=validator__pb2.SubmissionID.SerializeToString,
            ),
            'CreateAuditError': grpc.unary_unary_rpc_method_handler(
                    servicer.CreateAuditError,
                    request_deserializer=validator__pb2.AuditErrorRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'CreateAuditChecklist': grpc.unary_unary_rpc_method_handler(
                    servicer.CreateAuditChecklist,
                    request_deserializer=validator__pb2.AuditChecklistRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetValidatedModel': grpc.unary_unary_rpc_method_handler(
                    servicer.SetValidatedModel,
                    request_deserializer=validator__pb2.ValidatedModelRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusSubmitted': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusSubmitted,
                    request_deserializer=validator__pb2.SubmittedRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusRequestChanges': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusRequestChanges,
                    request_deserializer=validator__pb2.SubmissionID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusValidated': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusValidated,
                    request_deserializer=validator__pb2.SubmissionID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusNotValidated': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusNotValidated,
                    request_deserializer=validator__pb2.SubmissionID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusUploaded': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusUploaded,
                    request_deserializer=validator__pb2.StatusUploadedRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusNotUploaded': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusNotUploaded,
                    request_deserializer=validator__pb2.SubmissionID.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'SetStatusReleased': grpc.unary_unary_rpc_method_handler(
                    servicer.SetStatusReleased,
                    request_deserializer=validator__pb2.SubmissionReleaseRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'validator.ValidatorSubmissionService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('validator.ValidatorSubmissionService', rpc_method_handlers)


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

    @staticmethod
    def Create(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,
            '/validator.ValidatorSubmissionService/Create',
            validator__pb2.SubmissionCreate.SerializeToString,
            validator__pb2.SubmissionID.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def CreateAuditError(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,
            '/validator.ValidatorSubmissionService/CreateAuditError',
            validator__pb2.AuditErrorRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def CreateAuditChecklist(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,
            '/validator.ValidatorSubmissionService/CreateAuditChecklist',
            validator__pb2.AuditChecklistRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetValidatedModel(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,
            '/validator.ValidatorSubmissionService/SetValidatedModel',
            validator__pb2.ValidatedModelRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusSubmitted(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,
            '/validator.ValidatorSubmissionService/SetStatusSubmitted',
            validator__pb2.SubmittedRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusRequestChanges(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,
            '/validator.ValidatorSubmissionService/SetStatusRequestChanges',
            validator__pb2.SubmissionID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusValidated(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,
            '/validator.ValidatorSubmissionService/SetStatusValidated',
            validator__pb2.SubmissionID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusNotValidated(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,
            '/validator.ValidatorSubmissionService/SetStatusNotValidated',
            validator__pb2.SubmissionID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusUploaded(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,
            '/validator.ValidatorSubmissionService/SetStatusUploaded',
            validator__pb2.StatusUploadedRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusNotUploaded(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,
            '/validator.ValidatorSubmissionService/SetStatusNotUploaded',
            validator__pb2.SubmissionID.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def SetStatusReleased(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,
            '/validator.ValidatorSubmissionService/SetStatusReleased',
            validator__pb2.SubmissionReleaseRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)


class ValidatorOperationServiceStub(object):
    """Operations
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.Success = channel.unary_unary(
                '/validator.ValidatorOperationService/Success',
                request_serializer=validator__pb2.OperationSuccessRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)
        self.Fail = channel.unary_unary(
                '/validator.ValidatorOperationService/Fail',
                request_serializer=validator__pb2.OperationFailRequest.SerializeToString,
                response_deserializer=validator__pb2.NullResponse.FromString,
                _registered_method=True)


class ValidatorOperationServiceServicer(object):
    """Operations
    """

    def Success(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 Fail(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_ValidatorOperationServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Success': grpc.unary_unary_rpc_method_handler(
                    servicer.Success,
                    request_deserializer=validator__pb2.OperationSuccessRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
            'Fail': grpc.unary_unary_rpc_method_handler(
                    servicer.Fail,
                    request_deserializer=validator__pb2.OperationFailRequest.FromString,
                    response_serializer=validator__pb2.NullResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'validator.ValidatorOperationService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('validator.ValidatorOperationService', rpc_method_handlers)


 # This class is part of an EXPERIMENTAL API.
class ValidatorOperationService(object):
    """Operations
    """

    @staticmethod
    def Success(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,
            '/validator.ValidatorOperationService/Success',
            validator__pb2.OperationSuccessRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def Fail(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,
            '/validator.ValidatorOperationService/Fail',
            validator__pb2.OperationFailRequest.SerializeToString,
            validator__pb2.NullResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)


class ValidatorScriptServiceStub(object):
    """Scripts
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.Create = channel.unary_unary(
                '/validator.ValidatorScriptService/Create',
                request_serializer=validator__pb2.ScriptCreate.SerializeToString,
                response_deserializer=validator__pb2.ScriptID.FromString,
                _registered_method=True)
        self.Get = channel.unary_unary(
                '/validator.ValidatorScriptService/Get',
                request_serializer=validator__pb2.ScriptID.SerializeToString,
                response_deserializer=validator__pb2.Script.FromString,
                _registered_method=True)
        self.List = channel.unary_unary(
                '/validator.ValidatorScriptService/List',
                request_serializer=validator__pb2.ScriptListRequest.SerializeToString,
                response_deserializer=validator__pb2.ScriptListResponse.FromString,
                _registered_method=True)


class ValidatorScriptServiceServicer(object):
    """Scripts
    """

    def Create(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 Get(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 List(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_ValidatorScriptServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Create': grpc.unary_unary_rpc_method_handler(
                    servicer.Create,
                    request_deserializer=validator__pb2.ScriptCreate.FromString,
                    response_serializer=validator__pb2.ScriptID.SerializeToString,
            ),
            'Get': grpc.unary_unary_rpc_method_handler(
                    servicer.Get,
                    request_deserializer=validator__pb2.ScriptID.FromString,
                    response_serializer=validator__pb2.Script.SerializeToString,
            ),
            'List': grpc.unary_unary_rpc_method_handler(
                    servicer.List,
                    request_deserializer=validator__pb2.ScriptListRequest.FromString,
                    response_serializer=validator__pb2.ScriptListResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'validator.ValidatorScriptService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('validator.ValidatorScriptService', rpc_method_handlers)


 # This class is part of an EXPERIMENTAL API.
class ValidatorScriptService(object):
    """Scripts
    """

    @staticmethod
    def Create(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,
            '/validator.ValidatorScriptService/Create',
            validator__pb2.ScriptCreate.SerializeToString,
            validator__pb2.ScriptID.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def Get(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,
            '/validator.ValidatorScriptService/Get',
            validator__pb2.ScriptID.SerializeToString,
            validator__pb2.Script.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def List(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,
            '/validator.ValidatorScriptService/List',
            validator__pb2.ScriptListRequest.SerializeToString,
            validator__pb2.ScriptListResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)


class ValidatorScriptPolicyServiceStub(object):
    """ScriptPolicies
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.Create = channel.unary_unary(
                '/validator.ValidatorScriptPolicyService/Create',
                request_serializer=validator__pb2.ScriptPolicyCreate.SerializeToString,
                response_deserializer=validator__pb2.ScriptPolicyID.FromString,
                _registered_method=True)
        self.List = channel.unary_unary(
                '/validator.ValidatorScriptPolicyService/List',
                request_serializer=validator__pb2.ScriptPolicyListRequest.SerializeToString,
                response_deserializer=validator__pb2.ScriptPolicyListResponse.FromString,
                _registered_method=True)


class ValidatorScriptPolicyServiceServicer(object):
    """ScriptPolicies
    """

    def Create(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 List(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_ValidatorScriptPolicyServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Create': grpc.unary_unary_rpc_method_handler(
                    servicer.Create,
                    request_deserializer=validator__pb2.ScriptPolicyCreate.FromString,
                    response_serializer=validator__pb2.ScriptPolicyID.SerializeToString,
            ),
            'List': grpc.unary_unary_rpc_method_handler(
                    servicer.List,
                    request_deserializer=validator__pb2.ScriptPolicyListRequest.FromString,
                    response_serializer=validator__pb2.ScriptPolicyListResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'validator.ValidatorScriptPolicyService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('validator.ValidatorScriptPolicyService', rpc_method_handlers)


 # This class is part of an EXPERIMENTAL API.
class ValidatorScriptPolicyService(object):
    """ScriptPolicies
    """

    @staticmethod
    def Create(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,
            '/validator.ValidatorScriptPolicyService/Create',
            validator__pb2.ScriptPolicyCreate.SerializeToString,
            validator__pb2.ScriptPolicyID.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def List(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,
            '/validator.ValidatorScriptPolicyService/List',
            validator__pb2.ScriptPolicyListRequest.SerializeToString,
            validator__pb2.ScriptPolicyListResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)