Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W Z 

A

abort() - Method in interface io.atomix.core.transaction.AsyncTransaction
Aborts any changes made in this transaction context and discarding all locally cached updates.
abort() - Method in interface io.atomix.core.transaction.Transaction
Aborts any changes made in this transaction context and discarding all locally cached updates.
aborting(TransactionId) - Method in interface io.atomix.core.transaction.TransactionService
Marks the given transaction as rolling back.
AbstractAsyncPrimitive<A extends AsyncPrimitive,S> - Class in io.atomix.primitive
Abstract base class for primitives that interact with Raft replicated state machines via proxy.
AbstractEvent<T extends Enum,S> - Class in io.atomix.utils.event
Base event implementation.
AbstractIdentifier<T extends Comparable<T>> - Class in io.atomix.utils
Abstract identifier backed by another value, e.g.
AbstractListenerManager<E extends Event,L extends EventListener<E>> - Class in io.atomix.utils.event
Basis for components which need to export listener mechanism.
AbstractListenerManager() - Constructor for class io.atomix.utils.event.AbstractListenerManager
 
AbstractNamed - Class in io.atomix.utils
Abstract named object.
AbstractPrimitiveService<C> - Class in io.atomix.primitive.service
Raft service.
accept(Consumer<S>) - Method in interface io.atomix.primitive.proxy.ProxySession
Submits an empty operation to the given partition.
accept(Consumer<C>) - Method in interface io.atomix.primitive.session.Session
Sends an event to the client via the client proxy.
acceptAll(Consumer<S>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to all partitions.
acceptBy(String, Consumer<S>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to the owning partition for the given key.
acceptOn(PartitionId, Consumer<S>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to the given partition.
acquire() - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Acquires a permit from this semaphore.
acquire(int) - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Acquires the given number of permits from this semaphore.
acquire() - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Acquires a permit from this semaphore.
acquire(int) - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Acquires the given number of permits from this semaphore.
acquire() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Acquires a permit from this semaphore.
acquire(int) - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Acquires the given number of permits from this semaphore, blocking until all are available.
acquire() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
acquire(int) - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
acquireUninterruptibly() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
acquireUninterruptibly(int) - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
active() - Method in enum io.atomix.primitive.session.Session.State
 
active() - Method in enum io.atomix.protocols.raft.RaftServer.Role
Returns whether the role is a voting Raft member role.
add(E) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Adds the specified element to this collection if it is not already present (optional operation).
add(int, E) - Method in interface io.atomix.core.list.AsyncDistributedList
Inserts the specified element at the specified position in this list (optional operation).
add(E, int) - Method in interface io.atomix.core.multiset.AsyncDistributedMultiset
Adds a number of occurrences of an element to this multiset.
add(E) - Method in interface io.atomix.core.queue.AsyncDistributedQueue
Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions, returning true upon success and throwing an IllegalStateException if no space is currently available.
add(E) - Method in interface io.atomix.core.transaction.AsyncTransactionalSet
Adds the specified element to this set if it is not already present (optional operation).
add(E) - Method in interface io.atomix.core.transaction.TransactionalSet
Adds the specified element to this set if it is not already present (optional operation).
addAll(Collection<? extends E>) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Adds all of the elements in the specified collection to this collection if they're not already present (optional operation).
addAll(int, Collection<? extends E>) - Method in interface io.atomix.core.list.AsyncDistributedList
Inserts all of the elements in the specified collection into this list at the specified position (optional operation).
addAndGet(long) - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically adds the given value to the current value.
addAndGet(long) - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically adds the given value to the current value.
addAndGet(long) - Method in interface io.atomix.core.counter.AtomicCounter
Atomically adds the given value to the current value.
addAndGet(long) - Method in interface io.atomix.core.counter.DistributedCounter
Atomically adds the given value to the current value.
addAndGet(K, long) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Adds delta to the value currently associated with key, and returns the new value.
addAndGet(K, long) - Method in interface io.atomix.core.map.AtomicCounterMap
Adds delta to the value currently associated with key, and returns the new value.
addAndGet(long) - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically adds the given value to the current value.
addDiscoveryProviderType(NodeDiscoveryProvider.Type) - Method in class io.atomix.core.registry.SimpleRegistry.Builder
Adds a node discovery provider type.
addEventListener(EventType, Consumer<PrimitiveEvent>) - Method in interface io.atomix.primitive.session.SessionClient
Adds an event listener.
addEventListener(EventType, Consumer<PrimitiveEvent>) - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
addExtraType(Class<?>) - Method in class io.atomix.core.collection.DistributedCollectionBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.collection.DistributedCollectionConfig
Adds an extra serializable type.
addExtraType(Class<?>) - Method in class io.atomix.core.map.AtomicCounterMapBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.map.AtomicCounterMapConfig
Adds an extra serializable type.
addExtraType(Class<?>) - Method in class io.atomix.core.map.MapBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.map.MapConfig
Adds an extra serializable type.
addExtraType(Class<?>) - Method in class io.atomix.core.multimap.MultimapBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.multimap.MultimapConfig
Adds an extra serializable type.
addExtraType(Class<?>) - Method in class io.atomix.core.tree.AtomicDocumentTreeBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
Adds an extra serializable type.
addExtraType(Class<?>) - Method in class io.atomix.core.value.ValueBuilder
Adds an extra serializable type to the map.
addExtraType(Class<?>) - Method in class io.atomix.core.value.ValueConfig
Adds an extra serializable type.
addListener(String, Consumer<byte[]>) - Method in interface io.atomix.cluster.messaging.BroadcastService
Adds a broadcast listener for the given subject.
addListener(String, BiConsumer<Address, byte[]>) - Method in interface io.atomix.cluster.messaging.UnicastService
Adds a broadcast listener for the given subject.
addListener(String, BiConsumer<Address, byte[]>, Executor) - Method in interface io.atomix.cluster.messaging.UnicastService
Adds a broadcast listener for the given subject.
addListener(CollectionEventListener<E>) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Registers the specified listener to be notified whenever the collection is updated.
addListener(CollectionEventListener<E>, Executor) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Registers the specified listener to be notified whenever the collection is updated.
addListener(CollectionEventListener<E>) - Method in interface io.atomix.core.collection.DistributedCollection
Registers the specified listener to be notified whenever the collection is updated.
addListener(LeadershipEventListener<T>) - Method in interface io.atomix.core.election.AsyncLeaderElection
Registers a listener to be notified of Leadership changes for all topics.
addListener(LeadershipEventListener<T>) - Method in interface io.atomix.core.election.AsyncLeaderElector
Registers a listener to be notified of Leadership changes for all topics.
addListener(String, LeadershipEventListener<T>) - Method in interface io.atomix.core.election.AsyncLeaderElector
Registers a listener to be notified of Leadership changes for all topics.
addListener(LeadershipEventListener<T>) - Method in interface io.atomix.core.election.LeaderElection
Registers a listener to be notified of Leadership changes for all topics.
addListener(LeadershipEventListener<T>) - Method in interface io.atomix.core.election.LeaderElector
Registers a listener to be notified of Leadership changes for all topics.
addListener(String, LeadershipEventListener<T>) - Method in interface io.atomix.core.election.LeaderElector
Registers a listener to be notified of Leadership changes for all topics.
addListener(AtomicMapEventListener<K, V>) - Method in interface io.atomix.core.map.AsyncAtomicMap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMapEventListener<K, V>, Executor) - Method in interface io.atomix.core.map.AsyncAtomicMap
Registers the specified listener to be notified whenever the map is updated.
addListener(MapEventListener<K, V>) - Method in interface io.atomix.core.map.AsyncDistributedMap
Registers the specified listener to be notified whenever the map is updated.
addListener(MapEventListener<K, V>, Executor) - Method in interface io.atomix.core.map.AsyncDistributedMap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMapEventListener<K, V>) - Method in interface io.atomix.core.map.AtomicMap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMapEventListener<K, V>, Executor) - Method in interface io.atomix.core.map.AtomicMap
Registers the specified listener to be notified whenever the map is updated.
addListener(MapEventListener<K, V>) - Method in interface io.atomix.core.map.DistributedMap
Registers the specified listener to be notified whenever the map is updated.
addListener(MapEventListener<K, V>, Executor) - Method in interface io.atomix.core.map.DistributedMap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMultimapEventListener<K, V>) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMultimapEventListener<K, V>, Executor) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(MultimapEventListener<K, V>) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(MultimapEventListener<K, V>, Executor) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMultimapEventListener<K, V>) - Method in interface io.atomix.core.multimap.AtomicMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(AtomicMultimapEventListener<K, V>, Executor) - Method in interface io.atomix.core.multimap.AtomicMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(MultimapEventListener<K, V>) - Method in interface io.atomix.core.multimap.DistributedMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(MultimapEventListener<K, V>, Executor) - Method in interface io.atomix.core.multimap.DistributedMultimap
Registers the specified listener to be notified whenever the map is updated.
addListener(DocumentPath, DocumentTreeEventListener<V>) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Registers a listener to be notified when the subtree rooted at the specified path is modified.
addListener(DocumentPath, DocumentTreeEventListener<V>, Executor) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Registers a listener to be notified when the subtree rooted at the specified path is modified.
addListener(DocumentTreeEventListener<V>) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Registers a listener to be notified when the tree is modified.
addListener(DocumentTreeEventListener<V>, Executor) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Registers a listener to be notified when the tree is modified.
addListener(DocumentTreeEventListener<V>) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Registers a listener to be notified when the tree is modified.
addListener(DocumentPath, DocumentTreeEventListener<V>) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Registers a listener to be notified when a subtree rooted at the specified path is modified.
addListener(DocumentTreeEventListener<V>, Executor) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Registers a listener to be notified when the tree is modified.
addListener(DocumentPath, DocumentTreeEventListener<V>, Executor) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Registers a listener to be notified when a subtree rooted at the specified path is modified.
addListener(AtomicValueEventListener<V>) - Method in interface io.atomix.core.value.AsyncAtomicValue
Registers the specified listener to be notified whenever the atomic value is updated.
addListener(ValueEventListener<V>) - Method in interface io.atomix.core.value.AsyncDistributedValue
Registers the specified listener to be notified whenever the atomic value is updated.
addListener(AtomicValueEventListener<V>) - Method in interface io.atomix.core.value.AtomicValue
Registers the specified listener to be notified whenever the atomic value is updated.
addListener(ValueEventListener<V>) - Method in interface io.atomix.core.value.DistributedValue
Registers the specified listener to be notified whenever the atomic value is updated.
addListener(MapDelegateEventListener<K, V>) - Method in interface io.atomix.primitive.protocol.map.MapDelegate
Adds the specified listener to the map which will be notified whenever the mappings in the map are changed.
addListener(SetDelegateEventListener<E>) - Method in interface io.atomix.primitive.protocol.set.SetDelegate
Adds the specified listener to the set which will be notified whenever the entries in the set are changed.
addListener(ValueDelegateEventListener<V>) - Method in interface io.atomix.primitive.protocol.value.ValueDelegate
Registers the specified listener to be notified whenever the atomic value is updated.
addListener(SessionListener) - Method in interface io.atomix.primitive.session.Sessions
Adds a listener to the sessions.
addListener(L) - Method in class io.atomix.utils.event.AbstractListenerManager
 
addListener(L) - Method in class io.atomix.utils.event.ListenerRegistry
 
addListener(L) - Method in interface io.atomix.utils.event.ListenerService
Adds the specified listener.
addMultiple(Collection<E>) - Method in interface io.atomix.core.workqueue.AsyncWorkQueue
Adds a collection of tasks to the work queue.
addMultiple(Collection<E>) - Method in interface io.atomix.core.workqueue.WorkQueue
Adds a collection of tasks to the work queue.
addOne(E) - Method in interface io.atomix.core.workqueue.AsyncWorkQueue
Adds a single task to the work queue.
addOne(E) - Method in interface io.atomix.core.workqueue.WorkQueue
Adds a single task to the work queue.
addPartitionGroup(ManagedPartitionGroup) - Method in class io.atomix.core.AtomixBuilder
Adds a primitive partition group.
addPartitionGroup(PartitionGroupConfig) - Method in class io.atomix.core.AtomixConfig
Adds a partition group configuration.
addPartitionGroupType(PartitionGroup.Type) - Method in class io.atomix.core.registry.SimpleRegistry.Builder
Adds a partition group type.
addPrimitive(String, PrimitiveConfig) - Method in class io.atomix.core.AtomixConfig
Adds a primitive configuration.
addPrimitiveType(PrimitiveType) - Method in class io.atomix.core.registry.SimpleRegistry.Builder
Adds a primitive type.
addProfile(Profile) - Method in class io.atomix.core.AtomixBuilder
Adds an Atomix profile.
addProfile(ProfileConfig) - Method in class io.atomix.core.AtomixConfig
Adds an Atomix profile.
addProfileType(Profile.Type) - Method in class io.atomix.core.registry.SimpleRegistry.Builder
Adds a profile type to the builder.
addProtocolType(PrimitiveProtocol.Type) - Method in class io.atomix.core.registry.SimpleRegistry.Builder
Adds a protocol type.
address() - Method in interface io.atomix.cluster.messaging.MessagingService
Returns the local messaging service address.
address() - Method in class io.atomix.cluster.Node
Returns the node address.
Address - Class in io.atomix.utils.net
Representation of a network address.
Address(String, int) - Constructor for class io.atomix.utils.net.Address
 
Address(String, int, InetAddress) - Constructor for class io.atomix.utils.net.Address
 
address() - Method in class io.atomix.utils.net.Address
Returns the IP address.
address(boolean) - Method in class io.atomix.utils.net.Address
Returns the IP address.
Address.Type - Enum in io.atomix.utils.net
Address type.
addRoleChangeListener(Consumer<RaftServer.Role>) - Method in interface io.atomix.protocols.raft.RaftServer
Adds a role change listener.
addSerializer(Serializer, Class<?>...) - Method in class io.atomix.utils.serializer.SerializerBuilder
Adds a serializer to the builder.
addSession(RaftSession) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry
Adds a session.
addStateChangeListener(Consumer<PrimitiveState>) - Method in class io.atomix.primitive.AbstractAsyncPrimitive
 
