Package org.nuxeo.lib.stream.computation

Class ComputationPolicy

java.lang.Object
org.nuxeo.lib.stream.computation.ComputationPolicy
public class ComputationPolicy extends Object
Defines how a computation should handle the retries, fallback and batching if any.
Since:
10.3

  • Field Details

    • NO_RETRY

      public static final net.jodah.failsafe.RetryPolicy<Object> NO_RETRY

    • NONE

      public static final ComputationPolicy NONE

    • retryPolicy

      protected final net.jodah.failsafe.RetryPolicy<Object> retryPolicy

    • batchCapacity

      protected final int batchCapacity

    • batchThreshold

      protected final Duration batchThreshold

    • skipFailure

      protected final boolean skipFailure

    • skipFirstFailures

      protected final int skipFirstFailures

  • Constructor Details

  • Method Details

    • getRetryPolicy

      public net.jodah.failsafe.RetryPolicy<Object> getRetryPolicy()

    • getBatchCapacity

      public int getBatchCapacity()

    • getBatchThreshold

      public Duration getBatchThreshold()

    • continueOnFailure

      public boolean continueOnFailure()

    • getSkipFirstFailures

      public int getSkipFirstFailures()

    • isSkipFailure

      @Deprecated public boolean isSkipFailure()
      Deprecated.
      since 10.3 use continueOnFailure() instead

    • toString

      public String toString()
      Overrides:
      toString in class Object