blob: 7edc6dd3aac3518eaeb037daed1712374cbfa22f (
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
/**
* @class storage::StateReporter
* @ingroup storageserver
*
* @brief Writes config generation or health status and metrics
* as json to status page.
*/
#pragma once
#include "applicationgenerationfetcher.h"
#include <vespa/storage/common/storagecomponent.h>
#include <vespa/storageframework/generic/status/statusreporter.h>
#include <vespa/metrics/state_api_adapter.h>
#include <vespa/vespalib/net/http/metrics_producer.h>
#include <vespa/vespalib/net/http/state_api.h>
namespace vespalib {
class StringTokenizer;
}
namespace storage {
class StateReporter : public framework::StatusReporter,
public vespalib::MetricsProducer,
public vespalib::HealthProducer,
public vespalib::ComponentConfigProducer
{
public:
StateReporter(
StorageComponentRegister&,
metrics::MetricManager&,
ApplicationGenerationFetcher& generationFetcher,
const std::string& name = "status");
~StateReporter() override;
vespalib::string getReportContentType(const framework::HttpUrlPath&) const override;
bool reportStatus(std::ostream& out, const framework::HttpUrlPath& path) const override;
// Since we forward to the state API handlers, we require a union of the capabilities
// required for the content status pages _as well as_ those needed by the state API handlers.
// We only half-heartedly want to support the legacy state v1 mapping via the storagenode
// status HTTP server; everyone should use the searchnode HTTP server instead.
CapabilitySet required_capabilities() const noexcept override {
return StatusReporter::required_capabilities().union_of(CapabilitySet::of({
Capability::content_state_api(),
Capability::content_metrics_api()
}));
}
private:
metrics::MetricManager &_manager;
metrics::StateApiAdapter _metricsAdapter;
vespalib::StateApi _stateApi;
StorageComponent _component;
ApplicationGenerationFetcher& _generationFetcher;
std::string _name;
vespalib::string getMetrics(const vespalib::string &consumer) override;
vespalib::string getTotalMetrics(const vespalib::string &consumer) override;
Health getHealth() const override;
void getComponentConfig(Consumer &consumer) override;
};
} // storage
|
