io.aeron

Class DriverProxy

java.lang.Object

io.aeron.DriverProxy

public class DriverProxy
extends java.lang.Object

Separates the concern of communicating with the client conductor away from the rest of the client.

Writes commands into the client conductor buffer.

Note: this class is not thread safe and is expecting to be called within Aeron.Context.clientLock().

Constructor Summary

Constructors

Constructor and Description
DriverProxy(org.agrona.concurrent.ringbuffer.RingBuffer toDriverCommandBuffer, long clientId)

Method Summary

Modifier and Type	Method and Description
long	addCounter(int typeId, org.agrona.DirectBuffer keyBuffer, int keyOffset, int keyLength, org.agrona.DirectBuffer labelBuffer, int labelOffset, int labelLength)
long	addCounter(int typeId, java.lang.String label)
long	addDestination(long registrationId, java.lang.String endpointChannel)
long	addExclusivePublication(java.lang.String channel, int streamId)
long	addPublication(java.lang.String channel, int streamId)
long	addRcvDestination(long registrationId, java.lang.String endpointChannel)
long	addSubscription(java.lang.String channel, int streamId)
void	clientClose()
long	clientId()
long	removeCounter(long registrationId)
long	removeDestination(long registrationId, java.lang.String endpointChannel)
long	removePublication(long registrationId)
long	removeRcvDestination(long registrationId, java.lang.String endpointChannel)
long	removeSubscription(long registrationId)
void	sendClientKeepalive()
long	timeOfLastDriverKeepaliveMs()

Methods inherited from class java.lang.Object

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

Constructor Detail

DriverProxy

public DriverProxy(org.agrona.concurrent.ringbuffer.RingBuffer toDriverCommandBuffer,
                   long clientId)

Method Detail

timeOfLastDriverKeepaliveMs

public long timeOfLastDriverKeepaliveMs()

clientId

public long clientId()

addPublication

public long addPublication(java.lang.String channel,
                           int streamId)

addExclusivePublication

public long addExclusivePublication(java.lang.String channel,
                                    int streamId)

removePublication

public long removePublication(long registrationId)

addSubscription

public long addSubscription(java.lang.String channel,
                            int streamId)

removeSubscription

public long removeSubscription(long registrationId)

sendClientKeepalive

public void sendClientKeepalive()

addDestination

public long addDestination(long registrationId,
                           java.lang.String endpointChannel)

removeDestination

public long removeDestination(long registrationId,
                              java.lang.String endpointChannel)

addRcvDestination

public long addRcvDestination(long registrationId,
                              java.lang.String endpointChannel)

removeRcvDestination

public long removeRcvDestination(long registrationId,
                                 java.lang.String endpointChannel)

addCounter

public long addCounter(int typeId,
                       org.agrona.DirectBuffer keyBuffer,
                       int keyOffset,
                       int keyLength,
                       org.agrona.DirectBuffer labelBuffer,
                       int labelOffset,
                       int labelLength)

addCounter

public long addCounter(int typeId,
                       java.lang.String label)

removeCounter

public long removeCounter(long registrationId)

clientClose

public void clientClose()