File: //usr/local/aegis/PythonLoader/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)