#![allow(unknown_lints)]
#![allow(clippy::all)]
#![cfg_attr(rustfmt, rustfmt_skip)]
#![allow(box_pointers)]
#![allow(dead_code)]
#![allow(missing_docs)]
#![allow(non_camel_case_types)]
#![allow(non_snake_case)]
#![allow(non_upper_case_globals)]
#![allow(trivial_casts)]
#![allow(unsafe_code)]
#![allow(unused_imports)]
#![allow(unused_results)]
const METHOD_RUNTIME_SERVICE_VERSION: ::grpcio::Method<super::api::VersionRequest, super::api::VersionResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/Version",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_RUN_POD_SANDBOX: ::grpcio::Method<super::api::RunPodSandboxRequest, super::api::RunPodSandboxResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/RunPodSandbox",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_STOP_POD_SANDBOX: ::grpcio::Method<super::api::StopPodSandboxRequest, super::api::StopPodSandboxResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/StopPodSandbox",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_REMOVE_POD_SANDBOX: ::grpcio::Method<super::api::RemovePodSandboxRequest, super::api::RemovePodSandboxResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/RemovePodSandbox",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_POD_SANDBOX_STATUS: ::grpcio::Method<super::api::PodSandboxStatusRequest, super::api::PodSandboxStatusResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/PodSandboxStatus",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_LIST_POD_SANDBOX: ::grpcio::Method<super::api::ListPodSandboxRequest, super::api::ListPodSandboxResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ListPodSandbox",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_CREATE_CONTAINER: ::grpcio::Method<super::api::CreateContainerRequest, super::api::CreateContainerResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/CreateContainer",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_START_CONTAINER: ::grpcio::Method<super::api::StartContainerRequest, super::api::StartContainerResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/StartContainer",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_STOP_CONTAINER: ::grpcio::Method<super::api::StopContainerRequest, super::api::StopContainerResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/StopContainer",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_REMOVE_CONTAINER: ::grpcio::Method<super::api::RemoveContainerRequest, super::api::RemoveContainerResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/RemoveContainer",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_LIST_CONTAINERS: ::grpcio::Method<super::api::ListContainersRequest, super::api::ListContainersResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ListContainers",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_CONTAINER_STATUS: ::grpcio::Method<super::api::ContainerStatusRequest, super::api::ContainerStatusResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ContainerStatus",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_UPDATE_CONTAINER_RESOURCES: ::grpcio::Method<super::api::UpdateContainerResourcesRequest, super::api::UpdateContainerResourcesResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/UpdateContainerResources",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_REOPEN_CONTAINER_LOG: ::grpcio::Method<super::api::ReopenContainerLogRequest, super::api::ReopenContainerLogResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ReopenContainerLog",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_EXEC_SYNC: ::grpcio::Method<super::api::ExecSyncRequest, super::api::ExecSyncResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ExecSync",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_EXEC: ::grpcio::Method<super::api::ExecRequest, super::api::ExecResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/Exec",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_ATTACH: ::grpcio::Method<super::api::AttachRequest, super::api::AttachResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/Attach",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_PORT_FORWARD: ::grpcio::Method<super::api::PortForwardRequest, super::api::PortForwardResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/PortForward",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_CONTAINER_STATS: ::grpcio::Method<super::api::ContainerStatsRequest, super::api::ContainerStatsResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ContainerStats",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_LIST_CONTAINER_STATS: ::grpcio::Method<super::api::ListContainerStatsRequest, super::api::ListContainerStatsResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/ListContainerStats",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_UPDATE_RUNTIME_CONFIG: ::grpcio::Method<super::api::UpdateRuntimeConfigRequest, super::api::UpdateRuntimeConfigResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/UpdateRuntimeConfig",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_RUNTIME_SERVICE_STATUS: ::grpcio::Method<super::api::StatusRequest, super::api::StatusResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.RuntimeService/Status",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
#[derive(Clone)]
pub struct RuntimeServiceClient {
client: ::grpcio::Client,
}
impl RuntimeServiceClient {
pub fn new(channel: ::grpcio::Channel) -> Self {
RuntimeServiceClient {
client: ::grpcio::Client::new(channel),
}
}
pub fn version_opt(&self, req: &super::api::VersionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::VersionResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_VERSION, req, opt)
}
pub fn version(&self, req: &super::api::VersionRequest) -> ::grpcio::Result<super::api::VersionResponse> {
self.version_opt(req, ::grpcio::CallOption::default())
}
pub fn version_async_opt(&self, req: &super::api::VersionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::VersionResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_VERSION, req, opt)
}
pub fn version_async(&self, req: &super::api::VersionRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::VersionResponse>> {
self.version_async_opt(req, ::grpcio::CallOption::default())
}
pub fn run_pod_sandbox_opt(&self, req: &super::api::RunPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::RunPodSandboxResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_RUN_POD_SANDBOX, req, opt)
}
pub fn run_pod_sandbox(&self, req: &super::api::RunPodSandboxRequest) -> ::grpcio::Result<super::api::RunPodSandboxResponse> {
self.run_pod_sandbox_opt(req, ::grpcio::CallOption::default())
}
pub fn run_pod_sandbox_async_opt(&self, req: &super::api::RunPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RunPodSandboxResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_RUN_POD_SANDBOX, req, opt)
}
pub fn run_pod_sandbox_async(&self, req: &super::api::RunPodSandboxRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RunPodSandboxResponse>> {
self.run_pod_sandbox_async_opt(req, ::grpcio::CallOption::default())
}
pub fn stop_pod_sandbox_opt(&self, req: &super::api::StopPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::StopPodSandboxResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_STOP_POD_SANDBOX, req, opt)
}
pub fn stop_pod_sandbox(&self, req: &super::api::StopPodSandboxRequest) -> ::grpcio::Result<super::api::StopPodSandboxResponse> {
self.stop_pod_sandbox_opt(req, ::grpcio::CallOption::default())
}
pub fn stop_pod_sandbox_async_opt(&self, req: &super::api::StopPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StopPodSandboxResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_STOP_POD_SANDBOX, req, opt)
}
pub fn stop_pod_sandbox_async(&self, req: &super::api::StopPodSandboxRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StopPodSandboxResponse>> {
self.stop_pod_sandbox_async_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_pod_sandbox_opt(&self, req: &super::api::RemovePodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::RemovePodSandboxResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_REMOVE_POD_SANDBOX, req, opt)
}
pub fn remove_pod_sandbox(&self, req: &super::api::RemovePodSandboxRequest) -> ::grpcio::Result<super::api::RemovePodSandboxResponse> {
self.remove_pod_sandbox_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_pod_sandbox_async_opt(&self, req: &super::api::RemovePodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemovePodSandboxResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_REMOVE_POD_SANDBOX, req, opt)
}
pub fn remove_pod_sandbox_async(&self, req: &super::api::RemovePodSandboxRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemovePodSandboxResponse>> {
self.remove_pod_sandbox_async_opt(req, ::grpcio::CallOption::default())
}
pub fn pod_sandbox_status_opt(&self, req: &super::api::PodSandboxStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::PodSandboxStatusResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_POD_SANDBOX_STATUS, req, opt)
}
pub fn pod_sandbox_status(&self, req: &super::api::PodSandboxStatusRequest) -> ::grpcio::Result<super::api::PodSandboxStatusResponse> {
self.pod_sandbox_status_opt(req, ::grpcio::CallOption::default())
}
pub fn pod_sandbox_status_async_opt(&self, req: &super::api::PodSandboxStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PodSandboxStatusResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_POD_SANDBOX_STATUS, req, opt)
}
pub fn pod_sandbox_status_async(&self, req: &super::api::PodSandboxStatusRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PodSandboxStatusResponse>> {
self.pod_sandbox_status_async_opt(req, ::grpcio::CallOption::default())
}
pub fn list_pod_sandbox_opt(&self, req: &super::api::ListPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ListPodSandboxResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_LIST_POD_SANDBOX, req, opt)
}
pub fn list_pod_sandbox(&self, req: &super::api::ListPodSandboxRequest) -> ::grpcio::Result<super::api::ListPodSandboxResponse> {
self.list_pod_sandbox_opt(req, ::grpcio::CallOption::default())
}
pub fn list_pod_sandbox_async_opt(&self, req: &super::api::ListPodSandboxRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListPodSandboxResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_LIST_POD_SANDBOX, req, opt)
}
pub fn list_pod_sandbox_async(&self, req: &super::api::ListPodSandboxRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListPodSandboxResponse>> {
self.list_pod_sandbox_async_opt(req, ::grpcio::CallOption::default())
}
pub fn create_container_opt(&self, req: &super::api::CreateContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::CreateContainerResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_CREATE_CONTAINER, req, opt)
}
pub fn create_container(&self, req: &super::api::CreateContainerRequest) -> ::grpcio::Result<super::api::CreateContainerResponse> {
self.create_container_opt(req, ::grpcio::CallOption::default())
}
pub fn create_container_async_opt(&self, req: &super::api::CreateContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::CreateContainerResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_CREATE_CONTAINER, req, opt)
}
pub fn create_container_async(&self, req: &super::api::CreateContainerRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::CreateContainerResponse>> {
self.create_container_async_opt(req, ::grpcio::CallOption::default())
}
pub fn start_container_opt(&self, req: &super::api::StartContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::StartContainerResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_START_CONTAINER, req, opt)
}
pub fn start_container(&self, req: &super::api::StartContainerRequest) -> ::grpcio::Result<super::api::StartContainerResponse> {
self.start_container_opt(req, ::grpcio::CallOption::default())
}
pub fn start_container_async_opt(&self, req: &super::api::StartContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StartContainerResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_START_CONTAINER, req, opt)
}
pub fn start_container_async(&self, req: &super::api::StartContainerRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StartContainerResponse>> {
self.start_container_async_opt(req, ::grpcio::CallOption::default())
}
pub fn stop_container_opt(&self, req: &super::api::StopContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::StopContainerResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_STOP_CONTAINER, req, opt)
}
pub fn stop_container(&self, req: &super::api::StopContainerRequest) -> ::grpcio::Result<super::api::StopContainerResponse> {
self.stop_container_opt(req, ::grpcio::CallOption::default())
}
pub fn stop_container_async_opt(&self, req: &super::api::StopContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StopContainerResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_STOP_CONTAINER, req, opt)
}
pub fn stop_container_async(&self, req: &super::api::StopContainerRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StopContainerResponse>> {
self.stop_container_async_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_container_opt(&self, req: &super::api::RemoveContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::RemoveContainerResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_REMOVE_CONTAINER, req, opt)
}
pub fn remove_container(&self, req: &super::api::RemoveContainerRequest) -> ::grpcio::Result<super::api::RemoveContainerResponse> {
self.remove_container_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_container_async_opt(&self, req: &super::api::RemoveContainerRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemoveContainerResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_REMOVE_CONTAINER, req, opt)
}
pub fn remove_container_async(&self, req: &super::api::RemoveContainerRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemoveContainerResponse>> {
self.remove_container_async_opt(req, ::grpcio::CallOption::default())
}
pub fn list_containers_opt(&self, req: &super::api::ListContainersRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ListContainersResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_LIST_CONTAINERS, req, opt)
}
pub fn list_containers(&self, req: &super::api::ListContainersRequest) -> ::grpcio::Result<super::api::ListContainersResponse> {
self.list_containers_opt(req, ::grpcio::CallOption::default())
}
pub fn list_containers_async_opt(&self, req: &super::api::ListContainersRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListContainersResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_LIST_CONTAINERS, req, opt)
}
pub fn list_containers_async(&self, req: &super::api::ListContainersRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListContainersResponse>> {
self.list_containers_async_opt(req, ::grpcio::CallOption::default())
}
pub fn container_status_opt(&self, req: &super::api::ContainerStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ContainerStatusResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_CONTAINER_STATUS, req, opt)
}
pub fn container_status(&self, req: &super::api::ContainerStatusRequest) -> ::grpcio::Result<super::api::ContainerStatusResponse> {
self.container_status_opt(req, ::grpcio::CallOption::default())
}
pub fn container_status_async_opt(&self, req: &super::api::ContainerStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ContainerStatusResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_CONTAINER_STATUS, req, opt)
}
pub fn container_status_async(&self, req: &super::api::ContainerStatusRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ContainerStatusResponse>> {
self.container_status_async_opt(req, ::grpcio::CallOption::default())
}
pub fn update_container_resources_opt(&self, req: &super::api::UpdateContainerResourcesRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::UpdateContainerResourcesResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_UPDATE_CONTAINER_RESOURCES, req, opt)
}
pub fn update_container_resources(&self, req: &super::api::UpdateContainerResourcesRequest) -> ::grpcio::Result<super::api::UpdateContainerResourcesResponse> {
self.update_container_resources_opt(req, ::grpcio::CallOption::default())
}
pub fn update_container_resources_async_opt(&self, req: &super::api::UpdateContainerResourcesRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::UpdateContainerResourcesResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_UPDATE_CONTAINER_RESOURCES, req, opt)
}
pub fn update_container_resources_async(&self, req: &super::api::UpdateContainerResourcesRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::UpdateContainerResourcesResponse>> {
self.update_container_resources_async_opt(req, ::grpcio::CallOption::default())
}
pub fn reopen_container_log_opt(&self, req: &super::api::ReopenContainerLogRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ReopenContainerLogResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_REOPEN_CONTAINER_LOG, req, opt)
}
pub fn reopen_container_log(&self, req: &super::api::ReopenContainerLogRequest) -> ::grpcio::Result<super::api::ReopenContainerLogResponse> {
self.reopen_container_log_opt(req, ::grpcio::CallOption::default())
}
pub fn reopen_container_log_async_opt(&self, req: &super::api::ReopenContainerLogRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ReopenContainerLogResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_REOPEN_CONTAINER_LOG, req, opt)
}
pub fn reopen_container_log_async(&self, req: &super::api::ReopenContainerLogRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ReopenContainerLogResponse>> {
self.reopen_container_log_async_opt(req, ::grpcio::CallOption::default())
}
pub fn exec_sync_opt(&self, req: &super::api::ExecSyncRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ExecSyncResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_EXEC_SYNC, req, opt)
}
pub fn exec_sync(&self, req: &super::api::ExecSyncRequest) -> ::grpcio::Result<super::api::ExecSyncResponse> {
self.exec_sync_opt(req, ::grpcio::CallOption::default())
}
pub fn exec_sync_async_opt(&self, req: &super::api::ExecSyncRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ExecSyncResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_EXEC_SYNC, req, opt)
}
pub fn exec_sync_async(&self, req: &super::api::ExecSyncRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ExecSyncResponse>> {
self.exec_sync_async_opt(req, ::grpcio::CallOption::default())
}
pub fn exec_opt(&self, req: &super::api::ExecRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ExecResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_EXEC, req, opt)
}
pub fn exec(&self, req: &super::api::ExecRequest) -> ::grpcio::Result<super::api::ExecResponse> {
self.exec_opt(req, ::grpcio::CallOption::default())
}
pub fn exec_async_opt(&self, req: &super::api::ExecRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ExecResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_EXEC, req, opt)
}
pub fn exec_async(&self, req: &super::api::ExecRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ExecResponse>> {
self.exec_async_opt(req, ::grpcio::CallOption::default())
}
pub fn attach_opt(&self, req: &super::api::AttachRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::AttachResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_ATTACH, req, opt)
}
pub fn attach(&self, req: &super::api::AttachRequest) -> ::grpcio::Result<super::api::AttachResponse> {
self.attach_opt(req, ::grpcio::CallOption::default())
}
pub fn attach_async_opt(&self, req: &super::api::AttachRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::AttachResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_ATTACH, req, opt)
}
pub fn attach_async(&self, req: &super::api::AttachRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::AttachResponse>> {
self.attach_async_opt(req, ::grpcio::CallOption::default())
}
pub fn port_forward_opt(&self, req: &super::api::PortForwardRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::PortForwardResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_PORT_FORWARD, req, opt)
}
pub fn port_forward(&self, req: &super::api::PortForwardRequest) -> ::grpcio::Result<super::api::PortForwardResponse> {
self.port_forward_opt(req, ::grpcio::CallOption::default())
}
pub fn port_forward_async_opt(&self, req: &super::api::PortForwardRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PortForwardResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_PORT_FORWARD, req, opt)
}
pub fn port_forward_async(&self, req: &super::api::PortForwardRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PortForwardResponse>> {
self.port_forward_async_opt(req, ::grpcio::CallOption::default())
}
pub fn container_stats_opt(&self, req: &super::api::ContainerStatsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ContainerStatsResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_CONTAINER_STATS, req, opt)
}
pub fn container_stats(&self, req: &super::api::ContainerStatsRequest) -> ::grpcio::Result<super::api::ContainerStatsResponse> {
self.container_stats_opt(req, ::grpcio::CallOption::default())
}
pub fn container_stats_async_opt(&self, req: &super::api::ContainerStatsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ContainerStatsResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_CONTAINER_STATS, req, opt)
}
pub fn container_stats_async(&self, req: &super::api::ContainerStatsRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ContainerStatsResponse>> {
self.container_stats_async_opt(req, ::grpcio::CallOption::default())
}
pub fn list_container_stats_opt(&self, req: &super::api::ListContainerStatsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ListContainerStatsResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_LIST_CONTAINER_STATS, req, opt)
}
pub fn list_container_stats(&self, req: &super::api::ListContainerStatsRequest) -> ::grpcio::Result<super::api::ListContainerStatsResponse> {
self.list_container_stats_opt(req, ::grpcio::CallOption::default())
}
pub fn list_container_stats_async_opt(&self, req: &super::api::ListContainerStatsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListContainerStatsResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_LIST_CONTAINER_STATS, req, opt)
}
pub fn list_container_stats_async(&self, req: &super::api::ListContainerStatsRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListContainerStatsResponse>> {
self.list_container_stats_async_opt(req, ::grpcio::CallOption::default())
}
pub fn update_runtime_config_opt(&self, req: &super::api::UpdateRuntimeConfigRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::UpdateRuntimeConfigResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_UPDATE_RUNTIME_CONFIG, req, opt)
}
pub fn update_runtime_config(&self, req: &super::api::UpdateRuntimeConfigRequest) -> ::grpcio::Result<super::api::UpdateRuntimeConfigResponse> {
self.update_runtime_config_opt(req, ::grpcio::CallOption::default())
}
pub fn update_runtime_config_async_opt(&self, req: &super::api::UpdateRuntimeConfigRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::UpdateRuntimeConfigResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_UPDATE_RUNTIME_CONFIG, req, opt)
}
pub fn update_runtime_config_async(&self, req: &super::api::UpdateRuntimeConfigRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::UpdateRuntimeConfigResponse>> {
self.update_runtime_config_async_opt(req, ::grpcio::CallOption::default())
}
pub fn status_opt(&self, req: &super::api::StatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::StatusResponse> {
self.client.unary_call(&METHOD_RUNTIME_SERVICE_STATUS, req, opt)
}
pub fn status(&self, req: &super::api::StatusRequest) -> ::grpcio::Result<super::api::StatusResponse> {
self.status_opt(req, ::grpcio::CallOption::default())
}
pub fn status_async_opt(&self, req: &super::api::StatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StatusResponse>> {
self.client.unary_call_async(&METHOD_RUNTIME_SERVICE_STATUS, req, opt)
}
pub fn status_async(&self, req: &super::api::StatusRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::StatusResponse>> {
self.status_async_opt(req, ::grpcio::CallOption::default())
}
pub fn spawn<F>(&self, f: F) where F: ::futures::Future<Output = ()> + Send + 'static {
self.client.spawn(f)
}
}
pub trait RuntimeService {
fn version(&mut self, ctx: ::grpcio::RpcContext, req: super::api::VersionRequest, sink: ::grpcio::UnarySink<super::api::VersionResponse>);
fn run_pod_sandbox(&mut self, ctx: ::grpcio::RpcContext, req: super::api::RunPodSandboxRequest, sink: ::grpcio::UnarySink<super::api::RunPodSandboxResponse>);
fn stop_pod_sandbox(&mut self, ctx: ::grpcio::RpcContext, req: super::api::StopPodSandboxRequest, sink: ::grpcio::UnarySink<super::api::StopPodSandboxResponse>);
fn remove_pod_sandbox(&mut self, ctx: ::grpcio::RpcContext, req: super::api::RemovePodSandboxRequest, sink: ::grpcio::UnarySink<super::api::RemovePodSandboxResponse>);
fn pod_sandbox_status(&mut self, ctx: ::grpcio::RpcContext, req: super::api::PodSandboxStatusRequest, sink: ::grpcio::UnarySink<super::api::PodSandboxStatusResponse>);
fn list_pod_sandbox(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ListPodSandboxRequest, sink: ::grpcio::UnarySink<super::api::ListPodSandboxResponse>);
fn create_container(&mut self, ctx: ::grpcio::RpcContext, req: super::api::CreateContainerRequest, sink: ::grpcio::UnarySink<super::api::CreateContainerResponse>);
fn start_container(&mut self, ctx: ::grpcio::RpcContext, req: super::api::StartContainerRequest, sink: ::grpcio::UnarySink<super::api::StartContainerResponse>);
fn stop_container(&mut self, ctx: ::grpcio::RpcContext, req: super::api::StopContainerRequest, sink: ::grpcio::UnarySink<super::api::StopContainerResponse>);
fn remove_container(&mut self, ctx: ::grpcio::RpcContext, req: super::api::RemoveContainerRequest, sink: ::grpcio::UnarySink<super::api::RemoveContainerResponse>);
fn list_containers(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ListContainersRequest, sink: ::grpcio::UnarySink<super::api::ListContainersResponse>);
fn container_status(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ContainerStatusRequest, sink: ::grpcio::UnarySink<super::api::ContainerStatusResponse>);
fn update_container_resources(&mut self, ctx: ::grpcio::RpcContext, req: super::api::UpdateContainerResourcesRequest, sink: ::grpcio::UnarySink<super::api::UpdateContainerResourcesResponse>);
fn reopen_container_log(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ReopenContainerLogRequest, sink: ::grpcio::UnarySink<super::api::ReopenContainerLogResponse>);
fn exec_sync(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ExecSyncRequest, sink: ::grpcio::UnarySink<super::api::ExecSyncResponse>);
fn exec(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ExecRequest, sink: ::grpcio::UnarySink<super::api::ExecResponse>);
fn attach(&mut self, ctx: ::grpcio::RpcContext, req: super::api::AttachRequest, sink: ::grpcio::UnarySink<super::api::AttachResponse>);
fn port_forward(&mut self, ctx: ::grpcio::RpcContext, req: super::api::PortForwardRequest, sink: ::grpcio::UnarySink<super::api::PortForwardResponse>);
fn container_stats(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ContainerStatsRequest, sink: ::grpcio::UnarySink<super::api::ContainerStatsResponse>);
fn list_container_stats(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ListContainerStatsRequest, sink: ::grpcio::UnarySink<super::api::ListContainerStatsResponse>);
fn update_runtime_config(&mut self, ctx: ::grpcio::RpcContext, req: super::api::UpdateRuntimeConfigRequest, sink: ::grpcio::UnarySink<super::api::UpdateRuntimeConfigResponse>);
fn status(&mut self, ctx: ::grpcio::RpcContext, req: super::api::StatusRequest, sink: ::grpcio::UnarySink<super::api::StatusResponse>);
}
pub fn create_runtime_service<S: RuntimeService + Send + Clone + 'static>(s: S) -> ::grpcio::Service {
let mut builder = ::grpcio::ServiceBuilder::new();
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_VERSION, move |ctx, req, resp| {
instance.version(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_RUN_POD_SANDBOX, move |ctx, req, resp| {
instance.run_pod_sandbox(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_STOP_POD_SANDBOX, move |ctx, req, resp| {
instance.stop_pod_sandbox(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_REMOVE_POD_SANDBOX, move |ctx, req, resp| {
instance.remove_pod_sandbox(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_POD_SANDBOX_STATUS, move |ctx, req, resp| {
instance.pod_sandbox_status(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_LIST_POD_SANDBOX, move |ctx, req, resp| {
instance.list_pod_sandbox(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_CREATE_CONTAINER, move |ctx, req, resp| {
instance.create_container(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_START_CONTAINER, move |ctx, req, resp| {
instance.start_container(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_STOP_CONTAINER, move |ctx, req, resp| {
instance.stop_container(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_REMOVE_CONTAINER, move |ctx, req, resp| {
instance.remove_container(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_LIST_CONTAINERS, move |ctx, req, resp| {
instance.list_containers(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_CONTAINER_STATUS, move |ctx, req, resp| {
instance.container_status(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_UPDATE_CONTAINER_RESOURCES, move |ctx, req, resp| {
instance.update_container_resources(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_REOPEN_CONTAINER_LOG, move |ctx, req, resp| {
instance.reopen_container_log(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_EXEC_SYNC, move |ctx, req, resp| {
instance.exec_sync(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_EXEC, move |ctx, req, resp| {
instance.exec(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_ATTACH, move |ctx, req, resp| {
instance.attach(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_PORT_FORWARD, move |ctx, req, resp| {
instance.port_forward(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_CONTAINER_STATS, move |ctx, req, resp| {
instance.container_stats(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_LIST_CONTAINER_STATS, move |ctx, req, resp| {
instance.list_container_stats(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_UPDATE_RUNTIME_CONFIG, move |ctx, req, resp| {
instance.update_runtime_config(ctx, req, resp)
});
let mut instance = s;
builder = builder.add_unary_handler(&METHOD_RUNTIME_SERVICE_STATUS, move |ctx, req, resp| {
instance.status(ctx, req, resp)
});
builder.build()
}
const METHOD_IMAGE_SERVICE_LIST_IMAGES: ::grpcio::Method<super::api::ListImagesRequest, super::api::ListImagesResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.ImageService/ListImages",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_IMAGE_SERVICE_IMAGE_STATUS: ::grpcio::Method<super::api::ImageStatusRequest, super::api::ImageStatusResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.ImageService/ImageStatus",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_IMAGE_SERVICE_PULL_IMAGE: ::grpcio::Method<super::api::PullImageRequest, super::api::PullImageResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.ImageService/PullImage",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_IMAGE_SERVICE_REMOVE_IMAGE: ::grpcio::Method<super::api::RemoveImageRequest, super::api::RemoveImageResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.ImageService/RemoveImage",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
const METHOD_IMAGE_SERVICE_IMAGE_FS_INFO: ::grpcio::Method<super::api::ImageFsInfoRequest, super::api::ImageFsInfoResponse> = ::grpcio::Method {
ty: ::grpcio::MethodType::Unary,
name: "/runtime.v1alpha2.ImageService/ImageFsInfo",
req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
};
#[derive(Clone)]
pub struct ImageServiceClient {
client: ::grpcio::Client,
}
impl ImageServiceClient {
pub fn new(channel: ::grpcio::Channel) -> Self {
ImageServiceClient {
client: ::grpcio::Client::new(channel),
}
}
pub fn list_images_opt(&self, req: &super::api::ListImagesRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ListImagesResponse> {
self.client.unary_call(&METHOD_IMAGE_SERVICE_LIST_IMAGES, req, opt)
}
pub fn list_images(&self, req: &super::api::ListImagesRequest) -> ::grpcio::Result<super::api::ListImagesResponse> {
self.list_images_opt(req, ::grpcio::CallOption::default())
}
pub fn list_images_async_opt(&self, req: &super::api::ListImagesRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListImagesResponse>> {
self.client.unary_call_async(&METHOD_IMAGE_SERVICE_LIST_IMAGES, req, opt)
}
pub fn list_images_async(&self, req: &super::api::ListImagesRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ListImagesResponse>> {
self.list_images_async_opt(req, ::grpcio::CallOption::default())
}
pub fn image_status_opt(&self, req: &super::api::ImageStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ImageStatusResponse> {
self.client.unary_call(&METHOD_IMAGE_SERVICE_IMAGE_STATUS, req, opt)
}
pub fn image_status(&self, req: &super::api::ImageStatusRequest) -> ::grpcio::Result<super::api::ImageStatusResponse> {
self.image_status_opt(req, ::grpcio::CallOption::default())
}
pub fn image_status_async_opt(&self, req: &super::api::ImageStatusRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ImageStatusResponse>> {
self.client.unary_call_async(&METHOD_IMAGE_SERVICE_IMAGE_STATUS, req, opt)
}
pub fn image_status_async(&self, req: &super::api::ImageStatusRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ImageStatusResponse>> {
self.image_status_async_opt(req, ::grpcio::CallOption::default())
}
pub fn pull_image_opt(&self, req: &super::api::PullImageRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::PullImageResponse> {
self.client.unary_call(&METHOD_IMAGE_SERVICE_PULL_IMAGE, req, opt)
}
pub fn pull_image(&self, req: &super::api::PullImageRequest) -> ::grpcio::Result<super::api::PullImageResponse> {
self.pull_image_opt(req, ::grpcio::CallOption::default())
}
pub fn pull_image_async_opt(&self, req: &super::api::PullImageRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PullImageResponse>> {
self.client.unary_call_async(&METHOD_IMAGE_SERVICE_PULL_IMAGE, req, opt)
}
pub fn pull_image_async(&self, req: &super::api::PullImageRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::PullImageResponse>> {
self.pull_image_async_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_image_opt(&self, req: &super::api::RemoveImageRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::RemoveImageResponse> {
self.client.unary_call(&METHOD_IMAGE_SERVICE_REMOVE_IMAGE, req, opt)
}
pub fn remove_image(&self, req: &super::api::RemoveImageRequest) -> ::grpcio::Result<super::api::RemoveImageResponse> {
self.remove_image_opt(req, ::grpcio::CallOption::default())
}
pub fn remove_image_async_opt(&self, req: &super::api::RemoveImageRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemoveImageResponse>> {
self.client.unary_call_async(&METHOD_IMAGE_SERVICE_REMOVE_IMAGE, req, opt)
}
pub fn remove_image_async(&self, req: &super::api::RemoveImageRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::RemoveImageResponse>> {
self.remove_image_async_opt(req, ::grpcio::CallOption::default())
}
pub fn image_fs_info_opt(&self, req: &super::api::ImageFsInfoRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::api::ImageFsInfoResponse> {
self.client.unary_call(&METHOD_IMAGE_SERVICE_IMAGE_FS_INFO, req, opt)
}
pub fn image_fs_info(&self, req: &super::api::ImageFsInfoRequest) -> ::grpcio::Result<super::api::ImageFsInfoResponse> {
self.image_fs_info_opt(req, ::grpcio::CallOption::default())
}
pub fn image_fs_info_async_opt(&self, req: &super::api::ImageFsInfoRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ImageFsInfoResponse>> {
self.client.unary_call_async(&METHOD_IMAGE_SERVICE_IMAGE_FS_INFO, req, opt)
}
pub fn image_fs_info_async(&self, req: &super::api::ImageFsInfoRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::api::ImageFsInfoResponse>> {
self.image_fs_info_async_opt(req, ::grpcio::CallOption::default())
}
pub fn spawn<F>(&self, f: F) where F: ::futures::Future<Output = ()> + Send + 'static {
self.client.spawn(f)
}
}
pub trait ImageService {
fn list_images(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ListImagesRequest, sink: ::grpcio::UnarySink<super::api::ListImagesResponse>);
fn image_status(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ImageStatusRequest, sink: ::grpcio::UnarySink<super::api::ImageStatusResponse>);
fn pull_image(&mut self, ctx: ::grpcio::RpcContext, req: super::api::PullImageRequest, sink: ::grpcio::UnarySink<super::api::PullImageResponse>);
fn remove_image(&mut self, ctx: ::grpcio::RpcContext, req: super::api::RemoveImageRequest, sink: ::grpcio::UnarySink<super::api::RemoveImageResponse>);
fn image_fs_info(&mut self, ctx: ::grpcio::RpcContext, req: super::api::ImageFsInfoRequest, sink: ::grpcio::UnarySink<super::api::ImageFsInfoResponse>);
}
pub fn create_image_service<S: ImageService + Send + Clone + 'static>(s: S) -> ::grpcio::Service {
let mut builder = ::grpcio::ServiceBuilder::new();
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_IMAGE_SERVICE_LIST_IMAGES, move |ctx, req, resp| {
instance.list_images(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_IMAGE_SERVICE_IMAGE_STATUS, move |ctx, req, resp| {
instance.image_status(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_IMAGE_SERVICE_PULL_IMAGE, move |ctx, req, resp| {
instance.pull_image(ctx, req, resp)
});
let mut instance = s.clone();
builder = builder.add_unary_handler(&METHOD_IMAGE_SERVICE_REMOVE_IMAGE, move |ctx, req, resp| {
instance.remove_image(ctx, req, resp)
});
let mut instance = s;
builder = builder.add_unary_handler(&METHOD_IMAGE_SERVICE_IMAGE_FS_INFO, move |ctx, req, resp| {
instance.image_fs_info(ctx, req, resp)
});
builder.build()
}