Package io.jans.as.server.service.cluster

Class StatusIndexPoolService

java.lang.Object

io.jans.as.server.service.cluster.StatusIndexPoolService

@ApplicationScoped
public class StatusIndexPoolService
extends Object

Version:

1.0, 06/03/2024

Author:

Yuriy Movchan

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ATTEMPT_LIMIT
static long	DELAY_AFTER_EXPIRATION
static long	DELAY_IF_LOCKED
static long	LOCK_WAIT_BEFORE_UPDATE

Constructor Summary

Constructors

Constructor	Description
StatusIndexPoolService()

Method Summary

Modifier and Type	Method	Description
io.jans.model.token.StatusIndexPool	allocate(int nodeId)
String	baseDn()
String	createDn(int id)
List<io.jans.model.token.StatusIndexPool>	getAllPools()	Returns a list of all pools
List<io.jans.model.token.StatusIndexPool>	getNodePools(Integer nodeId)	Returns a list of all StatusIndexPools associated with ClusterNode
io.jans.model.token.StatusIndexPool	getPoolByDn(String dn)	Returns pool by dn
io.jans.model.token.StatusIndexPool	getPoolById(int id)	Returns pool by Id
io.jans.model.token.StatusIndexPool	getPoolByIndex(int index)	Gets pool by global status list index
io.jans.model.token.StatusIndexPool	getPoolLast()	Returns last (max) pool or null if none
List<io.jans.model.token.StatusIndexPool>	getPoolsExpired()	Returns a list of expired pools
void	init()
protected void	persist(io.jans.model.token.StatusIndexPool pool)
static io.jans.model.token.StatusIndexPool	setIndexes(io.jans.model.token.StatusIndexPool pool, int indexAllocationBlockSize)
void	update(io.jans.model.token.StatusIndexPool pool)
io.jans.model.token.StatusIndexPool	updateWithLock(String poolDn, List<Integer> indexes, io.jans.model.tokenstatus.TokenStatus status)

Methods inherited from class java.lang.Object

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

Field Details

ATTEMPT_LIMIT

public static final int ATTEMPT_LIMIT

See Also:

• Constant Field Values

DELAY_AFTER_EXPIRATION

public static long DELAY_AFTER_EXPIRATION

LOCK_WAIT_BEFORE_UPDATE

public static long LOCK_WAIT_BEFORE_UPDATE

DELAY_IF_LOCKED

public static long DELAY_IF_LOCKED

Constructor Details

StatusIndexPoolService

public StatusIndexPoolService()

Method Details

setIndexes

public static io.jans.model.token.StatusIndexPool setIndexes(io.jans.model.token.StatusIndexPool pool,
 int indexAllocationBlockSize)

init

@PostConstruct
public void init()

getPoolByDn

public io.jans.model.token.StatusIndexPool getPoolByDn(String dn)

Returns pool by dn

Returns:

pool

getPoolById

public io.jans.model.token.StatusIndexPool getPoolById(int id)

Returns pool by Id

Returns:

pool

getAllPools

public List<io.jans.model.token.StatusIndexPool> getAllPools()

Returns a list of all pools

Returns:

list of pools

getPoolLast

public io.jans.model.token.StatusIndexPool getPoolLast()

Returns last (max) pool or null if none

Returns:

pool

getPoolByIndex

public io.jans.model.token.StatusIndexPool getPoolByIndex(int index)

Gets pool by global status list index

Parameters:

index - status list index

Returns:

pool

getNodePools

public List<io.jans.model.token.StatusIndexPool> getNodePools(Integer nodeId)

Returns a list of all StatusIndexPools associated with ClusterNode

Returns:

list of pools

getPoolsExpired

public List<io.jans.model.token.StatusIndexPool> getPoolsExpired()

Returns a list of expired pools

Returns:

list of pools

persist

protected void persist(io.jans.model.token.StatusIndexPool pool)

update

public void update(io.jans.model.token.StatusIndexPool pool)

updateWithLock

public io.jans.model.token.StatusIndexPool updateWithLock(String poolDn,
 List<Integer> indexes,
 io.jans.model.tokenstatus.TokenStatus status)
                                                   throws IOException

Throws:

IOException

allocate

public io.jans.model.token.StatusIndexPool allocate(int nodeId)

baseDn

public String baseDn()

createDn

public String createDn(int id)