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
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "distributormetricsset.h"
#include <vespa/vespalib/util/memoryusage.h>
namespace storage::distributor {
using metrics::MetricSet;
BucketDbMetrics::BucketDbMetrics(const vespalib::string& db_type, metrics::MetricSet* owner)
: metrics::MetricSet("bucket_db", {{"bucket_db_type", db_type}}, "", owner),
memory_usage(this)
{}
BucketDbMetrics::~BucketDbMetrics() = default;
DistributorMetricSet::DistributorMetricSet()
: MetricSet("distributor", {{"distributor"}}, ""),
puts("puts", this),
put_condition_probes("put_condition_probes", this),
updates(this),
update_puts("update_puts", this),
update_gets("update_gets", this),
update_metadata_gets("update_metadata_gets", this),
removes("removes", this),
remove_condition_probes("remove_condition_probes", this),
removelocations("removelocations", this),
gets("gets", this),
stats("stats", this),
getbucketlists("getbucketlists", this),
visits(this),
stateTransitionTime("state_transition_time", {},
"Time it takes to complete a cluster state transition. If a "
"state transition is preempted before completing, its elapsed "
"time is counted as part of the total time spent for the final, "
"completed state transition", this),
set_cluster_state_processing_time("set_cluster_state_processing_time", {},
"Elapsed time where the distributor thread is blocked on processing "
"its bucket database upon receiving a new cluster state", this),
activate_cluster_state_processing_time("activate_cluster_state_processing_time", {},
"Elapsed time where the distributor thread is blocked on merging pending "
"bucket info into its bucket database upon activating a cluster state", this),
recoveryModeTime("recoverymodeschedulingtime", {},
"Time spent scheduling operations in recovery mode "
"after receiving new cluster state", this),
docsStored("docsstored",
{{"logdefault"},{"yamasdefault"}},
"Number of documents stored in all buckets controlled by "
"this distributor", this),
bytesStored("bytesstored",
{{"logdefault"},{"yamasdefault"}},
"Number of bytes stored in all buckets controlled by "
"this distributor", this),
mutable_dbs("mutable", this),
read_only_dbs("read_only", this)
{}
DistributorMetricSet::~DistributorMetricSet() = default;
} // storage
|
