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 writeNanos)
    Called once the whole message has been written, with its size and how long it took to write.

  • Field Details

  • Method Details

    • onWrite

      void onWrite(long bytes, long writeNanos)
      Called once the whole message has been written, with its size and how long it took to write. A view that several subscribers share is written once, so this is called once for all of them.
      Parameters:
      bytes - the number of bytes in the message, every batch it was written as counted, dictionary batches included
      writeNanos - the elapsed nanoseconds, not CPU time, from starting to encode the message until the visitor returned from its last batch; this includes the visitor's own time, such as delivering each batch