Package org.opendaylight.genius.idmanager

Class IdManager

java.lang.Object

org.opendaylight.genius.idmanager.IdManager

All Implemented Interfaces:

IdManagerMonitor, IdManagerService, org.opendaylight.yangtools.yang.binding.RpcService

@Singleton
public class IdManager
extends java.lang.Object
implements IdManagerService, IdManagerMonitor

Constructor Summary

Constructors

Constructor	Description
IdManager(org.opendaylight.mdsal.binding.api.DataBroker db, LockManagerService lockManager, IdUtils idUtils, org.opendaylight.daexim.DataImportBootReady dataImportBootReady, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, ShardStatusMonitor shardStatusMonitor)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AllocateIdOutput>>	allocateId(AllocateIdInput input)	Invoke allocateId RPC.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AllocateIdRangeOutput>>	allocateIdRange(AllocateIdRangeInput input)	Invoke allocateIdRange RPC.
void	close()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateIdPoolOutput>>	createIdPool(CreateIdPoolInput input)	Invoke createIdPool RPC.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteIdPoolOutput>>	deleteIdPool(DeleteIdPoolInput input)	Invoke deleteIdPool RPC.
java.util.Map<java.lang.String,java.lang.String>	getLocalPoolsDetails()	Obtain description of ID pool/s.
void	poolDeleted(java.lang.String parentPoolName, java.lang.String poolName)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReleaseIdOutput>>	releaseId(ReleaseIdInput input)	Invoke releaseId RPC.
void	start()
boolean	updateLocalIdPoolCache(IdPool idPool, java.lang.String parentPoolName)

Methods inherited from class java.lang.Object

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

Constructor Detail

IdManager

@Inject
public IdManager(org.opendaylight.mdsal.binding.api.DataBroker db,
                 LockManagerService lockManager,
                 IdUtils idUtils,
                 org.opendaylight.daexim.DataImportBootReady dataImportBootReady,
                 org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                 ShardStatusMonitor shardStatusMonitor)
          throws org.opendaylight.mdsal.common.api.ReadFailedException,
                 java.lang.InterruptedException

Throws:

org.opendaylight.mdsal.common.api.ReadFailedException

java.lang.InterruptedException

Method Detail

getLocalPoolsDetails

public java.util.Map<java.lang.String,java.lang.String> getLocalPoolsDetails()

Description copied from interface: IdManagerMonitor

Obtain description of ID pool/s. Suitable for usage e.g. by a CLI tool.

Specified by:

getLocalPoolsDetails in interface IdManagerMonitor

Returns:

Map with poolName as key, and a String describing the pool (e.g. with information about availableIds & releasedIds)

start

@PostConstruct
public void start()

close

@PreDestroy
public void close()

updateLocalIdPoolCache

public boolean updateLocalIdPoolCache(IdPool idPool,
                                      java.lang.String parentPoolName)

createIdPool

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateIdPoolOutput>> createIdPool(CreateIdPoolInput input)

Description copied from interface: IdManagerService

Invoke createIdPool RPC.

Specified by:

createIdPool in interface IdManagerService

Parameters:

input - of createIdPool

Returns:

output of createIdPool

allocateId

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AllocateIdOutput>> allocateId(AllocateIdInput input)

Description copied from interface: IdManagerService

Invoke allocateId RPC.

Specified by:

allocateId in interface IdManagerService

Parameters:

input - of allocateId

Returns:

output of allocateId

allocateIdRange

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AllocateIdRangeOutput>> allocateIdRange(AllocateIdRangeInput input)

Description copied from interface: IdManagerService

Invoke allocateIdRange RPC.

Specified by:

allocateIdRange in interface IdManagerService

Parameters:

input - of allocateIdRange

Returns:

output of allocateIdRange

deleteIdPool

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteIdPoolOutput>> deleteIdPool(DeleteIdPoolInput input)

Description copied from interface: IdManagerService

Invoke deleteIdPool RPC.

Specified by:

deleteIdPool in interface IdManagerService

Parameters:

input - of deleteIdPool

Returns:

output of deleteIdPool

releaseId

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReleaseIdOutput>> releaseId(ReleaseIdInput input)

Description copied from interface: IdManagerService

Invoke releaseId RPC.

Specified by:

releaseId in interface IdManagerService

Parameters:

input - of releaseId

Returns:

output of releaseId

poolDeleted

public void poolDeleted(java.lang.String parentPoolName,
                        java.lang.String poolName)