154 lines
5.5 KiB
Python
154 lines
5.5 KiB
Python
# -*- coding: utf8 -*-
|
|
#
|
|
# 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.
|
|
|
|
import collections
|
|
|
|
from django.core.urlresolvers import reverse
|
|
import django.utils.text
|
|
from openstack_dashboard.api import base as api_base
|
|
|
|
from tuskar_ui import api
|
|
from tuskar_ui.infrastructure.overview import views
|
|
from tuskar_ui.utils import metering
|
|
|
|
from tuskar_boxes.overview import forms
|
|
|
|
|
|
NODE_STATE_ICON = {
|
|
api.node.DISCOVERING_STATE: 'fa-search',
|
|
api.node.DISCOVERED_STATE: 'fa-search-plus',
|
|
api.node.DISCOVERY_FAILED_STATE: 'fa-search-minus',
|
|
api.node.MAINTENANCE_STATE: 'fa-exclamation-triangle',
|
|
api.node.FREE_STATE: 'fa-minus',
|
|
api.node.PROVISIONING_STATE: 'fa-spinner fa-spin',
|
|
api.node.PROVISIONED_STATE: 'fa-check',
|
|
api.node.DELETING_STATE: 'fa-spinner fa-spin',
|
|
api.node.PROVISIONING_FAILED_STATE: 'fa-exclamation-circle',
|
|
None: 'fa-question',
|
|
}
|
|
|
|
|
|
def flavor_nodes(request, flavor):
|
|
"""Lists all nodes that match the given flavor exactly."""
|
|
for node in api.node.Node.list(request, maintenance=False):
|
|
if all([
|
|
int(node.cpus) == int(flavor.vcpus),
|
|
int(node.memory_mb) == int(flavor.ram),
|
|
int(node.local_gb) == int(flavor.disk),
|
|
node.cpu_arch == flavor.cpu_arch,
|
|
]):
|
|
yield node
|
|
|
|
|
|
def node_role(request, node):
|
|
try:
|
|
resource = api.heat.Resource.get_by_node(request, node)
|
|
except LookupError:
|
|
return None
|
|
return resource.role
|
|
|
|
|
|
def _node_data(request, nodes):
|
|
for node in nodes:
|
|
role = node_role(request, node)
|
|
yield {
|
|
'uuid': node.uuid,
|
|
'role_name': role.name if role else '',
|
|
'role_slug': django.utils.text.slugify(role.name) if role else '',
|
|
'state': node.state,
|
|
'state_slug': django.utils.text.slugify(unicode(node.state)),
|
|
'state_icon': NODE_STATE_ICON.get(node.state,
|
|
NODE_STATE_ICON[None]),
|
|
'cpu_arch': node.cpu_arch,
|
|
'cpus': node.cpus,
|
|
'memory_mb': node.memory_mb,
|
|
'local_gb': node.local_gb,
|
|
}
|
|
|
|
|
|
def _flavor_data(request, flavors, flavor_roles):
|
|
for flavor in flavors:
|
|
nodes = list(_node_data(request, flavor_nodes(request, flavor)))
|
|
roles = flavor_roles.get(flavor.name, [])
|
|
if nodes or roles:
|
|
# Don't list empty flavors
|
|
yield {
|
|
'name': flavor.name,
|
|
'vcpus': flavor.vcpus,
|
|
'ram': flavor.ram,
|
|
'disk': flavor.disk,
|
|
'cpu_arch': flavor.cpu_arch,
|
|
'nodes': nodes,
|
|
'roles': roles,
|
|
}
|
|
|
|
|
|
class IndexView(views.IndexView):
|
|
template_name = "tuskar_boxes/overview/index.html"
|
|
form_class = forms.EditPlan
|
|
|
|
def get_context_data(self, *args, **kwargs):
|
|
context = super(IndexView, self).get_context_data(*args, **kwargs)
|
|
if not context['stack']:
|
|
roles = context['roles']
|
|
free_roles = []
|
|
flavor_roles = {}
|
|
for role in roles:
|
|
role['flavor_field'] = context['form'][role['id'] + '-flavor']
|
|
flavor = role['role'].flavor(context['plan'])
|
|
if flavor:
|
|
role['flavor_name'] = flavor.name
|
|
flavor_roles.setdefault(flavor.name, []).append(role)
|
|
else:
|
|
role['flavor_name'] = ''
|
|
free_roles.append(role)
|
|
context['free_roles'] = free_roles
|
|
|
|
flavors = api.flavor.Flavor.list(self.request)
|
|
flavors.sort(key=lambda np: (np.vcpus, np.ram, np.disk))
|
|
context['flavors'] = list(
|
|
_flavor_data(self.request, flavors, flavor_roles))
|
|
else:
|
|
nodes = list(_node_data(
|
|
self.request,
|
|
api.node.Node.list(self.request, maintenance=False),
|
|
))
|
|
|
|
nodes.sort(key=lambda node: node.get('role_name'))
|
|
nodes.reverse()
|
|
|
|
context['nodes'] = nodes
|
|
distribution = collections.Counter()
|
|
|
|
for node in nodes:
|
|
distribution[node['role_name']] += 1
|
|
for role in context['roles']:
|
|
role['distribution'] = int(float(distribution[role['name']]) /
|
|
len(nodes) * 100)
|
|
|
|
if api_base.is_service_enabled(self.request, 'metering'):
|
|
for role in context['roles']:
|
|
role['graph_url'] = (
|
|
reverse('horizon:infrastructure:roles:performance',
|
|
args=[role['id']]) + '?' +
|
|
metering.url_part('hardware.cpu.load.1min', False) +
|
|
'&date_options=0.041666'
|
|
)
|
|
return context
|
|
|
|
def get_progress_update(self, request, data):
|
|
out = super(IndexView, self).get_progress_update(request, data)
|
|
out['nodes'] = data.get('nodes', [])
|
|
return out
|