Class PublishMetrics
java.lang.Object
org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionPublishMetrics
(org.apache.sling.commons.metrics.MetricsService metricsService, String pubAgentName) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.sling.commons.metrics.Meter
Meter of requests returning anDistributionRequestState.ACCEPTED
state.org.apache.sling.commons.metrics.Timer
Timer capturing the duration in ms of building a content packageorg.apache.sling.commons.metrics.Meter
Meter of requests returning anDistributionRequestState.DROPPED
state.org.apache.sling.commons.metrics.Timer
Timer capturing the duration in ms of adding a package to the queueorg.apache.sling.commons.metrics.Histogram
Histogram of the exported content package size in Bytes.org.apache.sling.commons.metrics.Counter
Counter of queue access errors.org.apache.sling.commons.metrics.Counter
Counter of fetch operations to feed the queue cache.void
void
subscriberCount
(Supplier<Integer> subscriberCountCallback)
-
Field Details
-
PUB_COMPONENT
- See Also:
-
-
Constructor Details
-
PublishMetrics
public PublishMetrics(org.apache.sling.commons.metrics.MetricsService metricsService, String pubAgentName)
-
-
Method Details
-
getExportedPackageSize
public org.apache.sling.commons.metrics.Histogram getExportedPackageSize()Histogram of the exported content package size in Bytes.- Returns:
- a Sling Metrics histogram
-
getAcceptedRequests
public org.apache.sling.commons.metrics.Meter getAcceptedRequests()Meter of requests returning anDistributionRequestState.ACCEPTED
state.- Returns:
- a Sling Metrics meter
-
getDroppedRequests
public org.apache.sling.commons.metrics.Meter getDroppedRequests()Meter of requests returning anDistributionRequestState.DROPPED
state.- Returns:
- a Sling Metrics meter
-
getBuildPackageDuration
public org.apache.sling.commons.metrics.Timer getBuildPackageDuration()Timer capturing the duration in ms of building a content package- Returns:
- a Sling Metric timer
-
getEnqueuePackageDuration
public org.apache.sling.commons.metrics.Timer getEnqueuePackageDuration()Timer capturing the duration in ms of adding a package to the queue- Returns:
- a Sling Metric timer
-
getQueueCacheFetchCount
public org.apache.sling.commons.metrics.Counter getQueueCacheFetchCount()Counter of fetch operations to feed the queue cache.- Returns:
- a Sling Metric counter
-
getQueueAccessErrorCount
public org.apache.sling.commons.metrics.Counter getQueueAccessErrorCount()Counter of queue access errors.- Returns:
- a Sling Metric counter
-
subscriberCount
-
queueSize
-