Record Class TrackerClaim
java.lang.Object
java.lang.Record
io.fluxzero.common.tracking.TrackerClaim
- Record Components:
consumer- consumer nametrackerId- original tracker identityclientId- original client identity, used for connection livenessstart- inclusive segment boundaryend- exclusive segment boundarystartedAtMillis- time the original batch became activepurgeDelayMillis- configured processing timeout, or null when unboundedsingleTracker- whether ownership excludes every other tracker of this consumer
public record TrackerClaim(String consumer, String trackerId, String clientId, int start, int end, long startedAtMillis, Long purgeDelayMillis, boolean singleTracker)
extends Record
An active segment reservation transferred between elected Runtime instances.
This contains ownership only: persisted consumer positions remain the progress authority.
-
Constructor Summary
ConstructorsConstructorDescriptionTrackerClaim(String consumer, String trackerId, String clientId, int start, int end, long startedAtMillis, Long purgeDelayMillis, boolean singleTracker) Creates an instance of aTrackerClaimrecord class. -
Method Summary
Modifier and TypeMethodDescriptionclientId()Returns the value of theclientIdrecord component.consumer()Returns the value of theconsumerrecord component.intend()Returns the value of theendrecord component.final booleanIndicates whether some other object is "equal to" this one.final inthashCode()Returns a hash code value for this object.Returns the value of thepurgeDelayMillisrecord component.booleanReturns the value of thesingleTrackerrecord component.intstart()Returns the value of thestartrecord component.longReturns the value of thestartedAtMillisrecord component.final StringtoString()Returns a string representation of this record class.Returns the value of thetrackerIdrecord component.
-
Constructor Details
-
TrackerClaim
public TrackerClaim(String consumer, String trackerId, String clientId, int start, int end, long startedAtMillis, Long purgeDelayMillis, boolean singleTracker) Creates an instance of aTrackerClaimrecord class.- Parameters:
consumer- the value for theconsumerrecord componenttrackerId- the value for thetrackerIdrecord componentclientId- the value for theclientIdrecord componentstart- the value for thestartrecord componentend- the value for theendrecord componentstartedAtMillis- the value for thestartedAtMillisrecord componentpurgeDelayMillis- the value for thepurgeDelayMillisrecord componentsingleTracker- the value for thesingleTrackerrecord component
-
-
Method Details
-
toString
-
hashCode
-
equals
Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared withObjects::equals(Object,Object); primitive components are compared with thecomparemethod from their corresponding wrapper classes. -
consumer
-
trackerId
-
clientId
-
start
-
end
-
startedAtMillis
public long startedAtMillis()Returns the value of thestartedAtMillisrecord component.- Returns:
- the value of the
startedAtMillisrecord component
-
purgeDelayMillis
Returns the value of thepurgeDelayMillisrecord component.- Returns:
- the value of the
purgeDelayMillisrecord component
-
singleTracker
public boolean singleTracker()Returns the value of thesingleTrackerrecord component.- Returns:
- the value of the
singleTrackerrecord component
-