org.opendaylight.controller.remote.rpc.registry.gossip

Class BucketStoreAccess

java.lang.Object

org.opendaylight.controller.remote.rpc.registry.gossip.BucketStoreAccess

@Beta
public final class BucketStoreAccess
extends Object

Convenience access to BucketStoreActor. Used mostly by Gossiper.

Author:

Robert Varga

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BucketStoreAccess.Singletons

Constructor Summary

Constructors

Constructor and Description
BucketStoreAccess(akka.actor.ActorRef actorRef, scala.concurrent.ExecutionContext dispatcher, akka.util.Timeout timeout)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<Map<akka.actor.Address,Long>>	getBucketVersions()
<T extends BucketData<T>> scala.concurrent.Future<T>	getLocalData()
<T extends BucketData<T>> scala.concurrent.Future<Map<akka.actor.Address,Bucket<T>>>	getRemoteBuckets()

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketStoreAccess

public BucketStoreAccess(akka.actor.ActorRef actorRef,
                         scala.concurrent.ExecutionContext dispatcher,
                         akka.util.Timeout timeout)

Method Detail

getBucketVersions

public scala.concurrent.Future<Map<akka.actor.Address,Long>> getBucketVersions()

getLocalData

public <T extends BucketData<T>> scala.concurrent.Future<T> getLocalData()

getRemoteBuckets

public <T extends BucketData<T>> scala.concurrent.Future<Map<akka.actor.Address,Bucket<T>>> getRemoteBuckets()