openstack/zun
Code Issues Proposed changes

Add python CRI client

Browse Source 
This commit introduce the python-binding for iteracting with
CRI runtime via GRPC.
The client code is generated by protocol buffer [1] by using api.proto
in kubernetes/cri-api repo.

The generated CRI client code couldn't pass the pep8 check so this
commit also configure flake8 to skip the zun/criapi directory.

[1] https://developers.google.com/protocol-buffers/docs/pythontutorial

Implements: blueprint add-support-cri-runtime
Change-Id: I2e1a20b47fec5af1f4977148431e1135abd49812
This commit is contained in:
Hongbin Lu 2020-01-12 18:10:44 +00:00
parent f5286b90c5
commit 7c7ee59026
8 changed files with 8274 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lower-constraints.txt
View File

@ -39,6 +39,7 @@ Flask==0.12.3
gitdb2==2.0.3
GitPython==2.1.8
greenlet==0.4.13
grpcio==1.12.0
hacking==0.12.0
idna==2.6
imagesize==1.0.0
@ -104,6 +105,7 @@ pep8==1.5.7
pika==0.10.0
pika-pool==0.1.3
prettytable==0.7.2
protobuf==3.6.0
psutil==3.2.2
pyasn1==0.4.2
pycadf==2.7.0

2
requirements.txt
View File

@ -5,10 +5,12 @@
cotyledon>=1.5.0 # Apache-2.0
Flask>=0.12.3 # BSD
futurist>=1.6.0 # Apache-2.0
grpcio>=1.12.0 # Apache-2.0
PyYAML>=3.12 # MIT
eventlet!=0.18.3,!=0.20.1,>=0.18.2 # MIT
keystonemiddleware>=4.18.0 # Apache-2.0
pecan!=1.0.2,!=1.0.3,!=1.0.4,!=1.2,>=1.0.0 # BSD
protobuf>=3.6.0 # 3-Clause BSD
psutil>=3.2.2 # BSD
python-glanceclient>=2.8.0 # Apache-2.0
python-neutronclient>=6.7.0 # Apache-2.0

4
tools/flake8wrap.sh
View File

@ -13,8 +13,8 @@ if test "x$1" = "x-HEAD" ; then
shift
files=$(git diff --name-only HEAD~1 | tr '\n' ' ')
echo "Running flake8 on ${files}"
diff -u --from-file /dev/null ${files} | flake8 --max-complexity 34 --diff "$@"
diff -u --from-file /dev/null ${files} | flake8 --max-complexity 34 --exclude zun/criapi --diff "$@"
else
echo "Running flake8 on all files"
exec flake8 --max-complexity 34 "$@"
exec flake8 --max-complexity 34 --exclude zun/criapi "$@"
fi

49
tools/gen-criapi Executable file
View File

