io.aeron.driver.status

Class PerImageIndicator

java.lang.Object

io.aeron.driver.status.PerImageIndicator

public class PerImageIndicator
extends java.lang.Object

Allocates AtomicCounter indicating a per PublicationImage indication of presence for CongestionControl.

Field Summary

Fields

Modifier and Type	Field and Description
static int	PER_IMAGE_TYPE_ID Type id of a per Image indicator.

Constructor Summary

Constructors

Constructor and Description
PerImageIndicator()

Method Summary

Modifier and Type	Method and Description
static org.agrona.concurrent.status.AtomicCounter	allocate(org.agrona.MutableDirectBuffer tempBuffer, java.lang.String name, org.agrona.concurrent.status.CountersManager countersManager, long registrationId, int sessionId, int streamId, java.lang.String channel) Allocate a per PublicationImage indicator.

Methods inherited from class java.lang.Object

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

Field Detail

PER_IMAGE_TYPE_ID

public static final int PER_IMAGE_TYPE_ID

Type id of a per Image indicator.

See Also:

Constant Field Values

Constructor Detail

PerImageIndicator

public PerImageIndicator()

Method Detail

allocate

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

Allocate a per PublicationImage indicator.

Parameters:

tempBuffer - to be used for labels and key.

name - of the counter for the label.

countersManager - from which to allocated the underlying storage.

registrationId - to be associated with the counter.

sessionId - for the stream of messages.

streamId - for the stream of messages.

channel - for the stream of messages.

Returns:

a new AtomicCounter for tracking the indicator.