Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.BlockingQueue<MetricDatum> |
ServiceMetricCollectorSupport.queue |
private java.util.concurrent.BlockingQueue<MetricDatum> |
RequestMetricCollectorSupport.queue |
private java.util.concurrent.BlockingQueue<MetricDatum> |
MetricCollectorSupport.queue |
private java.util.concurrent.BlockingQueue<MetricDatum> |
BlockingRequestBuilder.queue |
Modifier and Type | Method and Description |
---|---|
(package private) MetricDatum |
BlockingRequestBuilder.cloneMetricDatum(MetricDatum md)
Returns a metric datum cloned from the given one.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<MetricDatum> |
PredefinedMetricTransformer.counterMetricOf(MetricType type,
Request<?> req,
java.lang.Object resp,
boolean includesRequestType)
Returns a list of metric datum recorded for the specified counter metric
type; or an empty list if there is none.
|
private java.util.Collection<MetricDatum> |
BlockingRequestBuilder.filterOSMetrics(java.util.Collection<MetricDatum> data)
Return a collection of metrics almost the same as the input except with
all OS metrics removed.
|
(package private) java.util.List<MetricDatum> |
MachineMetricFactory.generateMetrics() |
protected java.util.List<MetricDatum> |
PredefinedMetricTransformer.latencyMetricOf(MetricType metricType,
Request<?> req,
java.lang.Object response,
boolean includesRequestType)
Returns all the latency metric data recorded for the specified metric
event type; or an empty list if there is none.
|
protected java.util.List<MetricDatum> |
PredefinedMetricTransformer.latencyOfClientExecuteTime(Request<?> req,
java.lang.Object response)
Returns a request type specific metrics for
AWSRequestMetrics.Field.ClientExecuteTime which is special in the sense that it
makes a more accurate measurement by taking the TimingInfo at the
root into account. |
protected java.util.List<MetricDatum> |
PredefinedMetricTransformer.metricOfCount(AWSRequestMetrics.Field metricType,
Request<?> req,
java.lang.Object resp) |
protected java.util.List<MetricDatum> |
PredefinedMetricTransformer.metricOfRequestOrRetryCount(AWSRequestMetrics.Field metricType,
Request<?> req,
java.lang.Object resp)
Returns a list with a single metric datum for the specified retry or
request count predefined metric; or an empty list if there is none.
|
java.util.List<MetricDatum> |
PredefinedMetricTransformer.toMetricData(MetricType metricType,
Request<?> request,
Response<?> response)
Returns a non-null list of metric datum for the metrics collected for the
given request/response.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ServiceMetricCollectorSupport.addMetricsToQueue(MetricDatum metric)
Adds the given metric to the queue, returning true if successful or false
if no space available.
|
protected boolean |
RequestMetricCollectorSupport.addMetricsToQueue(MetricDatum metric)
Adds the given metric to the queue, returning true if successful or false
if no space available.
|
(package private) MetricDatum |
BlockingRequestBuilder.cloneMetricDatum(MetricDatum md)
Returns a metric datum cloned from the given one.
|
private void |
ServiceMetricCollectorSupport.safeAddMetricsToQueue(MetricDatum metric) |
private void |
BlockingRequestBuilder.summarize(MetricDatum datum,
java.util.Map<java.lang.String,MetricDatum> uniqueMetrics)
Summarizes the given datum into the statistics of the respective unique metric.
|
Modifier and Type | Method and Description |
---|---|
private void |
MachineMetricFactory.addFileDescriptorMetrics(java.util.List<MetricDatum> targetList,
java.util.Set<MachineMetric> customSet) |
private void |
MachineMetricFactory.addMemoryMetrics(java.util.List<MetricDatum> targetList,
java.util.Set<MachineMetric> customSet) |
private void |
MachineMetricFactory.addMetrics(java.util.List<MetricDatum> list,
MachineMetricFactory.MetricValues metricValues,
StandardUnit unit)
Add the given list of metrics and corresponding values specified in
"metricValues" to the given list of metric datum.
|
private void |
MachineMetricFactory.addThreadMetrics(java.util.List<MetricDatum> targetList,
java.util.Set<MachineMetric> customSet) |
private java.util.Collection<MetricDatum> |
BlockingRequestBuilder.filterOSMetrics(java.util.Collection<MetricDatum> data)
Return a collection of metrics almost the same as the input except with
all OS metrics removed.
|
private PutMetricDataRequest |
BlockingRequestBuilder.newPutMetricDataRequest(java.util.Collection<MetricDatum> data,
java.lang.String namespace,
Dimension... extraDims) |
private java.util.List<PutMetricDataRequest> |
BlockingRequestBuilder.newPutMetricDataRequests(java.util.Collection<MetricDatum> data) |
private void |
BlockingRequestBuilder.summarize(MetricDatum datum,
java.util.Map<java.lang.String,MetricDatum> uniqueMetrics)
Summarizes the given datum into the statistics of the respective unique metric.
|
private java.lang.Iterable<PutMetricDataRequest> |
BlockingRequestBuilder.toPutMetricDataRequests(java.util.Map<java.lang.String,MetricDatum> uniqueMetrics)
Consolidates the input metrics into a list of PutMetricDataRequest, each
within the maximum size limit imposed by CloudWatch.
|
Constructor and Description |
---|
BlockingRequestBuilder(CloudWatchMetricConfig config,
java.util.concurrent.BlockingQueue<MetricDatum> queue) |
MetricUploaderThread(CloudWatchMetricConfig config,
java.util.concurrent.BlockingQueue<MetricDatum> queue) |
MetricUploaderThread(CloudWatchMetricConfig config,
java.util.concurrent.BlockingQueue<MetricDatum> queue,
AmazonCloudWatchClient client) |
RequestMetricCollectorSupport(java.util.concurrent.BlockingQueue<MetricDatum> queue) |
ServiceMetricCollectorSupport(java.util.concurrent.BlockingQueue<MetricDatum> queue) |
Modifier and Type | Method and Description |
---|---|
java.util.List<MetricDatum> |
DynamoDBRequestMetricTransformer.toMetricData(MetricType metricType,
Request<?> request,
Response<?> response) |
private java.util.List<MetricDatum> |
DynamoDBRequestMetricTransformer.toMetricData0(MetricType metricType,
Request<?> req,
Response<?> response) |
Modifier and Type | Method and Description |
---|---|
static MetricDatum |
MetricData.newMetricDatum(MetricDatum from,
Dimension... dimensions)
Returns a new metric datum cloned from the given metric datum, but
replacing the dimensions with the newly specified ones.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<MetricDatum> |
RequestMetricTransformer.toMetricData(MetricType metricType,
Request<?> request,
Response<?> response)
Returns a list of metric datum for the metrics collected for the given
request/response, or null if this transformer does not recognize the
specific input metric type.
|
Modifier and Type | Method and Description |
---|---|
static MetricDatum |
MetricData.newMetricDatum(MetricDatum from,
Dimension... dimensions)
Returns a new metric datum cloned from the given metric datum, but
replacing the dimensions with the newly specified ones.
|
Modifier and Type | Field and Description |
---|---|
private SdkInternalList<MetricDatum> |
PutMetricDataRequest.metricData
A list of data describing the metric.
|
Modifier and Type | Method and Description |
---|---|
MetricDatum |
MetricDatum.clone() |
MetricDatum |
MetricDatum.withDimensions(java.util.Collection<Dimension> dimensions)
A list of dimensions associated with the metric.
|
MetricDatum |
MetricDatum.withDimensions(Dimension... dimensions)
A list of dimensions associated with the metric.
|
MetricDatum |
MetricDatum.withMetricName(java.lang.String metricName)
The name of the metric.
|
MetricDatum |
MetricDatum.withStatisticValues(StatisticSet statisticValues)
A set of statistical values describing the metric.
|
MetricDatum |
MetricDatum.withTimestamp(java.util.Date timestamp)
The time stamp used for the metric in ISO 8601 Universal Coordinated Time
(UTC) format.
|
MetricDatum |
MetricDatum.withUnit(StandardUnit unit)
The unit of the metric.
|
MetricDatum |
MetricDatum.withUnit(java.lang.String unit)
The unit of the metric.
|
MetricDatum |
MetricDatum.withValue(java.lang.Double value)
The value for the metric.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<MetricDatum> |
PutMetricDataRequest.getMetricData()
A list of data describing the metric.
|
Modifier and Type | Method and Description |
---|---|
PutMetricDataRequest |
PutMetricDataRequest.withMetricData(MetricDatum... metricData)
A list of data describing the metric.
|
Modifier and Type | Method and Description |
---|---|
void |
PutMetricDataRequest.setMetricData(java.util.Collection<MetricDatum> metricData)
A list of data describing the metric.
|
PutMetricDataRequest |
PutMetricDataRequest.withMetricData(java.util.Collection<MetricDatum> metricData)
A list of data describing the metric.
|
Modifier and Type | Method and Description |
---|---|
MetricDatum |
MetricDatumStaxUnmarshaller.unmarshall(StaxUnmarshallerContext context) |