public final class SubscriberCounterSet
extends java.lang.Object
implements SessionKeyed

Models counters associated with a subscriber.

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.lang.CharSequence`	`channel()`
`SubscriberCounterSet`	`copy()`
`long`	`incompleteData()`
`long`	`inflight(PublisherCounterSet publisher)`
`long`	`receiverHighWaterMark()`
`void`	`receiverHighWaterMark(long receiverHighWaterMark)`
`long`	`receiverPosition()`
`void`	`receiverPosition(long receiverPosition)`
`void`	`reset(java.lang.CharSequence channel, int sessionId, int streamId)`	Sets the relevant fields on this entity.
`int`	`sessionId()`
`void`	`sessionId(int sessionId)`
`int`	`streamId()`
`int`	`subscriberCount()`
`void`	`subscriberPosition(long registrationId, long subscriberPosition)`
`org.agrona.collections.Long2LongHashMap`	`subscriberPositions()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public org.agrona.collections.Long2LongHashMap subscriberPositions()

public void subscriberPosition(long registrationId,
                               long subscriberPosition)

public void receiverPosition(long receiverPosition)

public void receiverHighWaterMark(long receiverHighWaterMark)

public void sessionId(int sessionId)

public long inflight(PublisherCounterSet publisher)

public java.lang.CharSequence channel()

Class SubscriberCounterSet