io.aeron.driver.status

Class StatusUtil

java.lang.Object

io.aeron.driver.status.StatusUtil

public class StatusUtil
extends java.lang.Object

Functions for working with status counters.

Constructor Summary

Constructors

Constructor and Description
StatusUtil()

Method Summary

Modifier and Type	Method and Description
static org.agrona.concurrent.status.StatusIndicator	controllableIdleStrategy(org.agrona.concurrent.status.CountersReader countersReader) Return the controllable idle strategy StatusIndicator.
static org.agrona.concurrent.status.StatusIndicatorReader	receiveChannelStatus(org.agrona.concurrent.status.CountersReader countersReader, java.lang.String channel) Return the read-only status indicator for the given receive channel URI.
static org.agrona.concurrent.status.StatusIndicatorReader	sendChannelStatus(org.agrona.concurrent.status.CountersReader countersReader, java.lang.String channel) Return the read-only status indicator for the given send channel URI.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusUtil

public StatusUtil()

Method Detail

controllableIdleStrategy

public static org.agrona.concurrent.status.StatusIndicator controllableIdleStrategy(org.agrona.concurrent.status.CountersReader countersReader)

Return the controllable idle strategy StatusIndicator.

Parameters:

countersReader - that holds the status indicator.

Returns:

status indicator to use or null if not found.

sendChannelStatus

public static org.agrona.concurrent.status.StatusIndicatorReader sendChannelStatus(org.agrona.concurrent.status.CountersReader countersReader,
                                                                                   java.lang.String channel)

Return the read-only status indicator for the given send channel URI.

Parameters:

countersReader - that holds the status indicator.

channel - for the send channel.

Returns:

read-only status indicator that can be used to query the status of the send channel or null

See Also:

for status values and indications.

receiveChannelStatus

public static org.agrona.concurrent.status.StatusIndicatorReader receiveChannelStatus(org.agrona.concurrent.status.CountersReader countersReader,
                                                                                      java.lang.String channel)

Return the read-only status indicator for the given receive channel URI.

Parameters:

countersReader - that holds the status indicator.

channel - for the receive channel.

Returns:

read-only status indicator that can be used to query the status of the receive channel or null.

See Also:

for status values and indications.