blob: 6c0cb9a60138433bc184b17e02f0327add8e8a1e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "jsonwriter.h"
#include "state_api_adapter.h"
#include "metricmanager.h"
#include <vespa/vespalib/stllike/asciistream.h>
namespace metrics {
vespalib::string
StateApiAdapter::getMetrics(const vespalib::string &consumer)
{
MetricLockGuard guard(_manager.getMetricLock());
auto periods = _manager.getSnapshotPeriods(guard);
if (periods.empty() || !_manager.any_snapshots_taken(guard)) {
return ""; // no configuration or snapshots yet
}
const MetricSnapshot &snapshot(_manager.getMetricSnapshot(guard, periods[0]));
vespalib::asciistream json;
vespalib::JsonStream stream(json);
metrics::JsonWriter metricJsonWriter(stream);
_manager.visit(guard, snapshot, metricJsonWriter, consumer);
stream.finalize();
return json.str();
}
vespalib::string
StateApiAdapter::getTotalMetrics(const vespalib::string &consumer)
{
_manager.updateMetrics();
MetricLockGuard guard(_manager.getMetricLock());
_manager.checkMetricsAltered(guard);
system_time currentTime = vespalib::system_clock::now();
auto generated = std::make_unique<MetricSnapshot>("Total metrics from start until current time", 0s,
_manager.getTotalMetricSnapshot(guard).getMetrics(), true);
_manager.getActiveMetrics(guard).addToSnapshot(*generated, false, currentTime);
generated->setFromTime(_manager.getTotalMetricSnapshot(guard).getFromTime());
const MetricSnapshot &snapshot = *generated;
vespalib::asciistream json;
vespalib::JsonStream stream(json);
metrics::JsonWriter metricJsonWriter(stream);
_manager.visit(guard, snapshot, metricJsonWriter, consumer);
stream.finalize();
return json.str();
}
} // namespace metrics
|
