mirror of
https://github.com/ceph/ceph
synced 2025-02-20 01:17:47 +00:00
Merge pull request #61089 from pecastro/mgr_proto_build_generation
pybind/mgr: Protobuffer file generation for grpc deps. Reviewed-by: baum <NOT@FOUND> Reviewed-by: ceph-jenkins <NOT@FOUND> Reviewed-by: Ernesto Puerta <epuertat@redhat.com> Reviewed-by: Nizamudeen A <nia@redhat.com>
This commit is contained in:
Nizamudeen A
GitHub
commit
aa292e8c9a
5
.gitignore
vendored
5
.gitignore
vendored
@ -97,3 +97,8 @@ src/pybind/rbd/rbd.egg-info/
|
||||
src/pybind/rgw/build/
|
||||
src/pybind/rgw/rgw.c
|
||||
src/pybind/rgw/rgw.egg-info/
|
||||
|
||||
# GRPC protobuff file generation #PR 61089
|
||||
src/pybind/mgr/dashboard/services/proto/gateway.proto
|
||||
src/pybind/mgr/dashboard/services/proto/gateway_pb2.py
|
||||
src/pybind/mgr/dashboard/services/proto/gateway_pb2_grpc.py
|
||||
@ -1 +1 @@
|
||||
Subproject commit 322a86f7348af1bc173f01e6cc4b64e9a8075727
|
||||
Subproject commit bfed932f33367d055176fc921da68da517c59a6d
|
||||
@ -1,3 +1,32 @@
|
||||
# Required for building the dashboard grpc protos at build time
|
||||
set(CEPH_GRPC_VIRTUALENV ${CEPH_BUILD_VIRTUALENV}/ceph-grpc-virtualenv)
|
||||
set(CEPH_NVME_GATEWAY_PROTO_DIR ${CMAKE_CURRENT_SOURCE_DIR}/../../../../src/nvmeof/gateway/control/proto)
|
||||
|
||||
add_custom_command(
|
||||
OUTPUT ${CEPH_GRPC_VIRTUALENV}/lib/python*/site-packages/grpc_tools
|
||||
COMMAND ${CMAKE_SOURCE_DIR}/src/tools/setup-virtualenv.sh --python=${Python3_EXECUTABLE} ${CEPH_GRPC_VIRTUALENV}
|
||||
COMMAND ${CEPH_GRPC_VIRTUALENV}/bin/pip install grpcio-tools
|
||||
WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}
|
||||
COMMENT "grpcio-tools is being installed")
|
||||
|
||||
# protobuffer files generation
|
||||
add_custom_command(
|
||||
OUTPUT "${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2.py" "${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2_grpc.py"
|
||||
COMMAND cp ${CEPH_NVME_GATEWAY_PROTO_DIR}/gateway.proto dashboard/services/proto/gateway.proto
|
||||
COMMAND . ${CEPH_GRPC_VIRTUALENV}/bin/activate && ${CEPH_GRPC_VIRTUALENV}/bin/python -m grpc_tools.protoc --proto_path=. --python_out=. --grpc_python_out=. dashboard/services/proto/gateway.proto && deactivate
|
||||
WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}/..
|
||||
DEPENDS ${CEPH_NVME_GATEWAY_PROTO_DIR}/gateway.proto ${CEPH_GRPC_VIRTUALENV}/lib/python*/site-packages/grpc_tools
|
||||
COMMENT "proto generation for grpc deps")
|
||||
add_custom_target(mgr-dashboard-services-deps
|
||||
DEPENDS ${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2.py ${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2_grpc.py
|
||||
WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR})
|
||||
|
||||
add_custom_target(mgr-dashboard-services-build
|
||||
ALL
|
||||
DEPENDS mgr-dashboard-services-deps)
|
||||
|
||||
add_dependencies(tests mgr-dashboard-services-build)
|
||||
|
||||
install(DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}
|
||||
DESTINATION ${CEPH_INSTALL_DATADIR}/mgr
|
||||
${mgr_module_install_excludes}
|
||||
@ -14,6 +43,7 @@ if(WITH_MGR_DASHBOARD_FRONTEND)
|
||||
add_tox_test(mgr-dashboard-check TOX_ENVS check)
|
||||
add_tox_test(mgr-dashboard-openapi TOX_ENVS openapi-check)
|
||||
endif()
|
||||
|
||||
else()
|
||||
if(EXISTS ${CMAKE_CURRENT_SOURCE_DIR}/frontend/dist)
|
||||
# prebuilt
|
||||
|
||||
@ -11,5 +11,5 @@ pyyaml
|
||||
natsort
|
||||
setuptools
|
||||
jsonpatch
|
||||
grpcio==1.46.5
|
||||
grpcio-tools==1.46.5
|
||||
grpcio
|
||||
grpcio-tools
|
||||
|
||||
0
src/pybind/mgr/dashboard/services/proto/.gitkeep
Normal file
0
src/pybind/mgr/dashboard/services/proto/.gitkeep
Normal file
@ -1,488 +0,0 @@
|
||||
//
|
||||
// Copyright (c) 2021 International Business Machines
|
||||
// All rights reserved.
|
||||
//
|
||||
// SPDX-License-Identifier: MIT
|
||||
//
|
||||
// Authors: anita.shekar@ibm.com, sandy.kaur@ibm.com
|
||||
//
|
||||
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
enum AddressFamily {
|
||||
ipv4 = 0;
|
||||
ipv6 = 1;
|
||||
}
|
||||
|
||||
enum LogLevel {
|
||||
ERROR = 0;
|
||||
WARNING = 1;
|
||||
NOTICE = 2;
|
||||
INFO = 3;
|
||||
DEBUG = 4;
|
||||
}
|
||||
|
||||
enum GwLogLevel {
|
||||
notset = 0;
|
||||
debug = 10;
|
||||
info = 20;
|
||||
warning = 30;
|
||||
error = 40;
|
||||
critical = 50;
|
||||
}
|
||||
|
||||
service Gateway {
|
||||
// Creates a namespace from an RBD image
|
||||
rpc namespace_add(namespace_add_req) returns (nsid_status) {}
|
||||
|
||||
// Creates a subsystem
|
||||
rpc create_subsystem(create_subsystem_req) returns(req_status) {}
|
||||
|
||||
// Deletes a subsystem
|
||||
rpc delete_subsystem(delete_subsystem_req) returns(req_status) {}
|
||||
|
||||
// List namespaces
|
||||
rpc list_namespaces(list_namespaces_req) returns(namespaces_info) {}
|
||||
|
||||
// Resizes a namespace
|
||||
rpc namespace_resize(namespace_resize_req) returns (req_status) {}
|
||||
|
||||
// Gets namespace's IO stats
|
||||
rpc namespace_get_io_stats(namespace_get_io_stats_req) returns (namespace_io_stats_info) {}
|
||||
|
||||
// Sets namespace's qos limits
|
||||
rpc namespace_set_qos_limits(namespace_set_qos_req) returns (req_status) {}
|
||||
|
||||
// Changes namespace's load balancing group
|
||||
rpc namespace_change_load_balancing_group(namespace_change_load_balancing_group_req) returns (req_status) {}
|
||||
|
||||
// Deletes a namespace
|
||||
rpc namespace_delete(namespace_delete_req) returns (req_status) {}
|
||||
|
||||
// Adds a host to a subsystem
|
||||
rpc add_host(add_host_req) returns (req_status) {}
|
||||
|
||||
// Removes a host from a subsystem
|
||||
rpc remove_host(remove_host_req) returns (req_status) {}
|
||||
|
||||
// List hosts
|
||||
rpc list_hosts(list_hosts_req) returns(hosts_info) {}
|
||||
|
||||
// List connections
|
||||
rpc list_connections(list_connections_req) returns(connections_info) {}
|
||||
|
||||
// Creates a listener for a subsystem at a given IP/Port
|
||||
rpc create_listener(create_listener_req) returns(req_status) {}
|
||||
|
||||
// Deletes a listener from a subsystem at a given IP/Port
|
||||
rpc delete_listener(delete_listener_req) returns(req_status) {}
|
||||
|
||||
// List listeners
|
||||
rpc list_listeners(list_listeners_req) returns(listeners_info) {}
|
||||
|
||||
// List subsystems
|
||||
rpc list_subsystems(list_subsystems_req) returns(subsystems_info_cli) {}
|
||||
|
||||
// Gets subsystems
|
||||
rpc get_subsystems(get_subsystems_req) returns(subsystems_info) {}
|
||||
|
||||
// Set gateway ANA states
|
||||
rpc set_ana_state(ana_info) returns(req_status) {}
|
||||
|
||||
// Gets spdk nvmf log flags and level
|
||||
rpc get_spdk_nvmf_log_flags_and_level(get_spdk_nvmf_log_flags_and_level_req) returns(spdk_nvmf_log_flags_and_level_info) {}
|
||||
|
||||
// Disables spdk nvmf logs
|
||||
rpc disable_spdk_nvmf_logs(disable_spdk_nvmf_logs_req) returns(req_status) {}
|
||||
|
||||
// Set spdk nvmf logs
|
||||
rpc set_spdk_nvmf_logs(set_spdk_nvmf_logs_req) returns(req_status) {}
|
||||
|
||||
// Get gateway info
|
||||
rpc get_gateway_info(get_gateway_info_req) returns(gateway_info) {}
|
||||
|
||||
// Get gateway log level
|
||||
rpc get_gateway_log_level(get_gateway_log_level_req) returns(gateway_log_level_info) {}
|
||||
|
||||
// Set gateway log level
|
||||
rpc set_gateway_log_level(set_gateway_log_level_req) returns(req_status) {}
|
||||
}
|
||||
|
||||
// Request messages
|
||||
|
||||
message namespace_add_req {
|
||||
string rbd_pool_name = 1;
|
||||
string rbd_image_name = 2;
|
||||
string subsystem_nqn = 3;
|
||||
optional uint32 nsid = 4;
|
||||
uint32 block_size = 5;
|
||||
optional string uuid = 6;
|
||||
optional int32 anagrpid = 7;
|
||||
optional bool create_image = 8;
|
||||
optional uint64 size = 9;
|
||||
optional bool force = 10;
|
||||
}
|
||||
|
||||
message namespace_resize_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
uint64 new_size = 4;
|
||||
}
|
||||
|
||||
message namespace_get_io_stats_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
}
|
||||
|
||||
message namespace_set_qos_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
optional uint64 rw_ios_per_second = 4;
|
||||
optional uint64 rw_mbytes_per_second = 5;
|
||||
optional uint64 r_mbytes_per_second = 6;
|
||||
optional uint64 w_mbytes_per_second = 7;
|
||||
}
|
||||
|
||||
message namespace_change_load_balancing_group_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
int32 anagrpid = 4;
|
||||
}
|
||||
|
||||
message namespace_delete_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
}
|
||||
|
||||
message create_subsystem_req {
|
||||
string subsystem_nqn = 1;
|
||||
string serial_number = 2;
|
||||
optional uint32 max_namespaces = 3;
|
||||
bool enable_ha = 4;
|
||||
}
|
||||
|
||||
message delete_subsystem_req {
|
||||
string subsystem_nqn = 1;
|
||||
optional bool force = 2;
|
||||
}
|
||||
|
||||
message list_namespaces_req {
|
||||
string subsystem = 1;
|
||||
optional uint32 nsid = 2;
|
||||
optional string uuid = 3;
|
||||
}
|
||||
|
||||
message add_host_req {
|
||||
string subsystem_nqn = 1;
|
||||
string host_nqn = 2;
|
||||
}
|
||||
|
||||
message remove_host_req {
|
||||
string subsystem_nqn = 1;
|
||||
string host_nqn = 2;
|
||||
}
|
||||
|
||||
message list_hosts_req {
|
||||
string subsystem = 1;
|
||||
}
|
||||
|
||||
message list_connections_req {
|
||||
string subsystem = 1;
|
||||
}
|
||||
|
||||
message create_listener_req {
|
||||
string nqn = 1;
|
||||
string host_name = 2;
|
||||
string traddr = 3;
|
||||
optional AddressFamily adrfam = 5;
|
||||
optional uint32 trsvcid = 6;
|
||||
}
|
||||
|
||||
message delete_listener_req {
|
||||
string nqn = 1;
|
||||
string host_name = 2;
|
||||
string traddr = 3;
|
||||
optional AddressFamily adrfam = 5;
|
||||
optional uint32 trsvcid = 6;
|
||||
optional bool force = 7;
|
||||
}
|
||||
|
||||
message list_listeners_req {
|
||||
string subsystem = 1;
|
||||
}
|
||||
|
||||
message list_subsystems_req {
|
||||
optional string subsystem_nqn = 1;
|
||||
optional string serial_number = 2;
|
||||
}
|
||||
|
||||
message get_subsystems_req {
|
||||
}
|
||||
|
||||
message get_spdk_nvmf_log_flags_and_level_req {
|
||||
}
|
||||
|
||||
message disable_spdk_nvmf_logs_req {
|
||||
}
|
||||
|
||||
message set_spdk_nvmf_logs_req {
|
||||
optional LogLevel log_level = 1;
|
||||
optional LogLevel print_level = 2;
|
||||
}
|
||||
|
||||
message get_gateway_info_req {
|
||||
optional string cli_version = 1;
|
||||
}
|
||||
|
||||
message get_gateway_log_level_req {
|
||||
}
|
||||
|
||||
message set_gateway_log_level_req {
|
||||
GwLogLevel log_level = 1;
|
||||
}
|
||||
|
||||
// From https://nvmexpress.org/wp-content/uploads/NVM-Express-1_4-2019.06.10-Ratified.pdf page 138
|
||||
// Asymmetric Namespace Access state for all namespaces in this ANA
|
||||
// Group when accessed through this controller.
|
||||
// Value Description Reference
|
||||
// 01h ANA Optimized state 8.20.3.1
|
||||
// 02h ANA Non-Optimized state 8.20.3.2
|
||||
// 03h ANA Inaccessible state 8.20.3.3
|
||||
// 04h ANA Persistent Loss state 8.20.3.4
|
||||
// 0Fh ANA Change state 8.20.3.5
|
||||
// All others Reserved
|
||||
enum ana_state {
|
||||
UNSET = 0;
|
||||
OPTIMIZED = 1;
|
||||
NON_OPTIMIZED = 2;
|
||||
INACCESSIBLE = 3;
|
||||
}
|
||||
|
||||
message ana_group_state {
|
||||
uint32 grp_id = 1; // groupd id
|
||||
ana_state state = 2; // ANA state
|
||||
}
|
||||
|
||||
message nqn_ana_states {
|
||||
string nqn = 1; // subsystem nqn
|
||||
repeated ana_group_state states = 2; // list of group states
|
||||
}
|
||||
|
||||
message ana_info {
|
||||
repeated nqn_ana_states states = 1; // list of nqn states
|
||||
}
|
||||
|
||||
// Return messages
|
||||
|
||||
message req_status {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
}
|
||||
|
||||
message nsid_status {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
uint32 nsid = 3;
|
||||
}
|
||||
|
||||
message subsystems_info {
|
||||
repeated subsystem subsystems = 1;
|
||||
}
|
||||
|
||||
message subsystem {
|
||||
string nqn = 1;
|
||||
string subtype = 2;
|
||||
repeated listen_address listen_addresses = 3;
|
||||
repeated host hosts = 4;
|
||||
bool allow_any_host = 5;
|
||||
optional string serial_number = 6;
|
||||
optional string model_number = 7;
|
||||
optional uint32 max_namespaces = 8;
|
||||
optional uint32 min_cntlid = 9;
|
||||
optional uint32 max_cntlid = 10;
|
||||
repeated namespace namespaces = 11;
|
||||
}
|
||||
|
||||
message listen_address {
|
||||
string trtype = 1;
|
||||
string adrfam = 2;
|
||||
string traddr = 3;
|
||||
string trsvcid = 4;
|
||||
optional string transport = 5;
|
||||
}
|
||||
|
||||
message namespace {
|
||||
uint32 nsid = 1;
|
||||
string name = 2;
|
||||
optional string bdev_name = 3;
|
||||
optional string nguid = 4;
|
||||
optional string uuid = 5;
|
||||
optional uint32 anagrpid = 6;
|
||||
optional string nonce = 7;
|
||||
}
|
||||
|
||||
message subsystems_info_cli {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
repeated subsystem_cli subsystems = 3;
|
||||
}
|
||||
|
||||
message subsystem_cli {
|
||||
string nqn = 1;
|
||||
bool enable_ha = 2;
|
||||
string serial_number = 3;
|
||||
string model_number = 4;
|
||||
uint32 min_cntlid = 5;
|
||||
uint32 max_cntlid = 6;
|
||||
uint32 namespace_count = 7;
|
||||
string subtype = 8;
|
||||
uint32 max_namespaces = 9;
|
||||
}
|
||||
|
||||
message gateway_info {
|
||||
string cli_version = 1;
|
||||
string version = 2;
|
||||
string name = 3;
|
||||
string group = 4;
|
||||
string addr = 5;
|
||||
string port = 6;
|
||||
bool bool_status = 7;
|
||||
int32 status = 8;
|
||||
string error_message = 9;
|
||||
optional string spdk_version = 10;
|
||||
uint32 load_balancing_group = 11;
|
||||
string hostname = 12;
|
||||
}
|
||||
|
||||
message cli_version {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
string version = 3;
|
||||
}
|
||||
|
||||
message gw_version {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
string version = 3;
|
||||
}
|
||||
|
||||
message listener_info {
|
||||
string host_name = 1;
|
||||
string trtype = 2;
|
||||
AddressFamily adrfam = 3;
|
||||
string traddr = 4;
|
||||
uint32 trsvcid = 5;
|
||||
}
|
||||
|
||||
message listeners_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
repeated listener_info listeners = 3;
|
||||
}
|
||||
|
||||
message host {
|
||||
string nqn = 1;
|
||||
}
|
||||
|
||||
message hosts_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
bool allow_any_host = 3;
|
||||
string subsystem_nqn = 4;
|
||||
repeated host hosts = 5;
|
||||
}
|
||||
|
||||
message connection {
|
||||
string nqn = 1;
|
||||
string traddr = 2;
|
||||
uint32 trsvcid = 3;
|
||||
string trtype = 4;
|
||||
AddressFamily adrfam = 5;
|
||||
bool connected = 6;
|
||||
int32 qpairs_count = 7;
|
||||
int32 controller_id = 8;
|
||||
}
|
||||
|
||||
message connections_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
string subsystem_nqn = 3;
|
||||
repeated connection connections = 4;
|
||||
}
|
||||
|
||||
message namespace_cli {
|
||||
uint32 nsid = 1;
|
||||
string bdev_name = 2;
|
||||
string rbd_image_name = 3;
|
||||
string rbd_pool_name = 4;
|
||||
uint32 load_balancing_group = 5;
|
||||
uint32 block_size = 6;
|
||||
uint64 rbd_image_size = 7;
|
||||
string uuid = 8;
|
||||
uint64 rw_ios_per_second = 9;
|
||||
uint64 rw_mbytes_per_second = 10;
|
||||
uint64 r_mbytes_per_second = 11;
|
||||
uint64 w_mbytes_per_second = 12;
|
||||
}
|
||||
|
||||
message namespaces_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
string subsystem_nqn = 3;
|
||||
repeated namespace_cli namespaces = 4;
|
||||
}
|
||||
|
||||
message namespace_io_stats_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
string subsystem_nqn = 3;
|
||||
uint32 nsid = 4;
|
||||
string uuid = 5;
|
||||
string bdev_name = 6;
|
||||
uint64 tick_rate = 7;
|
||||
uint64 ticks = 8;
|
||||
uint64 bytes_read = 9;
|
||||
uint64 num_read_ops = 10;
|
||||
uint64 bytes_written = 11;
|
||||
uint64 num_write_ops = 12;
|
||||
uint64 bytes_unmapped = 13;
|
||||
uint64 num_unmap_ops = 14;
|
||||
uint64 read_latency_ticks = 15;
|
||||
uint64 max_read_latency_ticks = 16;
|
||||
uint64 min_read_latency_ticks = 17;
|
||||
uint64 write_latency_ticks = 18;
|
||||
uint64 max_write_latency_ticks = 19;
|
||||
uint64 min_write_latency_ticks = 20;
|
||||
uint64 unmap_latency_ticks = 21;
|
||||
uint64 max_unmap_latency_ticks = 22;
|
||||
uint64 min_unmap_latency_ticks = 23;
|
||||
uint64 copy_latency_ticks = 24;
|
||||
uint64 max_copy_latency_ticks = 25;
|
||||
uint64 min_copy_latency_ticks = 26;
|
||||
repeated uint32 io_error = 27;
|
||||
}
|
||||
|
||||
message spdk_log_flag_info {
|
||||
string name = 1;
|
||||
bool enabled = 2;
|
||||
}
|
||||
|
||||
message spdk_nvmf_log_flags_and_level_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
repeated spdk_log_flag_info nvmf_log_flags = 3;
|
||||
LogLevel log_level = 4;
|
||||
LogLevel log_print_level = 5;
|
||||
}
|
||||
|
||||
message gateway_log_level_info {
|
||||
int32 status = 1;
|
||||
string error_message = 2;
|
||||
GwLogLevel log_level = 3;
|
||||
}
|
||||
File diff suppressed because one or more lines are too long
@ -1,883 +0,0 @@
|
||||
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
|
||||
"""Client and server classes corresponding to protobuf-defined services."""
|
||||
import grpc
|
||||
|
||||
from dashboard.services.proto import gateway_pb2 as dashboard_dot_services_dot_proto_dot_gateway__pb2
|
||||
|
||||
|
||||
class GatewayStub(object):
|
||||
"""Missing associated documentation comment in .proto file."""
|
||||
|
||||
def __init__(self, channel):
|
||||
"""Constructor.
|
||||
|
||||
Args:
|
||||
channel: A grpc.Channel.
|
||||
"""
|
||||
self.namespace_add = channel.unary_unary(
|
||||
'/Gateway/namespace_add',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.FromString,
|
||||
)
|
||||
self.create_subsystem = channel.unary_unary(
|
||||
'/Gateway/create_subsystem',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.delete_subsystem = channel.unary_unary(
|
||||
'/Gateway/delete_subsystem',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.list_namespaces = channel.unary_unary(
|
||||
'/Gateway/list_namespaces',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.FromString,
|
||||
)
|
||||
self.namespace_resize = channel.unary_unary(
|
||||
'/Gateway/namespace_resize',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.namespace_get_io_stats = channel.unary_unary(
|
||||
'/Gateway/namespace_get_io_stats',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.FromString,
|
||||
)
|
||||
self.namespace_set_qos_limits = channel.unary_unary(
|
||||
'/Gateway/namespace_set_qos_limits',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.namespace_change_load_balancing_group = channel.unary_unary(
|
||||
'/Gateway/namespace_change_load_balancing_group',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.namespace_delete = channel.unary_unary(
|
||||
'/Gateway/namespace_delete',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.add_host = channel.unary_unary(
|
||||
'/Gateway/add_host',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.remove_host = channel.unary_unary(
|
||||
'/Gateway/remove_host',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.list_hosts = channel.unary_unary(
|
||||
'/Gateway/list_hosts',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.FromString,
|
||||
)
|
||||
self.list_connections = channel.unary_unary(
|
||||
'/Gateway/list_connections',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.FromString,
|
||||
)
|
||||
self.create_listener = channel.unary_unary(
|
||||
'/Gateway/create_listener',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.delete_listener = channel.unary_unary(
|
||||
'/Gateway/delete_listener',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.list_listeners = channel.unary_unary(
|
||||
'/Gateway/list_listeners',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.FromString,
|
||||
)
|
||||
self.list_subsystems = channel.unary_unary(
|
||||
'/Gateway/list_subsystems',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.FromString,
|
||||
)
|
||||
self.get_subsystems = channel.unary_unary(
|
||||
'/Gateway/get_subsystems',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.FromString,
|
||||
)
|
||||
self.set_ana_state = channel.unary_unary(
|
||||
'/Gateway/set_ana_state',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.get_spdk_nvmf_log_flags_and_level = channel.unary_unary(
|
||||
'/Gateway/get_spdk_nvmf_log_flags_and_level',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.FromString,
|
||||
)
|
||||
self.disable_spdk_nvmf_logs = channel.unary_unary(
|
||||
'/Gateway/disable_spdk_nvmf_logs',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.set_spdk_nvmf_logs = channel.unary_unary(
|
||||
'/Gateway/set_spdk_nvmf_logs',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
self.get_gateway_info = channel.unary_unary(
|
||||
'/Gateway/get_gateway_info',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.FromString,
|
||||
)
|
||||
self.get_gateway_log_level = channel.unary_unary(
|
||||
'/Gateway/get_gateway_log_level',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.FromString,
|
||||
)
|
||||
self.set_gateway_log_level = channel.unary_unary(
|
||||
'/Gateway/set_gateway_log_level',
|
||||
request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.SerializeToString,
|
||||
response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
)
|
||||
|
||||
|
||||
class GatewayServicer(object):
|
||||
"""Missing associated documentation comment in .proto file."""
|
||||
|
||||
def namespace_add(self, request, context):
|
||||
"""Creates a namespace from an RBD image
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def create_subsystem(self, request, context):
|
||||
"""Creates a subsystem
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def delete_subsystem(self, request, context):
|
||||
"""Deletes a subsystem
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def list_namespaces(self, request, context):
|
||||
"""List namespaces
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def namespace_resize(self, request, context):
|
||||
"""Resizes a namespace
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def namespace_get_io_stats(self, request, context):
|
||||
"""Gets namespace's IO stats
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def namespace_set_qos_limits(self, request, context):
|
||||
"""Sets namespace's qos limits
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def namespace_change_load_balancing_group(self, request, context):
|
||||
"""Changes namespace's load balancing group
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def namespace_delete(self, request, context):
|
||||
"""Deletes a namespace
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def add_host(self, request, context):
|
||||
"""Adds a host to a subsystem
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def remove_host(self, request, context):
|
||||
"""Removes a host from a subsystem
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def list_hosts(self, request, context):
|
||||
"""List hosts
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def list_connections(self, request, context):
|
||||
"""List connections
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def create_listener(self, request, context):
|
||||
"""Creates a listener for a subsystem at a given IP/Port
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def delete_listener(self, request, context):
|
||||
"""Deletes a listener from a subsystem at a given IP/Port
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def list_listeners(self, request, context):
|
||||
"""List listeners
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def list_subsystems(self, request, context):
|
||||
"""List subsystems
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def get_subsystems(self, request, context):
|
||||
"""Gets subsystems
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def set_ana_state(self, request, context):
|
||||
"""Set gateway ANA states
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def get_spdk_nvmf_log_flags_and_level(self, request, context):
|
||||
"""Gets spdk nvmf log flags and level
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def disable_spdk_nvmf_logs(self, request, context):
|
||||
"""Disables spdk nvmf logs
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def set_spdk_nvmf_logs(self, request, context):
|
||||
"""Set spdk nvmf logs
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def get_gateway_info(self, request, context):
|
||||
"""Get gateway info
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def get_gateway_log_level(self, request, context):
|
||||
"""Get gateway log level
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
def set_gateway_log_level(self, request, context):
|
||||
"""Set gateway log level
|
||||
"""
|
||||
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
|
||||
context.set_details('Method not implemented!')
|
||||
raise NotImplementedError('Method not implemented!')
|
||||
|
||||
|
||||
def add_GatewayServicer_to_server(servicer, server):
|
||||
rpc_method_handlers = {
|
||||
'namespace_add': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_add,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.SerializeToString,
|
||||
),
|
||||
'create_subsystem': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.create_subsystem,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'delete_subsystem': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.delete_subsystem,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'list_namespaces': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.list_namespaces,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.SerializeToString,
|
||||
),
|
||||
'namespace_resize': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_resize,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'namespace_get_io_stats': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_get_io_stats,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.SerializeToString,
|
||||
),
|
||||
'namespace_set_qos_limits': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_set_qos_limits,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'namespace_change_load_balancing_group': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_change_load_balancing_group,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'namespace_delete': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.namespace_delete,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'add_host': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.add_host,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'remove_host': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.remove_host,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'list_hosts': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.list_hosts,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.SerializeToString,
|
||||
),
|
||||
'list_connections': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.list_connections,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.SerializeToString,
|
||||
),
|
||||
'create_listener': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.create_listener,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'delete_listener': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.delete_listener,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'list_listeners': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.list_listeners,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.SerializeToString,
|
||||
),
|
||||
'list_subsystems': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.list_subsystems,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.SerializeToString,
|
||||
),
|
||||
'get_subsystems': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.get_subsystems,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.SerializeToString,
|
||||
),
|
||||
'set_ana_state': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.set_ana_state,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'get_spdk_nvmf_log_flags_and_level': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.get_spdk_nvmf_log_flags_and_level,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.SerializeToString,
|
||||
),
|
||||
'disable_spdk_nvmf_logs': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.disable_spdk_nvmf_logs,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'set_spdk_nvmf_logs': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.set_spdk_nvmf_logs,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
'get_gateway_info': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.get_gateway_info,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.SerializeToString,
|
||||
),
|
||||
'get_gateway_log_level': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.get_gateway_log_level,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.SerializeToString,
|
||||
),
|
||||
'set_gateway_log_level': grpc.unary_unary_rpc_method_handler(
|
||||
servicer.set_gateway_log_level,
|
||||
request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.FromString,
|
||||
response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
|
||||
),
|
||||
}
|
||||
generic_handler = grpc.method_handlers_generic_handler(
|
||||
'Gateway', rpc_method_handlers)
|
||||
server.add_generic_rpc_handlers((generic_handler,))
|
||||
|
||||
|
||||
# This class is part of an EXPERIMENTAL API.
|
||||
class Gateway(object):
|
||||
"""Missing associated documentation comment in .proto file."""
|
||||
|
||||
@staticmethod
|
||||
def namespace_add(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, '/Gateway/namespace_add',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def create_subsystem(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, '/Gateway/create_subsystem',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def delete_subsystem(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, '/Gateway/delete_subsystem',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def list_namespaces(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, '/Gateway/list_namespaces',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def namespace_resize(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, '/Gateway/namespace_resize',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def namespace_get_io_stats(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, '/Gateway/namespace_get_io_stats',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def namespace_set_qos_limits(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, '/Gateway/namespace_set_qos_limits',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def namespace_change_load_balancing_group(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, '/Gateway/namespace_change_load_balancing_group',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def namespace_delete(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, '/Gateway/namespace_delete',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def add_host(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, '/Gateway/add_host',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def remove_host(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, '/Gateway/remove_host',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def list_hosts(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, '/Gateway/list_hosts',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def list_connections(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, '/Gateway/list_connections',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def create_listener(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, '/Gateway/create_listener',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def delete_listener(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, '/Gateway/delete_listener',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def list_listeners(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, '/Gateway/list_listeners',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def list_subsystems(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, '/Gateway/list_subsystems',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def get_subsystems(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, '/Gateway/get_subsystems',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def set_ana_state(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, '/Gateway/set_ana_state',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def get_spdk_nvmf_log_flags_and_level(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, '/Gateway/get_spdk_nvmf_log_flags_and_level',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def disable_spdk_nvmf_logs(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, '/Gateway/disable_spdk_nvmf_logs',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def set_spdk_nvmf_logs(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, '/Gateway/set_spdk_nvmf_logs',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def get_gateway_info(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, '/Gateway/get_gateway_info',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def get_gateway_log_level(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, '/Gateway/get_gateway_log_level',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
|
||||
@staticmethod
|
||||
def set_gateway_log_level(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, '/Gateway/set_gateway_log_level',
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.SerializeToString,
|
||||
dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
|
||||
options, channel_credentials,
|
||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
|
||||
Loading…
Reference in New Issue
Block a user