Class TaskReactorTelemetry
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.telemetry.TaskReactorTelemetry
-
public class TaskReactorTelemetry extends Object
Telemetry utility for Task Reactor.
-
-
Constructor Summary
Constructors Constructor Description TaskReactorTelemetry()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
addEvent(String eventName, long value)
Adds a new telemetry event.static void
addWorkerIdleTimeEvent(Instant startTime, Instant endTime)
Adds a new event for the worker idle time.static void
addWorkerWorkingTimeEvent(Instant startTime, Instant endTime)
Adds a new event for the worker working time.static void
setTaskReactorInstanceNameSpanAttribute(Identifier value)
Sets the value of the Task Reactor instance name span attribute.static void
setWorkerIdSpanAttribute(WorkerId workerId)
Sets the value of the worker id span attribute.
-
-
-
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 timeendTime
- 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 timeendTime
- working end time
-
addEvent
public static void addEvent(String eventName, long value)
Adds a new telemetry event.- Parameters:
eventName
- event namevalue
- event value
-
-