Compare commits
No commits in common. "gh-pages" and "main" have entirely different histories.
16 changed files with 417 additions and 827 deletions
4
.gitignore
vendored
Normal file
4
.gitignore
vendored
Normal file
|
|
@ -0,0 +1,4 @@
|
|||
_build/
|
||||
.merlin
|
||||
*.install
|
||||
.*.swp
|
||||
22
CHANGES.md
Normal file
22
CHANGES.md
Normal file
|
|
@ -0,0 +1,22 @@
|
|||
# v0.0.5 (2024-04-10)
|
||||
|
||||
* Update to mirage-runtime 4.5.0 API changes (Arg.log_threshold is now
|
||||
Conv.log_threshold)
|
||||
|
||||
# v0.0.4 (2023-03-05)
|
||||
|
||||
* Remove mirage-solo5 dependency, now that mirage-solo5 and mirage-xen install
|
||||
a memory metrics themselves
|
||||
|
||||
# v0.0.3 (2022-09-26)
|
||||
|
||||
* Upgrade to Mirage 4.3.0+
|
||||
|
||||
# v0.0.2 (2022-08-08)
|
||||
|
||||
* Upgrade to MirageOS4 (mirage-solo5 >= 0.7.0), drop usage of deprecated
|
||||
OS.MM.malloc_metrics
|
||||
|
||||
# v0.0.1 (2022-05-22)
|
||||
|
||||
* Initial public release
|
||||
51
README.md
Normal file
51
README.md
Normal file
|
|
@ -0,0 +1,51 @@
|
|||
# Grafana MirageOS Unikernel monitoring
|
||||
|
||||
Using Influx, Telegraf, etc.
|
||||
|
||||
|
||||
|
||||
Best used on a private network interface for your unikernel.
|
||||
|
||||
# Output metrics to influx / telegraf
|
||||
|
||||
The provided `ip:port` in `create` is used to send every `interval` seconds
|
||||
gathered metrics to, using the Influx wire protocol.
|
||||
|
||||
# Dynamic adjustments of Log level and Metrics reporting
|
||||
|
||||
The `create` function has a *listener_port* argument (defaulting to 2323). On the
|
||||
customizable port TCP connections to the unikernel are possible. Each connection
|
||||
can transmit a command (as text) to adjust log level and enable or disable
|
||||
metrics sources:
|
||||
|
||||
The log level (prefix `L`) is specified, the same as the command-line argument `-l`:
|
||||
- `L*:debug` all log sources are enabled on the *debug* level.
|
||||
- `Lmonitoring-experiments:error` the log source monitoring-experiments is set to the *error* level.
|
||||
- `L*:info,monitoring-experiments:debug` all log sources are enabled on the *info* level, and the log source monitoring-experiments is set to the *debug* level.
|
||||
|
||||
The metrics (prefix `M`) sources can be enabled and disabled based on source name.
|
||||
First, if present, the all command is executed, then the tags, then specific sources:
|
||||
- `M*:disable,memory:enable,net-solo5:enable` disables all metrics sources, and then enables *memory* and *net-solo5*.
|
||||
- `Mnet-solo5:disable` disables the *net-solo5* metrics source.
|
||||
- `Mtag:http:enable` enables all metrics with the *http* tag.
|
||||
|
||||
The log levels for the log sources can be inspected:
|
||||
- `l` reports the default log level and the log level for all log sources with a different log level.
|
||||
- `l*` reports the default log level and the log level for all log sources.
|
||||
- `lmonitoring-experiments,dns` reports the log level for monitoring-experiments and dns respectively.
|
||||
|
||||
Likewise, metrics status can be similarly inspected:
|
||||
- `m` reports the default metrics status and the metrics status for all metrics sources with a different status.
|
||||
- `m*` reports the default metrics status, all enabled tags, and the metrics status of all metrics sources.
|
||||
- `mmemory,net-solo5` reports the metrics status for memory and net-solo5 respectively.
|
||||
|
||||
# Memprof tracing
|
||||
|
||||
The `create` function has a `memtrace_port` argument (defualts to 4242). On this
|
||||
port, when a TCP client connects,
|
||||
[OCaml memory profiling](https://ocaml.org/api/Gc.Memprof.html) is started and
|
||||
dumped to the client. The `sampling_rate` (defaults to 1e-4) is used. This uses
|
||||
the [memprof-mirage](https://github.com/hannesm/memprof-mirage) package.
|
||||
|
||||
The output trace is best being viewed with
|
||||
[memtrace_viewer](https://github.com/janestreet/memtrace_viewer/).
|
||||
2
dune-project
Normal file
2
dune-project
Normal file
|
|
@ -0,0 +1,2 @@
|
|||
(lang dune 1.0)
|
||||
(name mirage-monitoring)
|
||||
File diff suppressed because one or more lines are too long
19
index.html
19
index.html
|
|
@ -1,19 +0,0 @@
|
|||
<!DOCTYPE html>
|
||||
<html xmlns="http://www.w3.org/1999/xhtml">
|
||||
<head>
|
||||
<title>index</title>
|
||||
<link rel="stylesheet" href="./odoc.css"/>
|
||||
<meta charset="utf-8"/>
|
||||
<meta name="viewport" content="width=device-width,initial-scale=1.0"/>
|
||||
</head>
|
||||
<body>
|
||||
<main class="content">
|
||||
<div class="by-name">
|
||||
<h2>OCaml package documentation</h2>
|
||||
<ol>
|
||||
<li><a href="mirage-monitoring/index.html">mirage-monitoring</a> <span class="version">0.0.2</span></li>
|
||||
</ol>
|
||||
</div>
|
||||
</main>
|
||||
</body>
|
||||
</html>
|
||||
36
mirage-monitoring.opam
Normal file
36
mirage-monitoring.opam
Normal file
|
|
@ -0,0 +1,36 @@
|
|||
opam-version: "2.0"
|
||||
maintainer: "Robur <team@robur.coop>"
|
||||
authors: ["Robur <team@robur.coop>"]
|
||||
homepage: "https://github.com/robur-coop/mirage-monitoring"
|
||||
doc: "https://robur-coop.github.io/mirage-monitoring"
|
||||
dev-repo: "git+https://github.com/robur-coop/mirage-monitoring.git"
|
||||
bug-reports: "https://github.com/robur-coop/mirage-monitoring/issues"
|
||||
license: "AGPL-3.0-only"
|
||||
|
||||
depends: [
|
||||
"ocaml" {>= "4.11.0"}
|
||||
"dune"
|
||||
"logs" {>= "0.6.3"}
|
||||
"metrics" {>= "0.4.0"}
|
||||
"metrics-lwt" {>= "0.2.0"}
|
||||
"metrics-influx" {>= "0.2.0"}
|
||||
"mirage-time" {>= "2.0.0"}
|
||||
"tcpip" {>= "7.0.0"}
|
||||
"mirage-runtime" {>= "4.5.0"}
|
||||
"memtrace-mirage" {>= "0.2.1.2.2"}
|
||||
"mirage-clock" {>= "4.0.0"}
|
||||
]
|
||||
conflicts: [
|
||||
"mirage-solo5" {< "0.9.2"}
|
||||
"mirage-xen" {< "8.0.2"}
|
||||
]
|
||||
build: [
|
||||
["dune" "subst"] {dev}
|
||||
["dune" "build" "-p" name "-j" jobs]
|
||||
["dune" "runtest" "-p" name "-j" jobs] {with-test}
|
||||
]
|
||||
synopsis: "Monitoring of MirageOS unikernels"
|
||||
description: """
|
||||
Reporting metrics to Influx, Telegraf. Dynamic adjusting log level and metrics
|
||||
sources, memprof profiling.
|
||||
"""
|
||||
|
|
@ -1,12 +0,0 @@
|
|||
<!DOCTYPE html>
|
||||
<html xmlns="http://www.w3.org/1999/xhtml"><head><title>Make (mirage-monitoring.Mirage_monitoring.Make)</title><link rel="stylesheet" href="../../../odoc.css"/><meta charset="utf-8"/><meta name="generator" content="odoc 2.1.1"/><meta name="viewport" content="width=device-width,initial-scale=1.0"/><script src="../../../highlight.pack.js"></script><script>hljs.initHighlightingOnLoad();</script></head><body class="odoc"><nav class="odoc-nav"><a href="../index.html">Up</a> – <a href="../../index.html">mirage-monitoring</a> » <a href="../index.html">Mirage_monitoring</a> » Make</nav><header class="odoc-preamble"><h1>Module <code><span>Mirage_monitoring.Make</span></code></h1></header><nav class="odoc-toc"><ul><li><a href="#parameters">Parameters</a></li><li><a href="#signature">Signature</a></li></ul></nav><div class="odoc-content"><h2 id="parameters"><a href="#parameters" class="anchor"></a>Parameters</h2><div class="odoc-spec"><div class="spec parameter" id="argument-1-T" class="anchored"><a href="#argument-1-T" class="anchor"></a><code><span><span class="keyword">module</span> </span><span>T</span><span> : <span class="xref-unresolved">Mirage_time</span>.S</span></code></div></div><div class="odoc-spec"><div class="spec parameter" id="argument-2-P" class="anchored"><a href="#argument-2-P" class="anchor"></a><code><span><span class="keyword">module</span> </span><span>P</span><span> : <span class="xref-unresolved">Mirage_clock</span>.PCLOCK</span></code></div></div><div class="odoc-spec"><div class="spec parameter" id="argument-3-S" class="anchored"><a href="#argument-3-S" class="anchor"></a><code><span><span class="keyword">module</span> </span><span>S</span><span> : <span class="xref-unresolved">Tcpip</span>.Stack.V4V6</span></code></div></div><h2 id="signature"><a href="#signature" class="anchor"></a>Signature</h2><div class="odoc-spec"><div class="spec value" id="val-create" class="anchored"><a href="#val-create" class="anchor"></a><code><span><span class="keyword">val</span> create :
|
||||
<span>?interval:int <span class="arrow">-></span></span>
|
||||
<span>?quick:bool <span class="arrow">-></span></span>
|
||||
<span>?hostname:string <span class="arrow">-></span></span>
|
||||
<span><span class="xref-unresolved">Ipaddr</span>.t <span class="arrow">-></span></span>
|
||||
<span>?port:int <span class="arrow">-></span></span>
|
||||
<span>?listen_port:int <span class="arrow">-></span></span>
|
||||
<span>?memtrace_port:int <span class="arrow">-></span></span>
|
||||
<span>?sampling_rate:float <span class="arrow">-></span></span>
|
||||
<span><span class="xref-unresolved">S</span>.t <span class="arrow">-></span></span>
|
||||
unit</span></code></div><div class="spec-doc"><p><code>create ~interval ~quick ~hostname ip ~port ~listen_port ~memtrace_port ~sampling_rate stack</code> initiates monitoring on <code>stack</code> for the unikernel. The metrics are reported every <code>interval</code> (defaults to 10) seconds to <code>ip</code> on <code>port</code> (defaults to 8094) via TCP using the influxd wire protocol. On <code>listen_port</code> (defaults to 2323) a TCP connection can be initiated to adjust the log level and enable and disable metrics sources. On <code>memtrace_port</code> (defaults to 4242) a single TCP client can connect simultaneously to receive a <code>Gc.Memprof</code> trace. The <code>sampling_rate</code> defaults to <code>1e-4</code>. If <code>quick</code> is provided and <code>false</code> (defaults to <code>true</code>), <code>Solo5_os.Memory.stat</code> is used, otherwise <code>Solo5_os.Memory.quick_stat</code> is used.</p></div></div></div></body></html>
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
<!DOCTYPE html>
|
||||
<html xmlns="http://www.w3.org/1999/xhtml"><head><title>Mirage_monitoring (mirage-monitoring.Mirage_monitoring)</title><link rel="stylesheet" href="../../odoc.css"/><meta charset="utf-8"/><meta name="generator" content="odoc 2.1.1"/><meta name="viewport" content="width=device-width,initial-scale=1.0"/><script src="../../highlight.pack.js"></script><script>hljs.initHighlightingOnLoad();</script></head><body class="odoc"><nav class="odoc-nav"><a href="../index.html">Up</a> – <a href="../index.html">mirage-monitoring</a> » Mirage_monitoring</nav><header class="odoc-preamble"><h1>Module <code><span>Mirage_monitoring</span></code></h1></header><div class="odoc-content"><div class="odoc-spec"><div class="spec value" id="val-counter_metrics" class="anchored"><a href="#val-counter_metrics" class="anchor"></a><code><span><span class="keyword">val</span> counter_metrics :
|
||||
<span>f:<span>( <span><span class="type-var">'a</span> <span class="arrow">-></span></span> string )</span> <span class="arrow">-></span></span>
|
||||
<span>string <span class="arrow">-></span></span>
|
||||
<span><span>( <span><span class="xref-unresolved">Metrics</span>.field list</span>, <span><span class="type-var">'a</span> <span class="arrow">-></span></span> <span class="xref-unresolved">Metrics</span>.data )</span> <span class="xref-unresolved">Metrics</span>.src</span></span></code></div></div><div class="odoc-spec"><div class="spec value" id="val-vmname" class="anchored"><a href="#val-vmname" class="anchor"></a><code><span><span class="keyword">val</span> vmname : <span>string <span class="arrow">-></span></span> <span class="xref-unresolved">Metrics</span>.field</span></code></div><div class="spec-doc"><p><code>vmname name</code> creates a <code>tag</code> with the virtual machine name.</p></div></div><div class="odoc-spec"><div class="spec module" id="module-Make" class="anchored"><a href="#module-Make" class="anchor"></a><code><span><span class="keyword">module</span> <a href="Make/index.html">Make</a></span><span>
|
||||
(<a href="Make/index.html#argument-1-T">T</a> : <span class="xref-unresolved">Mirage_time</span>.S)
|
||||
(<a href="Make/index.html#argument-2-P">P</a> : <span class="xref-unresolved">Mirage_clock</span>.PCLOCK)
|
||||
(<a href="Make/index.html#argument-3-S">S</a> : <span class="xref-unresolved">Tcpip</span>.Stack.V4V6) :
|
||||
<span class="keyword">sig</span> ... <span class="keyword">end</span></span></code></div></div></div></body></html>
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
<!DOCTYPE html>
|
||||
<html xmlns="http://www.w3.org/1999/xhtml"><head><title>index (mirage-monitoring.index)</title><link rel="stylesheet" href="../odoc.css"/><meta charset="utf-8"/><meta name="generator" content="odoc 2.1.1"/><meta name="viewport" content="width=device-width,initial-scale=1.0"/><script src="../highlight.pack.js"></script><script>hljs.initHighlightingOnLoad();</script></head><body class="odoc"><nav class="odoc-nav"><a href="../index.html">Up</a> – mirage-monitoring</nav><header class="odoc-preamble"><h1 id="mirage-monitoring-index"><a href="#mirage-monitoring-index" class="anchor"></a>mirage-monitoring index</h1></header><nav class="odoc-toc"><ul><li><a href="#library-mirage-monitoring">Library mirage-monitoring</a></li></ul></nav><div class="odoc-content"><h2 id="library-mirage-monitoring"><a href="#library-mirage-monitoring" class="anchor"></a>Library mirage-monitoring</h2><p>The entry point of this library is the module: <a href="Mirage_monitoring/index.html"><code>Mirage_monitoring</code></a>.</p></div></body></html>
|
||||
783
odoc.css
783
odoc.css
|
|
@ -1,783 +0,0 @@
|
|||
@charset "UTF-8";
|
||||
/* Copyright (c) 2016 The odoc contributors. All rights reserved.
|
||||
Distributed under the ISC license, see terms at the end of the file.
|
||||
odoc 2.1.1 */
|
||||
|
||||
/* Fonts */
|
||||
@import url('https://fonts.googleapis.com/css?family=Fira+Mono:400,500');
|
||||
@import url('https://fonts.googleapis.com/css?family=Noticia+Text:400,400i,700');
|
||||
@import url('https://fonts.googleapis.com/css?family=Fira+Sans:400,400i,500,500i,600,600i,700,700i');
|
||||
|
||||
:root,
|
||||
.light:root {
|
||||
--main-background: #FFFFFF;
|
||||
|
||||
--color: #333333;
|
||||
--link-color: #2C94BD;
|
||||
--anchor-hover: #555;
|
||||
--anchor-color: #d5d5d5;
|
||||
--xref-shadow: #cc6666;
|
||||
--header-shadow: #ddd;
|
||||
--by-name-version-color: #aaa;
|
||||
--by-name-nav-link-color: #222;
|
||||
--target-background: rgba(187, 239, 253, 0.3);
|
||||
--target-shadow: rgba(187, 239, 253, 0.8);
|
||||
--pre-border-color: #eee;
|
||||
--code-background: #f6f8fa;
|
||||
|
||||
--li-code-background: #f6f8fa;
|
||||
--li-code-color: #0d2b3e;
|
||||
--toc-color: #1F2D3D;
|
||||
--toc-before-color: #777;
|
||||
--toc-background: #f6f8fa;
|
||||
--toc-list-border: #ccc;
|
||||
|
||||
--spec-summary-border-color: #5c9cf5;
|
||||
--spec-summary-background: var(--code-background);
|
||||
--spec-summary-hover-background: #ebeff2;
|
||||
--spec-details-after-background: rgba(0, 4, 15, 0.05);
|
||||
--spec-details-after-shadow: rgba(204, 204, 204, 0.53);
|
||||
}
|
||||
|
||||
.dark:root {
|
||||
--main-background: #202020;
|
||||
--code-background: #222;
|
||||
--line-numbers-background: rgba(0, 0, 0, 0.125);
|
||||
--navbar-background: #202020;
|
||||
|
||||
--color: #bebebe;
|
||||
--dirname-color: #666;
|
||||
--underline-color: #444;
|
||||
--visited-color: #002800;
|
||||
--visited-number-color: #252;
|
||||
--unvisited-color: #380000;
|
||||
--unvisited-number-color: #622;
|
||||
--somevisited-color: #303000;
|
||||
--highlight-color: #303e3f;
|
||||
--line-number-color: rgba(230, 230, 230, 0.3);
|
||||
--unvisited-margin-color: #622;
|
||||
--border: #333;
|
||||
--navbar-border: #333;
|
||||
--code-color: #ccc;
|
||||
|
||||
--li-code-background: #373737;
|
||||
--li-code-color: #999;
|
||||
--toc-color: #777;
|
||||
--toc-background: #252525;
|
||||
|
||||
--hljs-link: #999;
|
||||
--hljs-keyword: #cda869;
|
||||
--hljs-regexp: #f9ee98;
|
||||
--hljs-title: #dcdcaa;
|
||||
--hljs-type: #ac885b;
|
||||
--hljs-meta: #82aaff;
|
||||
--hljs-variable: #cf6a4c;
|
||||
}
|
||||
|
||||
@media (prefers-color-scheme: dark) {
|
||||
:root {
|
||||
--main-background: #202020;
|
||||
--code-background: #333;
|
||||
--line-numbers-background: rgba(0, 0, 0, 0.125);
|
||||
--navbar-background: #202020;
|
||||
|
||||
--meter-unvisited-color: #622;
|
||||
--meter-visited-color: #252;
|
||||
--meter-separator-color: black;
|
||||
|
||||
--color: #bebebe;
|
||||
--dirname-color: #666;
|
||||
--underline-color: #444;
|
||||
--visited-color: #002800;
|
||||
--visited-number-color: #252;
|
||||
--unvisited-color: #380000;
|
||||
--unvisited-number-color: #622;
|
||||
--somevisited-color: #303000;
|
||||
--highlight-color: #303e3f;
|
||||
--line-number-color: rgba(230, 230, 230, 0.3);
|
||||
--unvisited-margin-color: #622;
|
||||
--border: #333;
|
||||
--navbar-border: #333;
|
||||
--code-color: #ccc;
|
||||
--by-name-nav-link-color: var(--color);
|
||||
|
||||
--li-code-background: #373737;
|
||||
--li-code-color: #999;
|
||||
--toc-color: #777;
|
||||
--toc-before-color: #777;
|
||||
--toc-background: #252525;
|
||||
--toc-list-border: #ccc;
|
||||
--spec-summary-hover-background: #ebeff2;
|
||||
--spec-details-after-background: rgba(0, 4, 15, 0.05);
|
||||
--spec-details-after-shadow: rgba(204, 204, 204, 0.53);
|
||||
|
||||
--hljs-link: #999;
|
||||
--hljs-keyword: #cda869;
|
||||
--hljs-regexp: #f9ee98;
|
||||
--hljs-title: #dcdcaa;
|
||||
--hljs-type: #ac885b;
|
||||
--hljs-meta: #82aaff;
|
||||
--hljs-variable: #cf6a4c;
|
||||
}
|
||||
}
|
||||
|
||||
/* Reset a few things. */
|
||||
|
||||
html, body, div, span, applet, object, iframe, h1, h2, h3, h4, h5, h6, p, blockquote, pre, a, abbr, acronym, address, big, cite, code, del, dfn, em, img, ins, kbd, q, s, samp, small, strike, strong, sub, sup, tt, var, b, u, i, center, dl, dt, dd, ol, ul, li, fieldset, form, label, legend, table, caption, tbody, tfoot, thead, tr, th, td, article, aside, canvas, details, embed, figure, figcaption, footer, header, hgroup, menu, nav, output, ruby, section, summary, time, mark, audio, video {
|
||||
padding: 0;
|
||||
border: 0;
|
||||
font: inherit;
|
||||
vertical-align: baseline;
|
||||
|
||||
}
|
||||
|
||||
table {
|
||||
border-collapse: collapse;
|
||||
border-spacing: 0;
|
||||
}
|
||||
|
||||
*, *:before, *:after {
|
||||
box-sizing: border-box;
|
||||
}
|
||||
|
||||
html {
|
||||
font-size: 15px;
|
||||
}
|
||||
|
||||
body {
|
||||
text-align: left;
|
||||
background: #FFFFFF;
|
||||
color: var(--color);
|
||||
background-color: var(--main-background);
|
||||
}
|
||||
|
||||
body {
|
||||
max-width: 100ex;
|
||||
margin-left: calc(10vw + 20ex);
|
||||
margin-right: 4ex;
|
||||
margin-top: 20px;
|
||||
margin-bottom: 50px;
|
||||
font-family: "Noticia Text", Georgia, serif;
|
||||
line-height: 1.5;
|
||||
}
|
||||
|
||||
header {
|
||||
margin-bottom: 30px;
|
||||
}
|
||||
|
||||
nav {
|
||||
font-family: "Fira Sans", Helvetica, Arial, sans-serif;
|
||||
}
|
||||
|
||||
/* Basic markup elements */
|
||||
|
||||
b, strong {
|
||||
font-weight: bold;
|
||||
}
|
||||
|
||||
i {
|
||||
font-style: italic;
|
||||
}
|
||||
|
||||
em, i em.odd{
|
||||
font-style: italic;
|
||||
}
|
||||
|
||||
em.odd, i em {
|
||||
font-style: normal;
|
||||
}
|
||||
|
||||
sup {
|
||||
vertical-align: super;
|
||||
}
|
||||
|
||||
sub {
|
||||
vertical-align: sub;
|
||||
}
|
||||
|
||||
sup, sub {
|
||||
font-size: 12px;
|
||||
line-height: 0;
|
||||
margin-left: 0.2ex;
|
||||
}
|
||||
|
||||
ul, ol {
|
||||
list-style-position: outside
|
||||
}
|
||||
|
||||
ul>li {
|
||||
margin-left: 22px;
|
||||
}
|
||||
|
||||
ol>li {
|
||||
margin-left: 27.2px;
|
||||
}
|
||||
|
||||
li>*:first-child {
|
||||
margin-top: 0
|
||||
}
|
||||
|
||||
/* Text alignements, this should be forbidden. */
|
||||
|
||||
.left {
|
||||
text-align: left;
|
||||
}
|
||||
|
||||
.right {
|
||||
text-align: right;
|
||||
}
|
||||
|
||||
.center {
|
||||
text-align: center;
|
||||
}
|
||||
|
||||
/* Links and anchors */
|
||||
|
||||
a {
|
||||
text-decoration: none;
|
||||
color: var(--link-color);
|
||||
}
|
||||
|
||||
a:hover {
|
||||
box-shadow: 0 1px 0 0 var(--link-color);
|
||||
}
|
||||
|
||||
/* Linked highlight */
|
||||
*:target {
|
||||
background-color: var(--target-background) !important;
|
||||
box-shadow: 0 0px 0 1px var(--target-shadow) !important;
|
||||
border-radius: 1px;
|
||||
}
|
||||
|
||||
*:hover > a.anchor {
|
||||
visibility: visible;
|
||||
}
|
||||
|
||||
a.anchor:before {
|
||||
content: "#";
|
||||
}
|
||||
|
||||
a.anchor:hover {
|
||||
box-shadow: none;
|
||||
text-decoration: none;
|
||||
color: var(--anchor-hover);
|
||||
}
|
||||
|
||||
a.anchor {
|
||||
visibility: hidden;
|
||||
position: absolute;
|
||||
/* top: 0px; */
|
||||
/* margin-left: -3ex; */
|
||||
margin-left: -1.3em;
|
||||
font-weight: normal;
|
||||
font-style: normal;
|
||||
padding-right: 0.4em;
|
||||
padding-left: 0.4em;
|
||||
/* To remain selectable */
|
||||
color: var(--anchor-color);
|
||||
}
|
||||
|
||||
.spec > a.anchor {
|
||||
margin-left: -2.3em;
|
||||
padding-right: 0.9em;
|
||||
}
|
||||
|
||||
.xref-unresolved {
|
||||
color: #2C94BD;
|
||||
}
|
||||
.xref-unresolved:hover {
|
||||
box-shadow: 0 1px 0 0 var(--xref-shadow);
|
||||
}
|
||||
|
||||
/* Section and document divisions.
|
||||
Until at least 4.03 many of the modules of the stdlib start at .h7,
|
||||
we restart the sequence there like h2 */
|
||||
|
||||
h1, h2, h3, h4, h5, h6, .h7, .h8, .h9, .h10 {
|
||||
font-family: "Fira Sans", Helvetica, Arial, sans-serif;
|
||||
font-weight: 400;
|
||||
padding-top: 0.1em;
|
||||
line-height: 1.2;
|
||||
overflow-wrap: break-word;
|
||||
}
|
||||
|
||||
h1 {
|
||||
font-weight: 500;
|
||||
font-size: 2.441em;
|
||||
}
|
||||
|
||||
h1 {
|
||||
font-weight: 500;
|
||||
font-size: 1.953em;
|
||||
box-shadow: 0 1px 0 0 var(--header-shadow);
|
||||
}
|
||||
|
||||
h2 {
|
||||
font-size: 1.563em;
|
||||
}
|
||||
|
||||
h3 {
|
||||
font-size: 1.25em;
|
||||
}
|
||||
|
||||
small, .font_small {
|
||||
font-size: 0.8em;
|
||||
}
|
||||
|
||||
h1 code, h1 tt {
|
||||
font-size: inherit;
|
||||
font-weight: inherit;
|
||||
}
|
||||
|
||||
h2 code, h2 tt {
|
||||
font-size: inherit;
|
||||
font-weight: inherit;
|
||||
}
|
||||
|
||||
h3 code, h3 tt {
|
||||
font-size: inherit;
|
||||
font-weight: inherit;
|
||||
}
|
||||
|
||||
h3 code, h3 tt {
|
||||
font-size: inherit;
|
||||
font-weight: inherit;
|
||||
}
|
||||
|
||||
h4 {
|
||||
font-size: 1.12em;
|
||||
}
|
||||
|
||||
/* Comment delimiters, hidden but accessible to screen readers and
|
||||
selected for copy/pasting */
|
||||
|
||||
/* Taken from bootstrap */
|
||||
/* See also https://stackoverflow.com/a/27769435/4220738 */
|
||||
.comment-delim {
|
||||
position: absolute;
|
||||
width: 1px;
|
||||
height: 1px;
|
||||
padding: 0;
|
||||
margin: -1px;
|
||||
overflow: hidden;
|
||||
clip: rect(0, 0, 0, 0);
|
||||
white-space: nowrap;
|
||||
border: 0;
|
||||
}
|
||||
|
||||
/* Preformatted and code */
|
||||
|
||||
tt, code, pre {
|
||||
font-family: "Fira Mono", courier;
|
||||
font-weight: 400;
|
||||
}
|
||||
|
||||
pre {
|
||||
padding: 0.1em;
|
||||
border: 1px solid var(--pre-border-color);
|
||||
border-radius: 5px;
|
||||
overflow-x: auto;
|
||||
}
|
||||
|
||||
p code,
|
||||
li code {
|
||||
background-color: var(--li-code-background);
|
||||
color: var(--li-code-color);
|
||||
border-radius: 3px;
|
||||
padding: 0 0.3ex;
|
||||
}
|
||||
|
||||
p a > code {
|
||||
color: var(--link-color);
|
||||
}
|
||||
|
||||
code {
|
||||
white-space: pre-wrap;
|
||||
}
|
||||
|
||||
/* Code blocks (e.g. Examples) */
|
||||
|
||||
pre code {
|
||||
font-size: 0.893rem;
|
||||
}
|
||||
|
||||
/* Code lexemes */
|
||||
|
||||
.keyword {
|
||||
font-weight: 500;
|
||||
}
|
||||
|
||||
.arrow { white-space: nowrap }
|
||||
|
||||
/* Module member specification */
|
||||
|
||||
.spec {
|
||||
background-color: var(--spec-summary-background);
|
||||
border-radius: 3px;
|
||||
border-left: 4px solid var(--spec-summary-border-color);
|
||||
border-right: 5px solid transparent;
|
||||
padding: 0.35em 0.5em;
|
||||
}
|
||||
|
||||
.def-doc {
|
||||
margin-bottom: 10px;
|
||||
}
|
||||
|
||||
/* Spacing between items */
|
||||
div.odoc-spec,.odoc-include {
|
||||
margin-bottom: 2em;
|
||||
}
|
||||
|
||||
.spec.type .variant {
|
||||
margin-left: 2ch;
|
||||
}
|
||||
.spec.type .variant p {
|
||||
margin: 0;
|
||||
font-style: italic;
|
||||
}
|
||||
.spec.type .record {
|
||||
margin-left: 2ch;
|
||||
}
|
||||
.spec.type .record p {
|
||||
margin: 0;
|
||||
font-style: italic;
|
||||
}
|
||||
|
||||
div.def {
|
||||
margin-top: 0;
|
||||
text-indent: -2ex;
|
||||
padding-left: 2ex;
|
||||
}
|
||||
|
||||
div.def+div.def-doc {
|
||||
margin-left: 1ex;
|
||||
margin-top: 2.5px
|
||||
}
|
||||
|
||||
div.def-doc>*:first-child {
|
||||
margin-top: 0;
|
||||
}
|
||||
|
||||
/* Collapsible inlined include and module */
|
||||
|
||||
.odoc-include details {
|
||||
position: relative;
|
||||
}
|
||||
|
||||
.odoc-include.shadowed-include {
|
||||
display: none;
|
||||
}
|
||||
|
||||
.odoc-include details:after {
|
||||
z-index: -100;
|
||||
display: block;
|
||||
content: " ";
|
||||
position: absolute;
|
||||
border-radius: 0 1ex 1ex 0;
|
||||
right: -20px;
|
||||
top: 1px;
|
||||
bottom: 1px;
|
||||
width: 15px;
|
||||
background: var(--spec-details-after-background, rgba(0, 4, 15, 0.05));
|
||||
box-shadow: 0 0px 0 1px var(--spec-details-after-shadow, rgba(204, 204, 204, 0.53));
|
||||
}
|
||||
|
||||
.odoc-include summary {
|
||||
position: relative;
|
||||
margin-bottom: 1em;
|
||||
cursor: pointer;
|
||||
outline: none;
|
||||
}
|
||||
|
||||
.odoc-include summary:hover {
|
||||
background-color: var(--spec-summary-hover-background);
|
||||
}
|
||||
|
||||
/* FIXME: Does not work in Firefox. */
|
||||
.odoc-include summary::-webkit-details-marker {
|
||||
color: #888;
|
||||
transform: scaleX(-1);
|
||||
position: absolute;
|
||||
top: calc(50% - 5px);
|
||||
height: 11px;
|
||||
right: -29px;
|
||||
}
|
||||
|
||||
/* Records and variants FIXME */
|
||||
|
||||
div.def table {
|
||||
text-indent: 0em;
|
||||
padding: 0;
|
||||
margin-left: -2ex;
|
||||
}
|
||||
|
||||
td.def {
|
||||
padding-left: 2ex;
|
||||
}
|
||||
|
||||
td.def-doc *:first-child {
|
||||
margin-top: 0em;
|
||||
}
|
||||
|
||||
/* Lists of @tags */
|
||||
|
||||
.at-tags { list-style-type: none; margin-left: -3ex; }
|
||||
.at-tags li { padding-left: 3ex; text-indent: -3ex; }
|
||||
.at-tags .at-tag { text-transform: capitalize }
|
||||
|
||||
/* Lists of modules */
|
||||
|
||||
.modules { list-style-type: none; margin-left: -3ex; }
|
||||
.modules li { padding-left: 3ex; text-indent: -3ex; margin-top: 5px }
|
||||
.modules .synopsis { padding-left: 1ch; }
|
||||
|
||||
/* Odig package index */
|
||||
|
||||
.packages { list-style-type: none; margin-left: -3ex; }
|
||||
.packages li { padding-left: 3ex; text-indent: -3ex }
|
||||
.packages li a.anchor { padding-right: 0.5ch; padding-left: 3ch; }
|
||||
.packages .version { font-size: 10px; color: var(--by-name-version-color); }
|
||||
.packages .synopsis { padding-left: 1ch }
|
||||
|
||||
.by-name nav a {
|
||||
text-transform: uppercase;
|
||||
font-size: 18px;
|
||||
margin-right: 1ex;
|
||||
color: var(--by-name-nav-link-color,);
|
||||
display: inline-block;
|
||||
}
|
||||
|
||||
.by-tag nav a {
|
||||
margin-right: 1ex;
|
||||
color: var(--by-name-nav-link-color);
|
||||
display: inline-block;
|
||||
}
|
||||
|
||||
.by-tag ol { list-style-type: none; }
|
||||
.by-tag ol.tags li { margin-left: 1ch; display: inline-block }
|
||||
.by-tag td:first-child { text-transform: uppercase; }
|
||||
|
||||
/* Odig package page */
|
||||
|
||||
.package nav {
|
||||
display: inline;
|
||||
font-size: 14px;
|
||||
font-weight: normal;
|
||||
}
|
||||
|
||||
.package .version {
|
||||
font-size: 14px;
|
||||
}
|
||||
|
||||
.package.info {
|
||||
margin: 0;
|
||||
}
|
||||
|
||||
.package.info td:first-child {
|
||||
font-style: italic;
|
||||
padding-right: 2ex;
|
||||
}
|
||||
|
||||
.package.info ul {
|
||||
list-style-type: none;
|
||||
display: inline;
|
||||
margin: 0;
|
||||
}
|
||||
|
||||
.package.info li {
|
||||
display: inline-block;
|
||||
margin: 0;
|
||||
margin-right: 1ex;
|
||||
}
|
||||
|
||||
#info-authors li, #info-maintainers li {
|
||||
display: block;
|
||||
}
|
||||
|
||||
/* Sidebar and TOC */
|
||||
|
||||
.odoc-toc:before {
|
||||
display: block;
|
||||
content: "Contents";
|
||||
text-transform: uppercase;
|
||||
font-size: 1em;
|
||||
margin: 1.414em 0 0.5em;
|
||||
font-weight: 500;
|
||||
color: var(--toc-before-color);
|
||||
line-height: 1.2;
|
||||
}
|
||||
|
||||
.odoc-toc {
|
||||
position: fixed;
|
||||
top: 0px;
|
||||
bottom: 0px;
|
||||
left: 0px;
|
||||
max-width: 30ex;
|
||||
min-width: 26ex;
|
||||
width: 20%;
|
||||
background: var(--toc-background);
|
||||
overflow: auto;
|
||||
color: var(--toc-color);
|
||||
padding-left: 2ex;
|
||||
padding-right: 2ex;
|
||||
}
|
||||
|
||||
.odoc-toc ul li a {
|
||||
font-family: "Fira Sans", sans-serif;
|
||||
font-size: 0.95em;
|
||||
color: var(--color);
|
||||
font-weight: 400;
|
||||
line-height: 1.6em;
|
||||
display: block;
|
||||
}
|
||||
|
||||
.odoc-toc ul li a:hover {
|
||||
box-shadow: none;
|
||||
text-decoration: underline;
|
||||
}
|
||||
|
||||
/* First level titles */
|
||||
|
||||
.odoc-toc>ul>li>a {
|
||||
font-weight: 500;
|
||||
}
|
||||
|
||||
.odoc-toc li ul {
|
||||
margin: 0px;
|
||||
}
|
||||
|
||||
.odoc-toc ul {
|
||||
list-style-type: none;
|
||||
}
|
||||
|
||||
.odoc-toc ul li {
|
||||
margin: 0;
|
||||
}
|
||||
.odoc-toc>ul>li {
|
||||
margin-bottom: 0.3em;
|
||||
}
|
||||
|
||||
.odoc-toc ul li li {
|
||||
border-left: 1px solid var(--toc-list-border);
|
||||
margin-left: 5px;
|
||||
padding-left: 12px;
|
||||
}
|
||||
|
||||
/* Mobile adjustements. */
|
||||
|
||||
@media only screen and (max-width: 95ex) {
|
||||
.odoc-content {
|
||||
margin: auto;
|
||||
padding: 2em;
|
||||
}
|
||||
.odoc-toc {
|
||||
position: static;
|
||||
width: auto;
|
||||
min-width: unset;
|
||||
max-width: unset;
|
||||
border: none;
|
||||
padding: 0.2em 1em;
|
||||
border-radius: 5px;
|
||||
}
|
||||
}
|
||||
|
||||
/* Print adjustements. */
|
||||
|
||||
@media print {
|
||||
body {
|
||||
color: black;
|
||||
background: white;
|
||||
}
|
||||
body nav:first-child {
|
||||
visibility: hidden;
|
||||
}
|
||||
}
|
||||
|
||||
/* Syntax highlighting (based on github-gist) */
|
||||
|
||||
.hljs {
|
||||
display: block;
|
||||
background: var(--code-background);
|
||||
padding: 0.5em;
|
||||
color: var(--color);
|
||||
overflow-x: auto;
|
||||
}
|
||||
|
||||
.hljs-comment,
|
||||
.hljs-meta {
|
||||
color: #969896;
|
||||
}
|
||||
|
||||
.hljs-string,
|
||||
.hljs-variable,
|
||||
.hljs-template-variable,
|
||||
.hljs-strong,
|
||||
.hljs-emphasis,
|
||||
.hljs-quote {
|
||||
color: #df5000;
|
||||
}
|
||||
|
||||
.hljs-keyword,
|
||||
.hljs-selector-tag {
|
||||
color: #a71d5d;
|
||||
}
|
||||
|
||||
.hljs-type,
|
||||
.hljs-class .hljs-title {
|
||||
color: #458;
|
||||
font-weight: 500;
|
||||
}
|
||||
|
||||
.hljs-literal,
|
||||
.hljs-symbol,
|
||||
.hljs-bullet,
|
||||
.hljs-attribute {
|
||||
color: #0086b3;
|
||||
}
|
||||
|
||||
.hljs-section,
|
||||
.hljs-name {
|
||||
color: #63a35c;
|
||||
}
|
||||
|
||||
.hljs-tag {
|
||||
color: #333333;
|
||||
}
|
||||
|
||||
.hljs-attr,
|
||||
.hljs-selector-id,
|
||||
.hljs-selector-class,
|
||||
.hljs-selector-attr,
|
||||
.hljs-selector-pseudo {
|
||||
color: #795da3;
|
||||
}
|
||||
|
||||
.hljs-addition {
|
||||
color: #55a532;
|
||||
background-color: #eaffea;
|
||||
}
|
||||
|
||||
.hljs-deletion {
|
||||
color: #bd2c00;
|
||||
background-color: #ffecec;
|
||||
}
|
||||
|
||||
.hljs-link {
|
||||
text-decoration: underline;
|
||||
}
|
||||
|
||||
/*---------------------------------------------------------------------------
|
||||
Copyright (c) 2016 The odoc contributors
|
||||
|
||||
Permission to use, copy, modify, and/or distribute this software for any
|
||||
purpose with or without fee is hereby granted, provided that the above
|
||||
copyright notice and this permission notice appear in all copies.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
||||
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
||||
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
||||
ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
||||
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
||||
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
||||
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
||||
---------------------------------------------------------------------------*/
|
||||
BIN
one.png
Normal file
BIN
one.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 223 KiB |
6
src/dune
Normal file
6
src/dune
Normal file
|
|
@ -0,0 +1,6 @@
|
|||
(library
|
||||
(name mirage_monitoring)
|
||||
(public_name mirage-monitoring)
|
||||
(wrapped false)
|
||||
(libraries logs metrics metrics-lwt metrics-influx mirage-time mirage-clock
|
||||
memtrace-mirage tcpip mirage-runtime))
|
||||
275
src/mirage_monitoring.ml
Normal file
275
src/mirage_monitoring.ml
Normal file
|
|
@ -0,0 +1,275 @@
|
|||
open Lwt.Infix
|
||||
|
||||
let src = Logs.Src.create "mirage-monitoring" ~doc:"MirageOS monitoring"
|
||||
module Log = (val Logs.src_log src : Logs.LOG)
|
||||
|
||||
let ( let* ) = Result.bind
|
||||
|
||||
let create ~f =
|
||||
let data : (string, int) Hashtbl.t = Hashtbl.create 7 in
|
||||
(fun x ->
|
||||
let key = f x in
|
||||
let cur = match Hashtbl.find_opt data key with
|
||||
| None -> 0
|
||||
| Some x -> x
|
||||
in
|
||||
Hashtbl.replace data key (succ cur)),
|
||||
(fun () ->
|
||||
let data, total =
|
||||
Hashtbl.fold (fun key value (acc, total) ->
|
||||
(Metrics.uint key value :: acc), value + total)
|
||||
data ([], 0)
|
||||
in
|
||||
Metrics.uint "total" total :: data)
|
||||
|
||||
let counter_metrics ~f name =
|
||||
let open Metrics in
|
||||
let doc = "Counter metrics" in
|
||||
let incr, get = create ~f in
|
||||
let data thing = incr thing; Data.v (get ()) in
|
||||
Src.v ~doc ~tags:Metrics.Tags.[] ~data name
|
||||
|
||||
let vmname = Metrics.field ~doc:"name of the virtual machine" "vm" Metrics.String
|
||||
|
||||
let get_log_levels s =
|
||||
let qs = String.split_on_char ',' s in
|
||||
let srcs = Logs.Src.list () in
|
||||
let srcs = List.map (fun src -> Logs.Src.name src, Logs.Src.level src) srcs in
|
||||
let* srcs =
|
||||
match qs with
|
||||
| [""] ->
|
||||
let all_level = Logs.level () in
|
||||
Ok (("*", all_level) :: List.filter (fun (_,l) -> l <> all_level) srcs)
|
||||
| ["*"] ->
|
||||
let all_level = Logs.level () in
|
||||
Ok (("*", all_level) :: srcs)
|
||||
| qs ->
|
||||
let* () =
|
||||
let src_names = List.map fst srcs in
|
||||
match List.find_opt (fun src -> not (List.mem src src_names)) qs with
|
||||
| Some bad_src -> Error ("unknown source: " ^ bad_src)
|
||||
| None -> Ok ()
|
||||
in
|
||||
Ok (List.filter (fun (name, _) -> List.mem name qs) srcs)
|
||||
in
|
||||
let levels =
|
||||
List.map (fun (name, level) ->
|
||||
name ^ ":" ^ Logs.level_to_string level)
|
||||
srcs
|
||||
in
|
||||
Ok (`String (String.concat "," levels))
|
||||
|
||||
let get_metrics s =
|
||||
let qs = String.split_on_char ',' s in
|
||||
let srcs = Metrics.Src.list () in
|
||||
let srcs =
|
||||
List.map (fun src ->
|
||||
Metrics.Src.name src, Metrics.Src.is_active src)
|
||||
srcs
|
||||
in
|
||||
let* srcs =
|
||||
match qs with
|
||||
| [""] ->
|
||||
let all = Metrics.all_enabled () in
|
||||
Ok (("*", all) :: (List.filter (fun (_, b) -> b <> all) srcs))
|
||||
| ["*"] ->
|
||||
let all = Metrics.all_enabled () in
|
||||
let tags = Metrics.tags_enabled () in
|
||||
Ok (("*", all) :: List.map (fun t -> "tag:" ^ t, true) tags @ srcs)
|
||||
| qs ->
|
||||
let* () =
|
||||
let src_names = List.map fst srcs in
|
||||
match List.find_opt (fun src -> not (List.mem src src_names)) qs with
|
||||
| Some bad_src -> Error ("unknown source: " ^ bad_src)
|
||||
| None -> Ok ()
|
||||
in
|
||||
Ok (List.filter (fun (n, _) -> List.mem n qs) srcs)
|
||||
in
|
||||
let metrics =
|
||||
List.map (fun (name, act) ->
|
||||
name ^ ":" ^ if act then "enabled" else "disabled")
|
||||
srcs
|
||||
in
|
||||
Ok (`String (String.concat "," metrics))
|
||||
|
||||
let adjust_log_level s =
|
||||
let ts =
|
||||
List.map
|
||||
(fun s -> (fst Mirage_runtime.Conv.log_threshold) s)
|
||||
(String.split_on_char ',' s)
|
||||
in
|
||||
let* oks =
|
||||
List.fold_left (fun acc t ->
|
||||
let* acc = acc in
|
||||
match t with
|
||||
| `Ok l -> Ok (l :: acc)
|
||||
| `Error msg -> Error msg)
|
||||
(Ok []) ts
|
||||
in
|
||||
Mirage_runtime.set_level ~default:(Logs.level ()) oks;
|
||||
Ok `Empty
|
||||
|
||||
let enable_of_str s =
|
||||
let s = String.lowercase_ascii s in
|
||||
if s = "enable" || s = "on" then
|
||||
Ok `Enable
|
||||
else if s = "disable" || s = "off" then
|
||||
Ok `Disable
|
||||
else
|
||||
Error ("couldn't decode 'enable' or 'disable': " ^ s)
|
||||
|
||||
let adjust_metrics s =
|
||||
let ts =
|
||||
List.map (fun s ->
|
||||
match String.split_on_char ':' s with
|
||||
| [ en ] | [ "*" ; en ] ->
|
||||
let* en_or_d = enable_of_str en in
|
||||
Ok (`All, en_or_d)
|
||||
| [ src ; en ] ->
|
||||
let* en_or_d = enable_of_str en in
|
||||
Ok (`Src src, en_or_d)
|
||||
| [ "src" ; src ; en ] ->
|
||||
let* en_or_d = enable_of_str en in
|
||||
Ok (`Src src, en_or_d)
|
||||
| [ "tag" ; tag ; en ] ->
|
||||
let* en_or_d = enable_of_str en in
|
||||
Ok (`Tag tag, en_or_d)
|
||||
| _ -> Error ("couldn't decode metrics " ^ s))
|
||||
(String.split_on_char ',' s)
|
||||
in
|
||||
let* (all, srcs, tags) =
|
||||
List.fold_left (fun acc t ->
|
||||
let* (all, srcs, tags) = acc in
|
||||
let* t = t in
|
||||
match t with
|
||||
| `All, en_or_d -> Ok (Some en_or_d, srcs, tags)
|
||||
| `Src s, en_or_d -> Ok (all, (s, en_or_d) :: srcs, tags)
|
||||
| `Tag t, en_or_d -> Ok (all, srcs, (t, en_or_d) :: tags))
|
||||
(Ok (None, [], [])) ts
|
||||
in
|
||||
(match all with
|
||||
| Some `Enable -> Metrics.enable_all ()
|
||||
| Some `Disable -> Metrics.disable_all ()
|
||||
| None -> ());
|
||||
List.iter (fun (tag, e_or_d) ->
|
||||
match e_or_d with
|
||||
| `Enable -> Metrics.enable_tag tag
|
||||
| `Disable -> Metrics.disable_tag tag)
|
||||
tags ;
|
||||
List.iter (fun (src, e_or_d) ->
|
||||
match List.find_opt (fun s -> Metrics.Src.name s = src) (Metrics.Src.list ()), e_or_d with
|
||||
| Some src, `Enable -> Metrics.Src.enable src
|
||||
| Some src, `Disable -> Metrics.Src.disable src
|
||||
| None, _ ->
|
||||
Log.warn (fun m -> m "%s is not a valid metrics source." src))
|
||||
srcs ;
|
||||
Ok `Empty
|
||||
|
||||
module Make (T : Mirage_time.S) (P : Mirage_clock.PCLOCK) (S : Tcpip.Stack.V4V6) = struct
|
||||
module Memtrace = Memtrace.Make(P)(S.TCP)
|
||||
|
||||
let timer conn get host stack dst =
|
||||
let datas =
|
||||
Metrics.SM.fold (fun src (tags, data) acc ->
|
||||
let name = Metrics.Src.name src in
|
||||
Metrics_influx.encode_line_protocol (host@tags) data name :: acc)
|
||||
(get ()) []
|
||||
in
|
||||
let datas = String.concat "" datas in
|
||||
let write flow =
|
||||
Log.debug (fun m -> m "sending measurements");
|
||||
S.TCP.write flow (Cstruct.of_string datas) >|= function
|
||||
| Ok () -> ()
|
||||
| Error e ->
|
||||
Log.err (fun m -> m "error %a writing to metrics" S.TCP.pp_write_error e);
|
||||
conn := None
|
||||
in
|
||||
match !conn with
|
||||
| None ->
|
||||
begin
|
||||
Log.debug (fun m -> m "creating connection");
|
||||
S.TCP.create_connection (S.tcp stack) dst >>= function
|
||||
| Error msg ->
|
||||
Log.err (fun m -> m "couldn't create connection %a"
|
||||
S.TCP.pp_error msg);
|
||||
Lwt.return_unit
|
||||
| Ok flow ->
|
||||
conn := Some flow;
|
||||
write flow
|
||||
end
|
||||
| Some f -> write f
|
||||
|
||||
let timer_loop get host interval stack dst () =
|
||||
let conn = ref None in
|
||||
let rec one () =
|
||||
Lwt.join [
|
||||
timer conn get host stack dst;
|
||||
T.sleep_ns (Duration.of_sec interval)
|
||||
] >>= fun () ->
|
||||
(one[@tailcall]) ()
|
||||
in
|
||||
one ()
|
||||
|
||||
let create_listener stack port =
|
||||
S.TCP.listen (S.tcp stack) ~port (fun f ->
|
||||
(S.TCP.read f >>= function
|
||||
| Ok `Data data ->
|
||||
if Cstruct.length data > 0 then
|
||||
let rest = Cstruct.(to_string (shift data 1)) in
|
||||
let r =
|
||||
match Cstruct.get_char data 0 with
|
||||
| 'L' -> adjust_log_level rest
|
||||
| 'M' -> adjust_metrics rest
|
||||
| 'l' -> get_log_levels rest
|
||||
| 'm' -> get_metrics rest
|
||||
| _ -> Error "unknown command"
|
||||
in
|
||||
let msg =
|
||||
match r with
|
||||
| Ok `Empty -> "ok"
|
||||
| Ok `String reply -> "ok: " ^ reply
|
||||
| Error msg -> "error: " ^ msg
|
||||
in
|
||||
S.TCP.write f (Cstruct.of_string msg) >|= function
|
||||
| Ok () -> ()
|
||||
| Error e ->
|
||||
Log.warn (fun m -> m "write error on log & metrics listener %a"
|
||||
S.TCP.pp_write_error e)
|
||||
else
|
||||
(Log.debug (fun m -> m "received empty data on log & metrics listener");
|
||||
Lwt.return_unit)
|
||||
| Ok `Eof ->
|
||||
Log.debug (fun m -> m "EOF on log & metrics listener");
|
||||
Lwt.return_unit
|
||||
| Error e ->
|
||||
Log.debug (fun m -> m "read error on log & metrics listener %a"
|
||||
S.TCP.pp_error e);
|
||||
Lwt.return_unit) >>= fun () ->
|
||||
S.TCP.close f)
|
||||
|
||||
let create ?(interval = 10) ?hostname dst ?(port = 8094) ?(listen_port = 2323)
|
||||
?(memtrace_port = 4242) ?(sampling_rate = 1e-4) stack =
|
||||
S.TCP.listen (S.tcp stack) ~port:memtrace_port
|
||||
(fun f ->
|
||||
(* only allow a single tracing client *)
|
||||
match Memtrace.Memprof_tracer.active_tracer () with
|
||||
| Some _ ->
|
||||
Log.warn (fun m -> m "memtrace tracing already active");
|
||||
S.TCP.close f
|
||||
| None ->
|
||||
Logs.info (fun m -> m "starting memtrace tracing");
|
||||
let tracer = Memtrace.start_tracing ~context:None ~sampling_rate f in
|
||||
Lwt.async (fun () ->
|
||||
S.TCP.read f >|= fun _ ->
|
||||
Logs.info (fun m -> m "memtrace tracing read returned, closing");
|
||||
Memtrace.stop_tracing tracer);
|
||||
Lwt.return_unit);
|
||||
let get_cache, reporter = Metrics.cache_reporter () in
|
||||
Metrics.set_reporter reporter;
|
||||
Metrics.enable_all ();
|
||||
Metrics_lwt.init_periodic (fun () -> T.sleep_ns (Duration.of_sec interval));
|
||||
let host = match hostname with None -> [] | Some host -> [vmname host] in
|
||||
Lwt.async (timer_loop get_cache host interval stack (dst, port));
|
||||
create_listener stack listen_port
|
||||
end
|
||||
|
||||
21
src/mirage_monitoring.mli
Normal file
21
src/mirage_monitoring.mli
Normal file
|
|
@ -0,0 +1,21 @@
|
|||
|
||||
val counter_metrics : f:('a -> string) -> string ->
|
||||
(Metrics.field list, 'a -> Metrics.data) Metrics.src
|
||||
|
||||
val vmname : string -> Metrics.field
|
||||
(** [vmname name] creates a [tag] with the virtual machine name. *)
|
||||
|
||||
module Make (T : Mirage_time.S) (P : Mirage_clock.PCLOCK) (S : Tcpip.Stack.V4V6) : sig
|
||||
|
||||
val create : ?interval:int -> ?hostname:string -> Ipaddr.t -> ?port:int ->
|
||||
?listen_port:int -> ?memtrace_port:int -> ?sampling_rate:float -> S.t ->
|
||||
unit
|
||||
(** [create ~interval ~hostname ip ~port ~listen_port ~memtrace_port ~sampling_rate stack]
|
||||
initiates monitoring on [stack] for the unikernel. The metrics are reported
|
||||
every [interval] (defaults to 10) seconds to [ip] on [port] (defaults to
|
||||
8094) via TCP using the influxd wire protocol. On [listen_port] (defaults
|
||||
to 2323) a TCP connection can be initiated to adjust the log level and
|
||||
enable and disable metrics sources. On [memtrace_port] (defaults to 4242)
|
||||
a single TCP client can connect simultaneously to receive a [Gc.Memprof]
|
||||
trace. The [sampling_rate] defaults to [1e-4]. *)
|
||||
end
|
||||
Loading…
Reference in a new issue