# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc

import api_v1_lite_pb2 as api__v1__lite__pb2


class RuntimeServiceStub(object):
    """Runtime service defines the public APIs for remote container runtimes
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.Version = channel.unary_unary(
                '/runtime.v1.RuntimeService/Version',
                request_serializer=api__v1__lite__pb2.VersionRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.VersionResponse.FromString,
                )
        self.StopPodSandbox = channel.unary_unary(
                '/runtime.v1.RuntimeService/StopPodSandbox',
                request_serializer=api__v1__lite__pb2.StopPodSandboxRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.StopPodSandboxResponse.FromString,
                )
        self.PodSandboxStatus = channel.unary_unary(
                '/runtime.v1.RuntimeService/PodSandboxStatus',
                request_serializer=api__v1__lite__pb2.PodSandboxStatusRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.PodSandboxStatusResponse.FromString,
                )
        self.ListPodSandbox = channel.unary_unary(
                '/runtime.v1.RuntimeService/ListPodSandbox',
                request_serializer=api__v1__lite__pb2.ListPodSandboxRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.ListPodSandboxResponse.FromString,
                )
        self.StopContainer = channel.unary_unary(
                '/runtime.v1.RuntimeService/StopContainer',
                request_serializer=api__v1__lite__pb2.StopContainerRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.StopContainerResponse.FromString,
                )
        self.ListContainers = channel.unary_unary(
                '/runtime.v1.RuntimeService/ListContainers',
                request_serializer=api__v1__lite__pb2.ListContainersRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.ListContainersResponse.FromString,
                )
        self.ContainerStatus = channel.unary_unary(
                '/runtime.v1.RuntimeService/ContainerStatus',
                request_serializer=api__v1__lite__pb2.ContainerStatusRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.ContainerStatusResponse.FromString,
                )


class RuntimeServiceServicer(object):
    """Runtime service defines the public APIs for remote container runtimes
    """

    def Version(self, request, context):
        """Version returns the runtime name, runtime version, and runtime API version.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def StopPodSandbox(self, request, context):
        """StopPodSandbox stops any running process that is part of the sandbox and
        reclaims network resources (e.g., IP addresses) allocated to the sandbox.
        If there are any running containers in the sandbox, they must be forcibly
        terminated.
        This call is idempotent, and must not return an error if all relevant
        resources have already been reclaimed. kubelet will call StopPodSandbox
        at least once before calling RemovePodSandbox. It will also attempt to
        reclaim resources eagerly, as soon as a sandbox is not needed. Hence,
        multiple StopPodSandbox calls are expected.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def PodSandboxStatus(self, request, context):
        """PodSandboxStatus returns the status of the PodSandbox. If the PodSandbox is not
        present, returns an error.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def ListPodSandbox(self, request, context):
        """ListPodSandbox returns a list of PodSandboxes.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def StopContainer(self, request, context):
        """StopContainer stops a running container with a grace period (i.e., timeout).
        This call is idempotent, and must not return an error if the container has
        already been stopped.
        The runtime must forcibly kill the container after the grace period is
        reached.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def ListContainers(self, request, context):
        """ListContainers lists all containers by filters.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def ContainerStatus(self, request, context):
        """ContainerStatus returns status of the container. If the container is not
        present, returns an error.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


