Module org.elasticsearch.server
Package org.elasticsearch.rest

Interface IndexingPressureAwareContentAggregator.BodyPostProcessor

Enclosing class:
IndexingPressureAwareContentAggregator
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface IndexingPressureAwareContentAggregator.BodyPostProcessor
Transforms the accumulated request body before it is handed to the IndexingPressureAwareContentAggregator.CompletionHandler. Implementations must release the input reference when they produce new output.

  • Field Details

  • Method Details

    • process

      ReleasableBytesReference process(ReleasableBytesReference body, long maxSize) throws IOException
      Post-processes the accumulated request body (e.g. decompression).
      Parameters:
      body - The accumulated raw body to process. Unless the post-processor returns the same reference, it is responsible for closing it. The caller must not use this reference after this method returns.
      maxSize - The maximum permitted size for the result.
      Returns:
      The post-processed body. Must not exceed maxSize. The caller is responsible for closing the returned reference.
      Throws:
      IOException - on processing failure