public class DistributionMetricsService extends Object
Modifier and Type | Class and Description |
---|---|
class |
DistributionMetricsService.GaugeService<T> |
Modifier and Type | Field and Description |
---|---|
static String |
BASE_COMPONENT |
static String |
SUB_COMPONENT |
Constructor and Description |
---|
DistributionMetricsService() |
Modifier and Type | Method and Description |
---|---|
void |
activate(org.osgi.framework.BundleContext context) |
<T> DistributionMetricsService.GaugeService<T> |
createGauge(String name,
String description,
Supplier<T> supplier) |
org.apache.sling.commons.metrics.Meter |
getAcceptedRequests()
Meter of requests returning an
DistributionRequestState.ACCEPTED state. |
org.apache.sling.commons.metrics.Timer |
getBuildPackageDuration()
Timer capturing the duration in ms of building a content package
|
org.apache.sling.commons.metrics.Timer |
getCleanupPackageDuration()
Timer of the Package Cleanup Task execution duration.
|
org.apache.sling.commons.metrics.Counter |
getCleanupPackageRemovedCount()
Counter of package removed during the Package Cleanup Task.
|
org.apache.sling.commons.metrics.Meter |
getDroppedRequests()
Meter of requests returning an
DistributionRequestState.DROPPED state. |
org.apache.sling.commons.metrics.Timer |
getEnqueuePackageDuration()
Timer capturing the duration in ms of adding a package to the queue
|
org.apache.sling.commons.metrics.Histogram |
getExportedPackageSize()
Histogram of the exported content package size in Bytes.
|
org.apache.sling.commons.metrics.Meter |
getFailedPackageImports()
Meter of failures to import packages.
|
org.apache.sling.commons.metrics.Timer |
getImportedPackageDuration()
Timer capturing the duration in ms of successful packages import operations.
|
org.apache.sling.commons.metrics.Histogram |
getImportedPackageSize()
Histogram of the imported content package size in Byte.
|
org.apache.sling.commons.metrics.Counter |
getItemsBufferSize()
Counter of the package buffer size on the subscriber.
|
org.apache.sling.commons.metrics.Timer |
getPackageDistributedDuration()
Timer capturing the duration in ms of distributing a distribution package.
|
org.apache.sling.commons.metrics.Timer |
getProcessQueueItemDuration()
Timer capturing the duration in ms of processing a queue item.
|
org.apache.sling.commons.metrics.Counter |
getQueueCacheFetchCount()
Counter of fetch operations to feed the queue cache.
|
org.apache.sling.commons.metrics.Timer |
getRemovedFailedPackageDuration()
Timer capturing the duration in ms of packages successfully removed automatically from a subscriber supporting error queue.
|
org.apache.sling.commons.metrics.Timer |
getRemovedPackageDuration()
Timer capturing the duration in ms of packages successfully removed from an editable subscriber.
|
org.apache.sling.commons.metrics.Timer |
getSendStoredStatusDuration()
Timer capturing the duration in ms of sending a stored package status.
|
static <T> T |
timed(org.apache.sling.commons.metrics.Timer metric,
Callable<T> code)
Runs provided code updating provided metric
with its execution time.
|
static void |
timed(org.apache.sling.commons.metrics.Timer metric,
Runnable code)
Runs provided code updating provided metric
with its execution time.
|
public static final String BASE_COMPONENT
public static final String SUB_COMPONENT
public void activate(org.osgi.framework.BundleContext context)
public static void timed(org.apache.sling.commons.metrics.Timer metric, Runnable code) throws Exception
metric
- metric to updatecode
- code to clockException
- actually it doesn'tpublic static <T> T timed(org.apache.sling.commons.metrics.Timer metric, Callable<T> code) throws Exception
metric
- metric to updatecode
- code to clockcode.call()
invocationException
- if underlying code throwspublic org.apache.sling.commons.metrics.Counter getCleanupPackageRemovedCount()
public org.apache.sling.commons.metrics.Timer getCleanupPackageDuration()
public org.apache.sling.commons.metrics.Histogram getImportedPackageSize()
public org.apache.sling.commons.metrics.Histogram getExportedPackageSize()
public org.apache.sling.commons.metrics.Meter getAcceptedRequests()
DistributionRequestState.ACCEPTED
state.public org.apache.sling.commons.metrics.Meter getDroppedRequests()
DistributionRequestState.DROPPED
state.public org.apache.sling.commons.metrics.Counter getItemsBufferSize()
public org.apache.sling.commons.metrics.Timer getImportedPackageDuration()
public org.apache.sling.commons.metrics.Timer getRemovedPackageDuration()
public org.apache.sling.commons.metrics.Timer getRemovedFailedPackageDuration()
public org.apache.sling.commons.metrics.Meter getFailedPackageImports()
public org.apache.sling.commons.metrics.Timer getSendStoredStatusDuration()
public org.apache.sling.commons.metrics.Timer getProcessQueueItemDuration()
public org.apache.sling.commons.metrics.Timer getPackageDistributedDuration()
public org.apache.sling.commons.metrics.Timer getBuildPackageDuration()
public org.apache.sling.commons.metrics.Timer getEnqueuePackageDuration()
public org.apache.sling.commons.metrics.Counter getQueueCacheFetchCount()
public <T> DistributionMetricsService.GaugeService<T> createGauge(String name, String description, Supplier<T> supplier)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.