Module org.elasticsearch.server
Class CCSUsageTelemetry
java.lang.Object
org.elasticsearch.action.admin.cluster.stats.CCSUsageTelemetry
Service holding accumulated CCS search usage statistics. Individual cross-cluster searches will pass
CCSUsage data here to have it collated and aggregated. Snapshots of the current CCS Telemetry Usage
can be obtained by getting
Theory of operation: Each search creates a
When we need to return the current state of the telemetry, we can call
CCSTelemetrySnapshot objects.
Theory of operation: Each search creates a
CCSUsage.Builder, which can be updated during the progress of the search request,
and then it instantiates a CCSUsage object when the request is finished.
That object is passed to updateUsage(CCSUsage) on the request processing end (whether successful or not).
The updateUsage(CCSUsage) method will then update the internal counters and metrics.
When we need to return the current state of the telemetry, we can call
getCCSTelemetrySnapshot() which produces
a snapshot of the current state of the telemetry as CCSTelemetrySnapshot. These snapshots are additive so
when collecting the snapshots from multiple nodes, an empty snapshot is created and then all the node's snapshots are added
to it to obtain the summary telemetry.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classTelemetry of each remote involved in cross cluster searchesstatic enumResult of the request execution. -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
MRT_FEATURE
- See Also:
-
ASYNC_FEATURE
- See Also:
-
WILDCARD_FEATURE
- See Also:
-
PIT_FEATURE
- See Also:
-
KNOWN_CLIENTS
-
-
Constructor Details
-
CCSUsageTelemetry
public CCSUsageTelemetry() -
CCSUsageTelemetry
public CCSUsageTelemetry(boolean useMRT)
-
-
Method Details
-
updateUsage
-
getTelemetryByCluster
-
getCCSTelemetrySnapshot
-