Class IndexingPressure

java.lang.Object
org.elasticsearch.index.IndexingPressure
All Implemented Interfaces:
IndexingPressureMonitor

public class IndexingPressure extends Object implements IndexingPressureMonitor
  • Field Details

  • Constructor Details

    • IndexingPressure

      public IndexingPressure(Settings settings)
  • Method Details

    • startIncrementalCoordinating

      public IndexingPressure.Incremental startIncrementalCoordinating(int operations, long bytes, boolean forceExecution)
    • markCoordinatingOperationStarted

      public IndexingPressure.Coordinating markCoordinatingOperationStarted(int operations, long bytes, boolean forceExecution)
    • createCoordinatingOperation

      public IndexingPressure.Coordinating createCoordinatingOperation(boolean forceExecution)
    • validateAndMarkPrimaryOperationLocalToCoordinatingNodeStarted

      public Releasable validateAndMarkPrimaryOperationLocalToCoordinatingNodeStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean allowsOperationsBeyondSizeLimit)
    • validateAndMarkPrimaryOperationStarted

      public Releasable validateAndMarkPrimaryOperationStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean forceExecution, boolean allowsOperationsBeyondSizeLimit)
    • trackPrimaryOperationExpansion

      public Releasable trackPrimaryOperationExpansion(int operations, long expandedBytes, boolean forceExecution)
    • trackReplicaOperationExpansion

      public Releasable trackReplicaOperationExpansion(long expandedBytes, boolean forceExecution)
    • markReplicaOperationStarted

      public Releasable markReplicaOperationStarted(int operations, long bytes, boolean forceExecution)
    • stats

      public IndexingPressureStats stats()
    • getMaxAllowedOperationSizeInBytes

      public long getMaxAllowedOperationSizeInBytes()
      Description copied from interface: IndexingPressureMonitor
      Returns the maximum allowed size in bytes for any single indexing operation. Operations exceeding this limit may be rejected.
      Specified by:
      getMaxAllowedOperationSizeInBytes in interface IndexingPressureMonitor
      Returns:
      the maximum allowed operation size in bytes
    • addListener

      public void addListener(IndexingPressureMonitor.IndexingPressureListener listener)
      Description copied from interface: IndexingPressureMonitor
      Registers a listener to be notified of indexing pressure events. The listener will receive callbacks when operations are tracked or rejected.
      Specified by:
      addListener in interface IndexingPressureMonitor
      Parameters:
      listener - the listener to register for indexing pressure events