def add_RuntimeServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Version': grpc.unary_unary_rpc_method_handler(
                    servicer.Version,
                    request_deserializer=api__v1__lite__pb2.VersionRequest.FromString,
                    response_serializer=api__v1__lite__pb2.VersionResponse.SerializeToString,
            ),
            'StopPodSandbox': grpc.unary_unary_rpc_method_handler(
                    servicer.StopPodSandbox,
                    request_deserializer=api__v1__lite__pb2.StopPodSandboxRequest.FromString,
                    response_serializer=api__v1__lite__pb2.StopPodSandboxResponse.SerializeToString,
            ),
            'PodSandboxStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.PodSandboxStatus,
                    request_deserializer=api__v1__lite__pb2.PodSandboxStatusRequest.FromString,
                    response_serializer=api__v1__lite__pb2.PodSandboxStatusResponse.SerializeToString,
            ),
            'ListPodSandbox': grpc.unary_unary_rpc_method_handler(
                    servicer.ListPodSandbox,
                    request_deserializer=api__v1__lite__pb2.ListPodSandboxRequest.FromString,
                    response_serializer=api__v1__lite__pb2.ListPodSandboxResponse.SerializeToString,
            ),
            'StopContainer': grpc.unary_unary_rpc_method_handler(
                    servicer.StopContainer,
                    request_deserializer=api__v1__lite__pb2.StopContainerRequest.FromString,
                    response_serializer=api__v1__lite__pb2.StopContainerResponse.SerializeToString,
            ),
            'ListContainers': grpc.unary_unary_rpc_method_handler(
                    servicer.ListContainers,
                    request_deserializer=api__v1__lite__pb2.ListContainersRequest.FromString,
                    response_serializer=api__v1__lite__pb2.ListContainersResponse.SerializeToString,
            ),
            'ContainerStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.ContainerStatus,
                    request_deserializer=api__v1__lite__pb2.ContainerStatusRequest.FromString,
                    response_serializer=api__v1__lite__pb2.ContainerStatusResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'runtime.v1.RuntimeService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class RuntimeService(object):
    """Runtime service defines the public APIs for remote container runtimes
    """

    @staticmethod
    def Version(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/Version',
            api__v1__lite__pb2.VersionRequest.SerializeToString,
            api__v1__lite__pb2.VersionResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def StopPodSandbox(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/StopPodSandbox',
            api__v1__lite__pb2.StopPodSandboxRequest.SerializeToString,
            api__v1__lite__pb2.StopPodSandboxResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def PodSandboxStatus(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/PodSandboxStatus',
            api__v1__lite__pb2.PodSandboxStatusRequest.SerializeToString,
            api__v1__lite__pb2.PodSandboxStatusResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ListPodSandbox(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/ListPodSandbox',
            api__v1__lite__pb2.ListPodSandboxRequest.SerializeToString,
            api__v1__lite__pb2.ListPodSandboxResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def StopContainer(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/StopContainer',
            api__v1__lite__pb2.StopContainerRequest.SerializeToString,
            api__v1__lite__pb2.StopContainerResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ListContainers(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/ListContainers',
            api__v1__lite__pb2.ListContainersRequest.SerializeToString,
            api__v1__lite__pb2.ListContainersResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ContainerStatus(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.RuntimeService/ContainerStatus',
            api__v1__lite__pb2.ContainerStatusRequest.SerializeToString,
            api__v1__lite__pb2.ContainerStatusResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)


class ImageServiceStub(object):
    """ImageService defines the public APIs for managing images.
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.ListImages = channel.unary_unary(
                '/runtime.v1.ImageService/ListImages',
                request_serializer=api__v1__lite__pb2.ListImagesRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.ListImagesResponse.FromString,
                )
        self.ImageStatus = channel.unary_unary(
                '/runtime.v1.ImageService/ImageStatus',
                request_serializer=api__v1__lite__pb2.ImageStatusRequest.SerializeToString,
                response_deserializer=api__v1__lite__pb2.ImageStatusResponse.FromString,
                )


class ImageServiceServicer(object):
    """ImageService defines the public APIs for managing images.
    """

    def ListImages(self, request, context):
        """ListImages lists existing images.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def ImageStatus(self, request, context):
        """ImageStatus returns the status of the image. If the image is not
        present, returns a response with ImageStatusResponse.Image set to
        nil.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


def add_ImageServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'ListImages': grpc.unary_unary_rpc_method_handler(
                    servicer.ListImages,
                    request_deserializer=api__v1__lite__pb2.ListImagesRequest.FromString,
                    response_serializer=api__v1__lite__pb2.ListImagesResponse.SerializeToString,
            ),
            'ImageStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.ImageStatus,
                    request_deserializer=api__v1__lite__pb2.ImageStatusRequest.FromString,
                    response_serializer=api__v1__lite__pb2.ImageStatusResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'runtime.v1.ImageService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class ImageService(object):
    """ImageService defines the public APIs for managing images.
    """

    @staticmethod
    def ListImages(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.ImageService/ListImages',
            api__v1__lite__pb2.ListImagesRequest.SerializeToString,
            api__v1__lite__pb2.ListImagesResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ImageStatus(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1.ImageService/ImageStatus',
            api__v1__lite__pb2.ImageStatusRequest.SerializeToString,
            api__v1__lite__pb2.ImageStatusResponse.FromString,
            options, channel_credentials,
            call_credentials, compression, wait_for_ready, timeout, metadata)