Class TaskReactorTelemetry


  • public class TaskReactorTelemetry
    extends Object
    Telemetry utility for Task Reactor.
    • Constructor Detail

      • TaskReactorTelemetry

        public TaskReactorTelemetry()
    • Method Detail

      • setTaskReactorInstanceNameSpanAttribute

        public static void setTaskReactorInstanceNameSpanAttribute​(Identifier value)
        Sets the value of the Task Reactor instance name span attribute.
        Parameters:
        value - attribute value
      • setWorkerIdSpanAttribute

        public static void setWorkerIdSpanAttribute​(WorkerId workerId)
        Sets the value of the worker id span attribute.
        Parameters:
        workerId - attribute value
      • addWorkerIdleTimeEvent

        public static void addWorkerIdleTimeEvent​(Instant startTime,
                                                  Instant endTime)
        Adds a new event for the worker idle time.
        Parameters:
        startTime - idle start time
        endTime - idle end time
      • addWorkerWorkingTimeEvent

        public static void addWorkerWorkingTimeEvent​(Instant startTime,
                                                     Instant endTime)
        Adds a new event for the worker working time.
        Parameters:
        startTime - working start time
        endTime - working end time
      • addEvent

        public static void addEvent​(String eventName,
                                    long value)
        Adds a new telemetry event.
        Parameters:
        eventName - event name
        value - event value