public final class MetricsPolicy extends Object
| Modifier and Type | Field and Description |
|---|---|
int |
interval
Number of cluster tend iterations between metrics notification events.
|
Map<String,String> |
labels
Labels that can be sent to the metrics output
|
int |
latencyColumns
Number of elapsed time range buckets in latency histograms.
|
int |
latencyShift
Power of 2 multiple between each range bucket in latency histograms starting at column 3.
|
MetricsListener |
listener
Listener that handles metrics notification events.
|
String |
reportDir
Directory path to write metrics log files for listeners that write logs.
|
long |
reportSizeLimit
Metrics file size soft limit in bytes for listeners that write logs.
|
| Constructor and Description |
|---|
MetricsPolicy()
Default constructor.
|
MetricsPolicy(MetricsPolicy other)
Copy constructor.
|
MetricsPolicy(MetricsPolicy other,
com.aerospike.client.configuration.serializers.Configuration config,
boolean metricsEnabled)
Copy metrics policy from another metrics policy AND override certain policy attributes if they exist in the
configProvider.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
isMetricsRestartRequired() |
void |
setInterval(int interval) |
void |
setLabels(Map<String,String> labels) |
void |
setLatencyColumns(int latencyColumns) |
void |
setLatencyShift(int latencyShift) |
void |
setListener(MetricsListener listener) |
void |
setMetricsRestartRequired(boolean metricsRestartRequired) |
void |
setReportDir(String reportDir) |
void |
setReportSizeLimit(long reportSizeLimit) |
public MetricsListener listener
The listener could be overridden to send the metrics snapshot directly to OpenTelemetry.
public String reportDir
Default:
public long reportSizeLimit
When reportSizeLimit is reached or exceeded, the current metrics file is closed and a new
metrics file is created with a new timestamp. If reportSizeLimit is zero, the metrics file
size is unbounded and the file will only be closed when
AerospikeClient.disableMetrics() or
AerospikeClient.close() is called.
Default: 0
public int interval
ClientPolicy.tendInterval (default 1 second) plus the time to tend all
nodes.
Default: 30
public int latencyColumns
Default: 7
public int latencyShift
// latencyColumns=7 latencyShift=1
<=1ms >1ms >2ms >4ms >8ms >16ms >32ms
// latencyColumns=5 latencyShift=3
<=1ms >1ms >8ms >64ms >512ms
Default: 1public MetricsPolicy(MetricsPolicy other, com.aerospike.client.configuration.serializers.Configuration config, boolean metricsEnabled)
public MetricsPolicy(MetricsPolicy other)
public MetricsPolicy()
public void setListener(MetricsListener listener)
public void setReportDir(String reportDir)
public void setReportSizeLimit(long reportSizeLimit)
public void setInterval(int interval)
public void setLatencyColumns(int latencyColumns)
public void setLatencyShift(int latencyShift)
public boolean isMetricsRestartRequired()
public void setMetricsRestartRequired(boolean metricsRestartRequired)
Copyright © 2012–2025 Aerospike, Inc. All rights reserved.