1 files changed, 73 insertions, 0 deletions
diff --git a/src/pybind/mgr/dashboard/controllers/logs.py b/src/pybind/mgr/dashboard/controllers/logs.py
new file mode 100644
index 000000000..cc217ce0d
--- /dev/null
+++ b/src/pybind/mgr/dashboard/controllers/logs.py
@@ -0,0 +1,73 @@
+# -*- coding: utf-8 -*-
+from __future__ import absolute_import
+
+import collections
+
+from ..security import Scope
+from ..services.ceph_service import CephService
+from ..tools import NotificationQueue
+from . import APIDoc, APIRouter, BaseController, Endpoint, EndpointDoc, ReadPermission
+
+LOG_BUFFER_SIZE = 30
+
+LOGS_SCHEMA = {
+    "clog": ([str], ""),
+    "audit_log": ([{
+        "name": (str, ""),
+        "rank": (str, ""),
+        "addrs": ({
+            "addrvec": ([{
+                "type": (str, ""),
+                "addr": (str, "IP Address"),
+                "nonce": (int, ""),
+            }], ""),
+        }, ""),
+        "stamp": (str, ""),
+        "seq": (int, ""),
+        "channel": (str, ""),
+        "priority": (str, ""),
+        "message": (str, ""),
+    }], "Audit log")
+}
+
+
+@APIRouter('/logs', Scope.LOG)
+@APIDoc("Logs Management API", "Logs")
+class Logs(BaseController):
+    def __init__(self):
+        super().__init__()
+        self._log_initialized = False
+        self.log_buffer = collections.deque(maxlen=LOG_BUFFER_SIZE)
+        self.audit_buffer = collections.deque(maxlen=LOG_BUFFER_SIZE)
+
+    def append_log(self, log_struct):
+        if log_struct['channel'] == 'audit':
+            self.audit_buffer.appendleft(log_struct)
+        else:
+            self.log_buffer.appendleft(log_struct)
+
+    def load_buffer(self, buf, channel_name):
+        lines = CephService.send_command(
+            'mon', 'log last', channel=channel_name, num=LOG_BUFFER_SIZE, level='debug')
+        for line in lines:
+            buf.appendleft(line)
+
+    def initialize_buffers(self):
+        if not self._log_initialized:
+            self._log_initialized = True
+
+            self.load_buffer(self.log_buffer, 'cluster')
+            self.load_buffer(self.audit_buffer, 'audit')
+
+            NotificationQueue.register(self.append_log, 'clog')
+
+    @Endpoint()
+    @ReadPermission
+    @EndpointDoc("Display Logs Configuration",
+                 responses={200: LOGS_SCHEMA})
+    def all(self):
+        self.initialize_buffers()
+        return dict(
+            clog=list(self.log_buffer),
+            audit_log=list(self.audit_buffer),
+        )