addStateChangeListener(Consumer<PrimitiveState>) - Method in interface io.atomix.primitive.DistributedPrimitive
Registers a listener to be called when the primitive's state changes.
addStateChangeListener(Consumer<PrimitiveState>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Registers a session state change listener.
addStateChangeListener(Consumer<PrimitiveState>) - Method in interface io.atomix.primitive.proxy.ProxySession
Registers a session state change listener.
addStateChangeListener(Consumer<PrimitiveState>) - Method in interface io.atomix.primitive.session.SessionClient
Registers a session state change listener.
addStateChangeListener(Consumer<PrimitiveState>) - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
addType(NamespaceTypeConfig) - Method in class io.atomix.utils.serializer.NamespaceConfig
Adds a serializable type to the configuration.
addType(Class<?>) - Method in class io.atomix.utils.serializer.SerializerBuilder
Adds a serializable type to the builder.
addWhitelistPackage(String) - Method in class io.atomix.core.registry.ClasspathScanningRegistry.Builder
Adds a package to the whitelist.
anoint(T) - Method in interface io.atomix.core.election.AsyncLeaderElection
Attempts to promote a node to leadership displacing the current leader.
anoint(String, T) - Method in interface io.atomix.core.election.AsyncLeaderElector
Attempts to promote a node to leadership displacing the current leader.
anoint(T) - Method in interface io.atomix.core.election.LeaderElection
Attempts to promote a node to leadership displacing the current leader.
anoint(String, T) - Method in interface io.atomix.core.election.LeaderElector
Attempts to promote a node to leadership displacing the current leader.
anonymous() - Static method in class io.atomix.cluster.MemberId
Creates a new cluster node identifier from the specified string.
anonymous() - Static method in class io.atomix.cluster.NodeId
Creates a new cluster node identifier from the specified string.
AntiEntropyProtocol - Class in io.atomix.protocols.gossip
Anti-entropy protocol.
AntiEntropyProtocol.Type - Class in io.atomix.protocols.gossip
Gossip protocol type.
AntiEntropyProtocolBuilder - Class in io.atomix.protocols.gossip
Anti-entropy protocol builder.
AntiEntropyProtocolBuilder(AntiEntropyProtocolConfig) - Constructor for class io.atomix.protocols.gossip.AntiEntropyProtocolBuilder
 
AntiEntropyProtocolConfig - Class in io.atomix.protocols.gossip
Anti-entropy protocol configuration.
AntiEntropyProtocolConfig() - Constructor for class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
 
ApplicationException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ApplicationException
 
ApplicationException(Throwable) - Constructor for exception io.atomix.protocols.raft.RaftException.ApplicationException
 
apply(Function<S, R>) - Method in interface io.atomix.primitive.proxy.ProxySession
Submits an empty operation to the given partition.
apply(Commit<byte[]>) - Method in class io.atomix.primitive.service.AbstractPrimitiveService
 
apply(Commit<byte[]>) - Method in interface io.atomix.primitive.service.PrimitiveService
Applies a commit to the state machine.
apply(Commit<byte[]>) - Method in interface io.atomix.primitive.service.ServiceExecutor
Applies the given commit to the executor.
applyAll(Function<S, R>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to all partitions.
applyBy(String, Function<S, R>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to the owning partition for the given key.
applyBy(Object, Function<S, R>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to the owning partition for the given key.
applyOn(PartitionId, Function<S, R>) - Method in interface io.atomix.primitive.proxy.ProxyClient
Submits an empty operation to the given partition.
asMap() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns the multimap as a distributed map.
asMap() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns the multimap as a distributed map.
asMap() - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns the multimap as a distributed map.
asMap() - Method in interface io.atomix.core.multimap.DistributedMultimap
 
asVersion() - Method in class io.atomix.utils.time.LogicalTimestamp
Returns the timestamp as a version.
async() - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
 
async() - Method in interface io.atomix.core.collection.DistributedCollection
 
async() - Method in interface io.atomix.core.counter.AtomicCounter
 
async() - Method in interface io.atomix.core.counter.DistributedCounter
 
async() - Method in interface io.atomix.core.election.LeaderElection
 
async() - Method in interface io.atomix.core.election.LeaderElector
 
async() - Method in interface io.atomix.core.idgenerator.AtomicIdGenerator
 
async() - Method in interface io.atomix.core.iterator.SyncIterator
Returns the underlying asynchronous iterator.
async() - Method in interface io.atomix.core.list.DistributedList
 
async() - Method in interface io.atomix.core.lock.AtomicLock
 
async() - Method in interface io.atomix.core.lock.DistributedLock
 
async() - Method in interface io.atomix.core.map.AtomicCounterMap
 
async() - Method in interface io.atomix.core.map.AtomicMap
 
async() - Method in interface io.atomix.core.map.AtomicNavigableMap
 
async() - Method in interface io.atomix.core.map.AtomicSortedMap
 
async() - Method in interface io.atomix.core.map.DistributedMap
 
async() - Method in interface io.atomix.core.map.DistributedNavigableMap
 
async() - Method in interface io.atomix.core.map.DistributedSortedMap
 
async() - Method in interface io.atomix.core.multimap.AtomicMultimap
 
async() - Method in interface io.atomix.core.multimap.DistributedMultimap
 
async() - Method in interface io.atomix.core.multiset.DistributedMultiset
 
async() - Method in interface io.atomix.core.queue.DistributedQueue
 
async() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
 
async() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
async() - Method in interface io.atomix.core.set.DistributedNavigableSet
 
async() - Method in interface io.atomix.core.set.DistributedSet
 
async() - Method in interface io.atomix.core.set.DistributedSortedSet
 
async() - Method in interface io.atomix.core.transaction.Transaction
 
async() - Method in interface io.atomix.core.transaction.TransactionalMap
 
async() - Method in interface io.atomix.core.transaction.TransactionalSet
 
async() - Method in interface io.atomix.core.tree.AtomicDocumentTree
 
async() - Method in interface io.atomix.core.value.AtomicValue
 
async() - Method in interface io.atomix.core.value.DistributedValue
 
async() - Method in interface io.atomix.core.workqueue.WorkQueue
 
async() - Method in interface io.atomix.primitive.SyncPrimitive
Returns the underlying asynchronous primitive.
AsyncAtomicCounter - Interface in io.atomix.core.counter
An async atomic counter dispenses monotonically increasing values.
AsyncAtomicCounterMap<K> - Interface in io.atomix.core.map
An async atomic counter map dispenses monotonically increasing values associated with key.
AsyncAtomicDocumentTree<V> - Interface in io.atomix.core.tree
A hierarchical document tree data structure.
AsyncAtomicIdGenerator - Interface in io.atomix.core.idgenerator
An async ID generator for generating globally unique numbers.
AsyncAtomicLock - Interface in io.atomix.core.lock
Asynchronous lock primitive.
AsyncAtomicMap<K,V> - Interface in io.atomix.core.map
A distributed, strongly consistent map whose methods are all executed asynchronously.
AsyncAtomicMultimap<K,V> - Interface in io.atomix.core.multimap
Interface for a distributed multimap.
AsyncAtomicNavigableMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Asynchronous atomic navigable map.
AsyncAtomicSemaphore - Interface in io.atomix.core.semaphore
Distributed implementation of Semaphore.
AsyncAtomicSortedMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Asynchronous atomic sorted map.
AsyncAtomicValue<V> - Interface in io.atomix.core.value
Distributed version of java.util.concurrent.atomic.AtomicReference.
AsyncDistributedCollection<E> - Interface in io.atomix.core.collection
Asynchronous distributed collection.
AsyncDistributedCounter - Interface in io.atomix.core.counter
Distributed version of java.util.concurrent.atomic.AtomicLong.
AsyncDistributedCyclicBarrier - Interface in io.atomix.core.barrier
Distributed cyclic barrier.
AsyncDistributedList<E> - Interface in io.atomix.core.list
Asynchronous distributed list.
AsyncDistributedLock - Interface in io.atomix.core.lock
Asynchronous lock primitive.
AsyncDistributedMap<K,V> - Interface in io.atomix.core.map
Asynchronous distributed map.
AsyncDistributedMultimap<K,V> - Interface in io.atomix.core.multimap
Interface for a distributed multimap.
AsyncDistributedMultiset<E> - Interface in io.atomix.core.multiset
Asynchronous distributed multiset.
AsyncDistributedNavigableMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Asynchronous distributed navigable map.
AsyncDistributedNavigableSet<E extends Comparable<E>> - Interface in io.atomix.core.set
Asynchronous distributed navigable set.
AsyncDistributedQueue<E> - Interface in io.atomix.core.queue
Asynchronous distributed queue.
AsyncDistributedSemaphore - Interface in io.atomix.core.semaphore
Distributed implementation of Semaphore.
AsyncDistributedSet<E> - Interface in io.atomix.core.set
A distributed collection designed for holding unique elements.
AsyncDistributedSortedMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Asynchronous distributed sorted map.
AsyncDistributedSortedSet<E extends Comparable<E>> - Interface in io.atomix.core.set
Asynchronous distributed sorted set.
AsyncDistributedValue<V> - Interface in io.atomix.core.value
Distributed version of java.util.concurrent.atomic.AtomicReference.
AsyncIterable<T> - Interface in io.atomix.core.iterator
Asynchronously iterable object.
AsyncIterator<T> - Interface in io.atomix.core.iterator
Asynchronous iterator.
AsyncLeaderElection<T> - Interface in io.atomix.core.election
Distributed mutual exclusion primitive.
AsyncLeaderElector<T> - Interface in io.atomix.core.election
Distributed mutual exclusion primitive.
AsyncPrimitive - Interface in io.atomix.primitive
Asynchronous primitive.
AsyncTransaction - Interface in io.atomix.core.transaction
Asynchronous transaction.
AsyncTransactionalMap<K,V> - Interface in io.atomix.core.transaction
Asynchronous transactional map.
AsyncTransactionalSet<E> - Interface in io.atomix.core.transaction
Transactional set.
AsyncWorkQueue<E> - Interface in io.atomix.core.workqueue
Distributed Work Queue primitive.
AtomicCounter - Interface in io.atomix.core.counter
Distributed version of java.util.concurrent.atomic.AtomicLong.
AtomicCounterBuilder - Class in io.atomix.core.counter
Builder for AtomicCounter.
atomicCounterBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicCounter builder.
AtomicCounterConfig - Class in io.atomix.core.counter
Atomic counter configuration.
AtomicCounterConfig() - Constructor for class io.atomix.core.counter.AtomicCounterConfig
 
AtomicCounterMap<K> - Interface in io.atomix.core.map
Distributed version of com.google.common.util.concurrent.AtomicLongMap.
AtomicCounterMapBuilder<K> - Class in io.atomix.core.map
Builder for AtomicCounterMap.
atomicCounterMapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicCounterMap builder.
AtomicCounterMapConfig - Class in io.atomix.core.map
Atomic counter map configuration.
AtomicCounterMapConfig() - Constructor for class io.atomix.core.map.AtomicCounterMapConfig
 
AtomicCounterMapType<K> - Class in io.atomix.core.map
Atomic counter map primitive type.
AtomicCounterMapType() - Constructor for class io.atomix.core.map.AtomicCounterMapType
 
AtomicCounterType - Class in io.atomix.core.counter
Atomic counter primitive type.
AtomicCounterType() - Constructor for class io.atomix.core.counter.AtomicCounterType
 
AtomicDocumentTree<V> - Interface in io.atomix.core.tree
A hierarchical document tree data structure.
atomicDocumentTreeBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicDocumentTree builder.
AtomicDocumentTreeBuilder<V> - Class in io.atomix.core.tree
Builder for AtomicDocumentTree.
AtomicDocumentTreeConfig - Class in io.atomix.core.tree
Document tree configuration.
AtomicDocumentTreeConfig() - Constructor for class io.atomix.core.tree.AtomicDocumentTreeConfig
 
AtomicDocumentTreeType<V> - Class in io.atomix.core.tree
Document tree primitive type.
AtomicDocumentTreeType() - Constructor for class io.atomix.core.tree.AtomicDocumentTreeType
 
AtomicIdGenerator - Interface in io.atomix.core.idgenerator
Generator for globally unique numeric identifiers.
AtomicIdGeneratorBuilder - Class in io.atomix.core.idgenerator
Builder for AtomicIdGenerator.
atomicIdGeneratorBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicIdGenerator builder.
AtomicIdGeneratorConfig - Class in io.atomix.core.idgenerator
ID generator configuration.
AtomicIdGeneratorConfig() - Constructor for class io.atomix.core.idgenerator.AtomicIdGeneratorConfig
 
AtomicIdGeneratorType - Class in io.atomix.core.idgenerator
Atomic ID generator primitive type.
AtomicIdGeneratorType() - Constructor for class io.atomix.core.idgenerator.AtomicIdGeneratorType
 
AtomicLock - Interface in io.atomix.core.lock
Asynchronous lock primitive.
AtomicLockBuilder - Class in io.atomix.core.lock
Builder for AtomicIdGenerator.
atomicLockBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicLock builder.
AtomicLockConfig - Class in io.atomix.core.lock
Distributed lock configuration.
AtomicLockConfig() - Constructor for class io.atomix.core.lock.AtomicLockConfig
 
AtomicLockType - Class in io.atomix.core.lock
Atomic lock primitive type.
AtomicLockType() - Constructor for class io.atomix.core.lock.AtomicLockType
 
AtomicMap<K,V> - Interface in io.atomix.core.map
ConsistentMap provides the same functionality as AsyncAtomicMap with the only difference that all its methods block until the corresponding operation completes.
AtomicMapBuilder<K,V> - Class in io.atomix.core.map
Builder for AtomicMap instances.
atomicMapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicMap builder.
AtomicMapConfig - Class in io.atomix.core.map
Consistent map configuration.
AtomicMapConfig() - Constructor for class io.atomix.core.map.AtomicMapConfig
 
AtomicMapEvent<K,V> - Class in io.atomix.core.map
Representation of a ConsistentMap update notification.
AtomicMapEvent(AtomicMapEvent.Type, K, Versioned<V>, Versioned<V>) - Constructor for class io.atomix.core.map.AtomicMapEvent
Creates a new event object.
AtomicMapEvent.Type - Enum in io.atomix.core.map
MapEvent type.
AtomicMapEventListener<K,V> - Interface in io.atomix.core.map
Listener to be notified about updates to a ConsistentMap.
AtomicMapType<K,V> - Class in io.atomix.core.map
Consistent map primitive type.
AtomicMapType() - Constructor for class io.atomix.core.map.AtomicMapType
 
AtomicMultimap<K,V> - Interface in io.atomix.core.multimap
This provides a synchronous version of the functionality provided by AsyncAtomicMultimap.
AtomicMultimapBuilder<K,V> - Class in io.atomix.core.multimap
A builder class for AsyncConsistentMultimap.
atomicMultimapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicMultimap builder.
AtomicMultimapConfig - Class in io.atomix.core.multimap
Consistent multimap configuration.
AtomicMultimapConfig() - Constructor for class io.atomix.core.multimap.AtomicMultimapConfig
 
AtomicMultimapEvent<K,V> - Class in io.atomix.core.multimap
Representation of a ConsistentMultimap update notification.
AtomicMultimapEvent(AtomicMultimapEvent.Type, K, V, V) - Constructor for class io.atomix.core.multimap.AtomicMultimapEvent
Creates a new event object.
AtomicMultimapEvent.Type - Enum in io.atomix.core.multimap
MultimapEvent type.
AtomicMultimapEventListener<K,V> - Interface in io.atomix.core.multimap
Listener to be notified about updates to a ConsistentMultimap.
AtomicMultimapType<K,V> - Class in io.atomix.core.multimap
Consistent multimap primitive type.
AtomicMultimapType() - Constructor for class io.atomix.core.multimap.AtomicMultimapType
 
AtomicNavigableMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Atomic navigable map.
AtomicNavigableMapBuilder<K extends Comparable<K>,V> - Class in io.atomix.core.map
Builder for AtomicNavigableMap.
atomicNavigableMapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicNavigableMap builder.
AtomicNavigableMapConfig - Class in io.atomix.core.map
Consistent tree-map configuration.
AtomicNavigableMapConfig() - Constructor for class io.atomix.core.map.AtomicNavigableMapConfig
 
AtomicNavigableMapType<K extends Comparable<K>,V> - Class in io.atomix.core.map
Consistent tree map primitive type.
AtomicNavigableMapType() - Constructor for class io.atomix.core.map.AtomicNavigableMapType
 
AtomicSemaphore - Interface in io.atomix.core.semaphore
Distributed implementation of Semaphore.
atomicSemaphoreBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicSemaphore builder.
AtomicSemaphoreBuilder - Class in io.atomix.core.semaphore
Atomic semaphore builder.
AtomicSemaphoreConfig - Class in io.atomix.core.semaphore
Semaphore configuration.
AtomicSemaphoreConfig() - Constructor for class io.atomix.core.semaphore.AtomicSemaphoreConfig
 
AtomicSemaphoreType - Class in io.atomix.core.semaphore
Distributed semaphore primitive type.
AtomicSemaphoreType() - Constructor for class io.atomix.core.semaphore.AtomicSemaphoreType
 
AtomicSortedMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Atomic sorted map.
AtomicSortedMapBuilder<K extends Comparable<K>,V> - Class in io.atomix.core.map
Builder for AtomicSortedMap.
atomicSortedMapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new AtomicSortedMap builder.
AtomicSortedMapConfig - Class in io.atomix.core.map
Consistent sorted map configuration.
AtomicSortedMapConfig() - Constructor for class io.atomix.core.map.AtomicSortedMapConfig
 
AtomicSortedMapType<K extends Comparable<K>,V> - Class in io.atomix.core.map
Consistent sorted map primitive type.
AtomicSortedMapType() - Constructor for class io.atomix.core.map.AtomicSortedMapType
 
AtomicValue<V> - Interface in io.atomix.core.value
Distributed version of java.util.concurrent.atomic.AtomicReference.
atomicValueBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named AtomicValue builder.
AtomicValueBuilder<V> - Class in io.atomix.core.value
Builder for constructing new AtomicValue instances.
AtomicValueConfig - Class in io.atomix.core.value
Atomic value configuration.
AtomicValueConfig() - Constructor for class io.atomix.core.value.AtomicValueConfig
 
AtomicValueEvent<V> - Class in io.atomix.core.value
Representation of a AtomicValue update notification.
AtomicValueEvent(AtomicValueEvent.Type, V, V) - Constructor for class io.atomix.core.value.AtomicValueEvent
Creates a new event object.
AtomicValueEvent.Type - Enum in io.atomix.core.value
AtomicValueEvent type.
AtomicValueEventListener<V> - Interface in io.atomix.core.value
Listener to be notified about updates to a AtomicValue.
AtomicValueType<V> - Class in io.atomix.core.value
Atomic value primitive type.
AtomicValueType() - Constructor for class io.atomix.core.value.AtomicValueType
 
Atomix - Class in io.atomix.core
Primary interface for managing Atomix clusters and operating on distributed primitives.
Atomix(String...) - Constructor for class io.atomix.core.Atomix
 
Atomix(ClassLoader, String...) - Constructor for class io.atomix.core.Atomix
 
Atomix(File...) - Constructor for class io.atomix.core.Atomix
 
Atomix(ClassLoader, File...) - Constructor for class io.atomix.core.Atomix
 
Atomix(ClassLoader, List<File>) - Constructor for class io.atomix.core.Atomix
 
AtomixBuilder - Class in io.atomix.core
Builder for Atomix instance.
AtomixCluster - Class in io.atomix.cluster
Atomix cluster manager.
AtomixCluster(String) - Constructor for class io.atomix.cluster.AtomixCluster
 
AtomixCluster(File) - Constructor for class io.atomix.cluster.AtomixCluster
 
AtomixCluster(ClusterConfig, Version) - Constructor for class io.atomix.cluster.AtomixCluster
 
AtomixClusterBuilder - Class in io.atomix.cluster
Builder for an AtomixCluster instance.
AtomixConfig - Class in io.atomix.core
Atomix configuration.
AtomixConfig() - Constructor for class io.atomix.core.AtomixConfig
 
AtomixIOException - Exception in io.atomix.utils
Atomix I/O exception.
AtomixIOException() - Constructor for exception io.atomix.utils.AtomixIOException
 
AtomixIOException(String) - Constructor for exception io.atomix.utils.AtomixIOException
 
AtomixIOException(String, Object...) - Constructor for exception io.atomix.utils.AtomixIOException
 
AtomixIOException(String, Throwable) - Constructor for exception io.atomix.utils.AtomixIOException
 
AtomixIOException(Throwable) - Constructor for exception io.atomix.utils.AtomixIOException
 
AtomixRegistry - Interface in io.atomix.core
Atomix registry.
AtomixRuntimeException - Exception in io.atomix.utils
Atomix runtime exception.
AtomixRuntimeException() - Constructor for exception io.atomix.utils.AtomixRuntimeException
 
AtomixRuntimeException(String) - Constructor for exception io.atomix.utils.AtomixRuntimeException
 
AtomixRuntimeException(String, Object...) - Constructor for exception io.atomix.utils.AtomixRuntimeException
 
AtomixRuntimeException(String, Throwable) - Constructor for exception io.atomix.utils.AtomixRuntimeException
 
AtomixRuntimeException(Throwable) - Constructor for exception io.atomix.utils.AtomixRuntimeException
 
availablePermits() - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Query the current number of permits available.
availablePermits() - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Query the current number of permits available.
availablePermits() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Returns the current number of permits available.
availablePermits() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
await() - Method in interface io.atomix.core.barrier.AsyncDistributedCyclicBarrier
Waits until all parties have invoked await on this barrier.
await(Duration) - Method in interface io.atomix.core.barrier.AsyncDistributedCyclicBarrier
Waits until all parties have invoked await on this barrier.
await() - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
Waits until all parties have invoked await on this barrier.
await(Duration) - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
Waits until all parties have invoked await on this barrier.

B

backup(BackupOutput) - Method in interface io.atomix.primitive.service.PrimitiveService
Backs up the service state to the given buffer.
BackupInput - Interface in io.atomix.primitive.service
Backup input.
BackupOutput - Interface in io.atomix.primitive.service
Backup output.
backups() - Method in interface io.atomix.primitive.partition.Partition
Returns the partition's backups.
backups(int) - Method in class io.atomix.primitive.partition.PrimaryTerm
Returns an ordered list of backup members.
backups() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
backups() - Method in class io.atomix.protocols.raft.partition.RaftPartition
 
BASIC - Static variable in class io.atomix.utils.serializer.Namespaces
 
BASIC_MAX_SIZE - Static variable in class io.atomix.utils.serializer.Namespaces
 
begin() - Method in interface io.atomix.core.transaction.AsyncTransaction
Starts a new transaction.
begin() - Method in interface io.atomix.core.transaction.Transaction
Starts a new transaction.
begin() - Method in interface io.atomix.core.transaction.TransactionService
Returns a new transaction ID.
BEGIN_USER_CUSTOM_ID - Static variable in class io.atomix.utils.serializer.Namespaces
Kryo registration Id for user custom registration.
bootstrap() - Method in interface io.atomix.protocols.raft.RaftServer
Bootstraps a single-node cluster.
bootstrap(MemberId...) - Method in interface io.atomix.protocols.raft.RaftServer
Bootstraps the cluster using the provided cluster configuration.
bootstrap(Collection<MemberId>) - Method in interface io.atomix.protocols.raft.RaftServer
Bootstraps the cluster using the provided cluster configuration.
BootstrapDiscoveryBuilder - Class in io.atomix.cluster.discovery
Bootstrap discovery builder.
BootstrapDiscoveryBuilder() - Constructor for class io.atomix.cluster.discovery.BootstrapDiscoveryBuilder
 
BootstrapDiscoveryConfig - Class in io.atomix.cluster.discovery
Bootstrap discovery configuration.
BootstrapDiscoveryConfig() - Constructor for class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
 
BootstrapDiscoveryProvider - Class in io.atomix.cluster.discovery
Cluster membership provider that bootstraps membership from a pre-defined set of peers.
BootstrapDiscoveryProvider(Node...) - Constructor for class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
BootstrapDiscoveryProvider(Collection<Node>) - Constructor for class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
BootstrapDiscoveryProvider.Type - Class in io.atomix.cluster.discovery
Bootstrap member location provider type.
BootstrapService - Interface in io.atomix.cluster
Cluster bootstrap service.
borrow() - Method in class io.atomix.utils.serializer.Namespace
 
broadcast(String, byte[]) - Method in interface io.atomix.cluster.messaging.BroadcastService
Broadcasts the given message to all listeners for the given subject.
broadcast(String, M) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members.
broadcast(String, M, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members.
broadcast(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members.
broadcast(String, M, Function<M, byte[]>, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members.
broadcast(String, M) - Method in interface io.atomix.cluster.messaging.ClusterEventService
Broadcasts a message to all subscribers registered for the given topic.
broadcast(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterEventService
Broadcasts a message to all subscribers registered for the given topic.
broadcastIncludeSelf(String, M) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members over TCP including self.
broadcastIncludeSelf(String, M, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members including self.
broadcastIncludeSelf(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members over TCP including self.
broadcastIncludeSelf(String, M, Function<M, byte[]>, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Broadcasts a message to all members including self.
BroadcastService - Interface in io.atomix.cluster.messaging
Service for broadcast messaging between nodes.
BroadcastService.Builder - Interface in io.atomix.cluster.messaging
Broadcast service builder.
build() - Method in class io.atomix.cluster.AtomixClusterBuilder
 
build() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryBuilder
 
build() - Method in class io.atomix.cluster.discovery.DnsDiscoveryBuilder
 
build() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryBuilder
 
build() - Method in class io.atomix.cluster.MemberBuilder
 
build() - Method in class io.atomix.cluster.NodeBuilder
 
build() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocolBuilder
 
build() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolBuilder
 
build() - Method in class io.atomix.core.AtomixBuilder
Builds a new Atomix instance.
build() - Method in class io.atomix.core.profile.ConsensusProfileBuilder
 
build() - Method in class io.atomix.core.profile.DataGridProfileBuilder
 
build() - Method in class io.atomix.core.registry.ClasspathScanningRegistry.Builder
 
build() - Method in class io.atomix.core.registry.SimpleRegistry.Builder
 
build() - Method in class io.atomix.core.workqueue.WorkQueueStats.Builder
 
build() - Method in class io.atomix.primitive.PrimitiveBuilder
Builds a new instance of the primitive.
build() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolBuilder
 
build() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup.Builder
 
build() - Method in class io.atomix.protocols.backup.PrimaryBackupClient.Builder
 
build() - Method in class io.atomix.protocols.backup.PrimaryBackupServer.Builder
 
build() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolBuilder
 
build() - Method in class io.atomix.protocols.gossip.CrdtProtocolBuilder
 
build() - Method in class io.atomix.protocols.raft.MultiRaftProtocolBuilder
 
build() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder
 
build() - Method in interface io.atomix.utils.Builder
Builds the object.
build() - Method in class io.atomix.utils.serializer.Namespace.Builder
Builds a Namespace instance.
build(String) - Method in class io.atomix.utils.serializer.Namespace.Builder
Builds a Namespace instance.
build() - Method in class io.atomix.utils.serializer.SerializerBuilder
 
build() - Method in class io.atomix.utils.Version
Returns the build version number.
buildAsync() - Method in class io.atomix.primitive.PrimitiveBuilder
Builds a new instance of the primitive asynchronously.
builder() - Static method in class io.atomix.cluster.AtomixCluster
Returns a new Atomix builder.
builder(ClassLoader) - Static method in class io.atomix.cluster.AtomixCluster
Returns a new Atomix builder.
builder(String) - Static method in class io.atomix.cluster.AtomixCluster
Returns a new Atomix builder.
builder(String, ClassLoader) - Static method in class io.atomix.cluster.AtomixCluster
Returns a new Atomix builder.
builder(ClusterConfig) - Static method in class io.atomix.cluster.AtomixCluster
Returns a new Atomix builder.
builder() - Static method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
Creates a new bootstrap provider builder.
builder() - Static method in class io.atomix.cluster.discovery.DnsDiscoveryProvider
Creates a new DNS provider builder.
builder() - Static method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider
Returns a new multicast member location provider builder.
builder() - Static method in class io.atomix.cluster.Member
Returns a new member builder with no ID.
builder(String) - Static method in class io.atomix.cluster.Member
Returns a new member builder.
builder(MemberId) - Static method in class io.atomix.cluster.Member
Returns a new member builder.
Builder() - Constructor for class io.atomix.cluster.messaging.MessagingService.Builder
 
builder() - Static method in class io.atomix.cluster.Node
Returns a new member builder with no ID.
builder() - Static method in class io.atomix.cluster.protocol.PhiMembershipProtocol
Creates a new bootstrap provider builder.
builder() - Static method in class io.atomix.cluster.protocol.SwimMembershipProtocol
Creates a new bootstrap provider builder.
builder() - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(ClassLoader) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(AtomixRegistry) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(String) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(String, ClassLoader) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(String, AtomixRegistry) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(AtomixConfig) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(AtomixConfig, ClassLoader) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder(AtomixConfig, AtomixRegistry) - Static method in class io.atomix.core.Atomix
Returns a new Atomix builder.
builder() - Static method in class io.atomix.core.profile.ConsensusProfile
Creates a new consensus profile builder.
builder() - Static method in class io.atomix.core.profile.DataGridProfile
Creates a new data grid profile builder.
builder() - Static method in class io.atomix.core.registry.ClasspathScanningRegistry
Returns a new classpath scanning registry builder.
builder() - Static method in class io.atomix.core.registry.SimpleRegistry
Returns a new static registry builder.
Builder() - Constructor for class io.atomix.core.registry.SimpleRegistry.Builder
 
builder() - Static method in class io.atomix.core.workqueue.WorkQueueStats
Returns a WorkQueueStats builder.
Builder() - Constructor for class io.atomix.core.workqueue.WorkQueueStats.Builder
 
Builder() - Constructor for class io.atomix.primitive.session.SessionClient.Builder
 
builder() - Static method in class io.atomix.protocols.backup.MultiPrimaryProtocol
Returns a new multi-primary protocol builder.
builder(String) - Static method in class io.atomix.protocols.backup.MultiPrimaryProtocol
Returns a new multi-primary protocol builder for the given group.
builder(String) - Static method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
Returns a new primary-backup partition group builder.
builder() - Static method in class io.atomix.protocols.backup.PrimaryBackupClient
Returns a new primary-backup client builder.
Builder() - Constructor for class io.atomix.protocols.backup.PrimaryBackupClient.Builder
 
builder() - Static method in class io.atomix.protocols.backup.PrimaryBackupServer
Returns a new server builder.
Builder() - Constructor for class io.atomix.protocols.backup.PrimaryBackupServer.Builder
 
Builder() - Constructor for class io.atomix.protocols.backup.session.PrimaryBackupSessionClient.Builder
 
builder() - Static method in class io.atomix.protocols.gossip.AntiEntropyProtocol
Returns a new gossip protocol builder.
builder() - Static method in class io.atomix.protocols.gossip.CrdtProtocol
Returns a new CRDT protocol builder.
builder() - Static method in class io.atomix.protocols.raft.MultiRaftProtocol
Returns a new multi-Raft protocol builder.
builder(String) - Static method in class io.atomix.protocols.raft.MultiRaftProtocol
Returns a new multi-Raft protocol builder.
builder(String) - Static method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
Returns a new Raft partition group builder.
builder() - Static method in interface io.atomix.protocols.raft.RaftClient
Returns a new Raft client builder.
builder(MemberId...) - Static method in interface io.atomix.protocols.raft.RaftClient
Returns a new Raft client builder.
builder(Collection<MemberId>) - Static method in interface io.atomix.protocols.raft.RaftClient
Returns a new Raft client builder.
builder() - Static method in interface io.atomix.protocols.raft.RaftServer
Returns a new Raft server builder using the default host:port.
builder(MemberId) - Static method in interface io.atomix.protocols.raft.RaftServer
Returns a new Raft server builder.
Builder() - Constructor for class io.atomix.protocols.raft.session.RaftSessionClient.Builder
 
Builder<T> - Interface in io.atomix.utils
Object builder.
builder() - Static method in class io.atomix.utils.serializer.Namespace
Creates a new Namespace builder.
Builder() - Constructor for class io.atomix.utils.serializer.Namespace.Builder
 
builder() - Static method in interface io.atomix.utils.serializer.Serializer
Creates a new serializer builder.
builder(String) - Static method in interface io.atomix.utils.serializer.Serializer
Creates a new serializer builder.

C

CacheConfig - Class in io.atomix.core.cache
Cached primitive configuration.
CacheConfig() - Constructor for class io.atomix.core.cache.CacheConfig
 
CachedPrimitiveBuilder<B extends CachedPrimitiveBuilder<B,C,P>,C extends CachedPrimitiveConfig<C>,P extends SyncPrimitive> - Class in io.atomix.core.cache
Cached distributed primitive builder.
CachedPrimitiveConfig<C extends CachedPrimitiveConfig<C>> - Class in io.atomix.core.cache
Cached primitive configuration.
CachedPrimitiveConfig() - Constructor for class io.atomix.core.cache.CachedPrimitiveConfig
 
candidates() - Method in class io.atomix.core.election.Leadership
Returns an preference-ordered list of nodes that are in the leadership race for this topic.
candidates() - Method in class io.atomix.primitive.partition.PrimaryTerm
Returns the list of members.
canonical(EventType) - Static method in interface io.atomix.primitive.event.EventType
Simplifies the given event type.
canonicalize() - Method in interface io.atomix.primitive.event.EventType
Returns an identical event type in canonical form.
ceiling(E) - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns the least element in this set greater than or equal to the given element, or null if there is no such element.
ceilingEntry(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the least key greater than or equal to the given key, or null if there is no such key.
ceilingEntry(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the least key greater than or equal to the given key, or null if there is no such key.
ceilingEntry(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the least key greater than or equal to the key.
ceilingKey(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns the least key greater than or equal to the given key, or null if there is no such key.
ceilingKey(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns the least key greater than or equal to the given key, or null if there is no such key.
ceilingKey(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the lowest key greater than or equal to key.
child(String) - Method in interface io.atomix.core.tree.DocumentTreeNode
Returns the child node of this node with the specified relative path name.
childPath() - Method in class io.atomix.core.tree.DocumentPath
Returns the relative path to the given node.
children() - Method in interface io.atomix.core.tree.DocumentTreeNode
Returns the children of this node.
ClasspathScanningRegistry - Class in io.atomix.core.registry
Atomix registry that scans the classpath for registered objects.
ClasspathScanningRegistry.Builder - Class in io.atomix.core.registry
Classpath scanning registry builder.
clear() - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Removes all elements from the collection.
clear() - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Removes all entries from the map.
clear() - Method in interface io.atomix.core.map.AsyncAtomicMap
Removes all of the mappings from this map (optional operation).
clear() - Method in interface io.atomix.core.map.AsyncDistributedMap
Removes all of the mappings from this map (optional operation).
clear() - Method in interface io.atomix.core.map.AtomicCounterMap
Clears all entries from the map.
clear() - Method in interface io.atomix.core.map.AtomicMap
Removes all of the mappings from this map (optional operation).
clear() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Removes all key-value pairs, after which it will be empty.
clear() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Removes all key-value pairs, after which it will be empty.
clear() - Method in interface io.atomix.core.multimap.AtomicMultimap
Removes all key-value pairs, after which it will be empty.
clearCommands() - Method in class io.atomix.protocols.raft.session.RaftSession
Clears and returns all pending commands.
clearResults(long) - Method in class io.atomix.protocols.raft.session.RaftSession
Clears command results up to the given sequence number.
client() - Static method in interface io.atomix.core.profile.Profile
Creates a new client profile.
clientId() - Method in interface io.atomix.protocols.raft.RaftClient
Returns the globally unique client identifier.
ClientProfile - Class in io.atomix.core.profile
Client profile.
ClientProfile.Type - Class in io.atomix.core.profile
Client profile type.
ClientProfileConfig - Class in io.atomix.core.profile
Client profile configuration.
ClientProfileConfig() - Constructor for class io.atomix.core.profile.ClientProfileConfig
 
Clock<T extends Timestamp> - Interface in io.atomix.utils.time
Clock.
close() - Method in interface io.atomix.cluster.messaging.Subscription
Closes the subscription, causing it to be unregistered.
close() - Method in interface io.atomix.core.iterator.AsyncIterator
Closes the iterator.
close() - Method in interface io.atomix.core.iterator.SyncIterator
Closes the iterator.
close() - Method in interface io.atomix.core.transaction.TransactionParticipant
Closes the participant.
close() - Method in class io.atomix.primitive.AbstractAsyncPrimitive
 
close() - Method in interface io.atomix.primitive.AsyncPrimitive
Closes the primitive.
close() - Method in interface io.atomix.primitive.partition.ManagedPartitionGroup
Closes the partition group.
close() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Closes the counter.
close() - Method in interface io.atomix.primitive.protocol.map.MapDelegate
Closes the map.
close() - Method in interface io.atomix.primitive.protocol.set.SetDelegate
Closes the set.
close() - Method in interface io.atomix.primitive.protocol.value.ValueDelegate
Closes the counter.
close() - Method in interface io.atomix.primitive.proxy.ProxyClient
Closes the proxy client.
close() - Method in interface io.atomix.primitive.proxy.ProxySession
Closes the proxy session.
close(SessionId) - Method in class io.atomix.primitive.service.AbstractPrimitiveService
 
close(SessionId) - Method in interface io.atomix.primitive.service.PrimitiveService
Closes the session with the given identifier.
close() - Method in interface io.atomix.primitive.service.PrimitiveService
Closes the state machine.
close() - Method in interface io.atomix.primitive.session.SessionClient
Closes the proxy.
close() - Method in class io.atomix.primitive.Synchronous
 
close() - Method in interface io.atomix.primitive.SyncPrimitive
Closes the primitive.
close() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
Closes the primary-backup partition.
close() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
close() - Method in class io.atomix.protocols.backup.PrimaryBackupClient
Closes the primary-backup client.
close() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
close() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
close() - Method in interface io.atomix.protocols.raft.RaftClient
Closes the client.
close() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Closes the service context.
close() - Method in class io.atomix.protocols.raft.session.RaftSession
Closes the session.
ClosedSession() - Constructor for exception io.atomix.primitive.PrimitiveException.ClosedSession
 
ClosedSession(String) - Constructor for exception io.atomix.primitive.PrimitiveException.ClosedSession
 
ClosedSession(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ClosedSession
 
closeSession(long, long, RaftSession, boolean) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Unregister the given session.
cluster() - Method in interface io.atomix.protocols.raft.RaftServer
Returns the server's cluster configuration.
ClusterCommunicationService - Interface in io.atomix.cluster.messaging
High-level MemberId based intra-cluster messaging service.
ClusterConfig - Class in io.atomix.cluster
Cluster configuration.
ClusterConfig() - Constructor for class io.atomix.cluster.ClusterConfig
 
ClusterEventService - Interface in io.atomix.cluster.messaging
Publish-subscribe based messaging service.
ClusterMembershipEvent - Class in io.atomix.cluster
Describes cluster-related event.
ClusterMembershipEvent(ClusterMembershipEvent.Type, Member) - Constructor for class io.atomix.cluster.ClusterMembershipEvent
Creates an event of a given type and for the specified instance and the current time.
ClusterMembershipEvent(ClusterMembershipEvent.Type, Member, long) - Constructor for class io.atomix.cluster.ClusterMembershipEvent
Creates an event of a given type and for the specified device and time.
ClusterMembershipEvent.Type - Enum in io.atomix.cluster
Type of cluster-related events.
ClusterMembershipEventListener - Interface in io.atomix.cluster
Entity capable of receiving device cluster-related events.
ClusterMembershipService - Interface in io.atomix.cluster
Service for obtaining information about the individual members within the cluster.
CollectionEvent<E> - Class in io.atomix.core.collection
Representation of a DistributedCollection update notification.
CollectionEvent(CollectionEvent.Type, E) - Constructor for class io.atomix.core.collection.CollectionEvent
Creates a new event object.
CollectionEvent.Type - Enum in io.atomix.core.collection
Collection event type.
CollectionEventListener<E> - Interface in io.atomix.core.collection
Listener to be notified about updates to a DistributedSet.
Command - Annotation Type in io.atomix.primitive.operation
Command annotation.
command(String) - Static method in interface io.atomix.primitive.operation.OperationId
Returns a new command operation identifier.
CommandFailure() - Constructor for exception io.atomix.primitive.PrimitiveException.CommandFailure
 
CommandFailure(String) - Constructor for exception io.atomix.primitive.PrimitiveException.CommandFailure
 
CommandFailure(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.CommandFailure
 
commit() - Method in interface io.atomix.core.transaction.AsyncTransaction
Commits a transaction that was previously started thereby making its changes permanent and externally visible.
commit() - Method in interface io.atomix.core.transaction.Transaction
Commits a transaction that was previously started thereby making its changes permanent and externally visible.
commit(TransactionId) - Method in interface io.atomix.core.transaction.Transactional
Commits a previously prepared transaction and unlocks the object.
commit() - Method in interface io.atomix.core.transaction.TransactionParticipant
Commits the participant.
Commit<T> - Interface in io.atomix.primitive.service
Represents the committed state and metadata of a Raft state machine operation.
commit(long) - Method in class io.atomix.protocols.raft.session.RaftSession
Commits events for the given index.
CommitStatus - Enum in io.atomix.core.transaction
Transaction commit status.
committing(TransactionId) - Method in interface io.atomix.core.transaction.TransactionService
Marks the given transaction as committing.
CommunicationStrategy - Enum in io.atomix.protocols.raft.session
Strategy for selecting nodes to which to connect and submit operations.
compact() - Method in interface io.atomix.protocols.raft.RaftServer
Compacts server logs.
compareAndSet(long, long) - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically sets the given counter to the updated value if the current value is the expected value, otherwise no change occurs.
compareAndSet(long, long) - Method in interface io.atomix.core.counter.AtomicCounter
Atomically sets the given counter to the updated value if the current value is the expected value, otherwise no change occurs.
compareAndSet(V, V) - Method in interface io.atomix.core.value.AsyncAtomicValue
Atomically sets the value to the given updated value if the current value is equal to the expected value.
compareAndSet(V, V) - Method in interface io.atomix.core.value.AtomicValue
Atomically sets the value to the given updated value if the current value is equal to the expected value.
compareTo(NodeId) - Method in class io.atomix.cluster.NodeId
 
compareTo(DocumentPath) - Method in class io.atomix.core.tree.DocumentPath
 
compareTo(PartitionId) - Method in class io.atomix.primitive.partition.PartitionId
 
compareTo(PrimitiveProtocol.Type<C>) - Method in interface io.atomix.primitive.protocol.PrimitiveProtocol.Type
 
compareTo(Timestamp) - Method in class io.atomix.utils.time.LogicalTimestamp
 
compareTo(Timestamp) - Method in class io.atomix.utils.time.MultiValuedTimestamp
 
compareTo(Timestamp) - Method in class io.atomix.utils.time.VectorTimestamp
 
compareTo(Timestamp) - Method in class io.atomix.utils.time.Version
 
compareTo(Timestamp) - Method in class io.atomix.utils.time.WallClockTimestamp
 
compareTo(Version) - Method in class io.atomix.utils.Version
 
complete(TransactionId) - Method in interface io.atomix.core.transaction.TransactionService
Marks the given transaction as complete.
complete(Collection<String>) - Method in interface io.atomix.core.workqueue.AsyncWorkQueue
Completes a collection of tasks.
complete(String...) - Method in interface io.atomix.core.workqueue.AsyncWorkQueue
Completes a collection of tasks.
complete(Collection<String>) - Method in interface io.atomix.core.workqueue.WorkQueue
Completes a collection of tasks.
complete(String...) - Method in interface io.atomix.core.workqueue.WorkQueue
Completes a collection of tasks.
completeKeepAlive(long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Completes a keep-alive.
compute(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AsyncAtomicMap
Attempts to compute a mapping for the specified key and its current mapped value (or null if there is no current mapping).
compute(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AsyncDistributedMap
Attempts to compute a mapping for the specified key and its current mapped value (or null if there is no current mapping).
compute(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AtomicMap
Attempts to compute a mapping for the specified key and its current mapped value (or null if there is no current mapping).
computeIf(K, Predicate<? super V>, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AsyncAtomicMap
If the value for the specified key satisfies a condition, attempts to compute a new mapping given the key and its current mapped value.
computeIf(K, Predicate<? super V>, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AtomicMap
If the value for the specified key satisfies a condition, attempts to compute a new mapping given the key and its current mapped value.
computeIfAbsent(K, Function<? super K, ? extends V>) - Method in interface io.atomix.core.map.AsyncAtomicMap
If the specified key is not already associated with a value (or is mapped to null), attempts to compute its value using the given mapping function and enters it into this map unless null.
computeIfAbsent(K, Function<? super K, ? extends V>) - Method in interface io.atomix.core.map.AsyncDistributedMap
If the specified key is not already associated with a value (or is mapped to null), attempts to compute its value using the given mapping function and enters it into this map unless null.
computeIfAbsent(K, Function<? super K, ? extends V>) - Method in interface io.atomix.core.map.AtomicMap
If the specified key is not already associated with a value (or is mapped to null), attempts to compute its value using the given mapping function and enters it into this map unless null.
computeIfPresent(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AsyncAtomicMap
If the value for the specified key is present and non-null, attempts to compute a new mapping given the key and its current mapped value.
computeIfPresent(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AsyncDistributedMap
If the value for the specified key is present and non-null, attempts to compute a new mapping given the key and its current mapped value.
computeIfPresent(K, BiFunction<? super K, ? super V, ? extends V>) - Method in interface io.atomix.core.map.AtomicMap
If the value for the specified key is present and non-null, attempts to compute a new mapping given the key and its current mapped value.
ConcurrentModification() - Constructor for exception io.atomix.primitive.PrimitiveException.ConcurrentModification
 
config() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
config() - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider
 
config() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
config() - Method in class io.atomix.cluster.Member
 
config() - Method in class io.atomix.cluster.Node
 
config() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol
 
config() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol
 
config() - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration.
config(ClassLoader) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration.
config(AtomixRegistry) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration.
config(String...) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config(ClassLoader, String...) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config(AtomixRegistry, String...) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config(File...) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration.
config(List<File>) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config(ClassLoader, List<File>) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config(AtomixRegistry, List<File>) - Static method in class io.atomix.core.Atomix
Returns a new Atomix configuration from the given file.
config() - Method in class io.atomix.core.profile.ClientProfile
 
config() - Method in class io.atomix.core.profile.ConsensusProfile
 
config() - Method in class io.atomix.core.profile.DataGridProfile
 
config() - Method in class io.atomix.primitive.partition.PartitionGroupMembership
Returns the partition group configuration.
config() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
config() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
Config - Interface in io.atomix.utils.config
Atomix configuration.
config() - Method in interface io.atomix.utils.config.Configured
Returns the object configuration.
ConfigMapper - Class in io.atomix.utils.config
Utility for applying Typesafe configurations to Atomix configuration objects.
ConfigMapper(ClassLoader) - Constructor for class io.atomix.utils.config.ConfigMapper
 
ConfigService - Interface in io.atomix.primitive.config
Configuration service.
ConfigurationException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ConfigurationException
 
ConfigurationException - Exception in io.atomix.utils.config
Atomix configuration exception.
ConfigurationException(String) - Constructor for exception io.atomix.utils.config.ConfigurationException
 
ConfigurationException(String, Throwable) - Constructor for exception io.atomix.utils.config.ConfigurationException
 
configure(AtomixConfig) - Method in class io.atomix.core.profile.ClientProfile
 
configure(AtomixConfig) - Method in class io.atomix.core.profile.ConsensusProfile
 
configure(AtomixConfig) - Method in class io.atomix.core.profile.DataGridProfile
 
configure(AtomixConfig) - Method in interface io.atomix.core.profile.Profile
Configures the Atomix instance.
Configured<T extends Config> - Interface in io.atomix.utils.config
Interface for objects configured via a configuration object.
ConfiguredType<C extends TypedConfig> - Interface in io.atomix.utils
Configured type.
connect() - Method in class io.atomix.primitive.AbstractAsyncPrimitive
Connects the primitive.
connect(PartitionManagementService) - Method in interface io.atomix.primitive.partition.ManagedPartitionGroup
Connects to the partition group.
connect() - Method in interface io.atomix.primitive.proxy.ProxyClient
Connects the proxy client.
connect() - Method in interface io.atomix.primitive.proxy.ProxySession
Connects the proxy session.
connect() - Method in interface io.atomix.primitive.session.SessionClient
Connects the proxy.
connect(PartitionManagementService) - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
connect() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
connect(PartitionManagementService) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
connect() - Method in interface io.atomix.protocols.raft.RaftClient
Connects the client to Raft cluster via the default server address.
connect(MemberId...) - Method in interface io.atomix.protocols.raft.RaftClient
Connects the client to Raft cluster via the provided server addresses.
connect(Collection<MemberId>) - Method in interface io.atomix.protocols.raft.RaftClient
Connects the client to Raft cluster via the provided server addresses.
consensus(String...) - Static method in interface io.atomix.core.profile.Profile
Creates a consensus profile.
consensus(Collection<String>) - Static method in interface io.atomix.core.profile.Profile
Creates a consensus profile.
ConsensusProfile - Class in io.atomix.core.profile
Consensus profile.
ConsensusProfile.Type - Class in io.atomix.core.profile
Consensus profile type.
ConsensusProfileBuilder - Class in io.atomix.core.profile
Consensus profile builder.
ConsensusProfileConfig - Class in io.atomix.core.profile
Consensus profile configuration.
ConsensusProfileConfig() - Constructor for class io.atomix.core.profile.ConsensusProfileConfig
 
Consistency - Enum in io.atomix.primitive
Primitive consistency model.
contains(E) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Returns if this collection contains the specified element.
contains(E) - Method in interface io.atomix.core.transaction.AsyncTransactionalSet
Returns true if this set contains the specified element.
contains(E) - Method in interface io.atomix.core.transaction.TransactionalSet
Returns true if this set contains the specified element.
containsAll(Collection<? extends E>) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Returns if this collection contains all the elements in specified collection.
containsEntry(K, V) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns true if this map contains at least one key-value pair with key and value specified.
containsEntry(K, V) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns true if this map contains at least one key-value pair with key and value specified.
containsEntry(K, V) - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns true if this map contains at least one key-value pair with key and value specified.
containsKey(K) - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns true if this map contains a mapping for the specified key.
containsKey(K) - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns true if this map contains a mapping for the specified key.
containsKey(K) - Method in interface io.atomix.core.map.AtomicMap
Returns true if this map contains a mapping for the specified key.
containsKey(K) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns true if there is at lease one key-value pair with a key equal to key.
containsKey(K) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns true if there is at lease one key-value pair with a key equal to key.
containsKey(K) - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns true if there is at lease one key-value pair with a key equal to key.
containsKey(K) - Method in interface io.atomix.core.transaction.AsyncTransactionalMap
Returns true if this map contains a mapping for the specified key.
containsKey(K) - Method in interface io.atomix.core.transaction.TransactionalMap
Returns true if this map contains a mapping for the specified key.
containsValue(V) - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns true if this map contains the specified value.
containsValue(V) - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns true if this map maps one or more keys to the specified value.
containsValue(V) - Method in interface io.atomix.core.map.AtomicMap
Returns true if this map contains the specified value.
containsValue(V) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns true if this map contains at lease one key-value pair with a value equal to value.
containsValue(V) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns true if this map contains at lease one key-value pair with a value equal to value.
containsValue(V) - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns true if this map contains at lease one key-value pair with a value equal to value.
context() - Method in interface io.atomix.primitive.proxy.ProxySession
Returns the session thread context.
context() - Method in interface io.atomix.primitive.session.SessionClient
Returns the partition thread context.
context() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
count(Object) - Method in interface io.atomix.core.multiset.AsyncDistributedMultiset
Returns the number of occurrences of an element in this multiset (the count of the element).
counterBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedCounter builder.
CounterCompatibleBuilder<B extends CounterCompatibleBuilder<B>> - Interface in io.atomix.primitive.protocol.counter
Counter builder.
CounterDelegate - Interface in io.atomix.primitive.protocol.counter
Gossip-based counter service.
CounterProtocol - Interface in io.atomix.primitive.protocol.counter
Counter protocol.
CrdtProtocol - Class in io.atomix.protocols.gossip
Conflict-free Replicated Data Types (CRDT) protocol.
CrdtProtocol.Type - Class in io.atomix.protocols.gossip
CRDT protocol type.
CrdtProtocolBuilder - Class in io.atomix.protocols.gossip
CRDT protocol builder.
CrdtProtocolBuilder(CrdtProtocolConfig) - Constructor for class io.atomix.protocols.gossip.CrdtProtocolBuilder
 
CrdtProtocolConfig - Class in io.atomix.protocols.gossip
CRDT protocol configuration.
CrdtProtocolConfig() - Constructor for class io.atomix.protocols.gossip.CrdtProtocolConfig
 
create(String, V) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Creates a document tree node if one does not exist already.
create(DocumentPath, V) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Creates a document tree node if one does not exist already.
create(String, V) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Creates a document tree node if one does not exist already.
create(DocumentPath, V) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Creates a document tree node if one does not exist already.
create() - Method in class io.atomix.utils.serializer.Namespace
Creates a Kryo instance.
createException() - Method in class io.atomix.protocols.raft.RaftError
Creates a new exception for the error.
createGroup(C) - Method in interface io.atomix.primitive.partition.PartitionGroupFactory
Creates a new partition group.
createPrimitive(String, PrimitiveType) - Method in interface io.atomix.primitive.PrimitiveRegistry
Creates a new distributed primitive.
createRecursive(String, V) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Creates a document tree node recursively by creating all missing intermediate nodes in the path.
createRecursive(DocumentPath, V) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Creates a document tree node recursively by creating all missing intermediate nodes in the path.
createRecursive(String, V) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Creates a document tree node by first creating any missing intermediate nodes in the path.
createRecursive(DocumentPath, V) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Creates a document tree node by first creating any missing intermediate nodes in the path.
creationTime() - Method in class io.atomix.utils.time.Versioned
Returns the system time when this version was created.
currentIndex() - Method in interface io.atomix.primitive.service.ServiceContext
Returns the current state machine index.
currentIndex() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
 
currentOperation() - Method in interface io.atomix.primitive.service.ServiceContext
Returns the current operation type.
currentOperation() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
 
currentSession() - Method in interface io.atomix.primitive.service.ServiceContext
Returns the current session.
currentSession() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
 
cyclicBarrierBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedCyclicBarrier builder.

D

dataDirectory() - Method in class io.atomix.protocols.raft.partition.RaftPartition
Returns the partition data directory.
dataGrid() - Static method in interface io.atomix.core.profile.Profile
Creates a new data grid profile.
dataGrid(int) - Static method in interface io.atomix.core.profile.Profile
Creates a new data grid profile with the given number of partitions.
DataGridProfile - Class in io.atomix.core.profile
In-memory data grid profile.
DataGridProfile.Type - Class in io.atomix.core.profile
Data-grid profile type.
DataGridProfileBuilder - Class in io.atomix.core.profile
Data grid profile builder.
DataGridProfileConfig - Class in io.atomix.core.profile
Data grid profile configuration.
DataGridProfileConfig() - Constructor for class io.atomix.core.profile.DataGridProfileConfig
 
decode(byte[]) - Method in interface io.atomix.utils.serializer.Serializer
Deserialize the specified bytes.
decrementAndGet() - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically decrement by one and return the updated value.
decrementAndGet() - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically decrement by one and return the updated value.
decrementAndGet() - Method in interface io.atomix.core.counter.AtomicCounter
Atomically decrement by one and return the updated value.
decrementAndGet() - Method in interface io.atomix.core.counter.DistributedCounter
Atomically decrement by one and return the updated value.
decrementAndGet(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Decrements by one the value currently associated with key, and returns the new value.
decrementAndGet(K) - Method in interface io.atomix.core.map.AtomicCounterMap
Decrements by one the value currently associated with key, and returns the new value.
decrementAndGet() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically decrement by one and return the updated value.
DEFAULT - Static variable in class io.atomix.utils.serializer.Namespace
Default Kryo namespace.
DEFAULT_BUFFER_SIZE - Static variable in class io.atomix.utils.serializer.Namespace
Default buffer size used for serialization.
DEFAULT_OPERATION_TIMEOUT_MILLIS - Static variable in interface io.atomix.primitive.DistributedPrimitive
Default timeout for primitive operations.
delete() - Method in interface io.atomix.core.map.AsyncAtomicMap
 
delete() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
 
delete() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
 
delete() - Method in class io.atomix.primitive.AbstractAsyncPrimitive
 
delete() - Method in interface io.atomix.primitive.AsyncPrimitive
Purges state associated with this primitive.
delete() - Method in interface io.atomix.primitive.proxy.ProxyClient
Deletes the proxy client.
delete() - Method in interface io.atomix.primitive.proxy.ProxySession
Closes the proxy session and deletes the service.
delete() - Method in interface io.atomix.primitive.session.SessionClient
Closes the session and deletes the service.
delete() - Method in class io.atomix.primitive.Synchronous
 
delete() - Method in interface io.atomix.primitive.SyncPrimitive
Purges state associated with this primitive.
delete() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
delete() - Method in class io.atomix.protocols.raft.partition.RaftPartition
Deletes the partition.
deleted() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Returns a boolean indicating whether the service has been deleted.
deletePrimitive(String) - Method in interface io.atomix.primitive.PrimitiveRegistry
Deletes the given distributed primitive.
descendingIterator() - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns an iterator over the elements in this set, in descending order.
descendingKeySet() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a reverse order NavigableSet view of the keys contained in this map.
descendingKeySet() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a reverse order NavigableSet view of the keys contained in this map.
descendingKeySet() - Method in interface io.atomix.core.map.DistributedNavigableMap
 
descendingMap() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a reverse order view of the mappings contained in this map.
descendingMap() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a reverse order view of the mappings contained in this map.
descendingMap() - Method in interface io.atomix.core.map.DistributedNavigableMap
 
descendingSet() - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns a reverse order view of the elements contained in this set.
deserialize(byte[]) - Method in class io.atomix.utils.serializer.Namespace
Deserializes given byte array to Object using Kryo instance in pool.
deserialize(ByteBuffer) - Method in class io.atomix.utils.serializer.Namespace
Deserializes given byte buffer to Object using Kryo instance in pool.
deserialize(InputStream) - Method in class io.atomix.utils.serializer.Namespace
Deserializes given InputStream to an Object using Kryo instance in pool.
deserialize(InputStream, int) - Method in class io.atomix.utils.serializer.Namespace
Deserializes given InputStream to an Object using Kryo instance in pool.
DistributedCollection<E> - Interface in io.atomix.core.collection
Distributed collection.
DistributedCollectionBuilder<B extends DistributedCollectionBuilder<B,C,P,E>,C extends DistributedCollectionConfig<C>,P extends DistributedCollection<E>,E> - Class in io.atomix.core.collection
Distributed collection builder.
DistributedCollectionConfig<C extends DistributedCollectionConfig<C>> - Class in io.atomix.core.collection
Distributed collection configuration.
DistributedCollectionConfig() - Constructor for class io.atomix.core.collection.DistributedCollectionConfig
 
DistributedCollectionType<E> - Class in io.atomix.core.collection
Distributed collection primitive type.
DistributedCollectionType() - Constructor for class io.atomix.core.collection.DistributedCollectionType
 
DistributedCounter - Interface in io.atomix.core.counter
Distributed version of java.util.concurrent.atomic.AtomicLong.
DistributedCounterBuilder - Class in io.atomix.core.counter
Builder for DistributedCounter.
DistributedCounterConfig - Class in io.atomix.core.counter
Distributed counter configuration.
DistributedCounterConfig() - Constructor for class io.atomix.core.counter.DistributedCounterConfig
 
DistributedCounterType - Class in io.atomix.core.counter
Distributed counter primitive type.
DistributedCounterType() - Constructor for class io.atomix.core.counter.DistributedCounterType
 
DistributedCyclicBarrier - Interface in io.atomix.core.barrier
Distributed cyclic barrier.
DistributedCyclicBarrierBuilder - Class in io.atomix.core.barrier
Distributed cyclic barrier builder.
DistributedCyclicBarrierConfig - Class in io.atomix.core.barrier
Distributed cyclic barrier configuration.
DistributedCyclicBarrierConfig() - Constructor for class io.atomix.core.barrier.DistributedCyclicBarrierConfig
 
DistributedCyclicBarrierType - Class in io.atomix.core.barrier
Distributed cyclic barrier primitive type.
DistributedCyclicBarrierType() - Constructor for class io.atomix.core.barrier.DistributedCyclicBarrierType
 
DistributedList<E> - Interface in io.atomix.core.list
Distributed list.
DistributedListBuilder<E> - Class in io.atomix.core.list
Builder for distributed queue.
DistributedListConfig - Class in io.atomix.core.list
Distributed list configuration.
DistributedListConfig() - Constructor for class io.atomix.core.list.DistributedListConfig
 
DistributedListType<E> - Class in io.atomix.core.list
Distributed list primitive type.
DistributedListType() - Constructor for class io.atomix.core.list.DistributedListType
 
DistributedLock - Interface in io.atomix.core.lock
Distributed lock primitive.
DistributedLockBuilder - Class in io.atomix.core.lock
Builder for DistributedLock.
DistributedLockConfig - Class in io.atomix.core.lock
Distributed lock configuration.
DistributedLockConfig() - Constructor for class io.atomix.core.lock.DistributedLockConfig
 
DistributedLockType - Class in io.atomix.core.lock
Distributed lock primitive type.
DistributedLockType() - Constructor for class io.atomix.core.lock.DistributedLockType
 
DistributedMap<K,V> - Interface in io.atomix.core.map
Distributed map.
DistributedMapBuilder<K,V> - Class in io.atomix.core.map
Builder for DistributedMap instances.
DistributedMapConfig - Class in io.atomix.core.map
Distributed map configuration.
DistributedMapConfig() - Constructor for class io.atomix.core.map.DistributedMapConfig
 
DistributedMapType<K,V> - Class in io.atomix.core.map
Distributed map primitive type.
DistributedMapType() - Constructor for class io.atomix.core.map.DistributedMapType
 
DistributedMultimap<K,V> - Interface in io.atomix.core.multimap
This provides a synchronous version of the functionality provided by AsyncAtomicMultimap.
DistributedMultimapBuilder<K,V> - Class in io.atomix.core.multimap
A builder class for AsyncConsistentMultimap.
DistributedMultimapConfig - Class in io.atomix.core.multimap
Consistent multimap configuration.
DistributedMultimapConfig() - Constructor for class io.atomix.core.multimap.DistributedMultimapConfig
 
DistributedMultimapType<K,V> - Class in io.atomix.core.multimap
Distributed multimap primitive type.
DistributedMultimapType() - Constructor for class io.atomix.core.multimap.DistributedMultimapType
 
DistributedMultiset<E> - Interface in io.atomix.core.multiset
Distributed multiset.
DistributedMultisetBuilder<E> - Class in io.atomix.core.multiset
Builder for distributed multiset.
DistributedMultisetConfig - Class in io.atomix.core.multiset
Distributed multiset configuration.
DistributedMultisetConfig() - Constructor for class io.atomix.core.multiset.DistributedMultisetConfig
 
DistributedMultisetType<E> - Class in io.atomix.core.multiset
Placeholder type for the distributed multiset primitive type.
DistributedMultisetType() - Constructor for class io.atomix.core.multiset.DistributedMultisetType
 
DistributedNavigableMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Distributed navigable map.
DistributedNavigableMapBuilder<K extends Comparable<K>,V> - Class in io.atomix.core.map
Builder for DistributedNavigableMap instances.
DistributedNavigableMapBuilder(String, DistributedNavigableMapConfig, PrimitiveManagementService) - Constructor for class io.atomix.core.map.DistributedNavigableMapBuilder
 
DistributedNavigableMapConfig - Class in io.atomix.core.map
Distributed tree map configuration.
DistributedNavigableMapConfig() - Constructor for class io.atomix.core.map.DistributedNavigableMapConfig
 
DistributedNavigableMapType<K extends Comparable<K>,V> - Class in io.atomix.core.map
Distributed tree map primitive type.
DistributedNavigableMapType() - Constructor for class io.atomix.core.map.DistributedNavigableMapType
 
DistributedNavigableSet<E extends Comparable<E>> - Interface in io.atomix.core.set
Distributed navigable set.
DistributedNavigableSetBuilder<E extends Comparable<E>> - Class in io.atomix.core.set
Builder for distributed navigable set.
DistributedNavigableSetConfig - Class in io.atomix.core.set
Distributed navigable set configuration.
DistributedNavigableSetConfig() - Constructor for class io.atomix.core.set.DistributedNavigableSetConfig
 
DistributedNavigableSetType<E extends Comparable<E>> - Class in io.atomix.core.set
Distributed navigable set primitive type.
DistributedNavigableSetType() - Constructor for class io.atomix.core.set.DistributedNavigableSetType
 
DistributedPrimitive - Interface in io.atomix.primitive
Interface for all distributed primitives.
DistributedQueue<E> - Interface in io.atomix.core.queue
Distributed queue.
DistributedQueueBuilder<E> - Class in io.atomix.core.queue
Builder for distributed queue.
DistributedQueueConfig - Class in io.atomix.core.queue
Distributed queue configuration.
DistributedQueueConfig() - Constructor for class io.atomix.core.queue.DistributedQueueConfig
 
DistributedQueueType<E> - Class in io.atomix.core.queue
Distributed queue primitive type.
DistributedQueueType() - Constructor for class io.atomix.core.queue.DistributedQueueType
 
DistributedSemaphore - Class in io.atomix.core.semaphore
Distributed semaphore.
DistributedSemaphore() - Constructor for class io.atomix.core.semaphore.DistributedSemaphore
 
DistributedSemaphoreBuilder - Class in io.atomix.core.semaphore
Distributed semaphore builder.
DistributedSemaphoreConfig - Class in io.atomix.core.semaphore
Semaphore configuration.
DistributedSemaphoreConfig() - Constructor for class io.atomix.core.semaphore.DistributedSemaphoreConfig
 
DistributedSemaphoreType - Class in io.atomix.core.semaphore
Distributed semaphore primitive type.
DistributedSemaphoreType() - Constructor for class io.atomix.core.semaphore.DistributedSemaphoreType
 
DistributedSet<E> - Interface in io.atomix.core.set
A distributed collection designed for holding unique elements.
DistributedSetBuilder<E> - Class in io.atomix.core.set
Builder for distributed set.
DistributedSetConfig - Class in io.atomix.core.set
Distributed set configuration.
DistributedSetConfig() - Constructor for class io.atomix.core.set.DistributedSetConfig
 
DistributedSetType<E> - Class in io.atomix.core.set
Distributed set primitive type.
DistributedSetType() - Constructor for class io.atomix.core.set.DistributedSetType
 
DistributedSortedMap<K extends Comparable<K>,V> - Interface in io.atomix.core.map
Distributed sorted map.
DistributedSortedMapBuilder<K extends Comparable<K>,V> - Class in io.atomix.core.map
Builder for DistributedSortedMap instances.
DistributedSortedMapBuilder(String, DistributedSortedMapConfig, PrimitiveManagementService) - Constructor for class io.atomix.core.map.DistributedSortedMapBuilder
 
DistributedSortedMapConfig - Class in io.atomix.core.map
Distributed sorted map configuration.
DistributedSortedMapConfig() - Constructor for class io.atomix.core.map.DistributedSortedMapConfig
 
DistributedSortedMapType<K extends Comparable<K>,V> - Class in io.atomix.core.map
Distributed sorted map primitive type.
DistributedSortedMapType() - Constructor for class io.atomix.core.map.DistributedSortedMapType
 
DistributedSortedSet<E extends Comparable<E>> - Interface in io.atomix.core.set
Distributed sorted set.
DistributedSortedSetBuilder<E extends Comparable<E>> - Class in io.atomix.core.set
Builder for distributed sorted set.
DistributedSortedSetConfig - Class in io.atomix.core.set
Distributed sorted set configuration.
DistributedSortedSetConfig() - Constructor for class io.atomix.core.set.DistributedSortedSetConfig
 
DistributedSortedSetType<E extends Comparable<E>> - Class in io.atomix.core.set
Distributed sorted set primitive type.
DistributedSortedSetType() - Constructor for class io.atomix.core.set.DistributedSortedSetType
 
DistributedValue<V> - Interface in io.atomix.core.value
Distributed version of java.util.concurrent.atomic.AtomicReference.
DistributedValueBuilder<V> - Class in io.atomix.core.value
Builder for constructing new DistributedValue instances.
DistributedValueConfig - Class in io.atomix.core.value
Distributed value configuration.
DistributedValueConfig() - Constructor for class io.atomix.core.value.DistributedValueConfig
 
DistributedValueType<V> - Class in io.atomix.core.value
Distributed value primitive type.
DistributedValueType() - Constructor for class io.atomix.core.value.DistributedValueType
 
DnsDiscoveryBuilder - Class in io.atomix.cluster.discovery
DNS discovery builder.
DnsDiscoveryBuilder() - Constructor for class io.atomix.cluster.discovery.DnsDiscoveryBuilder
 
DnsDiscoveryConfig - Class in io.atomix.cluster.discovery
DNS discovery configuration.
DnsDiscoveryConfig() - Constructor for class io.atomix.cluster.discovery.DnsDiscoveryConfig
 
DnsDiscoveryProvider - Class in io.atomix.cluster.discovery
Cluster membership provider that uses DNS SRV lookups.
DnsDiscoveryProvider(String) - Constructor for class io.atomix.cluster.discovery.DnsDiscoveryProvider
 
DnsDiscoveryProvider.Type - Class in io.atomix.cluster.discovery
DNS node discovery provider type.
DocumentException - Exception in io.atomix.core.tree
Exceptions for use by the DocumentTree and DocumentPath.
DocumentException() - Constructor for exception io.atomix.core.tree.DocumentException
 
DocumentException(String) - Constructor for exception io.atomix.core.tree.DocumentException
 
DocumentException(String, Throwable) - Constructor for exception io.atomix.core.tree.DocumentException
 
DocumentException(Throwable) - Constructor for exception io.atomix.core.tree.DocumentException
 
DocumentException.Interrupted - Exception in io.atomix.core.tree
DocumentTree operation interrupted.
DocumentException.Timeout - Exception in io.atomix.core.tree
DocumentTree operation timeout.
DocumentPath - Class in io.atomix.core.tree
Unique key for nodes in the AtomicDocumentTree.
DocumentPath(String, DocumentPath) - Constructor for class io.atomix.core.tree.DocumentPath
Constructs a new document path.
DocumentTreeEvent<V> - Class in io.atomix.core.tree
A document tree modification event.
DocumentTreeEvent(DocumentTreeEvent.Type, DocumentPath, Optional<Versioned<V>>, Optional<Versioned<V>>) - Constructor for class io.atomix.core.tree.DocumentTreeEvent
Constructs a new DocumentTreeEvent.
DocumentTreeEvent.Type - Enum in io.atomix.core.tree
Nature of document tree node change.
DocumentTreeEventListener<V> - Interface in io.atomix.core.tree
A listener for DocumentTreeEvent.
DocumentTreeNode<V> - Interface in io.atomix.core.tree
A DocumentTree node.
drainPermits() - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Acquires and returns all permits that are immediately available.
drainPermits() - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Acquires and returns all permits that are immediately available.
drainPermits() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Acquires and returns all permits that are immediately available.
drainPermits() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 

E

element() - Method in class io.atomix.core.collection.CollectionEvent
Returns the entry this event concerns.
element() - Method in interface io.atomix.core.queue.AsyncDistributedQueue
Retrieves, but does not remove, the head of this queue.
element() - Method in class io.atomix.primitive.protocol.set.SetDelegateEvent
Returns the set element.
elementSet() - Method in interface io.atomix.core.multiset.AsyncDistributedMultiset
Returns the set of distinct elements contained in this multiset.
elementSet() - Method in interface io.atomix.core.multiset.DistributedMultiset
 
encode(T) - Method in interface io.atomix.utils.serializer.Serializer
Serialize the specified object.
enter(GroupMember) - Method in interface io.atomix.primitive.partition.PrimaryElection
Enters the primary election.
entries() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns a collection of each key-value pair in this map.
entries() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns a collection of each key-value pair in this map.
entries() - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns a collection of each key-value pair in this map.
entries() - Method in interface io.atomix.core.multimap.DistributedMultimap
Returns a collection of each key-value pair in this map.
entrySet() - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns the set of entries contained in this map.
entrySet() - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns a Set view of the mappings contained in this map.
entrySet() - Method in interface io.atomix.core.map.AtomicMap
Returns the set of entries contained in this map.
entrySet() - Method in interface io.atomix.core.map.DistributedMap
 
entrySet() - Method in interface io.atomix.core.multiset.AsyncDistributedMultiset
Returns a view of the contents of this multiset, grouped into Multiset.Entry instances, each providing an element of the multiset and the count of that element.
entrySet() - Method in interface io.atomix.core.multiset.DistributedMultiset
 
Epoch - Class in io.atomix.utils.time
Epoch.
Epoch(long) - Constructor for class io.atomix.utils.time.Epoch
Creates a new epoch timestamp.
equals(Object) - Method in class io.atomix.cluster.ClusterMembershipEvent
 
equals(Object) - Method in class io.atomix.cluster.Member
 
equals(Object) - Method in class io.atomix.cluster.Node
 
equals(Object) - Method in class io.atomix.cluster.NodeId
 
equals(Object) - Method in class io.atomix.cluster.protocol.GroupMembershipEvent
 
equals(Object) - Method in class io.atomix.core.election.Leader
 
equals(Object) - Method in class io.atomix.core.election.Leadership
 
equals(Object) - Method in class io.atomix.core.election.LeadershipEvent
 
equals(Object) - Method in class io.atomix.core.map.AtomicMapEvent
 
equals(Object) - Method in class io.atomix.core.map.MapEvent
 
equals(Object) - Method in class io.atomix.core.multimap.AtomicMultimapEvent
 
equals(Object) - Method in class io.atomix.core.multimap.MultimapEvent
 
equals(Object) - Method in class io.atomix.core.transaction.ParticipantInfo
 
equals(Object) - Method in class io.atomix.core.transaction.TransactionLog
 
equals(Object) - Method in class io.atomix.core.tree.DocumentPath
 
equals(Object) - Method in class io.atomix.core.value.AtomicValueEvent
 
equals(Object) - Method in class io.atomix.core.value.ValueEvent
 
equals(Object) - Method in class io.atomix.primitive.event.PrimitiveEvent
 
equals(Object) - Method in class io.atomix.primitive.operation.PrimitiveOperation
 
equals(Object) - Method in class io.atomix.primitive.partition.GroupMember
 
equals(Object) - Method in class io.atomix.primitive.partition.PartitionId
 
equals(Object) - Method in class io.atomix.primitive.partition.PartitionMetadata
 
equals(Object) - Method in class io.atomix.primitive.partition.PrimaryTerm
 
equals(Object) - Method in class io.atomix.primitive.PrimitiveInfo
 
equals(Object) - Method in class io.atomix.primitive.session.SessionMetadata
 
equals(Object) - Method in class io.atomix.protocols.raft.session.RaftSession
 
equals(Object) - Method in class io.atomix.utils.AbstractIdentifier
Compares two device key identifiers for equality.
equals(Object) - Method in class io.atomix.utils.net.Address
 
equals(Object) - Method in class io.atomix.utils.time.LogicalTimestamp
 
equals(Object) - Method in class io.atomix.utils.time.MultiValuedTimestamp
 
equals(Object) - Method in interface io.atomix.utils.time.Timestamp
 
equals(Object) - Method in class io.atomix.utils.time.VectorTimestamp
 
equals(Object) - Method in class io.atomix.utils.time.Version
 
equals(Object) - Method in class io.atomix.utils.time.Versioned
 
equals(Object) - Method in class io.atomix.utils.time.WallClockTimestamp
 
equals(Object) - Method in class io.atomix.utils.Version
 
Event - Annotation Type in io.atomix.primitive.event
Annotates an event method.
event(EventType) - Static method in class io.atomix.primitive.event.PrimitiveEvent
Creates a new primitive event.
event(EventType, byte[]) - Static method in class io.atomix.primitive.event.PrimitiveEvent
Creates a new primitive event.
Event<T,S> - Interface in io.atomix.utils.event
Abstraction of an of a time-stamped event pertaining to an arbitrary subject.
event(E) - Method in interface io.atomix.utils.event.EventListener
Reacts to the specified event.
EventFilter<E extends Event> - Interface in io.atomix.utils.event
Entity capable of filtering events.
EventListener<E extends Event> - Interface in io.atomix.utils.event
Entity capable of receiving events.
Events - Class in io.atomix.primitive.event
Event utilities.
EventSink<E extends Event> - Interface in io.atomix.utils.event
Abstraction of an event sink capable of processing the specified event types.
EventType - Interface in io.atomix.primitive.event
Raft event identifier.
evict(T) - Method in interface io.atomix.core.election.AsyncLeaderElection
Attempts to evict a node from all leadership elections it is registered for.
evict(T) - Method in interface io.atomix.core.election.AsyncLeaderElector
Attempts to evict a node from all leadership elections it is registered for.
evict(T) - Method in interface io.atomix.core.election.LeaderElection
Attempts to evict a node from all leadership elections it is registered for.
evict(T) - Method in interface io.atomix.core.election.LeaderElector
Attempts to evict a node from all leadership elections it is registered for.
execute(PrimitiveOperation) - Method in interface io.atomix.primitive.session.SessionClient
Executes an operation to the cluster.
execute(PrimitiveOperation) - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
executeCommand(long, long, long, RaftSession, PrimitiveOperation) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Executes the given command on the state machine.
executeQuery(long, long, long, RaftSession, PrimitiveOperation) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Executes the given query on the state machine.
expire(SessionId) - Method in class io.atomix.primitive.service.AbstractPrimitiveService
 
expire(SessionId) - Method in interface io.atomix.primitive.service.PrimitiveService
Expires the session with the given identifier.
expire() - Method in class io.atomix.protocols.raft.session.RaftSession
Expires the session.

F

first() - Method in interface io.atomix.core.set.AsyncDistributedSortedSet
Returns the first (lowest) element currently in this set.
firstEntry() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the least key in this map, or null if the map is empty.
firstEntry() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the least key in this map, or null if the map is empty.
firstEntry() - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the lowest key in the map.
firstKey() - Method in interface io.atomix.core.map.AsyncAtomicSortedMap
Returns the first (lowest) key currently in this map.
firstKey() - Method in interface io.atomix.core.map.AsyncDistributedSortedMap
Returns the first (lowest) key currently in this map.
firstKey() - Method in interface io.atomix.core.map.AtomicSortedMap
Returns the lowest key in the map.
FLOATING_ID - Static variable in class io.atomix.utils.serializer.Namespace
ID to use if this KryoNamespace does not define registration id.
floor(E) - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns the greatest element in this set less than or equal to the given element, or null if there is no such element.
floorEntry(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the greatest key less than or equal to the given key, or null if there is no such key.
floorEntry(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the greatest key less than or equal to the given key, or null if there is no such key.
floorEntry(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the greatest key less than or equal to key.
floorKey(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns the greatest key less than or equal to the given key, or null if there is no such key.
floorKey(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns the greatest key less than or equal to the given key, or null if there is no such key.
floorKey(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the highest key less than or equal to key.
from(String) - Static method in class io.atomix.cluster.MemberId
Creates a new cluster node identifier from the specified string.
from(String) - Static method in class io.atomix.cluster.NodeId
Creates a new cluster node identifier from the specified string.
from(String) - Static method in class io.atomix.core.transaction.TransactionId
Creates a new transaction identifier.
from(String) - Static method in class io.atomix.core.tree.DocumentPath
Creates a new DocumentPath from a period delimited path string.
from(String...) - Static method in class io.atomix.core.tree.DocumentPath
Creates a new DocumentPath from a list of path elements.
from(List<String>) - Static method in class io.atomix.core.tree.DocumentPath
Creates a new root DocumentPath from a list of path elements.
from(List<String>, String) - Static method in class io.atomix.core.tree.DocumentPath
Creates a new root DocumentPath from a list of path elements.
from(String) - Static method in interface io.atomix.primitive.event.EventType
Creates a new Raft event identifier.
from(String, OperationType) - Static method in interface io.atomix.primitive.operation.OperationId
Returns a new operation identifier.
from(String) - Static method in class io.atomix.primitive.partition.MemberGroupId
Creates a new member group identifier.
from(String, int) - Static method in class io.atomix.primitive.partition.PartitionId
Creates a partition identifier from an integer.
from(long) - Static method in class io.atomix.primitive.PrimitiveId
Creates a snapshot ID from the given number.
from(String) - Static method in class io.atomix.primitive.PrimitiveId
Creates a snapshot ID from the given string.
from(long) - Static method in class io.atomix.primitive.session.SessionId
Returns a new session ID from the given identifier.
from(String) - Static method in class io.atomix.utils.net.Address
Returns the address from the given host:port string.
from(String, int) - Static method in class io.atomix.utils.net.Address
Returns an address for the given host/port.
from(int) - Static method in class io.atomix.utils.net.Address
Returns an address for the local host and the given port.
from(long) - Static method in class io.atomix.utils.time.WallClockTimestamp
Returns a new wall clock timestamp for the given unix timestamp.
from(String) - Static method in class io.atomix.utils.Version
Returns a new version from the given version string.
from(int, int, int, String) - Static method in class io.atomix.utils.Version
Returns a new version from the given parts.

G

Generics - Class in io.atomix.utils
Generics utility.
get() - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Returns the current value of the counter without modifying it.
get() - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Returns the current value of the counter without modifying it.
get() - Method in interface io.atomix.core.counter.AtomicCounter
Returns the current value of the counter without modifying it.
get() - Method in interface io.atomix.core.counter.DistributedCounter
Returns the current value of the counter without modifying it.
get(int) - Method in interface io.atomix.core.list.AsyncDistributedList
Returns the element at the specified position in this list.
get(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Returns the value associated with key, or zero if there is no value associated with key.
get(K) - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns the value (and version) to which the specified key is mapped, or null if this map contains no mapping for the key.
get(K) - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(K) - Method in interface io.atomix.core.map.AtomicCounterMap
Returns the value associated with key, or zero if there is no value associated with key.
get(K) - Method in interface io.atomix.core.map.AtomicMap
Returns the value (and version) to which the specified key is mapped, or null if this map contains no mapping for the key.
get(K) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns a collection of values associated with the specified key, if the key is not in the map it will return an empty collection.
get(K) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns a collection of values associated with the specified key, if the key is not in the map it will return an empty collection.
get(K) - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns a collection of values associated with the specified key, if the key is not in the map it will return an empty collection.
get(K) - Method in interface io.atomix.core.transaction.AsyncTransactionalMap
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(K) - Method in interface io.atomix.core.transaction.TransactionalMap
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(String) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Returns the value of the tree node at specified path.
get(DocumentPath) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Returns the value of the tree node at specified path.
get(String) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Returns a document tree node.
get(DocumentPath) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Returns a document tree node.
get() - Method in interface io.atomix.core.value.AsyncAtomicValue
Gets the current value.
get() - Method in interface io.atomix.core.value.AsyncDistributedValue
Gets the current value.
get() - Method in interface io.atomix.core.value.AtomicValue
Gets the current value.
get() - Method in interface io.atomix.core.value.DistributedValue
Gets the current value.
get() - Method in class io.atomix.primitive.PrimitiveBuilder
Gets or builds a singleton instance of the primitive.
get() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Returns the counter value.
get() - Method in interface io.atomix.primitive.protocol.value.ValueDelegate
Gets the current value.
get(E) - Method in interface io.atomix.protocols.gossip.TimestampProvider
Returns the timestamp for the given entry.
getActiveTransactions() - Method in interface io.atomix.core.transaction.TransactionService
Returns the set of active transactions.
getAddress() - Method in class io.atomix.cluster.MemberConfig
Returns the member address.
getAddress() - Method in class io.atomix.cluster.NodeConfig
Returns the node address.
getAllPresent(Iterable<K>) - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns a map of the values associated with the keys in this map.
getAllPresent(Iterable<K>) - Method in interface io.atomix.core.map.AtomicMap
Returns a map of the values associated with the keys in this map.
getAndAdd(long) - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically adds the given value to the current value.
getAndAdd(long) - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically adds the given value to the current value.
getAndAdd(long) - Method in interface io.atomix.core.counter.AtomicCounter
Atomically adds the given value to the current value.
getAndAdd(long) - Method in interface io.atomix.core.counter.DistributedCounter
Atomically adds the given value to the current value.
getAndAdd(K, long) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Adds delta to the value currently associated with key, and returns the old value.
getAndAdd(K, long) - Method in interface io.atomix.core.map.AtomicCounterMap
Adds delta to the value currently associated with key, and returns the old value.
getAndAdd(long) - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically adds the given value to the current value.
getAndDecrement() - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically increment by one and return the previous value.
getAndDecrement() - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically decrement by one and return the previous value.
getAndDecrement() - Method in interface io.atomix.core.counter.AtomicCounter
Atomically decrement by one and return the previous value.
getAndDecrement() - Method in interface io.atomix.core.counter.DistributedCounter
Atomically decrement by one and return the previous value.
getAndDecrement(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Decrements by one the value currently associated with key, and returns the old value.
getAndDecrement(K) - Method in interface io.atomix.core.map.AtomicCounterMap
Decrements by one the value currently associated with key, and returns the old value.
getAndDecrement() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically decrement by one and return the previous value.
getAndIncrement() - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically increment by one and return the previous value.
getAndIncrement() - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically increment by one and return the previous value.
getAndIncrement() - Method in interface io.atomix.core.counter.AtomicCounter
Atomically increment by one and return the previous value.
getAndIncrement() - Method in interface io.atomix.core.counter.DistributedCounter
Atomically increment by one and return the previous value.
getAndIncrement(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Increments by one the value currently associated with key, and returns the old value.
getAndIncrement(K) - Method in interface io.atomix.core.map.AtomicCounterMap
Increments by one the value currently associated with key, and returns the old value.
getAndIncrement() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically increment by one and return the previous value.
getAndSet(V) - Method in interface io.atomix.core.value.AsyncAtomicValue
Atomically sets to the given value and returns the old value.
getAndSet(V) - Method in interface io.atomix.core.value.AsyncDistributedValue
Atomically sets to the given value and returns the old value.
getAndSet(V) - Method in interface io.atomix.core.value.AtomicValue
Atomically sets to the given value and returns the old value.
getAndSet(V) - Method in interface io.atomix.core.value.DistributedValue
Atomically sets to the given value and returns the old value.
getAndSet(V) - Method in interface io.atomix.primitive.protocol.value.ValueDelegate
Atomically sets to the given value and returns the old value.
getAntiEntropyInterval() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns the anti-entropy advertisement interval.
getAsync() - Method in class io.atomix.primitive.PrimitiveBuilder
Gets or builds a singleton instance of the primitive asynchronously.
getAtomicCounter(String) - Method in class io.atomix.core.Atomix
 
getAtomicCounter(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicCounterMap(String) - Method in class io.atomix.core.Atomix
 
getAtomicCounterMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicDocumentTree(String) - Method in class io.atomix.core.Atomix
 
getAtomicDocumentTree(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicIdGenerator(String) - Method in class io.atomix.core.Atomix
 
getAtomicIdGenerator(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicLock(String) - Method in class io.atomix.core.Atomix
 
getAtomicLock(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicMap(String) - Method in class io.atomix.core.Atomix
 
getAtomicMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicMultimap(String) - Method in class io.atomix.core.Atomix
 
getAtomicMultimap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicNavigableMap(String) - Method in class io.atomix.core.Atomix
 
getAtomicNavigableMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicSemaphore(String) - Method in class io.atomix.core.Atomix
 
getAtomicSemaphore(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicSortedMap(String) - Method in class io.atomix.core.Atomix
 
getAtomicSortedMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getAtomicValue(String) - Method in class io.atomix.core.Atomix
 
getAtomicValue(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getBackups() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the number of backups.
getBroadcastInterval() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryConfig
Returns the broadcast interval.
getBroadcastInterval() - Method in class io.atomix.cluster.MembershipConfig
Returns the reachability broadcast interval.
getBroadcastService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster broadcast service.
getBroadcastService() - Method in interface io.atomix.cluster.BootstrapService
Returns the cluster broadcast service
getCacheConfig() - Method in class io.atomix.core.cache.CachedPrimitiveConfig
Returns the cache configuration.
getChildren(String) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Returns the children of node at specified path in the form of a mapping from child name to child value.
getChildren(DocumentPath) - Method in interface io.atomix.core.tree.AsyncAtomicDocumentTree
Returns the children of node at specified path in the form of a mapping from child name to child value.
getChildren(String) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Returns the child values for this node.
getChildren(DocumentPath) - Method in interface io.atomix.core.tree.AtomicDocumentTree
Returns the child values for this node.
getClient() - Method in interface io.atomix.primitive.partition.Partition
Returns the partition client.
getClient() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
getClient() - Method in class io.atomix.protocols.raft.partition.RaftPartition
 
getClusterConfig() - Method in class io.atomix.core.AtomixConfig
Returns the cluster configuration.
getClusterId() - Method in class io.atomix.cluster.ClusterConfig
Returns the cluster identifier.
getCommand(long) - Method in class io.atomix.protocols.raft.session.RaftSession
Gets a pending command.
getCommands() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the collection of pending commands.
getCommandSequence() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session operation sequence number.
getCommunicationService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster communication service.
getCommunicationService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the cluster communication service.
getCommunicationStrategy() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the client communication strategy.
getCompactionConfig() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
Returns the compaction configuration.
getConfig(String, PrimitiveType) - Method in interface io.atomix.primitive.config.ConfigService
Returns the registered configuration for the given primitive.
getConfigService() - Method in class io.atomix.core.Atomix
Returns the primitive configuration service.
getConnectTimeout() - Method in class io.atomix.cluster.messaging.MessagingConfig
Returns the Netty connection timeout.
getConsistency() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the consistency level.
getCounter(String) - Method in class io.atomix.core.Atomix
 
getCounter(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getCyclicBarrier(String) - Method in class io.atomix.core.Atomix
 
getCyclicBarrier(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getDataGroup() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the data partition group name.
getDataGroup() - Method in class io.atomix.core.profile.DataGridProfileConfig
Returns the data partition group name.
getDataPath() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the data file path.
getDirectory(String) - Method in class io.atomix.protocols.raft.partition.RaftStorageConfig
Returns the partition data directory.
getDiscoveryConfig() - Method in class io.atomix.cluster.ClusterConfig
Returns the node discovery provider configuration.
getElectionFor(PartitionId) - Method in interface io.atomix.primitive.partition.PrimaryElectionService
Returns the primary election for the given partition identifier.
getElectionService() - Method in interface io.atomix.primitive.partition.PartitionManagementService
Returns the primary election service.
getElementType() - Method in class io.atomix.core.collection.DistributedCollectionConfig
Returns the element type.
getEventIndex() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session event index.
getEventMap(Class<?>) - Static method in class io.atomix.primitive.event.Events
Returns the collection of events provided by the given service interface.
getEventService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster event service.
getEventService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the cluster event service.
getExecutorService() - Method in class io.atomix.core.Atomix
Returns the core Atomix executor service.
getExecutorService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the primitive thread pool.
getExtraTypes() - Method in class io.atomix.core.collection.DistributedCollectionConfig
Returns the extra serializable types.
getExtraTypes() - Method in class io.atomix.core.map.AtomicCounterMapConfig
Returns the extra serializable types.
getExtraTypes() - Method in class io.atomix.core.map.MapConfig
Returns the extra serializable types.
getExtraTypes() - Method in class io.atomix.core.multimap.MultimapConfig
Returns the extra serializable types.
getExtraTypes() - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
Returns the extra serializable types.
getExtraTypes() - Method in class io.atomix.core.value.ValueConfig
Returns the extra serializable types.
getFailureThreshold() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
Deprecated.
getFailureThreshold() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryConfig
Deprecated.
getFailureThreshold() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocolConfig
Returns the failure detector threshold.
getFailureTimeout() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
Deprecated.
getFailureTimeout() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryConfig
Returns the base failure timeout.
getFailureTimeout() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocolConfig
Returns the base failure timeout.
getFailureTimeout() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns the base failure timeout.
getFreeDiskBuffer() - Method in class io.atomix.protocols.raft.partition.RaftCompactionConfig
Returns the free disk buffer.
getFreeMemoryBuffer() - Method in class io.atomix.protocols.raft.partition.RaftCompactionConfig
Returns the free memory buffer.
getGenericClassType(Object, Class<?>, int) - Static method in class io.atomix.utils.Generics
Returns the generic type at the given position for the given class.
getGenericInterfaceType(Object, Class<?>, int) - Static method in class io.atomix.utils.Generics
Returns the generic type at the given position for the given interface.
getGossipFanout() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns the gossip fanout.
getGossipInterval() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns the gossip interval.
getGossipInterval() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns the gossip interval.
getGossipInterval() - Method in class io.atomix.protocols.gossip.CrdtProtocolConfig
Returns the gossip interval.
getGroup() - Method in class io.atomix.cluster.MulticastConfig
Returns the multicast group.
getGroup() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the partition group.
getGroup() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the partition group.
getGroupType(String) - Method in interface io.atomix.primitive.partition.PartitionGroupTypeRegistry
Returns the partition group type with the given name.
getGroupTypes() - Method in interface io.atomix.primitive.partition.PartitionGroupTypeRegistry
Returns the collection of partition group type configurations.
getHeartbeatInterval() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
Deprecated.
getHeartbeatInterval() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocolConfig
Returns the heartbeat interval.
getHost() - Method in class io.atomix.cluster.MemberConfig
Returns the member host.
getId() - Method in class io.atomix.cluster.MemberConfig
Returns the member identifier.
getId() - Method in class io.atomix.cluster.NodeConfig
Returns the node identifier.
getId() - Method in class io.atomix.utils.serializer.NamespaceTypeConfig
Returns the type identifier.
getInterfaces() - Method in class io.atomix.cluster.messaging.MessagingConfig
Returns the local interfaces to which to bind the node.
getIsolation() - Method in class io.atomix.core.transaction.TransactionConfig
Returns the transaction isolation level.
getKeyStore() - Method in class io.atomix.cluster.messaging.TlsConfig
Returns the key store path.
getKeyStorePassword() - Method in class io.atomix.cluster.messaging.TlsConfig
Returns the key store password.
getKeyType() - Method in class io.atomix.core.map.AtomicCounterMapConfig
Returns the key type.
getKeyType() - Method in class io.atomix.core.map.MapConfig
Returns the key type.
getKeyType() - Method in class io.atomix.core.multimap.MultimapConfig
Returns the key type.
getLastApplied() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session index.
getLastCompleted() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the index of the highest event acked for the session.
getLastUpdated() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session update timestamp.
getLeader() - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns the current cluster leader.
getLeaderElection(String) - Method in class io.atomix.core.Atomix
 
getLeaderElection(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getLeaderElector(String) - Method in class io.atomix.core.Atomix
 
getLeaderElector(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getLeadership() - Method in interface io.atomix.core.election.AsyncLeaderElection
Returns the Leadership for the specified topic.
getLeadership(String) - Method in interface io.atomix.core.election.AsyncLeaderElector
Returns the Leadership for the specified topic.
getLeadership() - Method in interface io.atomix.core.election.LeaderElection
Returns the Leadership for the specified topic.
getLeadership(String) - Method in interface io.atomix.core.election.LeaderElector
Returns the Leadership for the specified topic.
getLeaderships() - Method in interface io.atomix.core.election.AsyncLeaderElector
Returns the current Leaderships for all topics.
getLeaderships() - Method in interface io.atomix.core.election.LeaderElector
Returns the current Leaderships for all topics.
getLevel() - Method in class io.atomix.protocols.raft.partition.RaftStorageConfig
Returns the partition storage level.
getList(String) - Method in class io.atomix.core.Atomix
 
getList(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getLocalMember() - Method in interface io.atomix.cluster.ClusterMembershipService
Returns the local member.
getLocalTimestamp() - Method in class io.atomix.utils.time.VectorClock
Returns the local logical timestamp.
getLock(String) - Method in class io.atomix.core.Atomix
 
getLock(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getManagementGroup() - Method in class io.atomix.core.AtomixConfig
Returns the system management partition group.
getManagementGroup() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the management partition group name.
getManagementGroup() - Method in class io.atomix.core.profile.DataGridProfileConfig
Returns the management partition group name.
getMap(String) - Method in class io.atomix.core.Atomix
 
getMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getMaxEntrySize() - Method in class io.atomix.protocols.raft.partition.RaftStorageConfig
Returns the maximum entry size.
getMaxRetries() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the maximum allowed number of retries.
getMaxRetries() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the maximum allowed number of retries.
getMaxTimeout() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the maximum session timeout.
getMember(String) - Method in interface io.atomix.cluster.ClusterMembershipService
Returns the specified member node.
getMember(MemberId) - Method in interface io.atomix.cluster.ClusterMembershipService
Returns the specified member.
getMember(Address) - Method in interface io.atomix.cluster.ClusterMembershipService
Returns a member by address.
getMember(MemberId) - Method in interface io.atomix.cluster.protocol.GroupMembershipProtocol
Returns the specified member.
getMember(MemberId) - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol
 
getMember(MemberId) - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol
 
getMemberGroup(Member) - Method in interface io.atomix.primitive.partition.MemberGroupService
Returns the group for the given node.
getMemberGroupProvider() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroupConfig
Returns the member group provider.
getMemberGroups(Collection<Member>) - Method in interface io.atomix.primitive.partition.MemberGroupProvider
Creates member groups from the given list of nodes.
getMemberGroups() - Method in interface io.atomix.primitive.partition.MemberGroupService
Returns the collection of member groups.
getMembers() - Method in interface io.atomix.cluster.ClusterMembershipService
Returns the set of current cluster members.
getMembers() - Method in interface io.atomix.cluster.protocol.GroupMembershipProtocol
Returns the set of current cluster members.
getMembers() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol
 
getMembers() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol
 
getMembers() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the consensus members.
getMembers() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
Returns the set of members in the partition group.
getMembers() - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns the set of known members in the cluster.
getMembership(String) - Method in interface io.atomix.primitive.partition.PartitionGroupMembershipService
Returns the members for the given group.
getMembershipConfig() - Method in class io.atomix.cluster.ClusterConfig
Deprecated.
since 3.1
getMemberships() - Method in interface io.atomix.primitive.partition.PartitionGroupMembershipService
Returns the membership for all partition groups.
getMembershipService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster membership service.
getMembershipService() - Method in interface io.atomix.primitive.partition.PartitionManagementService
Returns the cluster service.
getMembershipService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the cluster service.
getMessagingConfig() - Method in class io.atomix.cluster.ClusterConfig
Returns the cluster messaging configuration.
getMessagingService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster messaging service.
getMessagingService() - Method in interface io.atomix.cluster.BootstrapService
Returns the cluster messaging service.
getMessagingService() - Method in interface io.atomix.primitive.partition.PartitionManagementService
Returns the cluster messaging service.
getMethodMap(Class<?>) - Static method in class io.atomix.primitive.event.Events
Returns the collection of events provided by the given service interface.
getMethodMap(Class<?>) - Static method in class io.atomix.primitive.operation.Operations
Returns the collection of operations provided by the given service interface.
getMinTimeout() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the minimum session timeout.
getMulticastConfig() - Method in class io.atomix.cluster.ClusterConfig
Returns the multicast configuration.
getMultimap(String) - Method in class io.atomix.core.Atomix
 
getMultimap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getMultiset(String) - Method in class io.atomix.core.Atomix
 
getMultiset(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getName() - Method in class io.atomix.primitive.config.PrimitiveConfig
 
getName() - Method in class io.atomix.primitive.partition.PartitionGroupConfig
 
getName() - Method in interface io.atomix.utils.config.NamedConfig
Returns the configuration name.
getName() - Method in class io.atomix.utils.serializer.NamespaceConfig
Returns the serializer name.
getNamespaceConfig() - Method in class io.atomix.primitive.config.PrimitiveConfig
Returns the serializer configuration.
getNavigableMap(String) - Method in class io.atomix.core.Atomix
 
getNavigableMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getNavigableSet(String) - Method in class io.atomix.core.Atomix
 
getNavigableSet(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getNodeConfig() - Method in class io.atomix.cluster.ClusterConfig
Returns the local member configuration.
getNodes() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
Returns the configured bootstrap nodes.
getNodes() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
getNodes() - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider
 
getNodes() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
getNodes() - Method in interface io.atomix.cluster.discovery.NodeDiscoveryProvider
Returns the set of active nodes.
getNodes() - Method in interface io.atomix.cluster.discovery.NodeDiscoveryService
Returns the set of active nodes.
getNodeType() - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
Returns the node type.
getNumberWaiting() - Method in interface io.atomix.core.barrier.AsyncDistributedCyclicBarrier
Returns the number of parties currently waiting at the barrier.
getNumberWaiting() - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
Returns the number of parties currently waiting at the barrier.
getOperationMap(Class<?>) - Static method in class io.atomix.primitive.operation.Operations
Returns the collection of operations provided by the given service interface.
getOrDefault(K, V) - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns the value (and version) to which the specified key is mapped, or the provided default value if this map contains no mapping for the key.
getOrDefault(K, V) - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns the value to which the specified key is mapped, or defaultValue if this map contains no mapping for the key.
getOrDefault(K, V) - Method in interface io.atomix.core.map.AtomicMap
Returns the value (and version) to which the specified key is mapped, or the provided default value if this map contains no mapping for the key.
getParties() - Method in interface io.atomix.core.barrier.AsyncDistributedCyclicBarrier
Returns the number of parties required to trip this barrier.
getParties() - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
Returns the number of parties required to trip this barrier.
getPartition(PartitionId) - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns a partition by ID.
getPartition(String) - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns the partition for the given key.
getPartition(PartitionId) - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the proxy with the given identifier.
getPartition(String) - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the partition proxy for the given key.
getPartition(Object) - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the partition proxy for the given key.
getPartition(PartitionId) - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
getPartition(PartitionId) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
getPartitioner() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the protocol partitioner.
getPartitioner() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the protocol partitioner.
getPartitionGroup(String) - Method in interface io.atomix.primitive.partition.PartitionService
Returns a partition group by name.
getPartitionGroup(PrimitiveProtocol.Type) - Method in interface io.atomix.primitive.partition.PartitionService
Returns the first partition group that matches the given primitive type.
getPartitionGroup(ProxyProtocol) - Method in interface io.atomix.primitive.partition.PartitionService
Returns the first partition group that matches the given primitive protocol.
getPartitionGroups() - Method in class io.atomix.core.AtomixConfig
Returns the partition group configurations.
getPartitionGroups() - Method in interface io.atomix.primitive.partition.PartitionService
Returns a collection of all partition groups.
getPartitionGroupTypeRegistry() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the partition group type registry.
getPartitionId(String) - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the partition ID for the given key.
getPartitionId(Object) - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the partition ID for the given key.
getPartitionIds() - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns a sorted list of partition IDs.
getPartitionIds() - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the collection of all partition IDs.
getPartitionIds() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
getPartitionIds() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
getPartitions() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the number of data partitions to configure.
getPartitions() - Method in class io.atomix.core.profile.DataGridProfileConfig
Returns the number of data partitions to configure.
getPartitions() - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns a collection of all partitions.
getPartitions() - Method in class io.atomix.primitive.partition.PartitionGroupConfig
Returns the number of partitions in the group.
getPartitions() - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the collection of all partition proxies.
getPartitions() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
getPartitions() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
getPartitionService() - Method in class io.atomix.core.Atomix
Returns the partition service.
getPartitionService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the partition service.
getPartitionSize() - Method in class io.atomix.core.profile.ConsensusProfileConfig
Returns the data partition size.
getPartitionSize() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
Returns the partition size.
getPeers() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns the set of peers with which to gossip.
getPeerSelector() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns the gossip peer selector.
getPort() - Method in class io.atomix.cluster.messaging.MessagingConfig
Returns the local port to which to bind the node.
getPort() - Method in class io.atomix.cluster.MulticastConfig
Returns the multicast port.
getPrimitive(String) - Method in class io.atomix.core.AtomixConfig
Returns a primitive configuration.
getPrimitive(String, Supplier<CompletableFuture<P>>) - Method in interface io.atomix.primitive.PrimitiveCache
Gets or creates a locally cached multiton primitive instance.
getPrimitive(String, PrimitiveType<?, ?, P>) - Method in interface io.atomix.primitive.PrimitiveFactory
Gets or creates a distributed primitive.
getPrimitive(String, PrimitiveType<?, C, P>, C) - Method in interface io.atomix.primitive.PrimitiveFactory
Gets or creates a distributed primitive.
getPrimitive(String) - Method in interface io.atomix.primitive.PrimitiveRegistry
Returns the info for a single primitive.
getPrimitiveAsync(String, PrimitiveType<?, ?, P>) - Method in class io.atomix.core.Atomix
 
getPrimitiveAsync(String, PrimitiveType<?, C, P>, C) - Method in class io.atomix.core.Atomix
 
getPrimitiveAsync(String, PrimitiveType<?, ?, P>) - Method in interface io.atomix.primitive.PrimitiveFactory
Gets or creates a distributed primitive asynchronously.
getPrimitiveAsync(String, PrimitiveType<?, C, P>, C) - Method in interface io.atomix.primitive.PrimitiveFactory
Gets or creates a distributed primitive asynchronously.
getPrimitiveCache() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the local primitive cache.
getPrimitiveDefault(String) - Method in class io.atomix.core.AtomixConfig
Returns a default primitive configuration.
getPrimitiveDefaults() - Method in class io.atomix.core.AtomixConfig
Returns the primitive default configurations.
getPrimitiveRegistry() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the primitive registry.
getPrimitives() - Method in class io.atomix.core.Atomix
 
getPrimitives(PrimitiveType) - Method in class io.atomix.core.Atomix
 
getPrimitives() - Method in class io.atomix.core.AtomixConfig
Returns the primitive configurations.
getPrimitives() - Method in interface io.atomix.primitive.PrimitiveFactory
Returns a collection of open primitives.
getPrimitives(PrimitiveType) - Method in interface io.atomix.primitive.PrimitiveFactory
Returns a collection of open primitives of the given type.
getPrimitives() - Method in interface io.atomix.primitive.PrimitiveRegistry
Returns a collection of open primitives.
getPrimitives(PrimitiveType) - Method in interface io.atomix.primitive.PrimitiveRegistry
Returns a collection of open primitives of the given type.
getPrimitivesService() - Method in class io.atomix.core.Atomix
Returns the primitives service.
getPrimitiveType(String) - Method in class io.atomix.core.Atomix
 
getPrimitiveType(String) - Method in interface io.atomix.primitive.PrimitiveFactory
Returns a primitive type by name.
getPrimitiveType(String) - Method in interface io.atomix.primitive.PrimitiveTypeRegistry
Returns the primitive type for the given name.
getPrimitiveTypeRegistry() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the primitive type registry.
getPrimitiveTypes() - Method in interface io.atomix.primitive.partition.PartitionManagementService
Returns the primitive type registry.
getPrimitiveTypes() - Method in interface io.atomix.primitive.PrimitiveTypeRegistry
Returns the collection of registered primitive types.
getProbeInterval() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns the probe interval.
getProfiles() - Method in class io.atomix.core.AtomixConfig
Returns the Atomix profile.
getProfileType(String) - Method in interface io.atomix.core.profile.ProfileTypeRegistry
Returns the profile for the given name.
getProfileTypes() - Method in interface io.atomix.core.profile.ProfileTypeRegistry
Returns the collection of all registered profiles.
getProperties() - Method in class io.atomix.cluster.MemberConfig
Returns the member properties.
getProtocolConfig() - Method in class io.atomix.cluster.ClusterConfig
Returns the group membership protocol configuration.
getProtocolConfig() - Method in class io.atomix.primitive.config.PrimitiveConfig
Returns the protocol configuration.
getProtocolType(String) - Method in interface io.atomix.primitive.protocol.PrimitiveProtocolTypeRegistry
Returns the protocol type for the given configuration.
getProtocolTypeRegistry() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the primitive protocol type registry.
getProtocolTypes() - Method in interface io.atomix.primitive.protocol.PrimitiveProtocolTypeRegistry
Returns the collection of registered protocol types.
getQueue(String) - Method in class io.atomix.core.Atomix
 
getQueue(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getRack() - Method in class io.atomix.cluster.MemberConfig
Returns the member rack.
getReachabilityThreshold() - Method in class io.atomix.cluster.MembershipConfig
Returns the reachability failure detection threshold.
getReachabilityTimeout() - Method in class io.atomix.cluster.MembershipConfig
Returns the reachability failure timeout.
getReachableMembers() - Method in interface io.atomix.cluster.ClusterMembershipService
Returns the set of active reachable members.
getReadConsistency() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the read consistency level.
getRecovery() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the recovery strategy.
getRecoveryStrategy() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the client recovery strategy.
getRegistry() - Method in class io.atomix.core.Atomix
Returns the Atomix registry service.
getReplication() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the replication level.
getRequestSequence() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session request number.
getResolutionInterval() - Method in class io.atomix.cluster.discovery.DnsDiscoveryConfig
Returns the DNS resolution interval.
getResult(long) - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session response for the given sequence number.
getRetryDelay() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
Returns the retry delay.
getRetryDelay() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
Returns the retry delay.
getRole() - Method in class io.atomix.protocols.backup.PrimaryBackupServer
Returns the current server role.
getRole() - Method in interface io.atomix.protocols.raft.RaftServer
Returns the server role.
getSegmentSize() - Method in class io.atomix.protocols.raft.partition.RaftStorageConfig
Returns the Raft log segment size.
getSemaphore(String) - Method in class io.atomix.core.Atomix
 
getSemaphore(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getSerializationService() - Method in class io.atomix.core.Atomix
Returns the primitive serialization service.
getSerializationService() - Method in interface io.atomix.primitive.PrimitiveManagementService
Returns the primitive serialization service.
getSerializer() - Method in class io.atomix.utils.serializer.NamespaceTypeConfig
Returns the serializer class.
getServers() - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns the set of known members in the cluster.
getService() - Method in class io.atomix.cluster.discovery.DnsDiscoveryConfig
Returns the discovery service.
getService() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the state machine context associated with the session.
getSession(long) - Method in interface io.atomix.primitive.session.Sessions
Returns a session by session ID.
getSession(SessionId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry
Gets a session by session ID.
getSession(long) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry
Gets a session by session ID.
getSessionIdService() - Method in interface io.atomix.primitive.partition.PartitionManagementService
Returns the session ID generator service.
getSessions() - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns a list of open sessions.
getSessions(PrimitiveType) - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns a list of open sessions of the given type.
getSessions(PrimitiveType, String) - Method in interface io.atomix.protocols.raft.RaftMetadataClient
Returns a list of open sessions for the given service.
getSessions() - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry
Returns the collection of registered sessions.
getSessions(PrimitiveId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry
Returns a set of sessions associated with the given service.
getSet(String) - Method in class io.atomix.core.Atomix
 
getSet(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getSize() - Method in class io.atomix.core.cache.CacheConfig
Returns the cache size.
getSortedMap(String) - Method in class io.atomix.core.Atomix
 
getSortedMap(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getSortedSet(String) - Method in class io.atomix.core.Atomix
 
getSortedSet(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getState() - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the session state.
getState() - Method in interface io.atomix.primitive.proxy.ProxySession
Returns the session state.
getState() - Method in interface io.atomix.primitive.session.Session
Returns the session state.
getState() - Method in interface io.atomix.primitive.session.SessionClient
Returns the session state.
getState() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
getState() - Method in class io.atomix.protocols.raft.session.RaftSession
 
getStorageConfig() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
Returns the storage configuration.
getSubscriptions(String) - Method in interface io.atomix.cluster.messaging.ClusterEventService
Returns a list of subscriptions for the given topic.
getSuspectProbes() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns the number of probes to perform on suspect members.
getSystemMembership() - Method in interface io.atomix.primitive.partition.PartitionGroupMembershipService
Returns the system group membership.
getSystemPartitionGroup() - Method in interface io.atomix.primitive.partition.PartitionService
Returns the system partition group.
getTerm() - Method in interface io.atomix.primitive.partition.PrimaryElection
Returns the current term.
getTime() - Method in interface io.atomix.utils.time.Clock
Returns the current time of the clock.
getTime() - Method in class io.atomix.utils.time.LogicalClock
 
getTime() - Method in class io.atomix.utils.time.VectorClock
 
getTime() - Method in class io.atomix.utils.time.WallClock
 
getTimestamp(T) - Method in class io.atomix.utils.time.VectorClock
Returns the logical timestamp for the given identifier.
getTimestampProvider() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns the configured timestamp provider.
getTimestampProvider() - Method in class io.atomix.protocols.gossip.CrdtProtocolConfig
Returns the configured timestamp provider.
getTimestamps() - Method in class io.atomix.utils.time.VectorClock
Returns a collection of identifier-timestamp pairs.
getTlsConfig() - Method in class io.atomix.cluster.messaging.MessagingConfig
Returns the TLS configuration.
getTransactionService() - Method in class io.atomix.core.Atomix
Returns the transaction service.
getTransactionState(TransactionId) - Method in interface io.atomix.core.transaction.TransactionService
Returns a transaction state by ID.
getTrustStore() - Method in class io.atomix.cluster.messaging.TlsConfig
Returns the trust store path.
getTrustStorePassword() - Method in class io.atomix.cluster.messaging.TlsConfig
Returns the trust store password.
getType() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryConfig
 
getType() - Method in class io.atomix.cluster.discovery.DnsDiscoveryConfig
 
getType() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryConfig
 
getType() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocolConfig
 
getType() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
 
getType(Class<T>, String) - Method in interface io.atomix.core.AtomixRegistry
Returns a named registration by type.
getType() - Method in class io.atomix.core.barrier.DistributedCyclicBarrierConfig
 
getType() - Method in class io.atomix.core.counter.AtomicCounterConfig
 
getType() - Method in class io.atomix.core.counter.DistributedCounterConfig
 
getType() - Method in class io.atomix.core.election.LeaderElectionConfig
 
getType() - Method in class io.atomix.core.election.LeaderElectorConfig
 
getType() - Method in class io.atomix.core.idgenerator.AtomicIdGeneratorConfig
 
getType() - Method in class io.atomix.core.list.DistributedListConfig
 
getType() - Method in class io.atomix.core.lock.AtomicLockConfig
 
getType() - Method in class io.atomix.core.lock.DistributedLockConfig
 
getType() - Method in class io.atomix.core.map.AtomicCounterMapConfig
 
getType() - Method in class io.atomix.core.map.AtomicMapConfig
 
getType() - Method in class io.atomix.core.map.AtomicNavigableMapConfig
 
getType() - Method in class io.atomix.core.map.AtomicSortedMapConfig
 
getType() - Method in class io.atomix.core.map.DistributedMapConfig
 
getType() - Method in class io.atomix.core.map.DistributedNavigableMapConfig
 
getType() - Method in class io.atomix.core.map.DistributedSortedMapConfig
 
getType() - Method in class io.atomix.core.multimap.AtomicMultimapConfig
 
getType() - Method in class io.atomix.core.multimap.DistributedMultimapConfig
 
getType() - Method in class io.atomix.core.multiset.DistributedMultisetConfig
 
getType() - Method in class io.atomix.core.profile.ClientProfileConfig
 
getType() - Method in class io.atomix.core.profile.ConsensusProfileConfig
 
getType() - Method in class io.atomix.core.profile.DataGridProfileConfig
 
getType() - Method in class io.atomix.core.queue.DistributedQueueConfig
 
getType(Class<T>, String) - Method in class io.atomix.core.registry.ClasspathScanningRegistry
 
getType(Class<T>, String) - Method in class io.atomix.core.registry.SimpleRegistry
 
getType() - Method in class io.atomix.core.semaphore.AtomicSemaphoreConfig
 
getType() - Method in class io.atomix.core.semaphore.DistributedSemaphoreConfig
 
getType() - Method in class io.atomix.core.set.DistributedNavigableSetConfig
 
getType() - Method in class io.atomix.core.set.DistributedSetConfig
 
getType() - Method in class io.atomix.core.set.DistributedSortedSetConfig
 
getType() - Method in class io.atomix.core.transaction.TransactionalMapConfig
 
getType() - Method in class io.atomix.core.transaction.TransactionalSetConfig
 
getType() - Method in class io.atomix.core.transaction.TransactionConfig
 
getType() - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
 
getType() - Method in class io.atomix.core.value.AtomicValueConfig
 
getType() - Method in class io.atomix.core.value.DistributedValueConfig
 
getType() - Method in class io.atomix.core.workqueue.WorkQueueConfig
 
getType() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
 
getType() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroupConfig
 
getType() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
 
getType() - Method in class io.atomix.protocols.gossip.CrdtProtocolConfig
 
getType() - Method in class io.atomix.protocols.raft.MultiRaftProtocolConfig
 
getType() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
 
getType() - Method in exception io.atomix.protocols.raft.RaftException
Returns the exception type.
getType() - Method in interface io.atomix.utils.config.TypedConfig
Returns the type name.
getType() - Method in class io.atomix.utils.serializer.NamespaceTypeConfig
Returns the serializable type.
getTypes(Class<T>) - Method in interface io.atomix.core.AtomixRegistry
Returns the collection of registrations for the given type.
getTypes(Class<T>) - Method in class io.atomix.core.registry.ClasspathScanningRegistry
 
getTypes(Class<T>) - Method in class io.atomix.core.registry.SimpleRegistry
 
getTypes() - Method in class io.atomix.utils.serializer.NamespaceConfig
Returns the serializable types.
getUnicastService() - Method in class io.atomix.cluster.AtomixCluster
Returns the cluster unicast service.
getUnicastService() - Method in interface io.atomix.cluster.BootstrapService
Returns the cluster unicast service.
getValue(String) - Method in class io.atomix.core.Atomix
 
getValue(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getValueType() - Method in class io.atomix.core.map.MapConfig
Returns the value type.
getValueType() - Method in class io.atomix.core.multimap.MultimapConfig
Returns the value type.
getValueType() - Method in class io.atomix.core.value.ValueConfig
Returns the value type.
getWorkQueue(String) - Method in class io.atomix.core.Atomix
 
getWorkQueue(String) - Method in interface io.atomix.core.PrimitivesService
Deprecated.
since 3.1; use PrimitiveBuilder.get()
getZone() - Method in class io.atomix.cluster.MemberConfig
Returns the member zone.
GossipProtocol - Interface in io.atomix.primitive.protocol
Dissemination protocol.
group() - Method in class io.atomix.core.transaction.ParticipantInfo
Returns the partition group in which the participant is stored.
group() - Method in class io.atomix.primitive.partition.PartitionGroupMembership
Returns the partition group name.
group() - Method in class io.atomix.primitive.partition.PartitionId
Returns the partition group name.
group() - Method in interface io.atomix.primitive.protocol.ProxyProtocol
Returns the protocol partition group name.
group() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocol
 
group() - Method in class io.atomix.protocols.raft.MultiRaftProtocol
 
groupId() - Method in class io.atomix.primitive.partition.GroupMember
Returns the member group ID.
GroupMember - Class in io.atomix.primitive.partition
Primary election member.
GroupMember(MemberId, MemberGroupId) - Constructor for class io.atomix.primitive.partition.GroupMember
 
GroupMembershipEvent - Class in io.atomix.cluster.protocol
Group membership protocol event.
GroupMembershipEvent(GroupMembershipEvent.Type, Member) - Constructor for class io.atomix.cluster.protocol.GroupMembershipEvent
 
GroupMembershipEvent(GroupMembershipEvent.Type, Member, long) - Constructor for class io.atomix.cluster.protocol.GroupMembershipEvent
 
GroupMembershipEvent.Type - Enum in io.atomix.cluster.protocol
Group membership protocol event type.
GroupMembershipEventListener - Interface in io.atomix.cluster.protocol
Node discovery event listener.
GroupMembershipProtocol - Interface in io.atomix.cluster.protocol
Group membership protocol.
GroupMembershipProtocol.Type<C extends GroupMembershipProtocolConfig> - Interface in io.atomix.cluster.protocol
Group membership protocol type.
GroupMembershipProtocolBuilder - Class in io.atomix.cluster.protocol
Group membership protocol builder.
GroupMembershipProtocolBuilder() - Constructor for class io.atomix.cluster.protocol.GroupMembershipProtocolBuilder
 
GroupMembershipProtocolConfig - Class in io.atomix.cluster.protocol
Group membership protocol configuration.
GroupMembershipProtocolConfig() - Constructor for class io.atomix.cluster.protocol.GroupMembershipProtocolConfig
 

H

handle(OperationId, Function<Commit<byte[]>, byte[]>) - Method in interface io.atomix.primitive.service.ServiceExecutor
Registers a operation callback.
hasChildren() - Method in interface io.atomix.core.tree.DocumentTreeNode
Returns if this node has one or more children.
hashCode() - Method in class io.atomix.cluster.ClusterMembershipEvent
 
hashCode() - Method in class io.atomix.cluster.Member
 
hashCode() - Method in class io.atomix.cluster.Node
 
hashCode() - Method in class io.atomix.cluster.NodeId
 
hashCode() - Method in class io.atomix.cluster.protocol.GroupMembershipEvent
 
hashCode() - Method in class io.atomix.core.election.Leader
 
hashCode() - Method in class io.atomix.core.election.Leadership
 
hashCode() - Method in class io.atomix.core.election.LeadershipEvent
 
hashCode() - Method in class io.atomix.core.map.AtomicMapEvent
 
hashCode() - Method in class io.atomix.core.map.MapEvent
 
hashCode() - Method in class io.atomix.core.multimap.AtomicMultimapEvent
 
hashCode() - Method in class io.atomix.core.multimap.MultimapEvent
 
hashCode() - Method in class io.atomix.core.transaction.ParticipantInfo
 
hashCode() - Method in class io.atomix.core.transaction.TransactionLog
 
hashCode() - Method in class io.atomix.core.tree.DocumentPath
 
hashCode() - Method in class io.atomix.core.value.AtomicValueEvent
 
hashCode() - Method in class io.atomix.core.value.ValueEvent
 
hashCode() - Method in class io.atomix.primitive.event.PrimitiveEvent
 
hashCode() - Method in class io.atomix.primitive.operation.PrimitiveOperation
 
hashCode() - Method in class io.atomix.primitive.partition.GroupMember
 
hashCode() - Method in class io.atomix.primitive.partition.PartitionId
 
hashCode() - Method in class io.atomix.primitive.partition.PartitionMetadata
 
hashCode() - Method in class io.atomix.primitive.partition.PrimaryTerm
 
hashCode() - Method in class io.atomix.primitive.PrimitiveInfo
 
hashCode() - Method in class io.atomix.primitive.session.SessionMetadata
 
hashCode() - Method in class io.atomix.protocols.raft.session.RaftSession
 
hashCode() - Method in class io.atomix.utils.AbstractIdentifier
Returns the hashcode of the identifier.
hashCode() - Method in class io.atomix.utils.net.Address
 
hashCode() - Method in class io.atomix.utils.time.LogicalTimestamp
 
hashCode() - Method in class io.atomix.utils.time.MultiValuedTimestamp
 
hashCode() - Method in interface io.atomix.utils.time.Timestamp
 
hashCode() - Method in class io.atomix.utils.time.VectorTimestamp
 
hashCode() - Method in class io.atomix.utils.time.Version
 
hashCode() - Method in class io.atomix.utils.time.Versioned
 
hashCode() - Method in class io.atomix.utils.time.WallClockTimestamp
 
hashCode() - Method in class io.atomix.utils.Version
 
hasNext() - Method in interface io.atomix.core.iterator.AsyncIterator
Returns whether the iterator has a next item.
headMap(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
 
headMap(K, boolean) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a view of the portion of this map whose keys are less than (or equal to, if inclusive is true) toKey.
headMap(K) - Method in interface io.atomix.core.map.AsyncAtomicSortedMap
Returns a view of the portion of this map whose keys are strictly less than toKey.
headMap(K, boolean) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a view of the portion of this map whose keys are less than (or equal to, if inclusive is true) toKey.
headMap(K) - Method in interface io.atomix.core.map.AsyncDistributedSortedMap
Returns a view of the portion of this map whose keys are strictly less than toKey.
headMap(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
 
headMap(K, boolean) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns a view of the portion of this map whose keys are less than (or equal to, if inclusive is true) toKey.
headMap(K) - Method in interface io.atomix.core.map.AtomicSortedMap
Returns a view of the portion of this map whose keys are strictly less than toKey.
headMap(K, boolean) - Method in interface io.atomix.core.map.DistributedNavigableMap
 
headMap(K) - Method in interface io.atomix.core.map.DistributedSortedMap
 
headSet(E, boolean) - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns a view of the portion of this set whose elements are less than (or equal to, if inclusive is true) toElement.
headSet(E) - Method in interface io.atomix.core.set.AsyncDistributedSortedSet
Returns a view of the portion of this set whose elements are strictly less than toElement.
higher(E) - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns the least element in this set strictly greater than the given element, or null if there is no such element.
higherEntry(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the least key strictly greater than the given key, or null if there is no such key.
higherEntry(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the least key strictly greater than the given key, or null if there is no such key.
higherEntry(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the lest key greater than key.
higherKey(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns the least key strictly greater than the given key, or null if there is no such key.
higherKey(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns the least key strictly greater than the given key, or null if there is no such key.
higherKey(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the lowest key greater than key.
host() - Method in class io.atomix.cluster.Member
Returns the host to which the member belongs.
host() - Method in class io.atomix.utils.net.Address
Returns the host name.

I

id() - Method in class io.atomix.cluster.Member
 
id() - Method in class io.atomix.cluster.Node
Returns the instance identifier.
id() - Method in class io.atomix.core.election.Leader
Returns the identifier for of leader.
id() - Method in class io.atomix.primitive.operation.PrimitiveOperation
Returns the operation identifier.
id() - Method in interface io.atomix.primitive.partition.MemberGroup
Returns the group identifier.
id() - Method in interface io.atomix.primitive.partition.Partition
Returns the partition identifier.
id() - Method in class io.atomix.primitive.partition.PartitionMetadata
Returns the partition identifier.
id() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
id() - Method in class io.atomix.protocols.raft.partition.RaftPartition
 
id() - Method in class io.atomix.utils.AbstractIdentifier
Returns the backing identifier value.
id() - Method in interface io.atomix.utils.Identifier
Returns the backing identifier value.
Identifier<T extends Comparable<T>> - Interface in io.atomix.utils
Abstract identifier backed by another value, e.g.
identifier() - Method in class io.atomix.utils.time.VectorTimestamp
Returns the timestamp identifier.
IllegalDocumentModificationException - Exception in io.atomix.core.tree
An exception to be thrown when a node cannot be removed normally because it does not exist or because it is not a leaf node.
IllegalDocumentModificationException() - Constructor for exception io.atomix.core.tree.IllegalDocumentModificationException
 
IllegalDocumentModificationException(String) - Constructor for exception io.atomix.core.tree.IllegalDocumentModificationException
 
IllegalDocumentModificationException(String, Throwable) - Constructor for exception io.atomix.core.tree.IllegalDocumentModificationException
 
IllegalDocumentModificationException(Throwable) - Constructor for exception io.atomix.core.tree.IllegalDocumentModificationException
 
IllegalDocumentNameException - Exception in io.atomix.core.tree
An exception thrown when an illegally named node is submitted.
IllegalDocumentNameException() - Constructor for exception io.atomix.core.tree.IllegalDocumentNameException
 
IllegalDocumentNameException(String) - Constructor for exception io.atomix.core.tree.IllegalDocumentNameException
 
IllegalDocumentNameException(String, Throwable) - Constructor for exception io.atomix.core.tree.IllegalDocumentNameException
 
IllegalDocumentNameException(Throwable) - Constructor for exception io.atomix.core.tree.IllegalDocumentNameException
 
IllegalMemberState(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.IllegalMemberState
 
increasePermits(int) - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Increases the number of available permits by the indicated amount.
increasePermits(int) - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Increases the number of available permits by the indicated amount.
increasePermits(int) - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Increases the number of available permits by the indicated amount.
increment() - Method in class io.atomix.utils.time.LogicalClock
Increments the clock and returns the new timestamp.
incrementAndGet() - Method in interface io.atomix.core.counter.AsyncAtomicCounter
Atomically increment by one and return the updated value.
incrementAndGet() - Method in interface io.atomix.core.counter.AsyncDistributedCounter
Atomically increment by one and return the updated value.
incrementAndGet() - Method in interface io.atomix.core.counter.AtomicCounter
Atomically increment by one and return the updated value.
incrementAndGet() - Method in interface io.atomix.core.counter.DistributedCounter
Atomically increment by one and return the updated value.
incrementAndGet(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Increments by one the value currently associated with key, and returns the new value.
incrementAndGet(K) - Method in interface io.atomix.core.map.AtomicCounterMap
Increments by one the value currently associated with key, and returns the new value.
incrementAndGet() - Method in interface io.atomix.primitive.protocol.counter.CounterDelegate
Atomically increment by one and return the updated value.
incrementAndUpdate(LogicalTimestamp) - Method in class io.atomix.utils.time.LogicalClock
Increments the clock and updates it using the given timestamp.
index() - Method in interface io.atomix.primitive.service.Commit
Returns the commit index.
indexOf(Object) - Method in interface io.atomix.core.list.AsyncDistributedList
Returns the index of the first occurrence of the specified element in this list, or -1 if this list does not contain the element.
init(ServiceContext) - Method in class io.atomix.primitive.service.AbstractPrimitiveService
 
init(ServiceContext) - Method in interface io.atomix.primitive.service.PrimitiveService
Initializes the state machine.
INITIAL_ID - Static variable in class io.atomix.utils.serializer.Namespace
Smallest ID free to use for user defined registrations.
initialCapacity() - Method in class io.atomix.core.semaphore.AtomicSemaphoreConfig
 
initialCapacity() - Method in class io.atomix.core.semaphore.DistributedSemaphoreConfig
 
installSnapshot(SnapshotReader) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Installs a snapshot.
instance() - Static method in class io.atomix.core.barrier.DistributedCyclicBarrierType
Returns a new distributed count down latch type.
instance() - Static method in class io.atomix.core.collection.DistributedCollectionType
Returns a new distributed collection type.
instance() - Static method in class io.atomix.core.counter.AtomicCounterType
Returns a new atomic counter type.
instance() - Static method in class io.atomix.core.counter.DistributedCounterType
Returns a new distributed counter type.
instance() - Static method in class io.atomix.core.election.LeaderElectionType
Returns a new leader elector type.
instance() - Static method in class io.atomix.core.election.LeaderElectorType
Returns a new leader elector type.
instance() - Static method in class io.atomix.core.idgenerator.AtomicIdGeneratorType
Returns a new atomic ID generator type.
instance() - Static method in class io.atomix.core.list.DistributedListType
Returns a new distributed list type.
instance() - Static method in class io.atomix.core.lock.AtomicLockType
Returns a new distributed lock type.
instance() - Static method in class io.atomix.core.lock.DistributedLockType
Returns a new distributed lock type.
instance() - Static method in class io.atomix.core.map.AtomicCounterMapType
Returns a new atomic counter map type.
instance() - Static method in class io.atomix.core.map.AtomicMapType
Returns a new consistent map type.
instance() - Static method in class io.atomix.core.map.AtomicNavigableMapType
Returns a new consistent tree map type.
instance() - Static method in class io.atomix.core.map.AtomicSortedMapType
Returns a new consistent tree map type.
instance() - Static method in class io.atomix.core.map.DistributedMapType
Returns a new distributed map type.
instance() - Static method in class io.atomix.core.map.DistributedNavigableMapType
Returns a new distributed tree map type.
instance() - Static method in class io.atomix.core.map.DistributedSortedMapType
Returns a new distributed tree map type.
instance() - Static method in class io.atomix.core.multimap.AtomicMultimapType
Returns a new consistent multimap type.
instance() - Static method in class io.atomix.core.multimap.DistributedMultimapType
Returns a new distributed multimap type.
instance() - Static method in class io.atomix.core.multiset.DistributedMultisetType
Returns a new distributed multiset type.
instance() - Static method in class io.atomix.core.queue.DistributedQueueType
Returns a new distributed queue type.
instance() - Static method in class io.atomix.core.semaphore.AtomicSemaphoreType
Returns a semaphore type instance.
instance() - Static method in class io.atomix.core.semaphore.DistributedSemaphoreType
Returns a semaphore type instance.
instance() - Static method in class io.atomix.core.set.DistributedNavigableSetType
Returns a new distributed set type.
instance() - Static method in class io.atomix.core.set.DistributedSetType
Returns a new distributed set type.
instance() - Static method in class io.atomix.core.set.DistributedSortedSetType
Returns a new distributed set type.
instance() - Static method in class io.atomix.core.transaction.TransactionType
Returns a new consistent tree map type.
instance() - Static method in class io.atomix.core.tree.AtomicDocumentTreeType
Returns a new document tree type.
instance() - Static method in class io.atomix.core.value.AtomicValueType
Returns a new value type.
instance() - Static method in class io.atomix.core.value.DistributedValueType
Returns a new value type.
instance() - Static method in class io.atomix.core.workqueue.WorkQueueType
Returns a new work queue type instance.
instance() - Static method in class io.atomix.protocols.backup.MultiPrimaryProtocol
Returns an instance of the multi-primary protocol with the default configuration.
instance() - Static method in class io.atomix.protocols.gossip.AntiEntropyProtocol
Returns an instance of the anti-entropy protocol with the default configuration.
instance() - Static method in class io.atomix.protocols.gossip.CrdtProtocol
Returns an instance of the CRDT protocol with the default configuration.
instance() - Static method in class io.atomix.protocols.raft.MultiRaftProtocol
Returns an instance of the multi-Raft protocol with the default configuration.
Interrupted() - Constructor for exception io.atomix.core.tree.DocumentException.Interrupted
 
Interrupted() - Constructor for exception io.atomix.primitive.PrimitiveException.Interrupted
 
io.atomix.cluster - package io.atomix.cluster
Provides classes and interfaces for cluster management.
io.atomix.cluster.discovery - package io.atomix.cluster.discovery
Provides classes and interfaces for extensible cluster membership discovery.
io.atomix.cluster.messaging - package io.atomix.cluster.messaging
Provides high-level interfaces for direct and publish-subscribe inter-cluster communication.
io.atomix.cluster.protocol - package io.atomix.cluster.protocol
Provides interfaces and implementations for group membership protocols.
io.atomix.core - package io.atomix.core
Core APIs for managing Atomix clusters and operating on distributed primitives.
io.atomix.core.barrier - package io.atomix.core.barrier
Distributed barrier primitive.
io.atomix.core.cache - package io.atomix.core.cache
Cached primitive configurations and builders.
io.atomix.core.collection - package io.atomix.core.collection
Distributed collection primitives.
io.atomix.core.counter - package io.atomix.core.counter
Atomic counter primitive.
io.atomix.core.election - package io.atomix.core.election
Distributed leader election primitives.
io.atomix.core.idgenerator - package io.atomix.core.idgenerator
Atomic ID generator primitive.
io.atomix.core.iterator - package io.atomix.core.iterator
Primitive iterator interfaces.
io.atomix.core.list - package io.atomix.core.list
Distributed list primitive.
io.atomix.core.lock - package io.atomix.core.lock
Distributed lock primitive.
io.atomix.core.map - package io.atomix.core.map
Atomic map primitive.
io.atomix.core.multimap - package io.atomix.core.multimap
Atomic multimap primitive.
io.atomix.core.multiset - package io.atomix.core.multiset
Distributed multiset primitive.
io.atomix.core.profile - package io.atomix.core.profile
Distributed queueing primitive interfaces.
io.atomix.core.queue - package io.atomix.core.queue
Distributed queue primitive.
io.atomix.core.registry - package io.atomix.core.registry
 
io.atomix.core.semaphore - package io.atomix.core.semaphore
Distributed semaphore primitive.
io.atomix.core.set - package io.atomix.core.set
Distributed set primitive.
io.atomix.core.transaction - package io.atomix.core.transaction
Interfaces for managing distributed primitive transactions.
io.atomix.core.tree - package io.atomix.core.tree
Distributed tree primitive interfaces.
io.atomix.core.value - package io.atomix.core.value
Atomic value primitive.
io.atomix.core.workqueue - package io.atomix.core.workqueue
Distributed work processing primitives.
io.atomix.primitive - package io.atomix.primitive
Provides classes and interfaces for defining and managing primitive types.
io.atomix.primitive.config - package io.atomix.primitive.config
Primitive instance configuration store.
io.atomix.primitive.event - package io.atomix.primitive.event
Provides interfaces for defining distributed primitive events.
io.atomix.primitive.operation - package io.atomix.primitive.operation
Provides classes and interfaces for defining distributed primitive operations.
io.atomix.primitive.partition - package io.atomix.primitive.partition
Provides classes and interfaces for managing primitive partitions, partition groups, and member groups.
io.atomix.primitive.protocol - package io.atomix.primitive.protocol
Provides classes and interfaces for defining and managing primitive protocols.
io.atomix.primitive.protocol.counter - package io.atomix.primitive.protocol.counter
Interfaces for counter-compatible gossip protocols and delegates.
io.atomix.primitive.protocol.map - package io.atomix.primitive.protocol.map
Interfaces for map-compatible gossip protocols and delegates.
io.atomix.primitive.protocol.set - package io.atomix.primitive.protocol.set
Interfaces for set-compatible gossip protocols and delegates.
io.atomix.primitive.protocol.value - package io.atomix.primitive.protocol.value
Interfaces for value-compatible gossip protocols and delegates.
io.atomix.primitive.proxy - package io.atomix.primitive.proxy
Provides interfaces for operating on primitive services via Java proxies.
io.atomix.primitive.serialization - package io.atomix.primitive.serialization
 
io.atomix.primitive.service - package io.atomix.primitive.service
Provides classes and interfaces for defining distributed primitive state machines.
io.atomix.primitive.session - package io.atomix.primitive.session
Provides classes and interfaces for managing primitive sessions.
io.atomix.protocols.backup - package io.atomix.protocols.backup
Provides a PrimitiveProtocol implementation for multi-primary replication and classes for managing primary-backup clients/servers.
io.atomix.protocols.backup.partition - package io.atomix.protocols.backup.partition
Provides PartitionGroup and Partition implementations for primary-backup.
io.atomix.protocols.backup.session - package io.atomix.protocols.backup.session
Provides a SessionClient implementation for primary-backup.
io.atomix.protocols.gossip - package io.atomix.protocols.gossip
Gossip-based distributed primitive protocols.
io.atomix.protocols.raft - package io.atomix.protocols.raft
Provides classes and interfaces for managing Raft clients and servers.
io.atomix.protocols.raft.partition - package io.atomix.protocols.raft.partition
Provides PartitionGroup and Partition implementations for the Raft consensus protocol.
io.atomix.protocols.raft.service - package io.atomix.protocols.raft.service
Provides classes for managing Raft-based primitive services.
io.atomix.protocols.raft.session - package io.atomix.protocols.raft.session
Provides a Session implementation for the Raft consensus protocol.
io.atomix.storage - package io.atomix.storage
Provides classes and interfaces for managing storage objects.
io.atomix.utils - package io.atomix.utils
Provides utility classes and interfaces used throughout Atomix projects.
io.atomix.utils.config - package io.atomix.utils.config
Provides classes and interfaces for reading and mapping configuration files.
io.atomix.utils.event - package io.atomix.utils.event
Provides classes and interfaces for creating and handling generic events.
io.atomix.utils.net - package io.atomix.utils.net
Provides classes and interfaces for representing and operating on IP addresses.
io.atomix.utils.serializer - package io.atomix.utils.serializer
Provides classes and interfaces for binary serialization.
io.atomix.utils.time - package io.atomix.utils.time
Provides classes and interfaces for representing and operating on both logical and physical representations of time.
isActive() - Method in class io.atomix.cluster.Member
Returns a boolean indicating whether this member is an active member of the cluster.
isAncestorOf(DocumentPath) - Method in class io.atomix.core.tree.DocumentPath
Returns if the specified path belongs to a direct ancestor of the node pointed at by this path.
isBroadcastDisputes() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns whether to broadcast disputes to all peers.
isBroadcastUpdates() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns whether to broadcast member updates to all peers.
isBroken() - Method in interface io.atomix.core.barrier.AsyncDistributedCyclicBarrier
Returns whether this barrier is in a broken state.
isBroken() - Method in interface io.atomix.core.barrier.DistributedCyclicBarrier
Returns whether this barrier is in a broken state.
isCompatible() - Method in class io.atomix.utils.serializer.NamespaceConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.AtomixConfig
Returns whether compatible serialization is enabled for user types.
isCompatibleSerialization() - Method in class io.atomix.core.collection.DistributedCollectionConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.map.AtomicCounterMapConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.map.MapConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.multimap.MultimapConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
Returns whether compatible serialization is enabled.
isCompatibleSerialization() - Method in class io.atomix.core.value.ValueConfig
Returns whether compatible serialization is enabled.
isDescendentOf(DocumentPath) - Method in class io.atomix.core.tree.DocumentPath
Returns if the specified path is belongs to a subtree rooted this path.
isDynamic() - Method in class io.atomix.protocols.raft.partition.RaftCompactionConfig
Returns whether dynamic compaction is enabled.
isEmpty() - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Returns if the collection is empty.
isEmpty() - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Returns a boolean indicating whether the map is empty.
isEmpty() - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns true if the map is empty.
isEmpty() - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns true if this map contains no key-value mappings.
isEmpty() - Method in interface io.atomix.core.map.AtomicCounterMap
If the map is empty, returns true, otherwise false.
isEmpty() - Method in interface io.atomix.core.map.AtomicMap
Returns true if the map is empty.
isEmpty() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns if this multimap contains no key-value pairs.
isEmpty() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns if this multimap contains no key-value pairs.
isEmpty() - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns if this multimap contains no key-value pairs.
isEnabled() - Method in class io.atomix.cluster.messaging.TlsConfig
Returns whether TLS is enabled.
isEnabled() - Method in class io.atomix.cluster.MulticastConfig
Returns whether multicast is enabled.
isEnabled() - Method in class io.atomix.core.cache.CacheConfig
Returns whether caching is enabled.
isEnableShutdownHook() - Method in class io.atomix.core.AtomixConfig
Returns whether to enable the shutdown hook.
isFair() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
isFlushOnCommit() - Method in class io.atomix.protocols.raft.partition.RaftStorageConfig
Returns whether to flush logs to disk on commit.
isFollower() - Method in interface io.atomix.protocols.raft.RaftServer
Returns whether the server is a follower.
isLeader() - Method in interface io.atomix.protocols.raft.RaftServer
Returns whether the server is the leader.
isLocked() - Method in interface io.atomix.core.lock.AsyncAtomicLock
Returns a boolean indicating whether the lock is locked.
isLocked(Version) - Method in interface io.atomix.core.lock.AsyncAtomicLock
Returns a boolean indicating whether the lock is locked with the given version.
isLocked() - Method in interface io.atomix.core.lock.AsyncDistributedLock
Query whether this lock is locked or not.
isLocked() - Method in interface io.atomix.core.lock.AtomicLock
Returns a boolean indicating whether the lock is locked.
isLocked(Version) - Method in interface io.atomix.core.lock.AtomicLock
Returns a boolean indicating whether the lock is locked with the given version.
isLocked() - Method in interface io.atomix.core.lock.DistributedLock
Query whether this lock is locked or not.
isMember(Member) - Method in interface io.atomix.primitive.partition.MemberGroup
Returns a boolean indicating whether the given node is a member of the group.
isNewerThan(Timestamp) - Method in interface io.atomix.utils.time.Timestamp
Tests if this timestamp is newer than the specified timestamp.
isNotifySuspect() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocolConfig
Returns whether to notify a suspect node on state changes.
isNullValues() - Method in class io.atomix.core.map.AtomicMapConfig
Returns whether null values are supported by the map.
isNullValues() - Method in class io.atomix.core.map.DistributedMapConfig
Returns whether null values are supported by the map.
isNullValues() - Method in class io.atomix.core.map.DistributedNavigableMapConfig
Returns whether null values are supported by the map.
isNullValues() - Method in class io.atomix.core.map.DistributedSortedMapConfig
Returns whether null values are supported by the map.
isolation() - Method in interface io.atomix.core.transaction.AsyncTransaction
Returns the transaction isolation level.
Isolation - Enum in io.atomix.core.transaction
Transaction isolation levels.
isolation() - Method in interface io.atomix.core.transaction.Transaction
Returns the transaction isolation level.
isOlderThan(Timestamp) - Method in interface io.atomix.utils.time.Timestamp
Tests if this timestamp is older than the specified timestamp.
isOpen() - Method in interface io.atomix.core.transaction.AsyncTransaction
Returns if this transaction context is open.
isOpen() - Method in interface io.atomix.core.transaction.Transaction
Returns if this transaction context is open.
isReachable() - Method in class io.atomix.cluster.Member
Returns the node reachability.
isReadOnly() - Method in class io.atomix.primitive.config.PrimitiveConfig
Returns whether the primitive is read-only.
isRegistrationRequired() - Method in class io.atomix.core.collection.DistributedCollectionConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.core.map.AtomicCounterMapConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.core.map.MapConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.core.multimap.MultimapConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.core.tree.AtomicDocumentTreeConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.core.value.ValueConfig
Returns whether registration is required for serializable types.
isRegistrationRequired() - Method in class io.atomix.utils.serializer.NamespaceConfig
Returns whether registration is required.
isRelevant(E) - Method in interface io.atomix.utils.event.EventFilter
Indicates whether the specified event is of interest or not.
isRunning() - Method in class io.atomix.cluster.AtomixCluster
 
isRunning() - Method in class io.atomix.protocols.backup.PrimaryBackupServer
 
isRunning() - Method in interface io.atomix.protocols.raft.RaftServer
Returns a boolean indicating whether the server is running.
isRunning() - Method in interface io.atomix.utils.Managed
Returns a boolean value indicating whether the managed object is running.
isTimedOut(long) - Method in class io.atomix.protocols.raft.session.RaftSession
Returns a boolean indicating whether the session is timed out.
isTombstonesDisabled() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocolConfig
Returns whether tombstones are enabled.
isTypeRegistrationRequired() - Method in class io.atomix.core.AtomixConfig
Returns whether serializable type registration is required for user types.
iterator() - Method in interface io.atomix.core.collection.DistributedCollection
 
iterator() - Method in interface io.atomix.core.iterator.AsyncIterable
Returns an asynchronous iterator.
iterator() - Method in interface io.atomix.core.iterator.SyncIterable
Returns the synchronous iterator.

J

join(BootstrapService, Node) - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
join(BootstrapService, Node) - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider
 
join(BootstrapService, Node) - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
join(BootstrapService, Node) - Method in interface io.atomix.cluster.discovery.NodeDiscoveryProvider
Joins the cluster.
join(BootstrapService, NodeDiscoveryService, Member) - Method in interface io.atomix.cluster.protocol.GroupMembershipProtocol
Joins the cluster.
join(BootstrapService, NodeDiscoveryService, Member) - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol
 
join(BootstrapService, NodeDiscoveryService, Member) - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol
 
join(PartitionManagementService) - Method in interface io.atomix.primitive.partition.ManagedPartitionGroup
Joins the partition group.
join(PartitionManagementService) - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
join(PartitionManagementService) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
join(MemberId...) - Method in interface io.atomix.protocols.raft.RaftServer
Joins the cluster.
join(Collection<MemberId>) - Method in interface io.atomix.protocols.raft.RaftServer
Joins the cluster.

K

keepAlive(long, long, RaftSession, long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Keeps the given session alive.
keepAliveSessions(long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Keeps all sessions alive using the given timestamp.
key() - Method in class io.atomix.core.map.AtomicMapEvent
Returns the key this event concerns.
key() - Method in class io.atomix.core.map.MapEvent
Returns the key this event concerns.
key() - Method in class io.atomix.core.multimap.AtomicMultimapEvent
Returns the key this event concerns.
key() - Method in class io.atomix.core.multimap.MultimapEvent
Returns the key.
key() - Method in class io.atomix.primitive.protocol.map.MapDelegateEvent
Returns the map entry key.
keys() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns a multiset of the keys present in this multimap with one or more associated values each.
keys() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns a multiset of the keys present in this multimap with one or more associated values each.
keys() - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns a multiset of the keys present in this multimap with one or more associated values each.
keys() - Method in interface io.atomix.core.multimap.DistributedMultimap
Returns a multiset of the keys present in this multimap with one or more associated values each.
keySet() - Method in interface io.atomix.core.map.AsyncAtomicMap
Returns a Set view of the keys contained in this map.
keySet() - Method in interface io.atomix.core.map.AsyncDistributedMap
Returns a Set view of the keys contained in this map.
keySet() - Method in interface io.atomix.core.map.AtomicMap
Returns a Set view of the keys contained in this map.
keySet() - Method in interface io.atomix.core.map.DistributedMap
 
keySet() - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Returns a set of the keys contained in this multimap with one or more associated values.
keySet() - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Returns a set of the keys contained in this multimap with one or more associated values.
keySet() - Method in interface io.atomix.core.multimap.AtomicMultimap
Returns a set of the keys contained in this multimap with one or more associated values.
keySet() - Method in interface io.atomix.core.multimap.DistributedMultimap
Returns a set of the keys contained in this multimap with one or more associated values.

L

last() - Method in interface io.atomix.core.set.AsyncDistributedSortedSet
Returns the last (highest) element currently in this set.
lastEntry() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the greatest key in this map, or null if the map is empty.
lastEntry() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the greatest key in this map, or null if the map is empty.
lastEntry() - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the highest key in the map.
lastIndexOf(Object) - Method in interface io.atomix.core.list.AsyncDistributedList
Returns the index of the last occurrence of the specified element in this list, or -1 if this list does not contain the element.
lastKey() - Method in interface io.atomix.core.map.AsyncAtomicSortedMap
Returns the last (highest) key currently in this map.
lastKey() - Method in interface io.atomix.core.map.AsyncDistributedSortedMap
Returns the last (highest) key currently in this map.
lastKey() - Method in interface io.atomix.core.map.AtomicSortedMap
Returns the highest key in the map.
Leader<T> - Class in io.atomix.core.election
Topic leader.
Leader(T, long, long) - Constructor for class io.atomix.core.election.Leader
 
leader() - Method in class io.atomix.core.election.Leadership
Returns the leader for this topic.
leader() - Method in interface io.atomix.protocols.raft.RaftClient
Returns the current leader.
LeaderElection<T> - Interface in io.atomix.core.election
LeaderElector provides the same functionality as AsyncLeaderElection with the only difference that all its methods block until the corresponding operation completes.
LeaderElectionBuilder<T> - Class in io.atomix.core.election
Builder for constructing new AsyncLeaderElection instances.
leaderElectionBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named LeaderElection builder.
LeaderElectionConfig - Class in io.atomix.core.election
Leader election configuration.
LeaderElectionConfig() - Constructor for class io.atomix.core.election.LeaderElectionConfig
 
LeaderElectionType<T> - Class in io.atomix.core.election
Leader elector primitive type.
LeaderElectionType() - Constructor for class io.atomix.core.election.LeaderElectionType
 
LeaderElector<T> - Interface in io.atomix.core.election
LeaderElector provides the same functionality as AsyncLeaderElector with the only difference that all its methods block until the corresponding operation completes.
LeaderElectorBuilder<T> - Class in io.atomix.core.election
Builder for constructing new AsyncLeaderElector instances.
leaderElectorBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named LeaderElector builder.
LeaderElectorConfig - Class in io.atomix.core.election
Leader elector configuration.
LeaderElectorConfig() - Constructor for class io.atomix.core.election.LeaderElectorConfig
 
LeaderElectorType<T> - Class in io.atomix.core.election
Leader elector primitive type.
LeaderElectorType() - Constructor for class io.atomix.core.election.LeaderElectorType
 
Leadership<T> - Class in io.atomix.core.election
State of leadership for topic.
Leadership(Leader<T>, List<T>) - Constructor for class io.atomix.core.election.Leadership
 
LeadershipEvent<T> - Class in io.atomix.core.election
Describes leadership election event.
LeadershipEvent(LeadershipEvent.Type, String, Leadership<T>, Leadership<T>) - Constructor for class io.atomix.core.election.LeadershipEvent
Creates an event of a given type and for the specified instance and the current time.
LeadershipEvent(LeadershipEvent.Type, String, Leadership<T>, Leadership<T>, long) - Constructor for class io.atomix.core.election.LeadershipEvent
Creates an event of a given type and for the specified subject and time.
LeadershipEvent.Type - Enum in io.atomix.core.election
Type of leadership events.
LeadershipEventListener<T> - Interface in io.atomix.core.election
Entity capable of receiving leader elector events.
leastCommonAncestor(Collection<DocumentPath>) - Static method in class io.atomix.core.tree.DocumentPath
Returns the path that points to the least common ancestor of the specified collection of paths.
leave(Node) - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider
 
leave(Node) - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider
 
leave(Node) - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
leave(Node) - Method in interface io.atomix.cluster.discovery.NodeDiscoveryProvider
Leaves the cluster.
leave(Member) - Method in interface io.atomix.cluster.protocol.GroupMembershipProtocol
Leaves the cluster.
leave(Member) - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol
 
leave(Member) - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol
 
leave() - Method in interface io.atomix.protocols.raft.RaftServer
Leaves the Raft cluster.
listBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedList builder.
listen(MemberId...) - Method in interface io.atomix.protocols.raft.RaftServer
Joins the cluster as a passive listener.
listen(Collection<MemberId>) - Method in interface io.atomix.protocols.raft.RaftServer
Joins the cluster as a passive listener.
ListenerRegistry<E extends Event,L extends EventListener<E>> - Class in io.atomix.utils.event
Base implementation of an event sink and a registry capable of tracking listeners and dispatching events to them as part of event sink processing.
ListenerRegistry() - Constructor for class io.atomix.utils.event.ListenerRegistry
 
ListenerService<E extends Event,L extends EventListener<E>> - Interface in io.atomix.utils.event
Abstraction of a service capable of asynchronously notifying listeners.
loadFiles(Class<T>, List<File>, List<String>) - Method in class io.atomix.utils.config.ConfigMapper
Loads the given configuration file using the mapper, falling back to the given resources.
loadResources(Class<T>, String...) - Method in class io.atomix.utils.config.ConfigMapper
Loads the given resources using the configuration mapper.
loadResources(Class<T>, List<String>) - Method in class io.atomix.utils.config.ConfigMapper
Loads the given resources using the configuration mapper.
local() - Static method in class io.atomix.utils.net.Address
Returns an address that binds to all interfaces.
localMemberId() - Method in interface io.atomix.primitive.service.ServiceContext
Returns the local member ID
localMemberId() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
 
lock() - Method in interface io.atomix.core.lock.AsyncAtomicLock
Acquires the lock, blocking until it's available.
lock() - Method in interface io.atomix.core.lock.AsyncDistributedLock
Acquires the lock, blocking until it's available.
lock() - Method in interface io.atomix.core.lock.AtomicLock
Acquires the lock, blocking until it's available.
lockBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedLock builder.
log() - Method in interface io.atomix.core.transaction.TransactionParticipant
Returns the participant's transaction log.
logicalClock() - Method in interface io.atomix.primitive.service.ServiceContext
Returns the state machine's logical clock.
logicalClock() - Method in class io.atomix.protocols.raft.service.RaftServiceContext
 
LogicalClock - Class in io.atomix.utils.time
Logical clock.
LogicalClock() - Constructor for class io.atomix.utils.time.LogicalClock
 
LogicalClock(LogicalTimestamp) - Constructor for class io.atomix.utils.time.LogicalClock
 
logicalTime() - Method in interface io.atomix.primitive.service.Commit
Returns the logical time at which the operation was committed.
LogicalTimestamp - Class in io.atomix.utils.time
Timestamp based on logical sequence value.
LogicalTimestamp(long) - Constructor for class io.atomix.utils.time.LogicalTimestamp
 
lower(E) - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Returns the greatest element in this set strictly less than the given element, or null if there is no such element.
lowerEntry(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a key-value mapping associated with the greatest key strictly less than the given key, or null if there is no such key.
lowerEntry(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a key-value mapping associated with the greatest key strictly less than the given key, or null if there is no such key.
lowerEntry(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the largest key less than key.
lowerKey(K) - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns the greatest key strictly less than the given key, or null if there is no such key.
lowerKey(K) - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns the greatest key strictly less than the given key, or null if there is no such key.
lowerKey(K) - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the greatest key less than key.

M

major() - Method in class io.atomix.utils.Version
Returns the major version number.
MalformedAddressException - Exception in io.atomix.utils.net
Malformed address exception.
MalformedAddressException(String) - Constructor for exception io.atomix.utils.net.MalformedAddressException
 
MalformedAddressException(String, Throwable) - Constructor for exception io.atomix.utils.net.MalformedAddressException
 
Managed<T> - Interface in io.atomix.utils
Interface for types that can be asynchronously started and stopped.
ManagedBroadcastService - Interface in io.atomix.cluster.messaging
Managed broadcast service.
ManagedClusterCommunicationService - Interface in io.atomix.cluster.messaging
Managed cluster communicator.
ManagedClusterEventService - Interface in io.atomix.cluster.messaging
Managed cluster event service.
ManagedClusterMembershipService - Interface in io.atomix.cluster
Managed cluster.
ManagedMemberGroupService - Interface in io.atomix.primitive.partition
Manage member group service.
ManagedMessagingService - Interface in io.atomix.cluster.messaging
Managed messaging service.
ManagedNodeDiscoveryService - Interface in io.atomix.cluster.discovery
Managed node discovery service.
ManagedPartitionGroup - Interface in io.atomix.primitive.partition
Managed partition group.
ManagedPartitionGroupMembershipService - Interface in io.atomix.primitive.partition
Managed partition group membership service.
ManagedPartitionService - Interface in io.atomix.primitive.partition
Managed partition service.
ManagedPrimaryElection - Interface in io.atomix.primitive.partition
Managed primary election.
ManagedPrimaryElectionService - Interface in io.atomix.primitive.partition
Managed primary election service.
ManagedPrimitiveRegistry - Interface in io.atomix.primitive
Managed primitive registry.
ManagedPrimitivesService - Interface in io.atomix.core
Managed primitives service.
ManagedSessionIdService - Interface in io.atomix.primitive.session
Managed session ID service.
ManagedTransactionService - Interface in io.atomix.core.transaction
Managed transaction service.
ManagedUnicastService - Interface in io.atomix.cluster.messaging
Managed unicast service.
map(Function<T, U>) - Method in class io.atomix.core.election.Leader
Converts the leader identifier using the given mapping function.
map(Function<T, U>) - Method in class io.atomix.core.election.Leadership
Maps the leadership identifiers using the given mapper.
map(Function<T, U>) - Method in class io.atomix.core.transaction.TransactionLog
Maps this instance to another MapTransaction with different key and value types.
map(Function<E, F>) - Method in class io.atomix.core.workqueue.Task
Maps task from one payload type to another.
map(Function<T, U>) - Method in interface io.atomix.primitive.service.Commit
Converts the commit from one type to another.
map(Function<V, U>) - Method in class io.atomix.utils.time.Versioned
Maps this instance into another after transforming its value while retaining the same version and creationTime.
MapBuilder<B extends MapBuilder<B,C,P,K,V>,C extends MapConfig<C>,P extends SyncPrimitive,K,V> - Class in io.atomix.core.map
Base map builder.
mapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedMap builder.
mapBuilder(String) - Method in interface io.atomix.core.transaction.AsyncTransaction
Returns a new transactional map builder.
mapBuilder(String, ProxyProtocol) - Method in interface io.atomix.core.transaction.AsyncTransaction
Returns a new transactional map builder.
mapBuilder(String) - Method in interface io.atomix.core.transaction.Transaction
Returns a new transactional map builder.
MapCompatibleBuilder<B extends MapCompatibleBuilder<B>> - Interface in io.atomix.primitive.protocol.map
Map builder.
MapConfig<C extends MapConfig<C>> - Class in io.atomix.core.map
Map configuration.
MapConfig() - Constructor for class io.atomix.core.map.MapConfig
 
MapDelegate<K,V> - Interface in io.atomix.primitive.protocol.map
Gossip-based map service.
MapDelegateEvent<K,V> - Class in io.atomix.primitive.protocol.map
Map protocol event.
MapDelegateEvent(MapDelegateEvent.Type, K, V) - Constructor for class io.atomix.primitive.protocol.map.MapDelegateEvent
 
MapDelegateEvent(MapDelegateEvent.Type, K, V, long) - Constructor for class io.atomix.primitive.protocol.map.MapDelegateEvent
 
MapDelegateEvent.Type - Enum in io.atomix.primitive.protocol.map
Map protocol event type.
MapDelegateEventListener<K,V> - Interface in io.atomix.primitive.protocol.map
Map protocol event listener.
MapEvent<K,V> - Class in io.atomix.core.map
Representation of a ConsistentMap update notification.
MapEvent(MapEvent.Type, K, V, V) - Constructor for class io.atomix.core.map.MapEvent
Creates a new event object.
MapEvent.Type - Enum in io.atomix.core.map
MapEvent type.
MapEventListener<K,V> - Interface in io.atomix.core.map
Listener to be notified about updates to a ConsistentMap.
MapProtocol - Interface in io.atomix.primitive.protocol.map
Map protocol.
mapToNull() - Method in interface io.atomix.primitive.service.Commit
Converts the commit to a null valued commit.
MAX_BUFFER_SIZE - Static variable in class io.atomix.utils.serializer.Namespace
Maximum allowed buffer size.
maxTimeout() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the maximum session timeout.
Member - Class in io.atomix.cluster
Represents a node as a member in a cluster.
Member(MemberConfig) - Constructor for class io.atomix.cluster.Member
 
member(String) - Static method in class io.atomix.cluster.Member
Returns a new anonymous cluster member.
member(String, String) - Static method in class io.atomix.cluster.Member
Returns a new named cluster member.
member(Address) - Static method in class io.atomix.cluster.Member
Returns a new anonymous cluster member.
member(MemberId, Address) - Static method in class io.atomix.cluster.Member
Returns a new named cluster member.
member() - Method in class io.atomix.cluster.protocol.GroupMembershipEvent
Returns the member.
MemberBuilder - Class in io.atomix.cluster
Member builder.
MemberConfig - Class in io.atomix.cluster
Member configuration.
MemberConfig() - Constructor for class io.atomix.cluster.MemberConfig
 
MemberGroup - Interface in io.atomix.primitive.partition
Partition member group.
MemberGroupEvent - Class in io.atomix.primitive.partition
Member group event.
MemberGroupEvent(MemberGroupEvent.Type, Collection<MemberGroup>) - Constructor for class io.atomix.primitive.partition.MemberGroupEvent
 
MemberGroupEvent(MemberGroupEvent.Type, Collection<MemberGroup>, long) - Constructor for class io.atomix.primitive.partition.MemberGroupEvent
 
MemberGroupEvent.Type - Enum in io.atomix.primitive.partition
Member group event type.
MemberGroupEventListener - Interface in io.atomix.primitive.partition
Member group event listener.
MemberGroupId - Class in io.atomix.primitive.partition
Member group identifier.
MemberGroupId(String) - Constructor for class io.atomix.primitive.partition.MemberGroupId
 
MemberGroupProvider - Interface in io.atomix.primitive.partition
Member group provider.
MemberGroupService - Interface in io.atomix.primitive.partition
Member group service.
MemberGroupStrategy - Enum in io.atomix.primitive.partition
Member group strategy.
MemberId - Class in io.atomix.cluster
Controller cluster identity.
MemberId(String) - Constructor for class io.atomix.cluster.MemberId
 
memberId() - Method in class io.atomix.primitive.partition.GroupMember
Returns the member ID.
memberId() - Method in interface io.atomix.primitive.session.Session
Returns the member identifier to which the session belongs.
members() - Method in interface io.atomix.primitive.partition.Partition
Returns the collection of all members in the partition.
members() - Method in class io.atomix.primitive.partition.PartitionGroupMembership
Returns the partition group members.
members() - Method in class io.atomix.primitive.partition.PartitionMetadata
Returns the controller nodes that are members of this partition.
members() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
members() - Method in class io.atomix.protocols.raft.partition.RaftPartition
 
membership() - Method in class io.atomix.primitive.partition.PartitionGroupMembershipEvent
Returns the partition group membership.
MembershipConfig - Class in io.atomix.cluster
Cluster membership configuration.
MembershipConfig() - Constructor for class io.atomix.cluster.MembershipConfig
 
message() - Method in class io.atomix.protocols.raft.RaftError
Returns the error message.
MessagingConfig - Class in io.atomix.cluster.messaging
Messaging configuration.
MessagingConfig() - Constructor for class io.atomix.cluster.messaging.MessagingConfig
 
MessagingException - Exception in io.atomix.cluster.messaging
Top level exception for MessagingService failures.
MessagingException() - Constructor for exception io.atomix.cluster.messaging.MessagingException
 
MessagingException(String) - Constructor for exception io.atomix.cluster.messaging.MessagingException
 
MessagingException(String, Throwable) - Constructor for exception io.atomix.cluster.messaging.MessagingException
 
MessagingException(Throwable) - Constructor for exception io.atomix.cluster.messaging.MessagingException
 
MessagingException.NoRemoteHandler - Exception in io.atomix.cluster.messaging
Exception indicating no remote registered remote handler.
MessagingException.ProtocolException - Exception in io.atomix.cluster.messaging
Exception indicating failure due to invalid message structure such as an incorrect preamble.
MessagingException.RemoteHandlerFailure - Exception in io.atomix.cluster.messaging
Exception indicating handler failure.
MessagingService - Interface in io.atomix.cluster.messaging
Interface for low level messaging primitives.
MessagingService.Builder - Class in io.atomix.cluster.messaging
Messaging service builder.
metadata() - Method in interface io.atomix.protocols.raft.RaftClient
Returns the Raft metadata.
minor() - Method in class io.atomix.utils.Version
Returns the minor version number.
minTimeout() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the minimum session timeout.
multicast(String, M, Set<MemberId>) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Multicasts a message to a set of members over TCP.
multicast(String, M, Set<MemberId>, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Multicasts a message to a set of members.
multicast(String, M, Function<M, byte[]>, Set<MemberId>) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Multicasts a message to a set of members over TCP.
multicast(String, M, Function<M, byte[]>, Set<MemberId>, boolean) - Method in interface io.atomix.cluster.messaging.ClusterCommunicationService
Multicasts a message to a set of members.
MulticastConfig - Class in io.atomix.cluster
Multicast configuration.
MulticastConfig() - Constructor for class io.atomix.cluster.MulticastConfig
 
MulticastDiscoveryBuilder - Class in io.atomix.cluster.discovery
Multicast discovery provider builder.
MulticastDiscoveryConfig - Class in io.atomix.cluster.discovery
Multicast discovery configuration.
MulticastDiscoveryConfig() - Constructor for class io.atomix.cluster.discovery.MulticastDiscoveryConfig
 
MulticastDiscoveryProvider - Class in io.atomix.cluster.discovery
Cluster membership provider that uses multicast for member discovery.
MulticastDiscoveryProvider() - Constructor for class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
MulticastDiscoveryProvider(MulticastDiscoveryConfig) - Constructor for class io.atomix.cluster.discovery.MulticastDiscoveryProvider
 
MulticastDiscoveryProvider.Type - Class in io.atomix.cluster.discovery
Broadcast member location provider type.
MultimapBuilder<B extends MultimapBuilder<B,C,P,K,V>,C extends MultimapConfig<C>,P extends SyncPrimitive,K,V> - Class in io.atomix.core.multimap
Base multimap builder.
multimapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedMultimap builder.
MultimapConfig<C extends MultimapConfig<C>> - Class in io.atomix.core.multimap
Multimap configuration.
MultimapConfig() - Constructor for class io.atomix.core.multimap.MultimapConfig
 
MultimapEvent<K,V> - Class in io.atomix.core.multimap
Representation of a ConsistentMultimap update notification.
MultimapEvent(MultimapEvent.Type, K, V, V) - Constructor for class io.atomix.core.multimap.MultimapEvent
Creates a new event object.
MultimapEvent.Type - Enum in io.atomix.core.multimap
MultimapEvent type.
MultimapEventListener<K,V> - Interface in io.atomix.core.multimap
Listener to be notified about updates to a ConsistentMultimap.
MultiPrimaryProtocol - Class in io.atomix.protocols.backup
Multi-primary protocol.
MultiPrimaryProtocol.Type - Class in io.atomix.protocols.backup
Multi-primary protocol type.
MultiPrimaryProtocolBuilder - Class in io.atomix.protocols.backup
Multi-primary protocol builder.
MultiPrimaryProtocolConfig - Class in io.atomix.protocols.backup
Multi-primary protocol configuration.
MultiPrimaryProtocolConfig() - Constructor for class io.atomix.protocols.backup.MultiPrimaryProtocolConfig
 
MultiRaftProtocol - Class in io.atomix.protocols.raft
Multi-Raft protocol.
MultiRaftProtocol.Type - Class in io.atomix.protocols.raft
Multi-Raft protocol type.
MultiRaftProtocolBuilder - Class in io.atomix.protocols.raft
Multi-Raft protocol builder.
MultiRaftProtocolConfig - Class in io.atomix.protocols.raft
Raft protocol configuration.
MultiRaftProtocolConfig() - Constructor for class io.atomix.protocols.raft.MultiRaftProtocolConfig
 
multisetBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedMultiset builder.
MultiValuedTimestamp<T extends Comparable<T>,U extends Comparable<U>> - Class in io.atomix.utils.time
A logical timestamp that derives its value from two input values.
MultiValuedTimestamp(T, U) - Constructor for class io.atomix.utils.time.MultiValuedTimestamp
Creates a new timestamp based on two values.
MURMUR3 - Static variable in interface io.atomix.primitive.partition.Partitioner
Murmur 3 partitioner.
Murmur3Partitioner - Class in io.atomix.primitive.partition
Murmur 3 partitioner.
Murmur3Partitioner() - Constructor for class io.atomix.primitive.partition.Murmur3Partitioner
 

N

name() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider.Type
 
name() - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider.Type
 
name() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider.Type
 
name() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol.Type
 
name() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol.Type
 
name() - Method in class io.atomix.core.barrier.DistributedCyclicBarrierType
 
name() - Method in class io.atomix.core.collection.DistributedCollectionType
 
name() - Method in class io.atomix.core.counter.AtomicCounterType
 
name() - Method in class io.atomix.core.counter.DistributedCounterType
 
name() - Method in class io.atomix.core.election.LeaderElectionType
 
name() - Method in class io.atomix.core.election.LeaderElectorType
 
name() - Method in class io.atomix.core.idgenerator.AtomicIdGeneratorType
 
name() - Method in class io.atomix.core.list.DistributedListType
 
name() - Method in class io.atomix.core.lock.AtomicLockType
 
name() - Method in class io.atomix.core.lock.DistributedLockType
 
name() - Method in class io.atomix.core.map.AtomicCounterMapType
 
name() - Method in class io.atomix.core.map.AtomicMapType
 
name() - Method in class io.atomix.core.map.AtomicNavigableMapType
 
name() - Method in class io.atomix.core.map.AtomicSortedMapType
 
name() - Method in class io.atomix.core.map.DistributedMapType
 
name() - Method in class io.atomix.core.map.DistributedNavigableMapType
 
name() - Method in class io.atomix.core.map.DistributedSortedMapType
 
name() - Method in class io.atomix.core.multimap.AtomicMultimapType
 
name() - Method in class io.atomix.core.multimap.DistributedMultimapType
 
name() - Method in class io.atomix.core.multiset.DistributedMultisetType
 
name() - Method in class io.atomix.core.profile.ClientProfile.Type
 
name() - Method in class io.atomix.core.profile.ConsensusProfile.Type
 
name() - Method in class io.atomix.core.profile.DataGridProfile.Type
 
name() - Method in class io.atomix.core.queue.DistributedQueueType
 
name() - Method in class io.atomix.core.semaphore.AtomicSemaphoreType
 
name() - Method in class io.atomix.core.semaphore.DistributedSemaphoreType
 
name() - Method in class io.atomix.core.set.DistributedNavigableSetType
 
name() - Method in class io.atomix.core.set.DistributedSetType
 
name() - Method in class io.atomix.core.set.DistributedSortedSetType
 
name() - Method in class io.atomix.core.transaction.ParticipantInfo
Returns the participant name.
name() - Method in class io.atomix.core.transaction.TransactionType
 
name() - Method in class io.atomix.core.tree.AtomicDocumentTreeType
 
name() - Method in class io.atomix.core.value.AtomicValueType
 
name() - Method in class io.atomix.core.value.DistributedValueType
 
name() - Method in class io.atomix.core.workqueue.WorkQueueType
 
name() - Method in class io.atomix.primitive.AbstractAsyncPrimitive
 
name() - Method in interface io.atomix.primitive.DistributedPrimitive
Returns the name of this primitive.
name() - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns the partition group name.
name() - Method in class io.atomix.primitive.PrimitiveInfo
Returns the primitive name.
name() - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the primitive name.
name() - Method in interface io.atomix.primitive.proxy.ProxySession
Returns the primitive name.
name() - Method in interface io.atomix.primitive.session.SessionClient
Returns the primitive name.
name() - Method in class io.atomix.primitive.Synchronous
 
name() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocol.Type
 
name() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
Returns the partition name.
name() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
name() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup.Type
 
name() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
name() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocol.Type
 
name() - Method in class io.atomix.protocols.gossip.CrdtProtocol.Type
 
name() - Method in class io.atomix.protocols.raft.MultiRaftProtocol.Type
 
name() - Method in class io.atomix.protocols.raft.partition.RaftPartition
Returns the partition name.
name() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
name() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Type
 
name() - Method in interface io.atomix.protocols.raft.RaftServer
Returns the server name.
name() - Method in class io.atomix.utils.AbstractNamed
 
name() - Method in interface io.atomix.utils.Named
Returns the object name.
name() - Method in interface io.atomix.utils.Type
Returns the type name.
Named - Interface in io.atomix.utils
Named object.
NamedConfig<C extends NamedConfig<C>> - Interface in io.atomix.utils.config
Named configuration.
NamedType - Interface in io.atomix.utils
Named type.
namespace() - Method in class io.atomix.core.barrier.DistributedCyclicBarrierType
 
namespace() - Method in class io.atomix.core.election.LeaderElectionType
 
namespace() - Method in class io.atomix.core.election.LeaderElectorType
 
namespace() - Method in class io.atomix.core.list.DistributedListType
 
namespace() - Method in class io.atomix.core.map.AtomicMapType
 
namespace() - Method in class io.atomix.core.map.AtomicNavigableMapType
 
namespace() - Method in class io.atomix.core.map.AtomicSortedMapType
 
namespace() - Method in class io.atomix.core.map.DistributedMapType
 
namespace() - Method in class io.atomix.core.map.DistributedNavigableMapType
 
namespace() - Method in class io.atomix.core.map.DistributedSortedMapType
 
namespace() - Method in class io.atomix.core.multimap.AtomicMultimapType
 
namespace() - Method in class io.atomix.core.multimap.DistributedMultimapType
 
namespace() - Method in class io.atomix.core.multiset.DistributedMultisetType
 
namespace() - Method in class io.atomix.core.queue.DistributedQueueType
 
namespace() - Method in class io.atomix.core.semaphore.AtomicSemaphoreType
 
namespace() - Method in class io.atomix.core.semaphore.DistributedSemaphoreType
 
namespace() - Method in class io.atomix.core.set.DistributedNavigableSetType
 
namespace() - Method in class io.atomix.core.set.DistributedSetType
 
namespace() - Method in class io.atomix.core.set.DistributedSortedSetType
 
namespace() - Method in class io.atomix.core.tree.AtomicDocumentTreeType
 
namespace() - Method in class io.atomix.core.workqueue.WorkQueueType
 
namespace() - Method in interface io.atomix.primitive.partition.PartitionGroup.Type
Returns the partition group namespace.
namespace() - Method in interface io.atomix.primitive.PrimitiveType
Returns the primitive type namespace.
namespace() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup.Type
 
namespace() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Type
 
Namespace - Class in io.atomix.utils.serializer
Pool of Kryo instances, with classes pre-registered.
Namespace(NamespaceConfig) - Constructor for class io.atomix.utils.serializer.Namespace
 
Namespace.Builder - Class in io.atomix.utils.serializer
KryoNamespace builder.
NamespaceConfig - Class in io.atomix.utils.serializer
Namespace configuration.
NamespaceConfig() - Constructor for class io.atomix.utils.serializer.NamespaceConfig
 
Namespaces - Class in io.atomix.utils.serializer
 
NamespaceTypeConfig - Class in io.atomix.utils.serializer
Namespace type configuration.
NamespaceTypeConfig() - Constructor for class io.atomix.utils.serializer.NamespaceTypeConfig
 
navigableKeySet() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Returns a NavigableSet view of the keys contained in this map.
navigableKeySet() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Returns a NavigableSet view of the keys contained in this map.
navigableKeySet() - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns a navigable set of the keys in this map.
navigableKeySet() - Method in interface io.atomix.core.map.DistributedNavigableMap
 
navigableMapBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedNavigableMap builder.
NavigableMapCompatibleBuilder<B extends NavigableMapCompatibleBuilder<B>> - Interface in io.atomix.primitive.protocol.map
Map builder.
NavigableMapDelegate<K,V> - Interface in io.atomix.primitive.protocol.map
Navigable map protocol.
NavigableMapProtocol - Interface in io.atomix.primitive.protocol.map
Navigable map protocol.
navigableSetBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedNavigableSet builder.
NavigableSetCompatibleBuilder<B extends NavigableSetCompatibleBuilder<B>> - Interface in io.atomix.primitive.protocol.set
Set builder.
NavigableSetDelegate<E> - Interface in io.atomix.primitive.protocol.set
Navigable set protocol.
NavigableSetProtocol - Interface in io.atomix.primitive.protocol.set
Navigable set protocol.
newBuilder(String, DistributedCyclicBarrierConfig, PrimitiveManagementService) - Method in class io.atomix.core.barrier.DistributedCyclicBarrierType
 
newBuilder(String, DistributedCollectionConfig, PrimitiveManagementService) - Method in class io.atomix.core.collection.DistributedCollectionType
 
newBuilder(String, AtomicCounterConfig, PrimitiveManagementService) - Method in class io.atomix.core.counter.AtomicCounterType
 
newBuilder(String, DistributedCounterConfig, PrimitiveManagementService) - Method in class io.atomix.core.counter.DistributedCounterType
 
newBuilder(String, LeaderElectionConfig, PrimitiveManagementService) - Method in class io.atomix.core.election.LeaderElectionType
 
newBuilder(String, LeaderElectorConfig, PrimitiveManagementService) - Method in class io.atomix.core.election.LeaderElectorType
 
newBuilder(String, AtomicIdGeneratorConfig, PrimitiveManagementService) - Method in class io.atomix.core.idgenerator.AtomicIdGeneratorType
 
newBuilder(String, DistributedListConfig, PrimitiveManagementService) - Method in class io.atomix.core.list.DistributedListType
 
newBuilder(String, AtomicLockConfig, PrimitiveManagementService) - Method in class io.atomix.core.lock.AtomicLockType
 
newBuilder(String, DistributedLockConfig, PrimitiveManagementService) - Method in class io.atomix.core.lock.DistributedLockType
 
newBuilder(String, AtomicCounterMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.AtomicCounterMapType
 
newBuilder(String, AtomicMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.AtomicMapType
 
newBuilder(String, AtomicNavigableMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.AtomicNavigableMapType
 
newBuilder(String, AtomicSortedMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.AtomicSortedMapType
 
newBuilder(String, DistributedMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.DistributedMapType
 
newBuilder(String, DistributedNavigableMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.DistributedNavigableMapType
 
newBuilder(String, DistributedSortedMapConfig, PrimitiveManagementService) - Method in class io.atomix.core.map.DistributedSortedMapType
 
newBuilder(String, AtomicMultimapConfig, PrimitiveManagementService) - Method in class io.atomix.core.multimap.AtomicMultimapType
 
newBuilder(String, DistributedMultimapConfig, PrimitiveManagementService) - Method in class io.atomix.core.multimap.DistributedMultimapType
 
newBuilder(String, DistributedMultisetConfig, PrimitiveManagementService) - Method in class io.atomix.core.multiset.DistributedMultisetType
 
newBuilder(String, DistributedQueueConfig, PrimitiveManagementService) - Method in class io.atomix.core.queue.DistributedQueueType
 
newBuilder(String, AtomicSemaphoreConfig, PrimitiveManagementService) - Method in class io.atomix.core.semaphore.AtomicSemaphoreType
 
newBuilder(String, DistributedSemaphoreConfig, PrimitiveManagementService) - Method in class io.atomix.core.semaphore.DistributedSemaphoreType
 
newBuilder(String, DistributedNavigableSetConfig, PrimitiveManagementService) - Method in class io.atomix.core.set.DistributedNavigableSetType
 
newBuilder(String, DistributedSetConfig, PrimitiveManagementService) - Method in class io.atomix.core.set.DistributedSetType
 
newBuilder(String, DistributedSortedSetConfig, PrimitiveManagementService) - Method in class io.atomix.core.set.DistributedSortedSetType
 
newBuilder(String, TransactionConfig, PrimitiveManagementService) - Method in class io.atomix.core.transaction.TransactionType
 
newBuilder(String, AtomicDocumentTreeConfig, PrimitiveManagementService) - Method in class io.atomix.core.tree.AtomicDocumentTreeType
 
newBuilder(String, AtomicValueConfig, PrimitiveManagementService) - Method in class io.atomix.core.value.AtomicValueType
 
newBuilder(String, DistributedValueConfig, PrimitiveManagementService) - Method in class io.atomix.core.value.DistributedValueType
 
newBuilder(String, WorkQueueConfig, PrimitiveManagementService) - Method in class io.atomix.core.workqueue.WorkQueueType
 
newBuilder(String, C, PrimitiveManagementService) - Method in interface io.atomix.primitive.PrimitiveType
Returns a new primitive builder.
newBuilder() - Method in interface io.atomix.primitive.serialization.SerializationService
Returns a new serializer builder.
newBuilder(String) - Method in interface io.atomix.primitive.serialization.SerializationService
Returns a new serializer builder.
newConfig() - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider.Type
 
newConfig() - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider.Type
 
newConfig() - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider.Type
 
newConfig() - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol.Type
 
newConfig() - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol.Type
 
newConfig() - Method in class io.atomix.core.barrier.DistributedCyclicBarrierType
 
newConfig() - Method in class io.atomix.core.collection.DistributedCollectionType
 
newConfig() - Method in class io.atomix.core.counter.AtomicCounterType
 
newConfig() - Method in class io.atomix.core.counter.DistributedCounterType
 
newConfig() - Method in class io.atomix.core.election.LeaderElectionType
 
newConfig() - Method in class io.atomix.core.election.LeaderElectorType
 
newConfig() - Method in class io.atomix.core.idgenerator.AtomicIdGeneratorType
 
newConfig() - Method in class io.atomix.core.list.DistributedListType
 
newConfig() - Method in class io.atomix.core.lock.AtomicLockType
 
newConfig() - Method in class io.atomix.core.lock.DistributedLockType
 
newConfig() - Method in class io.atomix.core.map.AtomicCounterMapType
 
newConfig() - Method in class io.atomix.core.map.AtomicMapType
 
newConfig() - Method in class io.atomix.core.map.AtomicNavigableMapType
 
newConfig() - Method in class io.atomix.core.map.AtomicSortedMapType
 
newConfig() - Method in class io.atomix.core.map.DistributedMapType
 
newConfig() - Method in class io.atomix.core.map.DistributedNavigableMapType
 
newConfig() - Method in class io.atomix.core.map.DistributedSortedMapType
 
newConfig() - Method in class io.atomix.core.multimap.AtomicMultimapType
 
newConfig() - Method in class io.atomix.core.multimap.DistributedMultimapType
 
newConfig() - Method in class io.atomix.core.multiset.DistributedMultisetType
 
newConfig() - Method in class io.atomix.core.profile.ClientProfile.Type
 
newConfig() - Method in class io.atomix.core.profile.ConsensusProfile.Type
 
newConfig() - Method in class io.atomix.core.profile.DataGridProfile.Type
 
newConfig() - Method in class io.atomix.core.queue.DistributedQueueType
 
newConfig() - Method in class io.atomix.core.semaphore.AtomicSemaphoreType
 
newConfig() - Method in class io.atomix.core.semaphore.DistributedSemaphoreType
 
newConfig() - Method in class io.atomix.core.set.DistributedNavigableSetType
 
newConfig() - Method in class io.atomix.core.set.DistributedSetType
 
newConfig() - Method in class io.atomix.core.set.DistributedSortedSetType
 
newConfig() - Method in class io.atomix.core.transaction.TransactionType
 
newConfig() - Method in class io.atomix.core.tree.AtomicDocumentTreeType
 
newConfig() - Method in class io.atomix.core.value.AtomicValueType
 
newConfig() - Method in class io.atomix.core.value.DistributedValueType
 
newConfig() - Method in class io.atomix.core.workqueue.WorkQueueType
 
newConfig() - Method in interface io.atomix.primitive.PrimitiveType
Returns a new instance of the primitive configuration.
newConfig() - Method in class io.atomix.protocols.backup.MultiPrimaryProtocol.Type
 
newConfig() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup.Type
 
newConfig() - Method in class io.atomix.protocols.gossip.AntiEntropyProtocol.Type
 
newConfig() - Method in class io.atomix.protocols.gossip.CrdtProtocol.Type
 
newConfig() - Method in class io.atomix.protocols.raft.MultiRaftProtocol.Type
 
newConfig() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Type
 
newConfig() - Method in interface io.atomix.utils.ConfiguredType
Returns a new configuration.
newCounterDelegate(String, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.counter.CounterProtocol
Returns a new counter delegate.
newCounterDelegate(String, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.CrdtProtocol
 
newLeadership() - Method in class io.atomix.core.election.LeadershipEvent
Returns the new leadership for the topic.
newMapDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.map.MapProtocol
Returns a new map delegate.
newMapDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.AntiEntropyProtocol
 
newNavigableMapDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.map.NavigableMapProtocol
Returns a new navigable map delegate.
newNavigableSetDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.set.NavigableSetProtocol
Returns a new set delegate.
newNavigableSetDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.CrdtProtocol
 
newPartitionGroup(C) - Method in interface io.atomix.primitive.partition.PartitionGroup.Type
Creates a new partition group instance.
newPartitionGroup(PrimaryBackupPartitionGroupConfig) - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup.Type
 
newPartitionGroup(RaftPartitionGroupConfig) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Type
 
newProfile(ClientProfileConfig) - Method in class io.atomix.core.profile.ClientProfile.Type
 
newProfile(ConsensusProfileConfig) - Method in class io.atomix.core.profile.ConsensusProfile.Type
 
newProfile(DataGridProfileConfig) - Method in class io.atomix.core.profile.DataGridProfile.Type
 
newProfile(C) - Method in interface io.atomix.core.profile.Profile.Type
Creates a new instance of the profile.
newProtocol(C) - Method in interface io.atomix.cluster.protocol.GroupMembershipProtocol.Type
Creates a new instance of the protocol.
newProtocol(PhiMembershipProtocolConfig) - Method in class io.atomix.cluster.protocol.PhiMembershipProtocol.Type
 
newProtocol(SwimMembershipProtocolConfig) - Method in class io.atomix.cluster.protocol.SwimMembershipProtocol.Type
 
newProtocol() - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns a new primitive protocol.
newProtocol(C) - Method in interface io.atomix.primitive.protocol.PrimitiveProtocol.Type
Creates a new protocol instance.
newProtocol(MultiPrimaryProtocolConfig) - Method in class io.atomix.protocols.backup.MultiPrimaryProtocol.Type
 
newProtocol() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
newProtocol(AntiEntropyProtocolConfig) - Method in class io.atomix.protocols.gossip.AntiEntropyProtocol.Type
 
newProtocol(CrdtProtocolConfig) - Method in class io.atomix.protocols.gossip.CrdtProtocol.Type
 
newProtocol(MultiRaftProtocolConfig) - Method in class io.atomix.protocols.raft.MultiRaftProtocol.Type
 
newProtocol() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
newProvider(BootstrapDiscoveryConfig) - Method in class io.atomix.cluster.discovery.BootstrapDiscoveryProvider.Type
 
newProvider(DnsDiscoveryConfig) - Method in class io.atomix.cluster.discovery.DnsDiscoveryProvider.Type
 
newProvider(MulticastDiscoveryConfig) - Method in class io.atomix.cluster.discovery.MulticastDiscoveryProvider.Type
 
newProvider(C) - Method in interface io.atomix.cluster.discovery.NodeDiscoveryProvider.Type
Creates a new instance of the provider.
newProxy(String, PrimitiveType, Class<S>, ServiceConfig, PartitionService) - Method in interface io.atomix.primitive.protocol.ProxyProtocol
Returns a new primitive proxy for the given partition group.
newProxy(String, PrimitiveType, Class<S>, ServiceConfig, PartitionService) - Method in class io.atomix.protocols.backup.MultiPrimaryProtocol
 
newProxy(String, PrimitiveType, Class<S>, ServiceConfig, PartitionService) - Method in class io.atomix.protocols.raft.MultiRaftProtocol
 
newService(ServiceConfig) - Method in class io.atomix.core.barrier.DistributedCyclicBarrierType
 
newService(ServiceConfig) - Method in class io.atomix.core.collection.DistributedCollectionType
 
newService(ServiceConfig) - Method in class io.atomix.core.counter.AtomicCounterType
 
newService(ServiceConfig) - Method in class io.atomix.core.counter.DistributedCounterType
 
newService(ServiceConfig) - Method in class io.atomix.core.election.LeaderElectionType
 
newService(ServiceConfig) - Method in class io.atomix.core.election.LeaderElectorType
 
newService(ServiceConfig) - Method in class io.atomix.core.idgenerator.AtomicIdGeneratorType
 
newService(ServiceConfig) - Method in class io.atomix.core.list.DistributedListType
 
newService(ServiceConfig) - Method in class io.atomix.core.lock.AtomicLockType
 
newService(ServiceConfig) - Method in class io.atomix.core.lock.DistributedLockType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.AtomicCounterMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.AtomicMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.AtomicNavigableMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.AtomicSortedMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.DistributedMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.DistributedNavigableMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.map.DistributedSortedMapType
 
newService(ServiceConfig) - Method in class io.atomix.core.multimap.AtomicMultimapType
 
newService(ServiceConfig) - Method in class io.atomix.core.multimap.DistributedMultimapType
 
newService(ServiceConfig) - Method in class io.atomix.core.multiset.DistributedMultisetType
 
newService(ServiceConfig) - Method in class io.atomix.core.queue.DistributedQueueType
 
newService(ServiceConfig) - Method in class io.atomix.core.semaphore.AtomicSemaphoreType
 
newService(ServiceConfig) - Method in class io.atomix.core.semaphore.DistributedSemaphoreType
 
newService(ServiceConfig) - Method in class io.atomix.core.set.DistributedNavigableSetType
 
newService(ServiceConfig) - Method in class io.atomix.core.set.DistributedSetType
 
newService(ServiceConfig) - Method in class io.atomix.core.set.DistributedSortedSetType
 
newService(ServiceConfig) - Method in class io.atomix.core.transaction.TransactionType
 
newService(ServiceConfig) - Method in class io.atomix.core.tree.AtomicDocumentTreeType
 
newService(ServiceConfig) - Method in class io.atomix.core.value.AtomicValueType
 
newService(ServiceConfig) - Method in class io.atomix.core.value.DistributedValueType
 
newService(ServiceConfig) - Method in class io.atomix.core.workqueue.WorkQueueType
 
newService(ServiceConfig) - Method in interface io.atomix.primitive.PrimitiveType
Creates a new service instance from the given configuration.
newSetDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.set.SetProtocol
Returns a new set delegate.
newSetDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.AntiEntropyProtocol
 
newSetDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.CrdtProtocol
 
newSortedMapDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.map.SortedMapProtocol
Returns a new sorted map delegate.
newSortedSetDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.set.SortedSetProtocol
Returns a new set delegate.
newSortedSetDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.CrdtProtocol
 
newValue() - Method in class io.atomix.core.map.AtomicMapEvent
Returns the new value in the map associated with the key.
newValue() - Method in class io.atomix.core.map.MapEvent
Returns the new value in the map associated with the key.
newValue() - Method in class io.atomix.core.multimap.AtomicMultimapEvent
Returns the new value in the map associated with the key.
newValue() - Method in class io.atomix.core.multimap.MultimapEvent
Returns the new value in the map associated with the key.
newValue() - Method in class io.atomix.core.tree.DocumentTreeEvent
Returns the new value.
newValue() - Method in class io.atomix.core.value.AtomicValueEvent
Returns the newly set value.
newValue() - Method in class io.atomix.core.value.ValueEvent
Returns the newly set value.
newValueDelegate(String, Serializer, PrimitiveManagementService) - Method in interface io.atomix.primitive.protocol.value.ValueProtocol
Returns a new value delegate.
newValueDelegate(String, Serializer, PrimitiveManagementService) - Method in class io.atomix.protocols.gossip.CrdtProtocol
 
next() - Method in interface io.atomix.core.iterator.AsyncIterator
Returns the next item in the iterator.
nextCommandSequence() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the next operation sequence number.
nextId() - Method in interface io.atomix.core.idgenerator.AsyncAtomicIdGenerator
Returns the next globally unique numeric ID.
nextId() - Method in interface io.atomix.core.idgenerator.AtomicIdGenerator
Gets the next globally unique numeric identifier.
nextId(int) - Method in class io.atomix.utils.serializer.Namespace.Builder
Sets the next Kryo registration Id for following register entries.
nextRequestSequence() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the next request sequence number.
nextSessionId() - Method in interface io.atomix.primitive.session.SessionIdService
Returns the next unique session identifier.
node() - Method in class io.atomix.cluster.discovery.NodeDiscoveryEvent
Returns the node.
Node - Class in io.atomix.cluster
Represents a node.
Node(NodeConfig) - Constructor for class io.atomix.cluster.Node
 
NodeBuilder - Class in io.atomix.cluster
Node builder.
NodeConfig - Class in io.atomix.cluster
Node configuration.
NodeConfig() - Constructor for class io.atomix.cluster.NodeConfig
 
NodeDiscoveryBuilder - Class in io.atomix.cluster.discovery
Node discovery builder.
NodeDiscoveryBuilder() - Constructor for class io.atomix.cluster.discovery.NodeDiscoveryBuilder
 
NodeDiscoveryConfig - Class in io.atomix.cluster.discovery
Node discovery configuration.
NodeDiscoveryConfig() - Constructor for class io.atomix.cluster.discovery.NodeDiscoveryConfig
 
NodeDiscoveryEvent - Class in io.atomix.cluster.discovery
Node discovery event.
NodeDiscoveryEvent(NodeDiscoveryEvent.Type, Node) - Constructor for class io.atomix.cluster.discovery.NodeDiscoveryEvent
 
NodeDiscoveryEvent(NodeDiscoveryEvent.Type, Node, long) - Constructor for class io.atomix.cluster.discovery.NodeDiscoveryEvent
 
NodeDiscoveryEvent.Type - Enum in io.atomix.cluster.discovery
Node discovery event type.
NodeDiscoveryEventListener - Interface in io.atomix.cluster.discovery
Node discovery event listener.
NodeDiscoveryProvider - Interface in io.atomix.cluster.discovery
Cluster membership provider.
NodeDiscoveryProvider.Type<C extends NodeDiscoveryConfig> - Interface in io.atomix.cluster.discovery
Membership provider type.
NodeDiscoveryService - Interface in io.atomix.cluster.discovery
Node discovery service.
NodeId - Class in io.atomix.cluster
Node identifier.
NodeId(String) - Constructor for class io.atomix.cluster.NodeId
Creates a new cluster node identifier from the specified string.
NoLeader(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.NoLeader
 
NoRemoteHandler() - Constructor for exception io.atomix.cluster.messaging.MessagingException.NoRemoteHandler
 
NoSuchDocumentPathException - Exception in io.atomix.core.tree
An exception to be thrown when an invalid path is passed to the DocumentTree.
NoSuchDocumentPathException() - Constructor for exception io.atomix.core.tree.NoSuchDocumentPathException
 
NoSuchDocumentPathException(String) - Constructor for exception io.atomix.core.tree.NoSuchDocumentPathException
 
NoSuchDocumentPathException(String, Throwable) - Constructor for exception io.atomix.core.tree.NoSuchDocumentPathException
 
NoSuchDocumentPathException(Throwable) - Constructor for exception io.atomix.core.tree.NoSuchDocumentPathException
 

O

of(long) - Static method in class io.atomix.utils.time.Epoch
Returns a new logical timestamp for the given logical time.
of(long) - Static method in class io.atomix.utils.time.LogicalTimestamp
Returns a new logical timestamp for the given logical time.
offer(E) - Method in interface io.atomix.core.queue.AsyncDistributedQueue
Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions.
oldLeadership() - Method in class io.atomix.core.election.LeadershipEvent
Returns the prior leadership for the topic.
oldValue() - Method in class io.atomix.core.map.AtomicMapEvent
Returns the value associated with the key, before it was updated.
oldValue() - Method in class io.atomix.core.map.MapEvent
Returns the value associated with the key, before it was updated.
oldValue() - Method in class io.atomix.core.multimap.AtomicMultimapEvent
Returns the old value that was associated with the key.
oldValue() - Method in class io.atomix.core.multimap.MultimapEvent
Returns the old value that was associated with the key.
oldValue() - Method in class io.atomix.core.tree.DocumentTreeEvent
Returns the old value.
oldValue() - Method in class io.atomix.core.value.AtomicValueEvent
Returns the old replaced value.
oldValue() - Method in class io.atomix.core.value.ValueEvent
Returns the old replaced value.
onClose(Session) - Method in interface io.atomix.primitive.session.SessionListener
Called when a session was closed by the client.
onExpire(Session) - Method in interface io.atomix.primitive.session.SessionListener
Called when a session is expired by the system.
onOpen(Session) - Method in interface io.atomix.primitive.session.SessionListener
Called when a new session is registered.
onProcessLimit() - Method in interface io.atomix.utils.event.EventSink
Handles notification that event processing time limit has been exceeded.
onProcessLimit() - Method in class io.atomix.utils.event.ListenerRegistry
 
open() - Method in class io.atomix.protocols.raft.session.RaftSession
Opens the session.
openSession(long, long, RaftSession) - Method in class io.atomix.protocols.raft.service.RaftServiceContext
Registers the given session.
Operation - Annotation Type in io.atomix.primitive.operation
Operation annotation.
operation(OperationId) - Static method in class io.atomix.primitive.operation.PrimitiveOperation
Creates a new primitive operation with a simplified identifier and a null value.
operation(OperationId, byte[]) - Static method in class io.atomix.primitive.operation.PrimitiveOperation
Creates a new primitive operation with a simplified identifier.
operation() - Method in interface io.atomix.primitive.service.Commit
Returns the operation identifier.
OperationFailure(RaftError.Type, String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.OperationFailure
 
OperationId - Interface in io.atomix.primitive.operation
Raft operation identifier.
Operations - Class in io.atomix.primitive.operation
Operation utilities.
OperationType - Enum in io.atomix.primitive.operation
Raft operation type.
Ordering - Enum in io.atomix.primitive
Describes the order of a primitive data structure.
OutOfDiskSpace(String) - Constructor for exception io.atomix.storage.StorageException.OutOfDiskSpace
 

P

parent() - Method in class io.atomix.core.tree.DocumentPath
Returns a path for the parent of this node.
ParticipantInfo - Class in io.atomix.core.transaction
Transaction participant info.
ParticipantInfo(String, String, String, String) - Constructor for class io.atomix.core.transaction.ParticipantInfo
 
partition(String, List<PartitionId>) - Method in class io.atomix.primitive.partition.Murmur3Partitioner
 
Partition - Interface in io.atomix.primitive.partition
Atomix partition.
partition(K, List<PartitionId>) - Method in interface io.atomix.primitive.partition.Partitioner
Returns the partition ID to which the specified object maps.
PartitionClient - Interface in io.atomix.primitive.partition
Primitive client.
Partitioner<K> - Interface in io.atomix.primitive.partition
Interface for mapping from an object to partition ID.
PartitionGroup - Interface in io.atomix.primitive.partition
Primitive partition group.
PartitionGroup.Builder<C extends PartitionGroupConfig<C>> - Class in io.atomix.primitive.partition
Partition group builder.
PartitionGroup.Type<C extends PartitionGroupConfig<C>> - Interface in io.atomix.primitive.partition
Partition group type.
PartitionGroupConfig<C extends PartitionGroupConfig<C>> - Class in io.atomix.primitive.partition
Partition group configuration.
PartitionGroupConfig() - Constructor for class io.atomix.primitive.partition.PartitionGroupConfig
 
PartitionGroupFactory<C extends PartitionGroupConfig<C>,P extends ManagedPartitionGroup> - Interface in io.atomix.primitive.partition
Partition group factory.
PartitionGroupMembership - Class in io.atomix.primitive.partition
Partition group membership information.
PartitionGroupMembership(String, PartitionGroupConfig, Set<MemberId>, boolean) - Constructor for class io.atomix.primitive.partition.PartitionGroupMembership
 
PartitionGroupMembershipEvent - Class in io.atomix.primitive.partition
Partition group membership event.
PartitionGroupMembershipEvent(PartitionGroupMembershipEvent.Type, PartitionGroupMembership) - Constructor for class io.atomix.primitive.partition.PartitionGroupMembershipEvent
 
PartitionGroupMembershipEvent(PartitionGroupMembershipEvent.Type, PartitionGroupMembership, long) - Constructor for class io.atomix.primitive.partition.PartitionGroupMembershipEvent
 
PartitionGroupMembershipEvent.Type - Enum in io.atomix.primitive.partition
Partition group membership event type.
PartitionGroupMembershipEventListener - Interface in io.atomix.primitive.partition
Partition group membership event listener.
PartitionGroupMembershipService - Interface in io.atomix.primitive.partition
Partition group membership service.
PartitionGroupTypeRegistry - Interface in io.atomix.primitive.partition
Partition group type registry.
PartitionId - Class in io.atomix.primitive.partition
PartitionMetadata identifier.
PartitionId(String, int) - Constructor for class io.atomix.primitive.partition.PartitionId
Creates a partition identifier from an integer.
partitionId() - Method in class io.atomix.primitive.partition.PrimaryElectionEvent
Returns the partition ID.
partitionId() - Method in interface io.atomix.primitive.session.SessionClient
Returns the partition identifier.
partitionId() - Method in class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
PartitionManagementService - Interface in io.atomix.primitive.partition
Partition management service.
PartitionMetadata - Class in io.atomix.primitive.partition
A partition or shard is a group of controller nodes that are work together to maintain state.
PartitionMetadata(PartitionId, Collection<MemberId>) - Constructor for class io.atomix.primitive.partition.PartitionMetadata
 
PartitionService - Interface in io.atomix.primitive.partition
Partition service.
patch() - Method in class io.atomix.utils.Version
Returns the patch version number.
path() - Method in class io.atomix.core.tree.DocumentTreeEvent
Returns the path to the changed node.
path() - Method in interface io.atomix.core.tree.DocumentTreeNode
Returns the path to this node in a DocumentTree.
pathElements() - Method in class io.atomix.core.tree.DocumentPath
Returns the list of path elements representing this path in correct order.
payload() - Method in class io.atomix.core.workqueue.Task
Returns the task payload.
peek() - Method in interface io.atomix.core.queue.AsyncDistributedQueue
Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.
PeerSelector<E> - Interface in io.atomix.protocols.gossip
Peer selector.
PeerSelectors - Enum in io.atomix.protocols.gossip
Configurable peer selectors.
PhiMembershipProtocol - Class in io.atomix.cluster.protocol
Gossip based group membership protocol.
PhiMembershipProtocol(PhiMembershipProtocolConfig) - Constructor for class io.atomix.cluster.protocol.PhiMembershipProtocol
 
PhiMembershipProtocol.Type - Class in io.atomix.cluster.protocol
Bootstrap member location provider type.
PhiMembershipProtocolBuilder - Class in io.atomix.cluster.protocol
Gossip based group membership protocol builder.
PhiMembershipProtocolBuilder() - Constructor for class io.atomix.cluster.protocol.PhiMembershipProtocolBuilder
 
PhiMembershipProtocolConfig - Class in io.atomix.cluster.protocol
Gossip group membership protocol configuration.
PhiMembershipProtocolConfig() - Constructor for class io.atomix.cluster.protocol.PhiMembershipProtocolConfig
 
poll() - Method in interface io.atomix.core.queue.AsyncDistributedQueue
Retrieves and removes the head of this queue, or returns null if this queue is empty.
pollFirst() - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Retrieves and removes the first (lowest) element, or returns null if this set is empty.
pollFirstEntry() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Removes and returns a key-value mapping associated with the least key in this map, or null if the map is empty.
pollFirstEntry() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Removes and returns a key-value mapping associated with the least key in this map, or null if the map is empty.
pollFirstEntry() - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the lowest key in the map.
pollLast() - Method in interface io.atomix.core.set.AsyncDistributedNavigableSet
Retrieves and removes the last (highest) element, or returns null if this set is empty.
pollLastEntry() - Method in interface io.atomix.core.map.AsyncAtomicNavigableMap
Removes and returns a key-value mapping associated with the greatest key in this map, or null if the map is empty.
pollLastEntry() - Method in interface io.atomix.core.map.AsyncDistributedNavigableMap
Removes and returns a key-value mapping associated with the greatest key in this map, or null if the map is empty.
pollLastEntry() - Method in interface io.atomix.core.map.AtomicNavigableMap
Returns the entry associated with the highest key in the map.
populate(int) - Method in class io.atomix.utils.serializer.Namespace
Populates the Kryo pool.
port() - Method in class io.atomix.utils.net.Address
Returns the port.
prepare(TransactionLog<T>) - Method in interface io.atomix.core.transaction.Transactional
Prepares a transaction for commitment.
prepare() - Method in interface io.atomix.core.transaction.TransactionParticipant
Prepares the participant.
preparing(TransactionId, Set<ParticipantInfo>) - Method in interface io.atomix.core.transaction.TransactionService
Marks the given transaction as preparing.
primary() - Method in interface io.atomix.primitive.partition.Partition
Returns the partition's current primary.
primary() - Method in class io.atomix.primitive.partition.PrimaryTerm
Returns the primary member.
primary() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
primary() - Method in class io.atomix.protocols.raft.partition.RaftPartition
 
PrimaryBackupClient - Class in io.atomix.protocols.backup
Primary-backup client.
PrimaryBackupClient(String, PartitionId, ClusterMembershipService, PrimaryBackupClientProtocol, PrimaryElection, SessionIdService, ThreadContextFactory, boolean) - Constructor for class io.atomix.protocols.backup.PrimaryBackupClient
 
PrimaryBackupClient.Builder - Class in io.atomix.protocols.backup
Primary-backup client builder.
PrimaryBackupPartition - Class in io.atomix.protocols.backup.partition
Primary-backup partition.
PrimaryBackupPartition(PartitionId, MemberGroupProvider) - Constructor for class io.atomix.protocols.backup.partition.PrimaryBackupPartition
 
PrimaryBackupPartitionGroup - Class in io.atomix.protocols.backup.partition
Primary-backup partition group.
PrimaryBackupPartitionGroup(PrimaryBackupPartitionGroupConfig) - Constructor for class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
PrimaryBackupPartitionGroup.Builder - Class in io.atomix.protocols.backup.partition
Primary-backup partition group builder.
PrimaryBackupPartitionGroup.Type - Class in io.atomix.protocols.backup.partition
Primary-backup partition group type.
PrimaryBackupPartitionGroupConfig - Class in io.atomix.protocols.backup.partition
Primary-backup partition group configuration.
PrimaryBackupPartitionGroupConfig() - Constructor for class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroupConfig
 
PrimaryBackupServer - Class in io.atomix.protocols.backup
Primary-backup server.
PrimaryBackupServer.Builder - Class in io.atomix.protocols.backup
Primary-backup server builder
PrimaryBackupServer.Role - Enum in io.atomix.protocols.backup
Primary-backup role.
PrimaryBackupSessionClient - Class in io.atomix.protocols.backup.session
Primary-backup session client.
PrimaryBackupSessionClient(String, PartitionId, SessionId, PrimitiveType, PrimitiveDescriptor, ClusterMembershipService, PrimaryBackupClientProtocol, PrimaryElection, ThreadContext) - Constructor for class io.atomix.protocols.backup.session.PrimaryBackupSessionClient
 
PrimaryBackupSessionClient.Builder - Class in io.atomix.protocols.backup.session
Primary-backup partition proxy builder.
PrimaryElection - Interface in io.atomix.primitive.partition
Partition primary election.
PrimaryElectionEvent - Class in io.atomix.primitive.partition
Primary election event.
PrimaryElectionEvent(PrimaryElectionEvent.Type, PartitionId, PrimaryTerm) - Constructor for class io.atomix.primitive.partition.PrimaryElectionEvent
 
PrimaryElectionEvent.Type - Enum in io.atomix.primitive.partition
Returns the election event type.
PrimaryElectionEventListener - Interface in io.atomix.primitive.partition
Primary election event listener.
PrimaryElectionService - Interface in io.atomix.primitive.partition
Partition primary election service.
PrimaryTerm - Class in io.atomix.primitive.partition
Partition primary term.
PrimaryTerm(long, GroupMember, List<GroupMember>) - Constructor for class io.atomix.primitive.partition.PrimaryTerm
 
primitiveBuilder(String, PrimitiveType<B, C, P>) - Method in class io.atomix.core.Atomix
 
PrimitiveBuilder<B extends PrimitiveBuilder<B,C,P>,C extends PrimitiveConfig,P extends SyncPrimitive> - Class in io.atomix.primitive
Abstract builder for distributed primitives.
PrimitiveBuilder(PrimitiveType, String, C, PrimitiveManagementService) - Constructor for class io.atomix.primitive.PrimitiveBuilder
 
primitiveBuilder(String, PrimitiveType<B, C, P>) - Method in interface io.atomix.primitive.PrimitiveFactory
Creates a new named primitive builder of the given primitiveType.
PrimitiveCache - Interface in io.atomix.primitive
Atomix primitive cache.
PrimitiveConfig<C extends PrimitiveConfig<C>> - Class in io.atomix.primitive.config
Primitive configuration.
PrimitiveConfig() - Constructor for class io.atomix.primitive.config.PrimitiveConfig
 
PrimitiveEvent - Class in io.atomix.primitive.event
Raft event.
PrimitiveEvent(EventType, byte[]) - Constructor for class io.atomix.primitive.event.PrimitiveEvent
 
PrimitiveException - Exception in io.atomix.primitive
Top level exception for Store failures.
PrimitiveException() - Constructor for exception io.atomix.primitive.PrimitiveException
 
PrimitiveException(String) - Constructor for exception io.atomix.primitive.PrimitiveException
 
PrimitiveException(Throwable) - Constructor for exception io.atomix.primitive.PrimitiveException
 
PrimitiveException.ClosedSession - Exception in io.atomix.primitive
Closed session exception.
PrimitiveException.CommandFailure - Exception in io.atomix.primitive
Command failure exception.
PrimitiveException.ConcurrentModification - Exception in io.atomix.primitive
Store update conflicts with an in flight transaction.
PrimitiveException.Interrupted - Exception in io.atomix.primitive
Store operation interrupted.
PrimitiveException.QueryFailure - Exception in io.atomix.primitive
Query failure exception.
PrimitiveException.ServiceException - Exception in io.atomix.primitive
Primitive service exception.
PrimitiveException.Timeout - Exception in io.atomix.primitive
Store operation timeout.
PrimitiveException.Unavailable - Exception in io.atomix.primitive
Store is temporarily unavailable.
PrimitiveException.UnknownClient - Exception in io.atomix.primitive
Unknown client exception.
PrimitiveException.UnknownService - Exception in io.atomix.primitive
Unknown service exception.
PrimitiveException.UnknownSession - Exception in io.atomix.primitive
Unknown session exception.
PrimitiveFactory - Interface in io.atomix.primitive
Manages the creation of distributed primitive instances.
PrimitiveId - Class in io.atomix.primitive
Snapshot identifier.
PrimitiveId(Long) - Constructor for class io.atomix.primitive.PrimitiveId
 
PrimitiveInfo - Class in io.atomix.primitive
Distributed primitive info.
PrimitiveInfo(String, PrimitiveType) - Constructor for class io.atomix.primitive.PrimitiveInfo
 
PrimitiveManagementService - Interface in io.atomix.primitive
Primitive management service.
primitiveName() - Method in interface io.atomix.primitive.session.Session
Returns the session's service name.
primitiveName() - Method in class io.atomix.primitive.session.SessionMetadata
Returns the session name.
PrimitiveOperation - Class in io.atomix.primitive.operation
Base type for Raft state operations.
PrimitiveOperation(OperationId, byte[]) - Constructor for class io.atomix.primitive.operation.PrimitiveOperation
 
PrimitiveProtocol - Interface in io.atomix.primitive.protocol
Primitive protocol.
PrimitiveProtocol.Type<C extends PrimitiveProtocolConfig<C>> - Interface in io.atomix.primitive.protocol
Distributed primitive protocol type.
PrimitiveProtocolBuilder<B extends PrimitiveProtocolBuilder<B,C,P>,C extends PrimitiveProtocolConfig<C>,P extends PrimitiveProtocol> - Class in io.atomix.primitive.protocol
Primitive protocol builder.
PrimitiveProtocolConfig<C extends PrimitiveProtocolConfig<C>> - Class in io.atomix.primitive.protocol
Primitive protocol configuration.
PrimitiveProtocolConfig() - Constructor for class io.atomix.primitive.protocol.PrimitiveProtocolConfig
 
PrimitiveProtocolTypeRegistry - Interface in io.atomix.primitive.protocol
Primitive protocol type registry.
PrimitiveRegistry - Interface in io.atomix.primitive
Primitive registry.
PrimitiveService - Interface in io.atomix.primitive.service
Base class for user-provided services.
PrimitivesService - Interface in io.atomix.core
Manages the creation of distributed primitive instances.
PrimitiveState - Enum in io.atomix.primitive
State of distributed primitive.
PrimitiveType<B extends PrimitiveBuilder,C extends PrimitiveConfig,P extends SyncPrimitive> - Interface in io.atomix.primitive
Primitive type.
primitiveType() - Method in interface io.atomix.primitive.session.Session
Returns the session's service type.
primitiveType() - Method in class io.atomix.primitive.session.SessionMetadata
Returns the session type.
PrimitiveTypeRegistry - Interface in io.atomix.primitive
Primitive registry.
process(E) - Method in interface io.atomix.utils.event.EventSink
Processes the specified event.
process(E) - Method in class io.atomix.utils.event.ListenerRegistry
 
Profile - Interface in io.atomix.core.profile
Atomix profile.
Profile.Type<C extends ProfileConfig> - Interface in io.atomix.core.profile
Profile type.
ProfileBuilder - Class in io.atomix.core.profile
Profile builder.
ProfileBuilder() - Constructor for class io.atomix.core.profile.ProfileBuilder
 
ProfileConfig - Class in io.atomix.core.profile
Profile configuration.
ProfileConfig() - Constructor for class io.atomix.core.profile.ProfileConfig
 
ProfileTypeRegistry - Interface in io.atomix.core.profile
Profile type registry.
promote(T) - Method in interface io.atomix.core.election.AsyncLeaderElection
Attempts to promote a node to top of candidate list without displacing the current leader.
promote(String, T) - Method in interface io.atomix.core.election.AsyncLeaderElector
Attempts to promote a node to top of candidate list without displacing the current leader.
promote(T) - Method in interface io.atomix.core.election.LeaderElection
Attempts to promote a node to top of candidate list.
promote(String, T) - Method in interface io.atomix.core.election.LeaderElector
Attempts to promote a node to top of candidate list.
promote() - Method in interface io.atomix.protocols.raft.RaftServer
Promotes the server to leader if possible.
properties() - Method in class io.atomix.cluster.Member
Returns the member properties.
protocol() - Method in class io.atomix.core.transaction.ParticipantInfo
Returns the protocol type used by the participant.
protocol() - Method in interface io.atomix.core.transaction.TransactionParticipant
 
protocol() - Method in class io.atomix.primitive.AbstractAsyncPrimitive
 
protocol() - Method in interface io.atomix.primitive.DistributedPrimitive
Returns the primitive protocol.
protocol() - Method in interface io.atomix.primitive.partition.PartitionGroup
Returns the primitive protocol type supported by the partition group.
protocol() - Method in interface io.atomix.primitive.proxy.ProxyClient
Returns the client proxy protocol.
protocol() - Method in class io.atomix.primitive.Synchronous
 
protocol() - Method in class io.atomix.protocols.backup.partition.PrimaryBackupPartitionGroup
 
protocol() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
ProtocolException() - Constructor for exception io.atomix.cluster.messaging.MessagingException.ProtocolException
 
ProtocolException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ProtocolException
 
ProxyClient<S> - Interface in io.atomix.primitive.proxy
Primitive proxy.
ProxyCompatibleBuilder<B extends ProxyCompatibleBuilder<B>> - Interface in io.atomix.primitive.protocol
State machine replication compatible primitive.
ProxyProtocol - Interface in io.atomix.primitive.protocol
State machine replication-based primitive protocol.
ProxySession<S> - Interface in io.atomix.primitive.proxy
Proxy session.
publish(EventType) - Method in interface io.atomix.primitive.session.Session
Publishes an empty event to the session.
publish(EventType, T) - Method in interface io.atomix.primitive.session.Session
Publishes an event to the session.
publish(PrimitiveEvent) - Method in interface io.atomix.primitive.session.Session
Publishes an event to the session.
publish(PrimitiveEvent) - Method in class io.atomix.protocols.raft.session.RaftSession
 
put(K, long) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Associates ewValue with key in this map, and returns the value previously associated with key, or zero if there was no such value.
put(K, V) - Method in interface io.atomix.core.map.AsyncAtomicMap
Associates the specified value with the specified key in this map (optional operation).
put(K, V, Duration) - Method in interface io.atomix.core.map.AsyncAtomicMap
Associates the specified value with the specified key in this map (optional operation).
put(K, V) - Method in interface io.atomix.core.map.AsyncDistributedMap
Associates the specified value with the specified key in this map (optional operation).
put(K, long) - Method in interface io.atomix.core.map.AtomicCounterMap
Associates ewValue with key in this map, and returns the value previously associated with key, or zero if there was no such value.
put(K, V) - Method in interface io.atomix.core.map.AtomicMap
Associates the specified value with the specified key in this map (optional operation).
put(K, V, Duration) - Method in interface io.atomix.core.map.AtomicMap
Associates the specified value with the specified key in this map (optional operation).
put(K, V) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
If the key-value pair does not already exist adds either the key value pair or the value to the set of values associated with the key and returns true, if the key-value pair already exists then behavior is implementation specific with some implementations allowing duplicates and others ignoring put requests for existing entries.
put(K, V) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
If the key-value pair does not already exist adds either the key value pair or the value to the set of values associated with the key and returns true, if the key-value pair already exists then behavior is implementation specific with some implementations allowing duplicates and others ignoring put requests for existing entries.
put(K, V) - Method in interface io.atomix.core.multimap.AtomicMultimap
If the key-value pair does not already exist adds either the key value pair or the value to the set of values associated with the key and returns true, if the key-value pair already exists then behavior is implementation specific with some implementations allowing duplicates and others ignoring put requests for existing entries.
put(K, V) - Method in interface io.atomix.core.transaction.AsyncTransactionalMap
Associates the specified value with the specified key in this map (optional operation).
put(K, V) - Method in interface io.atomix.core.transaction.TransactionalMap
Associates the specified value with the specified key in this map (optional operation).
putAll(Map<? extends K, ? extends V>) - Method in interface io.atomix.core.map.AsyncDistributedMap
Copies all of the mappings from the specified map to this map (optional operation).
putAll(K, Collection<? extends V>) - Method in interface io.atomix.core.multimap.AsyncAtomicMultimap
Adds the set of key-value pairs of the specified key with each of the values in the iterable if each key-value pair does not already exist, if the pair does exist the behavior is implementation specific.
putAll(K, Collection<? extends V>) - Method in interface io.atomix.core.multimap.AsyncDistributedMultimap
Adds the set of key-value pairs of the specified key with each of the values in the iterable if each key-value pair does not already exist, if the pair does exist the behavior is implementation specific.
putAll(K, Collection<? extends V>) - Method in interface io.atomix.core.multimap.AtomicMultimap
Adds the set of key-value pairs of the specified key with each of the values in the iterable if each key-value pair does not already exist, if the pair does exist the behavior is implementation specific.
putAndGet(K, V) - Method in interface io.atomix.core.map.AsyncAtomicMap
Associates the specified value with the specified key in this map (optional operation).
putAndGet(K, V, Duration) - Method in interface io.atomix.core.map.AsyncAtomicMap
Associates the specified value with the specified key in this map (optional operation).
putAndGet(K, V) - Method in interface io.atomix.core.map.AtomicMap
Associates the specified value with the specified key in this map (optional operation).
putAndGet(K, V, Duration) - Method in interface io.atomix.core.map.AtomicMap
Associates the specified value with the specified key in this map (optional operation).
putIfAbsent(K, long) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
If key is not already associated with a value or if key is associated with zero, associate it with newValue.
putIfAbsent(K, V) - Method in interface io.atomix.core.map.AsyncAtomicMap
If the specified key is not already associated with a value associates it with the given value and returns null, else behaves as a get returning the existing mapping without making any changes.
putIfAbsent(K, V, Duration) - Method in interface io.atomix.core.map.AsyncAtomicMap
If the specified key is not already associated with a value associates it with the given value and returns null, else behaves as a get returning the existing mapping without making any changes.
putIfAbsent(K, V) - Method in interface io.atomix.core.map.AsyncDistributedMap
If the specified key is not already associated with a value (or is mapped to null) associates it with the given value and returns null, else returns the current value.
putIfAbsent(K, long) - Method in interface io.atomix.core.map.AtomicCounterMap
If key is not already associated with a value or if key is associated with zero, associate it with newValue.
putIfAbsent(K, V) - Method in interface io.atomix.core.map.AtomicMap
If the specified key is not already associated with a value associates it with the given value and returns null, else returns the current value.
putIfAbsent(K, V, Duration) - Method in interface io.atomix.core.map.AtomicMap
If the specified key is not already associated with a value associates it with the given value and returns null, else returns the current value.
putIfAbsent(K, V) - Method in interface io.atomix.core.transaction.AsyncTransactionalMap
If the specified key is not already associated with a value associates it with the given value and returns null, else returns the current value.
putIfAbsent(K, V) - Method in interface io.atomix.core.transaction.TransactionalMap
If the specified key is not already associated with a value associates it with the given value and returns null, else returns the current value.

Q

query(String) - Static method in interface io.atomix.primitive.operation.OperationId
Returns a new query operation identifier.
Query - Annotation Type in io.atomix.primitive.operation
Query annotation.
QueryFailure() - Constructor for exception io.atomix.primitive.PrimitiveException.QueryFailure
 
QueryFailure(String) - Constructor for exception io.atomix.primitive.PrimitiveException.QueryFailure
 
QueryFailure(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.QueryFailure
 
queueBuilder(String) - Method in interface io.atomix.core.PrimitivesService
Creates a new named DistributedQueue builder.
queueLength() - Method in class io.atomix.core.semaphore.QueueStatus
Get the count of requests waiting for permits.
queueStatus() - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Query the waiting queue status.
queueStatus() - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Query the waiting queue status.
queueStatus() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Query the waiting queue status.
QueueStatus - Class in io.atomix.core.semaphore
 
QueueStatus(int, int) - Constructor for class io.atomix.core.semaphore.QueueStatus
 

R

rack() - Method in class io.atomix.cluster.Member
Returns the rack to which the member belongs.
RaftClient - Interface in io.atomix.protocols.raft
Provides an interface for submitting operations to the Raft cluster.
RaftClient.Builder - Class in io.atomix.protocols.raft
Builds a new Raft client.
RaftCompactionConfig - Class in io.atomix.protocols.raft.partition
Raft compaction configuration.
RaftCompactionConfig() - Constructor for class io.atomix.protocols.raft.partition.RaftCompactionConfig
 
RaftError - Class in io.atomix.protocols.raft
Base type for Raft protocol errors.
RaftError(RaftError.Type, String) - Constructor for class io.atomix.protocols.raft.RaftError
 
RaftError.Type - Enum in io.atomix.protocols.raft
Raft error types.
RaftException - Exception in io.atomix.protocols.raft
Base Raft protocol exception.
RaftException.ApplicationException - Exception in io.atomix.protocols.raft
 
RaftException.ClosedSession - Exception in io.atomix.protocols.raft
 
RaftException.CommandFailure - Exception in io.atomix.protocols.raft
 
RaftException.ConfigurationException - Exception in io.atomix.protocols.raft
 
RaftException.IllegalMemberState - Exception in io.atomix.protocols.raft
 
RaftException.NoLeader - Exception in io.atomix.protocols.raft
 
RaftException.OperationFailure - Exception in io.atomix.protocols.raft
 
RaftException.ProtocolException - Exception in io.atomix.protocols.raft
 
RaftException.QueryFailure - Exception in io.atomix.protocols.raft
 
RaftException.Unavailable - Exception in io.atomix.protocols.raft
 
RaftException.UnknownClient - Exception in io.atomix.protocols.raft
 
RaftException.UnknownService - Exception in io.atomix.protocols.raft
 
RaftException.UnknownSession - Exception in io.atomix.protocols.raft
 
RaftMetadataClient - Interface in io.atomix.protocols.raft
Raft metadata.
RaftPartition - Class in io.atomix.protocols.raft.partition
Abstract partition.
RaftPartition(PartitionId, RaftPartitionGroupConfig, File, ThreadContextFactory) - Constructor for class io.atomix.protocols.raft.partition.RaftPartition
 
RaftPartitionGroup - Class in io.atomix.protocols.raft.partition
Raft partition group.
RaftPartitionGroup(RaftPartitionGroupConfig) - Constructor for class io.atomix.protocols.raft.partition.RaftPartitionGroup
 
RaftPartitionGroup.Builder - Class in io.atomix.protocols.raft.partition
Raft partition group builder.
RaftPartitionGroup.Type - Class in io.atomix.protocols.raft.partition
Raft partition group type.
RaftPartitionGroupConfig - Class in io.atomix.protocols.raft.partition
Raft partition group configuration.
RaftPartitionGroupConfig() - Constructor for class io.atomix.protocols.raft.partition.RaftPartitionGroupConfig
 
RaftServer - Interface in io.atomix.protocols.raft
Provides a standalone implementation of the Raft consensus algorithm.
RaftServer.Builder - Class in io.atomix.protocols.raft
Builds a single-use Raft server.
RaftServer.Role - Enum in io.atomix.protocols.raft
Raft server state types.
RaftServiceContext - Class in io.atomix.protocols.raft.service
Raft server state machine executor.
RaftServiceContext(PrimitiveId, String, PrimitiveType, ServiceConfig, PrimitiveService, RaftContext, ThreadContextFactory) - Constructor for class io.atomix.protocols.raft.service.RaftServiceContext
 
RaftSession - Class in io.atomix.protocols.raft.session
Raft session.
RaftSession(SessionId, MemberId, String, PrimitiveType, ReadConsistency, long, long, long, Serializer, RaftServiceContext, RaftContext, ThreadContextFactory) - Constructor for class io.atomix.protocols.raft.session.RaftSession
 
RaftSessionClient - Interface in io.atomix.protocols.raft.session
Raft primitive proxy.
RaftSessionClient.Builder - Class in io.atomix.protocols.raft.session
Raft proxy builder.
RaftSessionRegistry - Class in io.atomix.protocols.raft.session
Session manager.
RaftSessionRegistry() - Constructor for class io.atomix.protocols.raft.session.RaftSessionRegistry
 
RaftStorageConfig - Class in io.atomix.protocols.raft.partition
Raft storage configuration.
RaftStorageConfig() - Constructor for class io.atomix.protocols.raft.partition.RaftStorageConfig
 
ReadConsistency - Enum in io.atomix.protocols.raft
Constants for specifying Raft query consistency levels.
readConsistency() - Method in class io.atomix.protocols.raft.session.RaftSession
Returns the session read consistency.
readObject() - Method in interface io.atomix.primitive.service.BackupInput
Deserializes an object from the input.
records() - Method in class io.atomix.core.transaction.TransactionLog
Returns the list of transaction log records.
Recovery - Enum in io.atomix.primitive
Primitive session recovery strategy.
RecoveryStrategy - Enum in io.atomix.protocols.raft.session
Session recovery strategy.
reducePermits(int) - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Shrinks the number of available permits by the indicated reduction.
reducePermits(int) - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Shrinks the number of available permits by the indicated reduction.
reducePermits(int) - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Shrinks the number of available permits by the indicated reduction.
register(Object) - Method in interface io.atomix.primitive.proxy.ProxyClient
Registers a client proxy.
register(Object) - Method in interface io.atomix.primitive.proxy.ProxySession
Registers a client listener.
register(Session) - Method in class io.atomix.primitive.service.AbstractPrimitiveService
 
register(Session) - Method in interface io.atomix.primitive.service.PrimitiveService
Registers a primitive session.
register(OperationId, Runnable) - Method in interface io.atomix.primitive.service.ServiceExecutor
Registers a operation callback.
register(OperationId, Supplier<R>) - Method in interface io.atomix.primitive.service.ServiceExecutor
Registers a no argument operation callback.
register(OperationId, Consumer<Commit<T>>) - Method in interface io.atomix.primitive.service.ServiceExecutor
Registers a operation callback.
register(OperationId, Function<Commit<T>, R>) - Method in interface io.atomix.primitive.service.ServiceExecutor
Registers an operation callback.
register(Class<?>...) - Method in class io.atomix.utils.serializer.Namespace.Builder
Registers classes to be serialized using Kryo default serializer.
register(Serializer<?>, Class<?>...) - Method in class io.atomix.utils.serializer.Namespace.Builder
Registers serializer for the given set of classes.
register(Namespace) - Method in class io.atomix.utils.serializer.Namespace.Builder
Registers all the class registered to given KryoNamespace.
registerCommand(long, PendingCommand) - Method in class io.atomix.protocols.raft.session.RaftSession
Registers a pending command.
registerHandler(String, BiConsumer<Address, byte[]>, Executor) - Method in interface io.atomix.cluster.messaging.MessagingService
Registers a new message handler for message type.
registerHandler(String, BiFunction<Address, byte[], byte[]>, Executor) - Method in interface io.atomix.cluster.messaging.MessagingService
Registers a new message handler for message type.
registerHandler(String, BiFunction<Address, byte[], CompletableFuture<byte[]>>) - Method in interface io.atomix.cluster.messaging.MessagingService
Registers a new message handler for message type.
registerIndexQuery(long, Runnable) - Method in class io.atomix.protocols.raft.session.RaftSession
Registers a session index query.
registerResult(long, OperationResult) - Method in class io.atomix.protocols.raft.session.RaftSession
Registers a session result.
registerSequenceQuery(long, Runnable) - Method in class io.atomix.protocols.raft.session.RaftSession
Registers a causal session query.
registerTaskProcessor(Consumer<E>, int, Executor) - Method in interface io.atomix.core.workqueue.AsyncWorkQueue
Registers a task processing callback to be automatically invoked when new tasks are added to the work queue.
registerTaskProcessor(Consumer<E>, int, Executor) - Method in interface io.atomix.core.workqueue.WorkQueue
Registers a task processing callback to be automatically invoked when new tasks are added to the work queue.
registry() - Static method in interface io.atomix.core.AtomixRegistry
Creates a new registry.
registry(ClassLoader) - Static method in interface io.atomix.core.AtomixRegistry
Creates a new registry instance using the given class loader.
release() - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Releases a permit.
release(int) - Method in interface io.atomix.core.semaphore.AsyncAtomicSemaphore
Releases the given number of permits.
release() - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Releases a permit.
release(int) - Method in interface io.atomix.core.semaphore.AsyncDistributedSemaphore
Releases the given number of permits.
release() - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Releases a permit.
release(int) - Method in interface io.atomix.core.semaphore.AtomicSemaphore
Releases the given number of permits.
release() - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
release(int) - Method in class io.atomix.core.semaphore.DistributedSemaphore
 
release(Kryo) - Method in class io.atomix.utils.serializer.Namespace
 
RemoteHandlerFailure() - Constructor for exception io.atomix.cluster.messaging.MessagingException.RemoteHandlerFailure
 
remove(E) - Method in interface io.atomix.core.collection.AsyncDistributedCollection
Removes the specified element to this collection if it is present (optional operation).
remove(int) - Method in interface io.atomix.core.list.AsyncDistributedList
Removes the element at the specified position in this list (optional operation).
remove(K) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
Removes and returns the value associated with key.
remove(K, long) - Method in interface io.atomix.core.map.AsyncAtomicCounterMap
If (key, value) is currently in the map, this method removes it and returns true; otherwise, this method returns false.
remove(K) - Method in interface io.atomix.core.map.AsyncAtomicMap
Removes the mapping for a key from this map if it is present (optional operation).
remove(K, V) - Method in interface io.atomix.core.map.AsyncAtomicMap
Removes the entry for the specified key only if it is currently mapped to the specified value.
remove(K, long) - Method in interface io.atomix.core.map.AsyncAtomicMap
Removes the entry for the specified key only if its current version in the map is equal to the specified version.
remove(K) - Method in interface io.atomix.core.map.AsyncDistributedMap
Removes the mapping for a key from this map if it is present (optional operation).
remove(K, V) - Method in interface io.atomix.core.map.AsyncDistributedMap
Removes the entry for the specified key only if it is currently mapped to the specified value.
remove(K) - Method in interface io.atomix.core.map.