io.aeron.driver.status

Class ReceiverHwm

java.lang.Object

io.aeron.driver.status.ReceiverHwm

public class ReceiverHwm
extends java.lang.Object

The highest position the Receiver has observed on a session-channel-stream tuple while rebuilding the stream. It is possible the stream is not complete to this point if the stream has experienced loss.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME Human readable name for the counter.
static int	RECEIVER_HWM_TYPE_ID Type id of a receiver high-water-mark position counter.

Constructor Summary

Constructors

Constructor and Description
ReceiverHwm()

Method Summary

Modifier and Type	Method and Description
static org.agrona.concurrent.status.UnsafeBufferPosition	allocate(org.agrona.MutableDirectBuffer tempBuffer, org.agrona.concurrent.status.CountersManager countersManager, long registrationId, int sessionId, int streamId, java.lang.String channel)

Methods inherited from class java.lang.Object

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

Field Detail

RECEIVER_HWM_TYPE_ID

public static final int RECEIVER_HWM_TYPE_ID

Type id of a receiver high-water-mark position counter.

See Also:

Constant Field Values

NAME

public static final java.lang.String NAME

Human readable name for the counter.

See Also:

Constant Field Values

Constructor Detail

ReceiverHwm

public ReceiverHwm()

Method Detail

allocate

public static org.agrona.concurrent.status.UnsafeBufferPosition allocate(org.agrona.MutableDirectBuffer tempBuffer,
                                                                         org.agrona.concurrent.status.CountersManager countersManager,
                                                                         long registrationId,
                                                                         int sessionId,
                                                                         int streamId,
                                                                         java.lang.String channel)