Package org.springframework.batch.core.observability

Class BatchMetrics

java.lang.Object
org.springframework.batch.core.observability.BatchMetrics
public final class BatchMetrics extends Object
Central class for batch metrics. It provides:
  • the main entry point to interact with Micrometer's Metrics.globalRegistry with common metrics such as Timer and LongTaskTimer.
  • Some utility methods like calculating durations and formatting them in a human readable format.
Only intended for internal use.
Since:
4.2
Author:
Mahmoud Ben Hassine, Glenn Renfro

  • Field Details

    • METRICS_PREFIX

      public static final String METRICS_PREFIX
      See Also:

    • STATUS_SUCCESS

      public static final String STATUS_SUCCESS
      See Also:

    • STATUS_FAILURE

      public static final String STATUS_FAILURE
      See Also:

    • observationRegistry

      public static final io.micrometer.observation.ObservationRegistry observationRegistry
      Global ObservationRegistry. A DefaultMeterObservationHandler is attached to create a Timer for every finished Observation.

  • Method Details

    • createTimer

      public static io.micrometer.core.instrument.Timer createTimer(String name, String description, io.micrometer.core.instrument.Tag... tags)
      Create a Timer.
      Parameters:
      name - of the timer. Will be prefixed with METRICS_PREFIX.
      description - of the timer
      tags - of the timer
      Returns:
      a new timer instance

    • createObservation

      public static io.micrometer.observation.Observation createObservation(String name, io.micrometer.observation.Observation.Context context)
      Create a new Observation. It's not started, you must explicitly call Observation.start() to start it. Remember to register the DefaultMeterObservationHandler via the Metrics.globalRegistry.withTimerObservationHandler() in the user code. Otherwise you won't observe any metrics.
      Parameters:
      name - of the observation
      context - of the observation
      Returns:
      a new observation instance
      Since:
      5.0

    • createTimerSample

      public static io.micrometer.core.instrument.Timer.Sample createTimerSample()
      Create a new Timer.Sample.
      Returns:
      a new timer sample instance

    • createLongTaskTimer

      public static io.micrometer.core.instrument.LongTaskTimer createLongTaskTimer(String name, String description, io.micrometer.core.instrument.Tag... tags)
      Create a new LongTaskTimer.
      Parameters:
      name - of the long task timer. Will be prefixed with METRICS_PREFIX.
      description - of the long task timer.
      tags - of the timer
      Returns:
      a new long task timer instance

    • calculateDuration

      @Nullable public static Duration calculateDuration(@Nullable Date startTime, @Nullable Date endTime)
      Calculate the duration between two dates.
      Parameters:
      startTime - the start time
      endTime - the end time
      Returns:
      the duration between start time and end time

    • formatDuration

      public static String formatDuration(@Nullable Duration duration)
      Format a duration in a human readable format like: 2h32m15s10ms.
      Parameters:
      duration - to format
      Returns:
      A human readable duration