Package io.deephaven.extensions.barrage

Interface BarrageMessageWriter.WriteMetricsConsumer

All Known Implementing Classes:
BarragePerformanceLog.SnapshotMetricsHelper
Enclosing interface:
BarrageMessageWriter
public static interface BarrageMessageWriter.WriteMetricsConsumer
Optional metrics API to track how many bytes a barrage message consumed, and how many nanoseconds it took to write it.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final BarrageMessageWriter.WriteMetricsConsumer
    NO_OP
     

  • Method Summary

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

  • Field Details

  • Method Details

    • onWrite

      void onWrite(long bytes, long cpuNanos)
      Called after the entire message has been sent, with the total byte count and nanos of CPU time to send it.
      Parameters:
      bytes - number of bytes in the record batch message
      cpuNanos - nanoseconds it took to serialize and send the message