io.aeron.driver

Class AeronClient

java.lang.Object

io.aeron.driver.AeronClient

All Implemented Interfaces:

DriverManagedResource

public class AeronClient
extends java.lang.Object
implements DriverManagedResource

Aeron client library tracker.

Constructor Summary

Constructors

Constructor and Description
AeronClient(long clientId, long clientLivenessTimeoutNs, long nowMs, org.agrona.concurrent.status.AtomicCounter clientTimeouts, org.agrona.concurrent.status.AtomicCounter heartbeatStatus)

Method Summary

Modifier and Type	Method and Description
long	clientId()
void	close() Close resources that are not external.
boolean	hasReachedEndOfLife() Has resource reached end of its life and should be reclaimed?
boolean	hasTimedOut()
void	onTimeEvent(long timeNs, long timeMs, DriverConductor conductor) Inform resource of timeNs passing and pass it DriverConductor to inform of any state transitions.
void	timeOfLastKeepaliveMs(long nowMs)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.aeron.driver.DriverManagedResource

free

Constructor Detail

AeronClient

public AeronClient(long clientId,
                   long clientLivenessTimeoutNs,
                   long nowMs,
                   org.agrona.concurrent.status.AtomicCounter clientTimeouts,
                   org.agrona.concurrent.status.AtomicCounter heartbeatStatus)

Method Detail

close

public void close()

Description copied from interface: DriverManagedResource

Close resources that are not external.

Specified by:

close in interface DriverManagedResource

clientId

public long clientId()

timeOfLastKeepaliveMs

public void timeOfLastKeepaliveMs(long nowMs)

hasTimedOut

public boolean hasTimedOut()

onTimeEvent

public void onTimeEvent(long timeNs,
                        long timeMs,
                        DriverConductor conductor)

Description copied from interface: DriverManagedResource

Inform resource of timeNs passing and pass it DriverConductor to inform of any state transitions.

Specified by:

onTimeEvent in interface DriverManagedResource

Parameters:

timeNs - now in nanoseconds

timeMs - now in milliseconds for epoch

conductor - to inform of any state transitions

hasReachedEndOfLife

public boolean hasReachedEndOfLife()

Description copied from interface: DriverManagedResource

Has resource reached end of its life and should be reclaimed?

Specified by:

hasReachedEndOfLife in interface DriverManagedResource

Returns:

whether resource has reached end of life or not