@ -0,0 +1,49 @@
#!/bin/bash
function add_license_header {
file=$1
license=$(mktemp)
cat << EOF > $license
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
EOF
newfile=$(mktemp)
cat $license $file > $newfile
mv $newfile $file
}
ZUNROOT=${ZUNROOT:-/opt/stack/zun}
curl -o ${ZUNROOT}/zun/criapi/api.proto https://raw.githubusercontent.com/kubernetes/cri-api/master/pkg/apis/runtime/v1alpha2/api.proto
curl -o ${ZUNROOT}/zun/criapi/gogo.proto https://raw.githubusercontent.com/gogo/protobuf/master/gogoproto/gogo.proto
sed -i 's/github.com\/gogo\/protobuf\/gogoproto\/gogo.proto/zun\/criapi\/gogo.proto/' ${ZUNROOT}/zun/criapi/api.proto
python3 -m grpc_tools.protoc \
-I${ZUNROOT} \
--python_out=${ZUNROOT} \
${ZUNROOT}/zun/criapi/gogo.proto
python3 -m grpc_tools.protoc \
-I${ZUNROOT} \
--python_out=${ZUNROOT} \
--grpc_python_out=${ZUNROOT} \
${ZUNROOT}/zun/criapi/api.proto
for i in ${ZUNROOT}/zun/criapi/*.py; do
if [[ $i != *__init__.py ]]; then
add_license_header $i
fi
done
rm -f ${ZUNROOT}/zun/criapi/api.proto
rm -f ${ZUNROOT}/zun/criapi/gogo.proto

0
zun/criapi/__init__.py Normal file
View File

6859
zun/criapi/api_pb2.py Normal file
View File

File diff suppressed because one or more lines are too long

554
zun/criapi/api_pb2_grpc.py Normal file
View File

@ -0,0 +1,554 @@
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from zun.criapi import api_pb2 as zun_dot_criapi_dot_api__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=zun_dot_criapi_dot_api__pb2.VersionRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.VersionResponse.FromString,
)
self.RunPodSandbox = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/RunPodSandbox',
request_serializer=zun_dot_criapi_dot_api__pb2.RunPodSandboxRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.RunPodSandboxResponse.FromString,
)
self.StopPodSandbox = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/StopPodSandbox',
request_serializer=zun_dot_criapi_dot_api__pb2.StopPodSandboxRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.StopPodSandboxResponse.FromString,
)
self.RemovePodSandbox = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/RemovePodSandbox',
request_serializer=zun_dot_criapi_dot_api__pb2.RemovePodSandboxRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.RemovePodSandboxResponse.FromString,
)
self.PodSandboxStatus = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/PodSandboxStatus',
request_serializer=zun_dot_criapi_dot_api__pb2.PodSandboxStatusRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.PodSandboxStatusResponse.FromString,
)
self.ListPodSandbox = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ListPodSandbox',
request_serializer=zun_dot_criapi_dot_api__pb2.ListPodSandboxRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ListPodSandboxResponse.FromString,
)
self.CreateContainer = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/CreateContainer',
request_serializer=zun_dot_criapi_dot_api__pb2.CreateContainerRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.CreateContainerResponse.FromString,
)
self.StartContainer = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/StartContainer',
request_serializer=zun_dot_criapi_dot_api__pb2.StartContainerRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.StartContainerResponse.FromString,
)
self.StopContainer = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/StopContainer',
request_serializer=zun_dot_criapi_dot_api__pb2.StopContainerRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.StopContainerResponse.FromString,
)
self.RemoveContainer = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/RemoveContainer',
request_serializer=zun_dot_criapi_dot_api__pb2.RemoveContainerRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.RemoveContainerResponse.FromString,
)
self.ListContainers = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ListContainers',
request_serializer=zun_dot_criapi_dot_api__pb2.ListContainersRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ListContainersResponse.FromString,
)
self.ContainerStatus = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ContainerStatus',
request_serializer=zun_dot_criapi_dot_api__pb2.ContainerStatusRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ContainerStatusResponse.FromString,
)
self.UpdateContainerResources = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/UpdateContainerResources',
request_serializer=zun_dot_criapi_dot_api__pb2.UpdateContainerResourcesRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.UpdateContainerResourcesResponse.FromString,
)
self.ReopenContainerLog = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ReopenContainerLog',
request_serializer=zun_dot_criapi_dot_api__pb2.ReopenContainerLogRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ReopenContainerLogResponse.FromString,
)
self.ExecSync = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ExecSync',
request_serializer=zun_dot_criapi_dot_api__pb2.ExecSyncRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ExecSyncResponse.FromString,
)
self.Exec = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/Exec',
request_serializer=zun_dot_criapi_dot_api__pb2.ExecRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ExecResponse.FromString,
)
self.Attach = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/Attach',
request_serializer=zun_dot_criapi_dot_api__pb2.AttachRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.AttachResponse.FromString,
)
self.PortForward = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/PortForward',
request_serializer=zun_dot_criapi_dot_api__pb2.PortForwardRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.PortForwardResponse.FromString,
)
self.ContainerStats = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ContainerStats',
request_serializer=zun_dot_criapi_dot_api__pb2.ContainerStatsRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ContainerStatsResponse.FromString,
)
self.ListContainerStats = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/ListContainerStats',
request_serializer=zun_dot_criapi_dot_api__pb2.ListContainerStatsRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ListContainerStatsResponse.FromString,
)
self.UpdateRuntimeConfig = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/UpdateRuntimeConfig',
request_serializer=zun_dot_criapi_dot_api__pb2.UpdateRuntimeConfigRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.UpdateRuntimeConfigResponse.FromString,
)
self.Status = channel.unary_unary(
'/runtime.v1alpha2.RuntimeService/Status',
request_serializer=zun_dot_criapi_dot_api__pb2.StatusRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.StatusResponse.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 RunPodSandbox(self, request, context):
"""RunPodSandbox creates and starts a pod-level sandbox. Runtimes must ensure
the sandbox is in the ready state on success.
"""
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 RemovePodSandbox(self, request, context):
"""RemovePodSandbox removes the sandbox. If there are any running containers
in the sandbox, they must be forcibly terminated and removed.
This call is idempotent, and must not return an error if the sandbox has
already been removed.
"""
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 CreateContainer(self, request, context):
"""CreateContainer creates a new container in specified PodSandbox
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def StartContainer(self, request, context):
"""StartContainer starts the container.
"""
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.
TODO: what must the runtime do after the grace period is reached?
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def RemoveContainer(self, request, context):
"""RemoveContainer removes the container. If the container is running, the
container must be forcibly removed.
This call is idempotent, and must not return an error if the container has
already been removed.
"""
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 UpdateContainerResources(self, request, context):
"""UpdateContainerResources updates ContainerConfig of the container.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReopenContainerLog(self, request, context):
"""ReopenContainerLog asks runtime to reopen the stdout/stderr log file
for the container. This is often called after the log file has been
rotated. If the container is not running, container runtime can choose
to either create a new log file and return nil, or return an error.
Once it returns error, new container log file MUST NOT be created.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ExecSync(self, request, context):
"""ExecSync runs a command in a container synchronously.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Exec(self, request, context):
"""Exec prepares a streaming endpoint to execute a command in the container.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Attach(self, request, context):
"""Attach prepares a streaming endpoint to attach to a running container.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def PortForward(self, request, context):
"""PortForward prepares a streaming endpoint to forward ports from a PodSandbox.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ContainerStats(self, request, context):
"""ContainerStats returns stats of the container. If the container does not
exist, the call returns an error.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListContainerStats(self, request, context):
"""ListContainerStats returns stats of all running containers.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateRuntimeConfig(self, request, context):
"""UpdateRuntimeConfig updates the runtime configuration based on the given request.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Status(self, request, context):
"""Status returns the status of the runtime.
"""
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=zun_dot_criapi_dot_api__pb2.VersionRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.VersionResponse.SerializeToString,
),
'RunPodSandbox': grpc.unary_unary_rpc_method_handler(
servicer.RunPodSandbox,
request_deserializer=zun_dot_criapi_dot_api__pb2.RunPodSandboxRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.RunPodSandboxResponse.SerializeToString,
),
'StopPodSandbox': grpc.unary_unary_rpc_method_handler(
servicer.StopPodSandbox,
request_deserializer=zun_dot_criapi_dot_api__pb2.StopPodSandboxRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.StopPodSandboxResponse.SerializeToString,
),
'RemovePodSandbox': grpc.unary_unary_rpc_method_handler(
servicer.RemovePodSandbox,
request_deserializer=zun_dot_criapi_dot_api__pb2.RemovePodSandboxRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.RemovePodSandboxResponse.SerializeToString,
),
'PodSandboxStatus': grpc.unary_unary_rpc_method_handler(
servicer.PodSandboxStatus,
request_deserializer=zun_dot_criapi_dot_api__pb2.PodSandboxStatusRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.PodSandboxStatusResponse.SerializeToString,
),
'ListPodSandbox': grpc.unary_unary_rpc_method_handler(
servicer.ListPodSandbox,
request_deserializer=zun_dot_criapi_dot_api__pb2.ListPodSandboxRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ListPodSandboxResponse.SerializeToString,
),
'CreateContainer': grpc.unary_unary_rpc_method_handler(
servicer.CreateContainer,
request_deserializer=zun_dot_criapi_dot_api__pb2.CreateContainerRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.CreateContainerResponse.SerializeToString,
),
'StartContainer': grpc.unary_unary_rpc_method_handler(
servicer.StartContainer,
request_deserializer=zun_dot_criapi_dot_api__pb2.StartContainerRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.StartContainerResponse.SerializeToString,
),
'StopContainer': grpc.unary_unary_rpc_method_handler(
servicer.StopContainer,
request_deserializer=zun_dot_criapi_dot_api__pb2.StopContainerRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.StopContainerResponse.SerializeToString,
),
'RemoveContainer': grpc.unary_unary_rpc_method_handler(
servicer.RemoveContainer,
request_deserializer=zun_dot_criapi_dot_api__pb2.RemoveContainerRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.RemoveContainerResponse.SerializeToString,
),
'ListContainers': grpc.unary_unary_rpc_method_handler(
servicer.ListContainers,
request_deserializer=zun_dot_criapi_dot_api__pb2.ListContainersRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ListContainersResponse.SerializeToString,
),
'ContainerStatus': grpc.unary_unary_rpc_method_handler(
servicer.ContainerStatus,
request_deserializer=zun_dot_criapi_dot_api__pb2.ContainerStatusRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ContainerStatusResponse.SerializeToString,
),
'UpdateContainerResources': grpc.unary_unary_rpc_method_handler(
servicer.UpdateContainerResources,
request_deserializer=zun_dot_criapi_dot_api__pb2.UpdateContainerResourcesRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.UpdateContainerResourcesResponse.SerializeToString,
),
'ReopenContainerLog': grpc.unary_unary_rpc_method_handler(
servicer.ReopenContainerLog,
request_deserializer=zun_dot_criapi_dot_api__pb2.ReopenContainerLogRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ReopenContainerLogResponse.SerializeToString,
),
'ExecSync': grpc.unary_unary_rpc_method_handler(
servicer.ExecSync,
request_deserializer=zun_dot_criapi_dot_api__pb2.ExecSyncRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ExecSyncResponse.SerializeToString,
),
'Exec': grpc.unary_unary_rpc_method_handler(
servicer.Exec,
request_deserializer=zun_dot_criapi_dot_api__pb2.ExecRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ExecResponse.SerializeToString,
),
'Attach': grpc.unary_unary_rpc_method_handler(
servicer.Attach,
request_deserializer=zun_dot_criapi_dot_api__pb2.AttachRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.AttachResponse.SerializeToString,
),
'PortForward': grpc.unary_unary_rpc_method_handler(
servicer.PortForward,
request_deserializer=zun_dot_criapi_dot_api__pb2.PortForwardRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.PortForwardResponse.SerializeToString,
),
'ContainerStats': grpc.unary_unary_rpc_method_handler(
servicer.ContainerStats,
request_deserializer=zun_dot_criapi_dot_api__pb2.ContainerStatsRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ContainerStatsResponse.SerializeToString,
),
'ListContainerStats': grpc.unary_unary_rpc_method_handler(
servicer.ListContainerStats,
request_deserializer=zun_dot_criapi_dot_api__pb2.ListContainerStatsRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ListContainerStatsResponse.SerializeToString,
),
'UpdateRuntimeConfig': grpc.unary_unary_rpc_method_handler(
servicer.UpdateRuntimeConfig,
request_deserializer=zun_dot_criapi_dot_api__pb2.UpdateRuntimeConfigRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.UpdateRuntimeConfigResponse.SerializeToString,
),
'Status': grpc.unary_unary_rpc_method_handler(
servicer.Status,
request_deserializer=zun_dot_criapi_dot_api__pb2.StatusRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.StatusResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'runtime.v1alpha2.RuntimeService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
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=zun_dot_criapi_dot_api__pb2.ListImagesRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ListImagesResponse.FromString,
)
self.ImageStatus = channel.unary_unary(
'/runtime.v1alpha2.ImageService/ImageStatus',
request_serializer=zun_dot_criapi_dot_api__pb2.ImageStatusRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ImageStatusResponse.FromString,
)
self.PullImage = channel.unary_unary(
'/runtime.v1alpha2.ImageService/PullImage',
request_serializer=zun_dot_criapi_dot_api__pb2.PullImageRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.PullImageResponse.FromString,
)
self.RemoveImage = channel.unary_unary(
'/runtime.v1alpha2.ImageService/RemoveImage',
request_serializer=zun_dot_criapi_dot_api__pb2.RemoveImageRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.RemoveImageResponse.FromString,
)
self.ImageFsInfo = channel.unary_unary(
'/runtime.v1alpha2.ImageService/ImageFsInfo',
request_serializer=zun_dot_criapi_dot_api__pb2.ImageFsInfoRequest.SerializeToString,
response_deserializer=zun_dot_criapi_dot_api__pb2.ImageFsInfoResponse.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 PullImage(self, request, context):
"""PullImage pulls an image with authentication config.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def RemoveImage(self, request, context):
"""RemoveImage removes the image.
This call is idempotent, and must not return an error if the image has
already been removed.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ImageFsInfo(self, request, context):
"""ImageFSInfo returns information of the filesystem that is used to store images.
"""
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=zun_dot_criapi_dot_api__pb2.ListImagesRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ListImagesResponse.SerializeToString,
),
'ImageStatus': grpc.unary_unary_rpc_method_handler(
servicer.ImageStatus,
request_deserializer=zun_dot_criapi_dot_api__pb2.ImageStatusRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ImageStatusResponse.SerializeToString,
),
'PullImage': grpc.unary_unary_rpc_method_handler(
servicer.PullImage,
request_deserializer=zun_dot_criapi_dot_api__pb2.PullImageRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.PullImageResponse.SerializeToString,
),
'RemoveImage': grpc.unary_unary_rpc_method_handler(
servicer.RemoveImage,
request_deserializer=zun_dot_criapi_dot_api__pb2.RemoveImageRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.RemoveImageResponse.SerializeToString,
),
'ImageFsInfo': grpc.unary_unary_rpc_method_handler(
servicer.ImageFsInfo,
request_deserializer=zun_dot_criapi_dot_api__pb2.ImageFsInfoRequest.FromString,
response_serializer=zun_dot_criapi_dot_api__pb2.ImageFsInfoResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'runtime.v1alpha2.ImageService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))

806
zun/criapi/gogo_pb2.py Normal file
View File

File diff suppressed because one or more lines are too long