org.opendaylight.genius.utils.clustering

Class ClusteringUtils

java.lang.Object

org.opendaylight.genius.utils.clustering.ClusteringUtils

public class ClusteringUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ClusteringUtils()

Method Summary

Modifier and Type	Method and Description
static com.google.common.util.concurrent.ListenableFuture<Boolean>	checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, org.opendaylight.controller.md.sal.common.api.clustering.Entity entity, long sleepBetweenRetries, int maxRetries)
static com.google.common.util.concurrent.ListenableFuture<Boolean>	checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, String entityType, String nodeId)
static com.google.common.util.concurrent.ListenableFuture<Boolean>	checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, String entityType, org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier nodeId)
static Boolean	isEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, org.opendaylight.controller.md.sal.common.api.clustering.Entity entity, long sleepBetweenRetries, int retries)
static void	setDataStoreJobCoordinator(DataStoreJobCoordinator ds)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteringUtils

public ClusteringUtils()

Method Detail

setDataStoreJobCoordinator

public static void setDataStoreJobCoordinator(DataStoreJobCoordinator ds)

checkNodeEntityOwner

public static com.google.common.util.concurrent.ListenableFuture<Boolean> checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                                                                               String entityType,
                                                                                               String nodeId)

checkNodeEntityOwner

public static com.google.common.util.concurrent.ListenableFuture<Boolean> checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                                                                               String entityType,
                                                                                               org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier nodeId)

checkNodeEntityOwner

public static com.google.common.util.concurrent.ListenableFuture<Boolean> checkNodeEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                                                                               org.opendaylight.controller.md.sal.common.api.clustering.Entity entity,
                                                                                               long sleepBetweenRetries,
                                                                                               int maxRetries)

isEntityOwner

public static Boolean isEntityOwner(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                    org.opendaylight.controller.md.sal.common.api.clustering.Entity entity,
                                    long sleepBetweenRetries,
                                    int retries)