@EndpointDoc("Get information about the NVMeoF gateway")
@convert_to_model(model.GatewayInfo)
@handle_nvmeof_error
- def list(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.get_gateway_info(
+ def list(self, gw_group: Optional[str] = None, server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_gateway_info(
NVMeoFClient.pb2.get_gateway_info_req()
)
@EndpointDoc("Get the version of the NVMeoF gateway")
@convert_to_model(model.GatewayVersion)
@handle_nvmeof_error
- def version(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- gw_info = NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.get_gateway_info(
+ def version(self, gw_group: Optional[str] = None, server_address: Optional[str] = None):
+ gw_info = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_gateway_info(
NVMeoFClient.pb2.get_gateway_info_req()
)
return NVMeoFClient.pb2.gw_version(status=gw_info.status,
@EndpointDoc("Get NVMeoF gateway log level information")
@convert_to_model(model.GatewayLogLevelInfo)
@handle_nvmeof_error
- def get_log_level(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- gw_log_level = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.get_gateway_log_level(
+ def get_log_level(self, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
+ gw_log_level = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_gateway_log_level(
NVMeoFClient.pb2.get_gateway_log_level_req()
)
return gw_log_level
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def set_log_level(self, log_level: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
+ server_address: Optional[str] = None):
log_level = log_level.lower()
gw_log_level = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.set_gateway_log_level(
+ server_address=server_address).stub.set_gateway_log_level(
NVMeoFClient.pb2.set_gateway_log_level_req(log_level=log_level)
)
return gw_log_level
@EndpointDoc("Get NVMeoF statistics for the gateway")
@convert_to_model(model.GatewayStatsInfo)
@handle_nvmeof_error
- def get_gw_stats(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- gw_stats = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.get_gateway_stats(
+ def get_gw_stats(self, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
+ gw_stats = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_gateway_stats(
NVMeoFClient.pb2.get_gateway_stats_req()
)
return gw_stats
@convert_to_model(model.GatewayListenersInfo)
@handle_nvmeof_error
def listener_info(self, nqn: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- gw_listener_info = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.show_gateway_listeners_info(
+ server_address: Optional[str] = None):
+ gw_listener_info = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.show_gateway_listeners_info(
NVMeoFClient.pb2.show_gateway_listeners_info_req(subsystem_nqn=nqn)
)
return gw_listener_info
@handle_nvmeof_error
def get_spdk_log_level(
self, all_log_flags: Optional[bool] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None
+ gw_group: Optional[str] = None, server_address: Optional[str] = None
):
- spdk_log_level = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.get_spdk_nvmf_log_flags_and_level(
+ spdk_log_level = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_spdk_nvmf_log_flags_and_level(
NVMeoFClient.pb2.get_spdk_nvmf_log_flags_and_level_req(all_log_flags=all_log_flags)
)
return spdk_log_level
def set_spdk_log_level(self, log_level: Optional[str] = None,
print_level: Optional[str] = None,
extra_log_flags: Optional[List[str]] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None):
+ gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
log_level = log_level.upper() if log_level else None
print_level = print_level.upper() if print_level else None
- spdk_log_level = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.set_spdk_nvmf_logs(
+ spdk_log_level = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.set_spdk_nvmf_logs(
NVMeoFClient.pb2.set_spdk_nvmf_logs_req(log_level=log_level,
print_level=print_level,
extra_log_flags=extra_log_flags)
def disable_spdk_log_level(
self, extra_log_flags: Optional[List[str]] = None,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- spdk_log_level = NVMeoFClient(gw_group=gw_group,
- traddr=traddr).stub.disable_spdk_nvmf_logs(
+ spdk_log_level = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.disable_spdk_nvmf_logs(
NVMeoFClient.pb2.disable_spdk_nvmf_logs_req(extra_log_flags=extra_log_flags)
)
return spdk_log_level
@EndpointDoc("List all NVMeoF subsystems")
@convert_to_model(model.SubsystemList)
@handle_nvmeof_error
- def list(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_subsystems(
+ def list(self, gw_group: Optional[str] = None, server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_subsystems(
NVMeoFClient.pb2.list_subsystems_req()
)
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.SubsystemList)
@handle_nvmeof_error
- def get(self, nqn: str, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_subsystems(
+ def get(self, nqn: str, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_subsystems(
NVMeoFClient.pb2.list_subsystems_req(subsystem_nqn=nqn)
)
"serial_number": Param(int, "Subsystem serial number", True, None),
"dhchap_key": Param(int, "Subsystem DH-HMAC-CHAP key", True, None),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.SubsystemStatus)
def create(self, nqn: str, enable_ha: Optional[bool] = True,
max_namespaces: Optional[int] = None, no_group_append: Optional[bool] = False,
serial_number: Optional[str] = None, dhchap_key: Optional[str] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.create_subsystem(
+ gw_group: Optional[str] = None, server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.create_subsystem(
NVMeoFClient.pb2.create_subsystem_req(
subsystem_nqn=nqn, serial_number=serial_number,
max_namespaces=max_namespaces, enable_ha=enable_ha,
"nqn": Param(str, "NVMeoF subsystem NQN"),
"force": Param(bool, "Force delete", True, False),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def delete(self, nqn: str, force: Optional[str] = "false", gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.delete_subsystem(
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.delete_subsystem(
NVMeoFClient.pb2.delete_subsystem_req(
subsystem_nqn=nqn, force=str_to_bool(force)
)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"dhchap_key": Param(str, "Subsystem DH-HMAC-CHAP key"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@empty_response
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def change_key(self, nqn: str, dhchap_key: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.change_subsystem_key(
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.change_subsystem_key(
NVMeoFClient.pb2.change_subsystem_key_req(
subsystem_nqn=nqn, dhchap_key=dhchap_key
)
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@empty_response
@NvmeofCLICommand("nvmeof subsystem del_key", model.RequestStatus)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
- def del_key(self, nqn: str, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.change_subsystem_key(
+ def del_key(self, nqn: str, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.change_subsystem_key(
NVMeoFClient.pb2.change_subsystem_key_req(
subsystem_nqn=nqn, dhchap_key=None
)
@NvmeofCLICommand("nvmeof get_subsystems", model.GetSubsystems)
@convert_to_model(model.GetSubsystems)
@handle_nvmeof_error
- def get_subsystems(self, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.get_subsystems(
+ def get_subsystems(
+ self,
+ gw_group: Optional[str] = None,
+ server_address: Optional[str] = None
+ ):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.get_subsystems(
NVMeoFClient.pb2.get_subsystems_req()
)
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.ListenerList)
@handle_nvmeof_error
- def list(self, nqn: str, gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_listeners(
+ def list(self, nqn: str, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_listeners(
NVMeoFClient.pb2.list_listeners_req(subsystem=nqn)
)
"trsvcid": Param(int, "NVMeoF transport service port", True, 4420),
"adrfam": Param(int, "NVMeoF address family (0 - IPv4, 1 - IPv6)", True, 0),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
traddr: str,
trsvcid: int = 4420,
adrfam: int = 0, # IPv4,
- gw_group: Optional[str] = None
+ gw_group: Optional[str] = None,
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.create_listener(
+ client = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ )
+ return client.stub.create_listener(
NVMeoFClient.pb2.create_listener_req(
nqn=nqn,
host_name=host_name,
"trsvcid": Param(int, "NVMeoF transport service port", True, 4420),
"adrfam": Param(int, "NVMeoF address family (0 - IPv4, 1 - IPv6)", True, 0),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
trsvcid: int = 4420,
adrfam: int = 0, # IPv4
force: bool = False,
- gw_group: Optional[str] = None
+ gw_group: Optional[str] = None,
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.delete_listener(
+ client = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ )
+ return client.stub.delete_listener(
NVMeoFClient.pb2.delete_listener_req(
nqn=nqn,
host_name=host_name,
"nqn": Param(str, "NVMeoF subsystem NQN", True, None),
"nsid": Param(str, "NVMeoF Namespace ID to filter by", True, None),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.NamespaceList)
@handle_nvmeof_error
def list(self, nqn: Optional[str] = None, nsid: Optional[str] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_namespaces(
+ gw_group: Optional[str] = None, server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_namespaces(
NVMeoFClient.pb2.list_namespaces_req(subsystem=nqn,
nsid=int(nsid) if nsid else None)
)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.NamespaceList)
@handle_nvmeof_error
def get(self, nqn: str, nsid: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_namespaces(
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_namespaces(
NVMeoFClient.pb2.list_namespaces_req(subsystem=nqn, nsid=int(nsid))
)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.NamespaceIOStats)
@handle_nvmeof_error
def io_stats(self, nqn: str, nsid: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_get_io_stats(
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_get_io_stats(
NVMeoFClient.pb2.namespace_get_io_stats_req(
subsystem_nqn=nqn, nsid=int(nsid))
)
"Create a new NVMeoF namespace.",
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
- "rbd_pool": Param(str, "RBD pool name"),
"rbd_image_name": Param(str, "RBD image name"),
+ "rbd_pool": Param(str, "RBD pool name"),
+ "nsid": Param(str, "Create RBD image", True, None),
"create_image": Param(bool, "Create RBD image"),
"size": Param(int, "Deprecated. Use `rbd_image_size` instead"),
"rbd_image_size": Param(int, "RBD image size"),
"trash_image": Param(bool, "Trash the RBD image when namespace is removed"),
"block_size": Param(int, "NVMeoF namespace block size"),
"load_balancing_group": Param(int, "Load balancing group"),
- "disable_auto_resize": Param(str, "Disable auto resize", True, None),
- "read_only": Param(str, "Read only namespace", True, None),
- "gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "Target gateway address", True, None),
"force": Param(
bool,
"Force create namespace even it image is used by other namespace"
"no_auto_visible": Param(
bool,
"Namespace will be visible only for the allowed hosts"
- )
+ ),
+ "disable_auto_resize": Param(str, "Disable auto resize", True, None),
+ "read_only": Param(str, "Read only namespace", True, None),
+ "gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.NamespaceCreation)
disable_auto_resize: Optional[bool] = False,
read_only: Optional[bool] = False,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None,
+ server_address: Optional[str] = None,
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_add(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_add(
NVMeoFClient.pb2.namespace_add_req(
subsystem_nqn=nqn,
nsid=int(nsid) if nsid else None,
"load_balancing_group": Param(int, "Load balancing group"),
"disable_auto_resize": Param(str, "Disable auto resize", True, None),
"read_only": Param(str, "Read only namespace", True, None),
- "gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "Target gateway address", True, None),
"force": Param(
bool,
"Force create namespace even it image is used by other namespace"
"no_auto_visible": Param(
bool,
"Namespace will be visible only for the allowed hosts"
- )
+ ),
+ "gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "Target gateway address", True, None),
},
)
@convert_to_model(model.NamespaceCreation)
disable_auto_resize: Optional[bool] = False,
read_only: Optional[bool] = False,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None,
+ server_address: Optional[str] = None,
):
if size and rbd_image_size:
raise DashboardException(
size_b = convert_to_bytes(size, default_unit='MB')
if rbd_image_size:
rbd_image_size_b = convert_to_bytes(rbd_image_size, default_unit='MB')
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_add(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_add(
NVMeoFClient.pb2.namespace_add_req(
subsystem_nqn=nqn,
nsid=int(nsid) if nsid else None,
"Set QOS limits even if they were changed by RBD"
),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
w_mbytes_per_second: Optional[int] = None,
force: Optional[bool] = False,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
return NVMeoFClient(
gw_group=gw_group,
- traddr=traddr
+ server_address=server_address
).stub.namespace_set_qos_limits(
NVMeoFClient.pb2.namespace_set_qos_req(
subsystem_nqn=nqn,
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
- "load_balancing_group": Param(int, "Load balancing group"),
+ "load_balancing_group": Param(int, "Load balancing group", True, None),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
load_balancing_group: Optional[int] = None,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
return NVMeoFClient(
gw_group=gw_group,
- traddr=traddr
+ server_address=server_address
).stub.namespace_change_load_balancing_group(
NVMeoFClient.pb2.namespace_change_load_balancing_group_req(
subsystem_nqn=nqn, nsid=int(nsid), anagrpid=load_balancing_group
"nsid": Param(str, "NVMeoF Namespace ID"),
"rbd_image_size": Param(int, "RBD image size"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
rbd_image_size: int,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
mib = 1024 * 1024
new_size_mib = int((rbd_image_size + mib - 1) / mib)
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_resize(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_resize(
NVMeoFClient.pb2.namespace_resize_req(
subsystem_nqn=nqn, nsid=int(nsid), new_size=new_size_mib
)
"nsid": Param(str, "NVMeoF Namespace ID"),
"rbd_image_size": Param(str, "RBD image size"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
rbd_image_size: str,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
if rbd_image_size:
rbd_image_size_b = convert_to_bytes(rbd_image_size, default_unit='MB')
mib = 1024 * 1024
rbd_image_size_mb = rbd_image_size_b // mib
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_resize(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_resize(
NVMeoFClient.pb2.namespace_resize_req(
subsystem_nqn=nqn, nsid=int(nsid), new_size=rbd_image_size_mb
)
"has no access to the subsystem"
),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
host_nqn: str,
force: Optional[bool] = None,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_add_host(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_add_host(
NVMeoFClient.pb2.namespace_add_host_req(subsystem_nqn=nqn,
nsid=int(nsid),
host_nqn=host_nqn,
"nsid": Param(str, "NVMeoF Namespace ID"),
"host_nqn": Param(str, 'NVMeoF host NQN. Use "*" to allow any host.'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
host_nqn: str,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_delete_host(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_delete_host(
NVMeoFClient.pb2.namespace_delete_host_req(
subsystem_nqn=nqn,
nsid=int(nsid),
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
"auto_visible": Param(bool, 'True if visible to all hosts'),
+ "force": Param(bool, 'True if visible to all hosts', True, False),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
auto_visible: str,
force: Optional[bool] = False,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_change_visibility(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_change_visibility(
NVMeoFClient.pb2.namespace_change_visibility_req(
subsystem_nqn=nqn,
nsid=int(nsid),
'namespace when RBD image is resized'
),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
auto_resize_enabled: bool,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_set_auto_resize(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_set_auto_resize(
NVMeoFClient.pb2.namespace_set_auto_resize_req(
subsystem_nqn=nqn,
nsid=int(nsid),
"nsid": Param(str, "NVMeoF Namespace ID"),
"rbd_trash_image_on_delete": Param(bool, 'True if active'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nsid: str,
rbd_trash_image_on_delete: str,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
return NVMeoFClient(
gw_group=gw_group,
- traddr=traddr,
+ server_address=server_address,
).stub.namespace_set_rbd_trash_image(
NVMeoFClient.pb2.namespace_set_rbd_trash_image_req(
subsystem_nqn=nqn,
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "traddr": Param(str, "NVMeoF gateway address", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
nqn: str,
nsid: str,
gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_resize(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_resize(
NVMeoFClient.pb2.namespace_resize_req(
subsystem_nqn=nqn,
nsid=int(nsid),
"rw_mbytes_per_second": Param(int, "Read/Write MB/s"),
"r_mbytes_per_second": Param(int, "Read MB/s"),
"w_mbytes_per_second": Param(int, "Write MB/s"),
+ "trash_image": Param(bool, "Trash RBD image after removing namespace"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "trash_image": Param(bool, "Trash RBD image after removing namespace")
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.NamespaceList)
rw_mbytes_per_second: Optional[int] = None,
r_mbytes_per_second: Optional[int] = None,
w_mbytes_per_second: Optional[int] = None,
- gw_group: Optional[str] = None,
- traddr: Optional[str] = None,
trash_image: Optional[bool] = None,
+ gw_group: Optional[str] = None,
+ server_address: Optional[str] = None,
):
contains_failure = False
mib = 1024 * 1024
new_size_mib = int((rbd_image_size + mib - 1) / mib)
- resp = NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_resize(
+ resp = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_resize(
NVMeoFClient.pb2.namespace_resize_req(
subsystem_nqn=nqn, nsid=int(nsid), new_size=new_size_mib
)
if contains_failure:
cherrypy.response.status = 202
- response = NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_namespaces(
+ response = NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_namespaces(
NVMeoFClient.pb2.list_namespaces_req(subsystem=nqn, nsid=int(nsid))
)
return response
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"nsid": Param(str, "NVMeoF Namespace ID"),
+ "force": Param(str, "Force remove the RBD image", True, False),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
- "force": Param(str, "Force remove the RBD image")
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
self,
nqn: str,
nsid: str,
+ force: Optional[str] = "false",
gw_group: Optional[str] = None,
- traddr: Optional[str] = None,
- force: Optional[str] = "false"
+ server_address: Optional[str] = None,
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.namespace_delete(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.namespace_delete(
NVMeoFClient.pb2.namespace_delete_req(
subsystem_nqn=nqn,
nsid=int(nsid),
"clear_alerts": Param(bool, "Clear any host alert signal after getting its value",
True, False),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.HostsInfo, finalize=_update_hosts)
@handle_nvmeof_error
def list(
self, nqn: str, clear_alerts: Optional[bool] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None
+ gw_group: Optional[str] = None, server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_hosts(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_hosts(
NVMeoFClient.pb2.list_hosts_req(subsystem=nqn, clear_alerts=clear_alerts)
)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"host_nqn": Param(str, 'NVMeoF host NQN. Use "*" to allow any host.'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def create(
self, nqn: str, host_nqn: str, dhchap_key: Optional[str] = None,
- psk: Optional[str] = None, gw_group: Optional[str] = None, traddr: Optional[str] = None
+ psk: Optional[str] = None, gw_group: Optional[str] = None,
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.add_host(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.add_host(
NVMeoFClient.pb2.add_host_req(subsystem_nqn=nqn, host_nqn=host_nqn,
dhchap_key=dhchap_key, psk=psk)
)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"host_nqn": Param(str, 'NVMeoF host NQN. Use "*" to disallow any host.'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def delete(self, nqn: str, host_nqn: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.remove_host(
+ server_address: Optional[str] = None):
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.remove_host(
NVMeoFClient.pb2.remove_host_req(subsystem_nqn=nqn, host_nqn=host_nqn)
)
"host_nqn": Param(str, 'NVMeoF host NQN'),
"dhchap_key": Param(str, 'Host DH-HMAC-CHAP key'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def change_key(
self, nqn: str, host_nqn: str, dhchap_key: str,
- gw_group: Optional[str] = None, traddr: Optional[str] = None
+ gw_group: Optional[str] = None, server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.change_host_key(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.change_host_key(
NVMeoFClient.pb2.change_host_key_req(subsystem_nqn=nqn,
host_nqn=host_nqn,
dhchap_key=dhchap_key)
"nqn": Param(str, "NVMeoF subsystem NQN"),
"host_nqn": Param(str, 'NVMeoF host NQN.'),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.RequestStatus)
@handle_nvmeof_error
def del_key(
self, nqn: str, host_nqn: str, gw_group: Optional[str] = None,
- traddr: Optional[str] = None
+ server_address: Optional[str] = None
):
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.change_host_key(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.change_host_key(
NVMeoFClient.pb2.change_host_key_req(subsystem_nqn=nqn,
host_nqn=host_nqn,
dhchap_key=None)
parameters={
"nqn": Param(str, "NVMeoF subsystem NQN"),
"gw_group": Param(str, "NVMeoF gateway group", True, None),
+ "server_address": Param(str, "NVMeoF gateway address", True, None),
},
)
@convert_to_model(model.ConnectionList)
@handle_nvmeof_error
def list(self, nqn: Optional[str] = None,
- gw_group: Optional[str] = None, traddr: Optional[str] = None):
+ gw_group: Optional[str] = None, server_address: Optional[str] = None):
if not nqn:
nqn = '*'
- return NVMeoFClient(gw_group=gw_group, traddr=traddr).stub.list_connections(
+ return NVMeoFClient(
+ gw_group=gw_group,
+ server_address=server_address
+ ).stub.list_connections(
NVMeoFClient.pb2.list_connections_req(subsystem=nqn)
)