HEX
Server: nginx/1.22.0
System: Linux iZuf6jdxbygmf6cco977lcZ 5.10.84-10.4.al8.x86_64 #1 SMP Tue Apr 12 12:31:07 CST 2022 x86_64
User: root (0)
PHP: 7.4.29
Disabled: passthru,exec,system,chroot,chgrp,chown,shell_exec,proc_open,proc_get_status,ini_alter,ini_restore,dl,readlink,symlink,popepassthru,stream_socket_server,fsocket,popen
Upload Files
File: //usr/local/aegis/PythonLoaderTemp/third_party/litecri/api_lite_pb2_grpc.py
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

import api_lite_pb2 as api__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.v1alpha2.RuntimeService/Version',
                request_serializer=api__lite__pb2.VersionRequest.SerializeToString,
                response_deserializer=api__lite__pb2.VersionResponse.FromString,
                )
        self.PodSandboxStatus = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/PodSandboxStatus',
                request_serializer=api__lite__pb2.PodSandboxStatusRequest.SerializeToString,
                response_deserializer=api__lite__pb2.PodSandboxStatusResponse.FromString,
                )
        self.ContainerStatus = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/ContainerStatus',
                request_serializer=api__lite__pb2.ContainerStatusRequest.SerializeToString,
                response_deserializer=api__lite__pb2.ContainerStatusResponse.FromString,
                )
        self.StopPodSandbox = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/StopPodSandbox',
                request_serializer=api__lite__pb2.StopPodSandboxRequest.SerializeToString,
                response_deserializer=api__lite__pb2.StopPodSandboxResponse.FromString,
                )
        self.ListPodSandbox = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/ListPodSandbox',
                request_serializer=api__lite__pb2.ListPodSandboxRequest.SerializeToString,
                response_deserializer=api__lite__pb2.ListPodSandboxResponse.FromString,
                )
        self.StopContainer = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/StopContainer',
                request_serializer=api__lite__pb2.StopContainerRequest.SerializeToString,
                response_deserializer=api__lite__pb2.StopContainerResponse.FromString,
                )
        self.ListContainers = channel.unary_unary(
                '/runtime.v1alpha2.RuntimeService/ListContainers',
                request_serializer=api__lite__pb2.ListContainersRequest.SerializeToString,
                response_deserializer=api__lite__pb2.ListContainersResponse.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 PodSandboxStatus(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 ContainerStatus(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 StopPodSandbox(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 ListPodSandbox(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 StopContainer(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 ListContainers(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_RuntimeServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'Version': grpc.unary_unary_rpc_method_handler(
                    servicer.Version,
                    request_deserializer=api__lite__pb2.VersionRequest.FromString,
                    response_serializer=api__lite__pb2.VersionResponse.SerializeToString,
            ),
            'PodSandboxStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.PodSandboxStatus,
                    request_deserializer=api__lite__pb2.PodSandboxStatusRequest.FromString,
                    response_serializer=api__lite__pb2.PodSandboxStatusResponse.SerializeToString,
            ),
            'ContainerStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.ContainerStatus,
                    request_deserializer=api__lite__pb2.ContainerStatusRequest.FromString,
                    response_serializer=api__lite__pb2.ContainerStatusResponse.SerializeToString,
            ),
            'StopPodSandbox': grpc.unary_unary_rpc_method_handler(
                    servicer.StopPodSandbox,
                    request_deserializer=api__lite__pb2.StopPodSandboxRequest.FromString,
                    response_serializer=api__lite__pb2.StopPodSandboxResponse.SerializeToString,
            ),
            'ListPodSandbox': grpc.unary_unary_rpc_method_handler(
                    servicer.ListPodSandbox,
                    request_deserializer=api__lite__pb2.ListPodSandboxRequest.FromString,
                    response_serializer=api__lite__pb2.ListPodSandboxResponse.SerializeToString,
            ),
            'StopContainer': grpc.unary_unary_rpc_method_handler(
                    servicer.StopContainer,
                    request_deserializer=api__lite__pb2.StopContainerRequest.FromString,
                    response_serializer=api__lite__pb2.StopContainerResponse.SerializeToString,
            ),
            'ListContainers': grpc.unary_unary_rpc_method_handler(
                    servicer.ListContainers,
                    request_deserializer=api__lite__pb2.ListContainersRequest.FromString,
                    response_serializer=api__lite__pb2.ListContainersResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'runtime.v1alpha2.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,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1alpha2.RuntimeService/Version',
            api__lite__pb2.VersionRequest.SerializeToString,
            api__lite__pb2.VersionResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def PodSandboxStatus(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, '/runtime.v1alpha2.RuntimeService/PodSandboxStatus',
            api__lite__pb2.PodSandboxStatusRequest.SerializeToString,
            api__lite__pb2.PodSandboxStatusResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ContainerStatus(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, '/runtime.v1alpha2.RuntimeService/ContainerStatus',
            api__lite__pb2.ContainerStatusRequest.SerializeToString,
            api__lite__pb2.ContainerStatusResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def StopPodSandbox(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, '/runtime.v1alpha2.RuntimeService/StopPodSandbox',
            api__lite__pb2.StopPodSandboxRequest.SerializeToString,
            api__lite__pb2.StopPodSandboxResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ListPodSandbox(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, '/runtime.v1alpha2.RuntimeService/ListPodSandbox',
            api__lite__pb2.ListPodSandboxRequest.SerializeToString,
            api__lite__pb2.ListPodSandboxResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def StopContainer(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, '/runtime.v1alpha2.RuntimeService/StopContainer',
            api__lite__pb2.StopContainerRequest.SerializeToString,
            api__lite__pb2.StopContainerResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ListContainers(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, '/runtime.v1alpha2.RuntimeService/ListContainers',
            api__lite__pb2.ListContainersRequest.SerializeToString,
            api__lite__pb2.ListContainersResponse.FromString,
            options, channel_credentials,
            insecure, 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.v1alpha2.ImageService/ListImages',
                request_serializer=api__lite__pb2.ListImagesRequest.SerializeToString,
                response_deserializer=api__lite__pb2.ListImagesResponse.FromString,
                )
        self.ImageStatus = channel.unary_unary(
                '/runtime.v1alpha2.ImageService/ImageStatus',
                request_serializer=api__lite__pb2.ImageStatusRequest.SerializeToString,
                response_deserializer=api__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__lite__pb2.ListImagesRequest.FromString,
                    response_serializer=api__lite__pb2.ListImagesResponse.SerializeToString,
            ),
            'ImageStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.ImageStatus,
                    request_deserializer=api__lite__pb2.ImageStatusRequest.FromString,
                    response_serializer=api__lite__pb2.ImageStatusResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'runtime.v1alpha2.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,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/runtime.v1alpha2.ImageService/ListImages',
            api__lite__pb2.ListImagesRequest.SerializeToString,
            api__lite__pb2.ListImagesResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ImageStatus(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, '/runtime.v1alpha2.ImageService/ImageStatus',
            api__lite__pb2.ImageStatusRequest.SerializeToString,
            api__lite__pb2.ImageStatusResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)