Package org.nuxeo.runtime.stream

Class StreamProbe

java.lang.Object
org.nuxeo.runtime.stream.StreamProbe
All Implemented Interfaces:
Probe
public class StreamProbe extends Object implements Probe
A probe to detect when computation has been terminated due to failure. A delay is applied before returning the failure code.
Since:
11.1

  • Field Details

    • STREAM_PROBE_DELAY_PROPERTY

      public static final String STREAM_PROBE_DELAY_PROPERTY
      See Also:

    • STREAM_PROBE_DELAY_DEFAULT

      public static final Duration STREAM_PROBE_DELAY_DEFAULT

    • FAILURE_MESSAGE

      protected static final String FAILURE_MESSAGE
      See Also:

    • globalFailureCount

      protected io.dropwizard.metrics5.Counter globalFailureCount

    • detected

      protected Long detected

    • timeout

      protected Duration timeout

    • FORMATTER

      protected static final DateTimeFormatter FORMATTER

  • Constructor Details

    • StreamProbe

      public StreamProbe()

  • Method Details

    • run

      public ProbeStatus run()
      Specified by:
      run in interface Probe

    • getTimeout

      protected Duration getTimeout()

    • getFailures

      protected long getFailures()

    • getCounter

      protected io.dropwizard.metrics5.Counter getCounter()

    • reset

      public void reset()
      Reset failure counter for testing purpose.
      Since:
      11.1