Package io.deephaven.extensions.barrage

Class BarragePerformanceLog.SnapshotMetricsHelper

java.lang.Object

io.deephaven.extensions.barrage.BarragePerformanceLog.SnapshotMetricsHelper

All Implemented Interfaces:

BarrageMessageWriter.WriteMetricsConsumer

Enclosing class:

BarragePerformanceLog

public static class BarragePerformanceLog.SnapshotMetricsHelper
extends Object
implements BarrageMessageWriter.WriteMetricsConsumer

Field Summary

Fields

Modifier and Type	Field	Description
long	queueNanos
final Instant	requestTm
long	snapshotNanos
String	tableId
String	tableKey

Fields inherited from interface io.deephaven.extensions.barrage.BarrageMessageWriter.WriteMetricsConsumer

NO_OP

Constructor Summary

Constructors

Constructor	Description
SnapshotMetricsHelper()

Method Summary

Modifier and Type	Method	Description
void	onWrite(long bytesWritten, long writeNanos)	Called after the entire message has been sent, with the total byte count and nanos of CPU time to send it.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

requestTm

public final Instant requestTm

tableId

public String tableId

tableKey

public String tableKey

queueNanos

public long queueNanos

snapshotNanos

public long snapshotNanos

Constructor Details

SnapshotMetricsHelper

public SnapshotMetricsHelper()

Method Details

onWrite

public void onWrite(long bytesWritten,
 long writeNanos)

Description copied from interface: BarrageMessageWriter.WriteMetricsConsumer

Called after the entire message has been sent, with the total byte count and nanos of CPU time to send it.

Specified by:

onWrite in interface BarrageMessageWriter.WriteMetricsConsumer

Parameters:

bytesWritten - number of bytes in the record batch message

writeNanos - nanoseconds it took to serialize and send the message