Modifier and Type | Method and Description |
---|---|
default void |
TokenStore.extendClaim(String processorName,
int segment)
Extends the claim on the current token held by the this node for the given
processorName and
segment . |
TrackingToken |
TokenStore.fetchToken(String processorName,
int segment)
|
default void |
TokenStore.initializeTokenSegments(String processorName,
int segmentCount)
Initializes the given
segmentCount number of segments for the given processorName to track its
tokens. |
default void |
TokenStore.initializeTokenSegments(String processorName,
int segmentCount,
TrackingToken initialToken)
Initializes the given
segmentCount number of segments for the given processorName to track its
tokens. |
void |
TokenStore.storeToken(TrackingToken token,
String processorName,
int segment)
Stores the given
token in the store. |
Modifier and Type | Method and Description |
---|---|
void |
InMemoryTokenStore.initializeTokenSegments(String processorName,
int segmentCount) |
void |
InMemoryTokenStore.initializeTokenSegments(String processorName,
int segmentCount,
TrackingToken initialToken) |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
JdbcTokenStore.fetchToken(String processorName,
int segment) |
void |
JdbcTokenStore.initializeTokenSegments(String processorName,
int segmentCount) |
void |
JdbcTokenStore.initializeTokenSegments(String processorName,
int segmentCount,
TrackingToken initialToken) |
void |
JdbcTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
void |
JpaTokenStore.extendClaim(String processorName,
int segment) |
void |
JpaTokenStore.initializeTokenSegments(String processorName,
int segmentCount) |
void |
JpaTokenStore.initializeTokenSegments(String processorName,
int segmentCount,
TrackingToken initialToken) |
Modifier and Type | Method and Description |
---|---|
void |
MongoTokenStore.extendClaim(String processorName,
int segment) |
TrackingToken |
MongoTokenStore.fetchToken(String processorName,
int segment)
|
void |
MongoTokenStore.initializeTokenSegments(String processorName,
int segmentCount) |
void |
MongoTokenStore.initializeTokenSegments(String processorName,
int segmentCount,
TrackingToken initialToken) |
void |
MongoTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
Copyright © 2010–2018. All rights reserved.