From 13525f8d886e1f72ce74fbdd97ee70ebcf7d6b23 Mon Sep 17 00:00:00 2001 From: baiziyu Date: Sat, 23 Oct 2021 16:11:03 +0800 Subject: [PATCH] Add log search function code. Add log search function code. Change-Id: Ib54a5d5fd8885962f84077921202c2d56bf1b31d --- venus_dashboard/api/__init__.py | 0 venus_dashboard/api/venus.py | 49 +++ venus_dashboard/api/venus_rest_api.py | 44 +++ venus_dashboard/log_search/__init__.py | 0 venus_dashboard/log_search/panel.py | 26 ++ .../templates/log_search/index.html | 13 + venus_dashboard/log_search/tests.py | 326 ++++++++++++++++++ venus_dashboard/log_search/urls.py | 26 ++ venus_dashboard/log_search/views.py | 27 ++ .../openstack-service-api/venus.service.js | 43 +++ .../dashboard/admin/services/venus.service.js | 49 +++ .../static/dashboard/admin/venus.module.js | 6 + .../venus/logSearch/logSearch.controller.js | 51 +++ .../admin/venus/logSearch/logSearch.css | 0 .../admin/venus/logSearch/logSearch.html | 55 +++ 15 files changed, 715 insertions(+) create mode 100644 venus_dashboard/api/__init__.py create mode 100644 venus_dashboard/api/venus.py create mode 100644 venus_dashboard/api/venus_rest_api.py create mode 100644 venus_dashboard/log_search/__init__.py create mode 100644 venus_dashboard/log_search/panel.py create mode 100644 venus_dashboard/log_search/templates/log_search/index.html create mode 100644 venus_dashboard/log_search/tests.py create mode 100644 venus_dashboard/log_search/urls.py create mode 100644 venus_dashboard/log_search/views.py create mode 100644 venus_dashboard/static/app/core/openstack-service-api/venus.service.js create mode 100644 venus_dashboard/static/dashboard/admin/services/venus.service.js create mode 100644 venus_dashboard/static/dashboard/admin/venus.module.js create mode 100644 venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.controller.js create mode 100644 venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.css create mode 100644 venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.html diff --git a/venus_dashboard/api/__init__.py b/venus_dashboard/api/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/venus_dashboard/api/venus.py b/venus_dashboard/api/venus.py new file mode 100644 index 0000000..b1eec47 --- /dev/null +++ b/venus_dashboard/api/venus.py @@ -0,0 +1,49 @@ +# Copyright 2015 - Alcatel-Lucent +# +# 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 logging + +from horizon.utils.memoized import memoized +from openstack_dashboard.api import base +from keystoneauth1.identity.generic.token import Token +from keystoneauth1.session import Session +from venusclient.v1 import client + + +LOG = logging.getLogger(__name__) + + +@memoized +def venusclient(request): + endpoint = base.url_for(request, 'identity') + token_id = request.user.token.id + tenant_name = request.user.tenant_name + project_domain_id = request.user.token.project.get('domain_id', 'Default') + auth = Token(auth_url=endpoint, + token=token_id, + project_name=tenant_name, + project_domain_id=project_domain_id) + session = Session(auth=auth, timeout=600) + return client.Client(session=session) + + +def log_storage_days(request): + return venusclient(request).config.get_days() + + +def logs(request, start_time, end_time, page_size, page_num): + return venusclient(request).config.get_logs(start_time=start_time, + end_time=end_time, + page_size=page_size, + page_num=page_num) diff --git a/venus_dashboard/api/venus_rest_api.py b/venus_dashboard/api/venus_rest_api.py new file mode 100644 index 0000000..b1bf61e --- /dev/null +++ b/venus_dashboard/api/venus_rest_api.py @@ -0,0 +1,44 @@ +# Copyright 2015 - Alcatel-Lucent +# +# 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.views import generic +import json +import logging +from openstack_dashboard.api.rest import urls +from openstack_dashboard.api.rest import utils as rest_utils +from venus_dashboard.api import venus + +LOG = logging.getLogger(__name__) + + +@urls.register +class LogStorageDays(generic.View): + url_regex = r'venus/log_storage_days/$' + + @rest_utils.ajax() + def get(self, request): + return venus.log_storage_days(request) + + +@urls.register +class Logs(generic.View): + url_regex = r'venus/logs/$' + + @rest_utils.ajax() + def get(self, request): + start_time = request.GET.get('start_time', 0) + end_time = request.GET.get('end_time', 0) + page_size = request.GET.get('page_size', 20) + page_num = request.GET.get('page_num', 1) + return venus.logs(request, start_time, end_time, page_size, page_num) diff --git a/venus_dashboard/log_search/__init__.py b/venus_dashboard/log_search/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/venus_dashboard/log_search/panel.py b/venus_dashboard/log_search/panel.py new file mode 100644 index 0000000..5c96063 --- /dev/null +++ b/venus_dashboard/log_search/panel.py @@ -0,0 +1,26 @@ +# Copyright 2012 United States Government as represented by the +# Administrator of the National Aeronautics and Space Administration. +# All Rights Reserved. +# +# Copyright 2012 Nebula, Inc. +# +# 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.utils.translation import ugettext_lazy as _ + +import horizon + + +class LogSearch(horizon.Panel): + name = _("Log Search") + slug = 'venus' diff --git a/venus_dashboard/log_search/templates/log_search/index.html b/venus_dashboard/log_search/templates/log_search/index.html new file mode 100644 index 0000000..7653233 --- /dev/null +++ b/venus_dashboard/log_search/templates/log_search/index.html @@ -0,0 +1,13 @@ +{% extends 'base.html' %} +{% load i18n %} +{% block title %}Log Search{% endblock %} + +{% block page_header %} +{% include "horizon/common/_page_header.html" with title=_("Log Search") %} +{% endblock page_header %} + +{% block main %} +
+ +
+{% endblock %} diff --git a/venus_dashboard/log_search/tests.py b/venus_dashboard/log_search/tests.py new file mode 100644 index 0000000..acd9430 --- /dev/null +++ b/venus_dashboard/log_search/tests.py @@ -0,0 +1,326 @@ +# Copyright 2012 United States Government as represented by the +# Administrator of the National Aeronautics and Space Administration. +# All Rights Reserved. +# +# Copyright 2012 Nebula, Inc. +# +# 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 datetime +# import logging +# +# from django.test.utils import override_settings +# from django.urls import reverse +# from django.utils import timezone +# +# from openstack_dashboard import api +# from openstack_dashboard.test import helpers as test +# from openstack_dashboard import usage +# +# +# INDEX_URL = reverse('horizon:project:overview:index') +# +# +# class UsageViewTests(test.TestCase): +# +# @test.create_mocks({ +# api.nova: ('usage_get',), +# api.neutron: ('is_quotas_extension_supported',), +# usage.quotas: ('tenant_quota_usages',), +# }, stop_mock=False) +# # NOTE: _stub_api_calls() and _check_api_calls() are used as pair +# # and the test logic will be placed between these calls, +# # so we cannot stop mocking when exiting this method. +# def _stub_api_calls(self, nova_stu_enabled=True, +# stu_exception=False, overview_days_range=1, +# quota_usage_overrides=None, +# quota_extension_support=True): +# self.mock_is_quotas_extension_supported.return_value = \ +# quota_extension_support +# if nova_stu_enabled: +# self._nova_stu_enabled(stu_exception, +# overview_days_range=overview_days_range) +# +# self._stub_tenant_quota_usages(overrides=quota_usage_overrides) +# +# def _check_api_calls(self, nova_stu_enabled=True, +# stu_exception=False, overview_days_range=1): +# if nova_stu_enabled: +# self._check_stu_enabled(stu_exception, +# overview_days_range=overview_days_range) +# else: +# self.mock_usage_get.assert_not_called() +# self._check_tenant_quota_usages() +# +# @staticmethod +# def _add_quota_usages(usages, quota_usages, excludes=None): +# excludes = excludes or [] +# for k in quota_usages.usages: +# if k in excludes: +# continue +# quota = quota_usages[k]['quota'] +# if quota == float('inf'): +# quota = -1 +# usages.add_quota(api.base.Quota(k, quota)) +# usages.tally(k, quota_usages[k]['used']) +# +# def _stub_tenant_quota_usages(self, overrides): +# usages_data = usage.quotas.QuotaUsage() +# self._add_quota_usages(usages_data, self.quota_usages.first(), +# # At now, nova quota_usages contains +# # volumes and gigabytes. +# excludes=('volumes', 'gigabytes')) +# self._add_quota_usages( +# usages_data, self.neutron_quota_usages.first()) +# self._add_quota_usages(usages_data, self.cinder_quota_usages.first()) +# if overrides: +# for key, value in overrides.items(): +# if 'quota' in value: +# usages_data.add_quota(api.base.Quota(key, value['quota'])) +# if 'used' in value: +# usages_data.tally(key, value['used']) +# self.mock_tenant_quota_usages.return_value = usages_data +# +# def _check_tenant_quota_usages(self): +# self.mock_tenant_quota_usages.assert_called_once_with( +# test.IsHttpRequest()) +# +# def _nova_stu_enabled(self, exception=False, overview_days_range=1): +# if exception: +# self.mock_usage_get.side_effect = exception +# else: +# usage = api.nova.NovaUsage(self.usages.first()) +# self.mock_usage_get.return_value = usage +# +# def _check_stu_enabled(self, exception=False, overview_days_range=1): +# now = timezone.now() +# if overview_days_range: +# start_day = now - datetime.timedelta(days=overview_days_range) +# else: +# start_day = datetime.date(now.year, now.month, 1) +# start = datetime.datetime(start_day.year, start_day.month, +# start_day.day, 0, 0, 0, 0) +# end = datetime.datetime(now.year, now.month, now.day, 23, 59, 59, 0) +# +# self.mock_usage_get.assert_called_once_with( +# test.IsHttpRequest(), self.tenant.id, start, end) +# +# def _common_assertions(self, nova_stu_enabled, +# maxTotalFloatingIps=50): +# res = self.client.get(reverse('horizon:project:overview:index')) +# usages = res.context['usage'] +# self.assertTemplateUsed(res, 'project/overview/usage.html') +# self.assertIsInstance(usages, usage.ProjectUsage) +# self.assertEqual(nova_stu_enabled, +# res.context['simple_tenant_usage_enabled']) +# if nova_stu_enabled: +# self.assertContains(res, 'form-inline') +# else: +# self.assertNotContains(res, 'form-inline') +# self.assertEqual(usages.limits['floatingip']['quota'], +# maxTotalFloatingIps) +# +# @override_settings(OVERVIEW_DAYS_RANGE=None) +# def test_usage(self): +# self._test_usage(nova_stu_enabled=True, overview_days_range=None) +# +# def test_usage_1_day(self): +# self._test_usage(nova_stu_enabled=True) +# +# @override_settings( +# OVERVIEW_DAYS_RANGE=None, +# OPENSTACK_USE_SIMPLE_TENANT_USAGE=False, +# ) +# def test_usage_disabled(self): +# self._test_usage(nova_stu_enabled=False, overview_days_range=None) +# +# def _test_usage(self, nova_stu_enabled, overview_days_range=1): +# self._stub_api_calls(nova_stu_enabled, +# overview_days_range=overview_days_range) +# +# self._common_assertions(nova_stu_enabled) +# +# self._check_api_calls(nova_stu_enabled, +# overview_days_range=overview_days_range) +# +# def test_unauthorized(self): +# url = reverse('horizon:admin:volumes:index') +# +# # Avoid the log message in the test +# # when unauthorized exception will be logged +# logging.disable(logging.ERROR) +# res = self.client.get(url) +# logging.disable(logging.NOTSET) +# +# self.assertEqual(403, res.status_code) +# +# def test_usage_csv(self): +# self._test_usage_csv(nova_stu_enabled=True) +# +# @override_settings(OVERVIEW_DAYS_RANGE=1) +# def test_usage_csv_1_day(self): +# self._test_usage_csv(nova_stu_enabled=True, overview_days_range=1) +# +# @override_settings(OPENSTACK_USE_SIMPLE_TENANT_USAGE=False) +# def test_usage_csv_disabled(self): +# self._test_usage_csv(nova_stu_enabled=False) +# +# def _test_usage_csv(self, nova_stu_enabled=True, overview_days_range=1): +# self._stub_api_calls(nova_stu_enabled, +# overview_days_range=overview_days_range) +# +# res = self.client.get(reverse('horizon:project:overview:index') + +# "?format=csv") +# self.assertTemplateUsed(res, 'project/overview/usage.csv') +# self.assertIsInstance(res.context['usage'], usage.ProjectUsage) +# self._check_api_calls(nova_stu_enabled, +# overview_days_range=overview_days_range) +# +# def test_usage_exception_usage(self): +# self._stub_api_calls(stu_exception=self.exceptions.nova) +# +# res = self.client.get(reverse('horizon:project:overview:index')) +# self.assertTemplateUsed(res, 'project/overview/usage.html') +# self.assertEqual(res.context['usage'].usage_list, []) +# +# self._check_api_calls(stu_exception=self.exceptions.nova) +# +# def test_usage_default_tenant(self): +# self._stub_api_calls() +# +# res = self.client.get(reverse('horizon:project:overview:index')) +# self.assertTemplateUsed(res, 'project/overview/usage.html') +# self.assertIsInstance(res.context['usage'], usage.ProjectUsage) +# +# self._check_api_calls() +# +# @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True}) +# def test_usage_with_neutron(self): +# self._test_usage_with_neutron(neutron_sg_enabled=True) +# +# @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True}) +# def test_usage_with_neutron_nova_security_group(self): +# self._test_usage_with_neutron(neutron_sg_enabled=False) +# +# @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True}) +# def test_usage_with_neutron_floating_ip_disabled(self): +# self._test_usage_with_neutron(neutron_fip_enabled=False) +# +# def _test_usage_with_neutron(self, +# neutron_sg_enabled=True, +# neutron_fip_enabled=True): +# self._stub_api_calls() +# self._test_usage_with_neutron_check(neutron_sg_enabled, +# neutron_fip_enabled) +# self._check_api_calls() +# +# def _test_usage_with_neutron_check(self, neutron_sg_enabled=True, +# neutron_fip_expected=True, +# max_fip_expected=50, +# max_sg_expected=20): +# res = self.client.get(reverse('horizon:project:overview:index')) +# if neutron_fip_expected: +# self.assertContains(res, 'Floating IPs') +# self.assertContains(res, 'Security Groups') +# +# res_limits = res.context['usage'].limits +# max_floating_ips = res_limits['floatingip']['quota'] +# self.assertEqual(max_floating_ips, max_fip_expected) +# if neutron_sg_enabled: +# max_security_groups = res_limits['security_group']['quota'] +# self.assertEqual(max_security_groups, max_sg_expected) +# +# def test_usage_cinder(self): +# self._stub_api_calls( +# quota_usage_overrides={'volumes': {'used': 4}, +# 'gigabytes': {'used': 400}} +# ) +# +# res = self.client.get(reverse('horizon:project:overview:index')) +# usages = res.context['usage'] +# self.assertTemplateUsed(res, 'project/overview/usage.html') +# self.assertIsInstance(usages, usage.ProjectUsage) +# +# self.assertEqual(usages.limits['volumes']['used'], 4) +# self.assertEqual(usages.limits['volumes']['quota'], 10) +# self.assertEqual(usages.limits['gigabytes']['used'], 400) +# self.assertEqual(usages.limits['gigabytes']['quota'], 1000) +# +# self._check_api_calls(nova_stu_enabled=True) +# +# # nova_stu_enable=False is specified below, so we need this. +# @override_settings(OPENSTACK_USE_SIMPLE_TENANT_USAGE=False) +# def _test_usage_charts(self, quota_usage_overrides=None, +# quota_extension_support=True): +# self._stub_api_calls(nova_stu_enabled=False, +# quota_usage_overrides=quota_usage_overrides, +# quota_extension_support=quota_extension_support) +# +# res = self.client.get(reverse('horizon:project:overview:index')) +# +# self._check_api_calls(nova_stu_enabled=False) +# +# return res +# +# def test_usage_charts_created(self): +# res = self._test_usage_charts( +# quota_usage_overrides={'floatingip': {'quota': -1, 'used': 1234}}) +# self.assertIn('charts', res.context) +# charts = res.context['charts'] +# +# self.assertEqual(['Compute', 'Volume', 'Network'], +# [c['title'] for c in charts]) +# +# compute_charts = [c for c in charts if c['title'] == 'Compute'][0] +# chart_ram = [c for c in compute_charts['charts'] +# if c['type'] == 'ram'][0] +# # Check mb_float_format filter is applied +# self.assertEqual(10000, chart_ram['quota']) +# self.assertEqual('9.8GB', chart_ram['quota_display']) +# self.assertEqual(0, chart_ram['used']) +# self.assertEqual('0B', chart_ram['used_display']) +# +# volume_charts = [c for c in charts if c['title'] == 'Volume'][0] +# chart_gigabytes = [c for c in volume_charts['charts'] +# if c['type'] == 'gigabytes'][0] +# # Check diskgbformat filter is applied +# self.assertEqual(1000, chart_gigabytes['quota']) +# self.assertEqual('1000GB', chart_gigabytes['quota_display']) +# self.assertEqual(0, chart_gigabytes['used']) +# self.assertEqual('0B', chart_gigabytes['used_display']) +# +# network_charts = [c for c in charts if c['title'] == 'Network'][0] +# chart_fip = [c for c in network_charts['charts'] +# if c['type'] == 'floatingip'][0] +# # Check intcomma default filter is applied +# self.assertEqual(float('inf'), chart_fip['quota']) +# self.assertEqual(float('inf'), chart_fip['quota_display']) +# self.assertEqual(1234, chart_fip['used']) +# self.assertEqual('1,234', chart_fip['used_display']) +# +# def test_disallowed_network_chart(self): +# res = self._test_usage_charts( +# quota_usage_overrides={'floatingip': {'quota': -1, 'used': 1234}}, +# quota_extension_support=False) +# charts = res.context['charts'] +# self.assertEqual(['Compute', 'Volume'], +# [c['title'] for c in charts]) +# +# def test_usage_charts_infinite_quota(self): +# res = self._test_usage_charts( +# quota_usage_overrides={'floatingip': {'quota': -1}}) +# +# max_floating_ips = res.context['usage'].limits['floatingip']['quota'] +# self.assertEqual(max_floating_ips, float("inf")) +# +# self.assertContains(res, '(No Limit)') diff --git a/venus_dashboard/log_search/urls.py b/venus_dashboard/log_search/urls.py new file mode 100644 index 0000000..2360f53 --- /dev/null +++ b/venus_dashboard/log_search/urls.py @@ -0,0 +1,26 @@ +# Copyright 2012 United States Government as represented by the +# Administrator of the National Aeronautics and Space Administration. +# All Rights Reserved. +# +# Copyright 2012 Nebula, Inc. +# +# 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.urls import url + +from venus_dashboard.log_search import views +import venus_dashboard.api.venus_rest_api #noqa + +urlpatterns = [ + url(r'^log_search$', views.LogSearch.as_view(), name='index'), +] diff --git a/venus_dashboard/log_search/views.py b/venus_dashboard/log_search/views.py new file mode 100644 index 0000000..5e10e38 --- /dev/null +++ b/venus_dashboard/log_search/views.py @@ -0,0 +1,27 @@ +# Copyright 2012 United States Government as represented by the +# Administrator of the National Aeronautics and Space Administration. +# All Rights Reserved. +# +# Copyright 2012 Nebula, Inc. +# +# 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 horizon import views + + +class LogSearch(views.APIView): + template_name = 'log_search/index.html' + + def get_data(self, request, context, *args, **kwargs): + return context diff --git a/venus_dashboard/static/app/core/openstack-service-api/venus.service.js b/venus_dashboard/static/app/core/openstack-service-api/venus.service.js new file mode 100644 index 0000000..413eb79 --- /dev/null +++ b/venus_dashboard/static/app/core/openstack-service-api/venus.service.js @@ -0,0 +1,43 @@ +(function () { + 'use strict'; + + angular + .module('horizon.app.core.openstack-service-api') + .factory('horizon.app.core.openstack-service-api.venus', venusAPI); + + venusAPI.$inject = [ + 'horizon.framework.util.http.service', + 'horizon.framework.widgets.toast.service' + + ]; + + function venusAPI(apiService, toastService) { + + function getLogStorageDays() { + var url = '/api/venus/log_storage_days/'; + + return apiService.get(url) + .catch(function () { + // toastService.add('error', gettext('Unable to fetch the venus log storage days.')); + }); + } + + function getLogs(config) { + config = config || {}; + var url = '/api/venus/logs/'; + + return apiService.get(url, config) + .catch(function () { + // toastService.add('error', gettext('Unable to fetch the venus logs.')); + }); + } + + var service = { + getLogStorageDays: getLogStorageDays, + getLogs: getLogs + }; + + return service; + } + +}()); diff --git a/venus_dashboard/static/dashboard/admin/services/venus.service.js b/venus_dashboard/static/dashboard/admin/services/venus.service.js new file mode 100644 index 0000000..c3fad73 --- /dev/null +++ b/venus_dashboard/static/dashboard/admin/services/venus.service.js @@ -0,0 +1,49 @@ +(function () { + 'use strict'; + + angular + .module('horizon.dashboard.admin.venus') + .service('venusSrv', venusSrv); + + venusSrv.$inject = ['$http', '$injector']; + + function venusSrv($http, $injector) { + var venusAPI; + + if ($injector.has('horizon.app.core.openstack-service-api.venus')) { + venusAPI = $injector.get('horizon.app.core.openstack-service-api.venus'); + } + + function getLogStorageDays() { + if (venusAPI) { + return venusAPI.getLogStorageDays() + .then(function (data) { + return data; + }) + .catch(function (err) { + console.error(err); + } + ); + } + } + + function getLogs(config) { + config = {params: config}; + if (venusAPI) { + return venusAPI.getLogs(config) + .then(function (data) { + return data; + }) + .catch(function (err) { + console.error(err); + } + ); + } + } + + return { + getLogStorageDays: getLogStorageDays, + getLogs: getLogs + }; + } +})(); diff --git a/venus_dashboard/static/dashboard/admin/venus.module.js b/venus_dashboard/static/dashboard/admin/venus.module.js new file mode 100644 index 0000000..a54ff14 --- /dev/null +++ b/venus_dashboard/static/dashboard/admin/venus.module.js @@ -0,0 +1,6 @@ +(function() { + 'use strict'; + + angular.module('horizon.dashboard.admin.venus',['ui.bootstrap']); + +})(); diff --git a/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.controller.js b/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.controller.js new file mode 100644 index 0000000..9046e0f --- /dev/null +++ b/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.controller.js @@ -0,0 +1,51 @@ +(function () { + 'use strict'; + + angular + .module('horizon.dashboard.admin.venus') + .controller('LogSearchController', LogSearchController); + + LogSearchController.$inject = ['$scope', 'venusSrv']; + + function LogSearchController($scope, venusSrv) { + $scope.STATIC_URL = STATIC_URL; + $scope.model = { + start_time: new Date(), + end_time: new Date(), + condition: 'module_name', + page_size: 20, + page_num: 1 + }; + $scope.tableData = []; + + $scope.getData = function() { + var config = { + start_time: $scope.model.start_time.getTime() / 1000, + end_time: $scope.model.end_time.getTime() / 1000, + page_size: $scope.model.page_size, + page_num: $scope.model.page_num + }; + venusSrv.getLogs(config).then(function(res) { + $scope.tableData = []; + if (res.data.hasOwnProperty('data')) { + $scope.tableData = res.data.data.values; + } + }); + }; + + function init() { + var end_time = new Date(); + end_time.setMilliseconds(0); + var start_time = new Date(); + start_time.setMilliseconds(0); + start_time.setTime(end_time.getTime() - 24 * 60 * 60 * 1000); + $scope.model.start_time = start_time; + $scope.model.end_time = end_time; + + $scope.getData(); + } + + init(); + } + +})(); diff --git a/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.css b/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.css new file mode 100644 index 0000000..e69de29 diff --git a/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.html b/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.html new file mode 100644 index 0000000..faa602d --- /dev/null +++ b/venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.html @@ -0,0 +1,55 @@ +
+
+
+
+
+ +
+ - +
+ +
+
+ +
+
+ +
+
+ +
+
+
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + +
时间主机模块组件级别项目ID用户ID描述
暂无数据。
{$ item.time $}{$ item.host_name $}{$ item.module_name $}{$ item.program_name $}{$ item.level $}{$ item.project_id $}{$ item.user_id $}{$ item.desc $}
+
+
\ No newline at end of file