Package org.onosproject.store.primitives
Interface DistributedPrimitiveCreator
-
public interface DistributedPrimitiveCreator
Interface for entity that can create instances of different distributed primitives.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Set<java.lang.String>
getAsyncAtomicCounterNames()
Returns the names of all createdAsyncAtomicCounter
instances.java.util.Set<java.lang.String>
getAsyncConsistentMapNames()
Returns the names of all createdAsyncConsistentMap
instances.java.util.Set<java.lang.String>
getWorkQueueNames()
Returns the names of all createdWorkQueue
instances.<K> AsyncAtomicCounterMap<K>
newAsyncAtomicCounterMap(AtomicCounterMapOptions options)
Creates a newAsyncAtomicCounterMap
.<V> AsyncAtomicValue<V>
newAsyncAtomicValue(AtomicValueOptions options)
Creates a newAsyncAtomicValue
.<K,V>
AsyncConsistentMap<K,V>newAsyncConsistentMap(ConsistentMapOptions options)
Creates a newAsyncConsistentMap
.<K,V>
AsyncConsistentMultimap<K,V>newAsyncConsistentSetMultimap(ConsistentMultimapOptions options)
Creates a new set backedAsyncConsistentMultimap
.<V> AsyncConsistentTreeMap<V>
newAsyncConsistentTreeMap(ConsistentTreeMapOptions options)
Creates a newAsyncConsistentTreeMap
.AsyncAtomicCounter
newAsyncCounter(AtomicCounterOptions options)
Creates a newAsyncAtomicCounter
.AsyncDistributedLock
newAsyncDistributedLock(DistributedLockOptions options)
Creates a newAsyncDistributedLock
.<E> AsyncDistributedSet<E>
newAsyncDistributedSet(DistributedSetOptions options)
Creates a newAsyncDistributedSet
.<V> AsyncDocumentTree<V>
newAsyncDocumentTree(DocumentTreeOptions options)
Creates a newAsyncDocumentTree
.AsyncAtomicIdGenerator
newAsyncIdGenerator(AtomicIdGeneratorOptions options)
Creates a newAsyncAtomixIdGenerator
.AsyncLeaderElector
newAsyncLeaderElector(LeaderElectorOptions options)
Creates a newAsyncLeaderElector
.<E> WorkQueue<E>
newWorkQueue(WorkQueueOptions options)
Creates a newWorkQueue
.
-
-
-
Method Detail
-
newAsyncConsistentMap
<K,V> AsyncConsistentMap<K,V> newAsyncConsistentMap(ConsistentMapOptions options)
Creates a newAsyncConsistentMap
.- Type Parameters:
K
- key typeV
- value type- Parameters:
options
- map options- Returns:
- map
-
newAsyncConsistentTreeMap
<V> AsyncConsistentTreeMap<V> newAsyncConsistentTreeMap(ConsistentTreeMapOptions options)
Creates a newAsyncConsistentTreeMap
.- Type Parameters:
V
- value type- Parameters:
options
- tree map options- Returns:
- distributedTreeMap
-
newAsyncConsistentSetMultimap
<K,V> AsyncConsistentMultimap<K,V> newAsyncConsistentSetMultimap(ConsistentMultimapOptions options)
Creates a new set backedAsyncConsistentMultimap
.- Type Parameters:
K
- key typeV
- value type- Parameters:
options
- multimap options- Returns:
- set backed distributedMultimap
-
newAsyncAtomicCounterMap
<K> AsyncAtomicCounterMap<K> newAsyncAtomicCounterMap(AtomicCounterMapOptions options)
Creates a newAsyncAtomicCounterMap
.- Type Parameters:
K
- key type- Parameters:
options
- counter map options- Returns:
- atomic counter map
-
newAsyncCounter
AsyncAtomicCounter newAsyncCounter(AtomicCounterOptions options)
Creates a newAsyncAtomicCounter
.- Parameters:
options
- counter options- Returns:
- counter
-
newAsyncIdGenerator
AsyncAtomicIdGenerator newAsyncIdGenerator(AtomicIdGeneratorOptions options)
Creates a newAsyncAtomixIdGenerator
.- Parameters:
options
- ID generator options- Returns:
- ID generator
-
newAsyncAtomicValue
<V> AsyncAtomicValue<V> newAsyncAtomicValue(AtomicValueOptions options)
Creates a newAsyncAtomicValue
.- Type Parameters:
V
- value type- Parameters:
options
- value options- Returns:
- value
-
newAsyncDistributedSet
<E> AsyncDistributedSet<E> newAsyncDistributedSet(DistributedSetOptions options)
Creates a newAsyncDistributedSet
.- Type Parameters:
E
- set entry type- Parameters:
options
- set options- Returns:
- set
-
newAsyncDistributedLock
AsyncDistributedLock newAsyncDistributedLock(DistributedLockOptions options)
Creates a newAsyncDistributedLock
.- Parameters:
options
- lock options- Returns:
- lock
-
newAsyncLeaderElector
AsyncLeaderElector newAsyncLeaderElector(LeaderElectorOptions options)
Creates a newAsyncLeaderElector
.- Parameters:
options
- leader elector options- Returns:
- leader elector
-
newWorkQueue
<E> WorkQueue<E> newWorkQueue(WorkQueueOptions options)
Creates a newWorkQueue
.- Type Parameters:
E
- work element type- Parameters:
options
- work queue options- Returns:
- work queue
-
newAsyncDocumentTree
<V> AsyncDocumentTree<V> newAsyncDocumentTree(DocumentTreeOptions options)
Creates a newAsyncDocumentTree
.- Type Parameters:
V
- document tree node value type- Parameters:
options
- tree options- Returns:
- document tree
-
getAsyncConsistentMapNames
java.util.Set<java.lang.String> getAsyncConsistentMapNames()
Returns the names of all createdAsyncConsistentMap
instances.- Returns:
- set of
AsyncConsistentMap
names
-
getAsyncAtomicCounterNames
java.util.Set<java.lang.String> getAsyncAtomicCounterNames()
Returns the names of all createdAsyncAtomicCounter
instances.- Returns:
- set of
AsyncAtomicCounter
names
-
getWorkQueueNames
java.util.Set<java.lang.String> getWorkQueueNames()
Returns the names of all createdWorkQueue
instances.- Returns:
- set of
WorkQueue
names
-
-