974838e37e
Session is now required and can only be automatically created via client.get_client. Switch to using get_client. Change-Id: I0db7a95c4a99fe4157b3623a14135eb7b5dd69d9
427 lines
15 KiB
Python
Executable File
427 lines
15 KiB
Python
Executable File
#
|
|
# Copyright 2015, 2016 Hewlett Packard Enterprise Development Company LP
|
|
# Copyright 2016 Cray Inc.
|
|
# Copyright 2017 Intel Corporation
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
from django.conf import settings
|
|
|
|
from ironicclient import client
|
|
from ironicclient.v1 import resource_fields as res_fields
|
|
|
|
from horizon.utils.memoized import memoized # noqa
|
|
|
|
from openstack_dashboard.api import base
|
|
|
|
|
|
DEFAULT_IRONIC_API_VERSION = '1.34'
|
|
DEFAULT_INSECURE = False
|
|
DEFAULT_CACERT = None
|
|
IRONIC_CLIENT_CLASS_NAME = 'baremetal'
|
|
|
|
|
|
@memoized
|
|
def ironicclient(request):
|
|
"""Returns a client connected to the Ironic backend.
|
|
|
|
:param request: HTTP request.
|
|
:return: Ironic client.
|
|
"""
|
|
insecure = getattr(settings, 'OPENSTACK_SSL_NO_VERIFY', DEFAULT_INSECURE)
|
|
cacert = getattr(settings, 'OPENSTACK_SSL_CACERT', DEFAULT_CACERT)
|
|
ironic_url = base.url_for(request, IRONIC_CLIENT_CLASS_NAME)
|
|
|
|
return client.get_client(1,
|
|
endpoint=ironic_url,
|
|
os_ironic_api_version=DEFAULT_IRONIC_API_VERSION,
|
|
project_id=request.user.project_id,
|
|
token=request.user.token.id,
|
|
insecure=insecure,
|
|
cacert=cacert)
|
|
|
|
|
|
def node_list(request):
|
|
"""Retrieve a list of nodes.
|
|
|
|
:param request: HTTP request.
|
|
:return: A list of nodes.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.list
|
|
"""
|
|
node_manager = ironicclient(request).node
|
|
return node_manager.list(detail=True, limit=0)
|
|
|
|
|
|
def node_get(request, node_id):
|
|
"""Retrieve a node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.get
|
|
"""
|
|
return ironicclient(request).node.get(node_id)
|
|
|
|
|
|
def node_list_ports(request, node_id):
|
|
"""List all the ports on a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: A full list of ports. (limit=0)
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.list_ports
|
|
"""
|
|
return ironicclient(request).node.list_ports(node_id, limit=0, detail=True)
|
|
|
|
|
|
def node_set_power_state(request, node_id, state, soft=False):
|
|
"""Set power state for a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param state: the power state to set ['on', 'off', 'reboot'].
|
|
:param soft: flag for graceful power 'off' or reboot
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_power_state
|
|
"""
|
|
return ironicclient(request).node.set_power_state(node_id,
|
|
state,
|
|
soft)
|
|
|
|
|
|
def node_set_provision_state(request, node_id, state, cleansteps=None):
|
|
"""Set the target provision state for a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param state: the target provision state to set.
|
|
:param cleansteps: Optional list of cleaning steps
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_provision_state
|
|
"""
|
|
node_manager = ironicclient(request).node
|
|
return node_manager.set_provision_state(node_id,
|
|
state,
|
|
cleansteps=cleansteps)
|
|
|
|
|
|
def node_set_console_mode(request, node_id, enabled):
|
|
"""Start or stop the serial console for a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param enabled: True to start the console, False to stop it
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_console_mode
|
|
"""
|
|
return ironicclient(request).node.set_console_mode(node_id, enabled)
|
|
|
|
|
|
def node_get_console(request, node_id):
|
|
"""Get connection information for a node's console.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: Console connection information
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.get_console
|
|
"""
|
|
return ironicclient(request).node.get_console(node_id)
|
|
|
|
|
|
def node_set_maintenance(request, node_id, state, maint_reason=None):
|
|
"""Set the maintenance mode on a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param state: The maintenance state to set.
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_maintenance
|
|
"""
|
|
return ironicclient(request).node.set_maintenance(
|
|
node_id,
|
|
state,
|
|
maint_reason=maint_reason)
|
|
|
|
|
|
def node_create(request, params):
|
|
"""Create a node
|
|
|
|
:param request: HTTP request.
|
|
:param params: Dictionary of node parameters
|
|
"""
|
|
node_manager = ironicclient(request).node
|
|
node = node_manager.create(**params)
|
|
return dict([(f, getattr(node, f, ''))
|
|
for f in res_fields.NODE_DETAILED_RESOURCE.fields])
|
|
|
|
|
|
def node_delete(request, node_id):
|
|
"""Delete a node from inventory.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.delete
|
|
"""
|
|
return ironicclient(request).node.delete(node_id)
|
|
|
|
|
|
def node_update(request, node_id, patch):
|
|
"""Update a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param patch: Sequence of update operations
|
|
:return: node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.update
|
|
"""
|
|
node = ironicclient(request).node.update(node_id, patch)
|
|
return dict([(f, getattr(node, f, ''))
|
|
for f in res_fields.NODE_DETAILED_RESOURCE.fields])
|
|
|
|
|
|
def node_validate(request, node_id):
|
|
"""Validate a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: List of dictionaries, each containing an interface status
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.validate
|
|
"""
|
|
ifaces = ironicclient(request).node.validate(node_id)
|
|
result = []
|
|
for interface, status in ifaces.to_dict().items():
|
|
data = {'interface': interface}
|
|
data.update(status)
|
|
result.append(data)
|
|
return result
|
|
|
|
|
|
def node_get_boot_device(request, node_id):
|
|
"""Get the boot device for a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: Dictionary with keys "boot_device" and "persistent"
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.get_boot_device
|
|
"""
|
|
return ironicclient(request).node.get_boot_device(node_id)
|
|
|
|
|
|
def node_set_boot_device(request, node_id, device, persistent):
|
|
"""Set the boot device for a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param device: boot device.
|
|
:param persistent: True or False.
|
|
:return: null.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_boot_device
|
|
"""
|
|
return ironicclient(request).node.set_boot_device(node_id,
|
|
device,
|
|
persistent)
|
|
|
|
|
|
def node_get_supported_boot_devices(request, node_id):
|
|
"""Get the list of supported boot devices for a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: List of supported boot devices (strings)
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.get_boot_device
|
|
"""
|
|
result = ironicclient(request).node.get_supported_boot_devices(node_id)
|
|
return result.get('supported_boot_devices', [])
|
|
|
|
|
|
def node_inject_nmi(request, node_id):
|
|
"""Inject Non-Masking Interrupts into a specified node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: Empty response.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.inject_nmi
|
|
"""
|
|
return ironicclient(request).node.inject_nmi(node_id)
|
|
|
|
|
|
def driver_list(request):
|
|
"""Retrieve a list of drivers.
|
|
|
|
:param request: HTTP request.
|
|
:return: A list of drivers.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.driver.html#ironicclient.v1.driver.DriverManager.list
|
|
"""
|
|
return ironicclient(request).driver.list()
|
|
|
|
|
|
def driver_properties(request, driver_name):
|
|
"""Retrieve the properties of a specified driver
|
|
|
|
:param request: HTTP request
|
|
:param driver_name: Name of the driver
|
|
:return: Property list
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.driver.html#ironicclient.v1.driver.DriverManager.properties
|
|
"""
|
|
return ironicclient(request).driver.properties(driver_name)
|
|
|
|
|
|
def driver_details(request, driver_name):
|
|
"""Retrieve the details of a specified driver
|
|
|
|
:param request: HTTP request
|
|
:param driver_name: Name of the driver
|
|
:return: dictionary of driver details
|
|
|
|
https://docs.openstack.org/python-ironicclient/latest/cli/osc/v1/index.html#baremetal-driver-show
|
|
"""
|
|
details = ironicclient(request).driver.get(driver_name)
|
|
return details.to_dict()
|
|
|
|
|
|
def port_create(request, params):
|
|
"""Create network port
|
|
|
|
:param request: HTTP request
|
|
:param params: Port creation parameters
|
|
:return: Port
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.port.html#ironicclient.v1.port.PortManager.create
|
|
"""
|
|
port_manager = ironicclient(request).port
|
|
return port_manager.create(**params)
|
|
|
|
|
|
def port_delete(request, port_uuid):
|
|
"""Delete a network port
|
|
|
|
:param request: HTTP request
|
|
:param port_uuid: Port uuid
|
|
:return: Port
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.port.html#ironicclient.v1.port.PortManager.delete
|
|
"""
|
|
return ironicclient(request).port.delete(port_uuid)
|
|
|
|
|
|
def port_update(request, port_uuid, patch):
|
|
"""Update a specified port.
|
|
|
|
:param request: HTTP request.
|
|
:param port_id: The UUID of the port.
|
|
:param patch: Sequence of update operations
|
|
:return: Port.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.port.html#ironicclient.v1.port.PortManager.update
|
|
"""
|
|
port = ironicclient(request).port.update(port_uuid, patch)
|
|
return dict([(f, getattr(port, f, ''))
|
|
for f in res_fields.PORT_DETAILED_RESOURCE.fields])
|
|
|
|
|
|
def portgroup_list(request, node_id):
|
|
"""List the portgroups associated with a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:return: A full list of portgroups. (limit=0)
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.portgroup.html#ironicclient.v1.portgroup.PortgroupManager.list_portgroups
|
|
"""
|
|
return ironicclient(request).portgroup.list(node_id, limit=0, detail=True)
|
|
|
|
|
|
def portgroup_create(request, params):
|
|
"""Create a portgroup.
|
|
|
|
:param request: HTTP request.
|
|
:param params: Portgroup creation parameters.
|
|
:return: Portgroup.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.portgroup.html#ironicclient.v1.portgroup.PortgroupManager.create
|
|
"""
|
|
portgroup_manager = ironicclient(request).portgroup
|
|
return portgroup_manager.create(**params)
|
|
|
|
|
|
def portgroup_delete(request, portgroup_id):
|
|
"""Delete a portgroup from the DB.
|
|
|
|
:param request: HTTP request.
|
|
:param portgroup_id: The UUID or name of the portgroup.
|
|
:return: Portgroup.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.portgroup.html#ironicclient.v1.portgroup.PortgroupManager.delete
|
|
"""
|
|
return ironicclient(request).portgroup.delete(portgroup_id)
|
|
|
|
|
|
def portgroup_update(request, portgroup_id, patch):
|
|
"""Update a specified portgroup.
|
|
|
|
:param request: HTTP request.
|
|
:param portgroup_id: The UUID or name of the portgroup.
|
|
:param patch: Sequence of update operations
|
|
:return: Portgroup.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.port.html#ironicclient.v1.portgroup.PortgroupManager.update
|
|
"""
|
|
portgroup = ironicclient(request).portgroup.update(portgroup_id, patch)
|
|
return dict([(f, getattr(portgroup, f, ''))
|
|
for f in res_fields.PORTGROUP_DETAILED_RESOURCE.fields])
|
|
|
|
|
|
def portgroup_get_ports(request, portgroup_id):
|
|
"""Get the ports associated with a specified portgroup.
|
|
|
|
:param request: HTTP request.
|
|
:param portgroup_id: The UUID or name of the portgroup.
|
|
:return: List of ports.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.portgroup.html#ironicclient.v1.portgroup.PortgroupManager.list_ports
|
|
"""
|
|
return ironicclient(request).portgroup.list_ports(portgroup_id)
|
|
|
|
|
|
def node_set_raid_config(request, node_id, target_raid_config):
|
|
"""Set target raid configuration for a given node.
|
|
|
|
:param request: HTTP request.
|
|
:param node_id: The UUID or name of the node.
|
|
:param target_raid_config: Target raid configuration.
|
|
:return: Node.
|
|
|
|
http://docs.openstack.org/developer/python-ironicclient/api/ironicclient.v1.node.html#ironicclient.v1.node.NodeManager.set_target_raid_config
|
|
"""
|
|
return ironicclient(request).node.set_target_raid_config(
|
|
node_id,
|
|
target_raid_config)
|