io.aeron.driver.reports

Class LossReportReader

java.lang.Object

io.aeron.driver.reports.LossReportReader

public class LossReportReader
extends java.lang.Object

Reader that provides the function to read entries from a LossReport.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	LossReportReader.EntryConsumer Consumer function to be implemented by caller of the read method.

Constructor Summary

Constructors

Constructor and Description
LossReportReader()

Method Summary

Modifier and Type	Method and Description
static int	read(org.agrona.concurrent.AtomicBuffer buffer, LossReportReader.EntryConsumer entryConsumer) Read a LossReport contained in the buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

LossReportReader

public LossReportReader()

Method Detail

read

public static int read(org.agrona.concurrent.AtomicBuffer buffer,
                       LossReportReader.EntryConsumer entryConsumer)

Read a LossReport contained in the buffer. This can be done concurrently.

Parameters:

buffer - containing the loss report.

entryConsumer - to be called to accept each entry in the report.

Returns:

the number of entries read.