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

A

AbstractAccumulator<T> - Class in io.atomix.utils

Base implementation of an item accumulator.

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

accept(T, Throwable) - Method in class io.atomix.utils.concurrent.ComposableFuture

acceptEither(CompletionStage<? extends T>, Consumer<? super T>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

acceptEither(CompletionStage<? extends T>, Consumer<? super T>) - Method in class io.atomix.utils.concurrent.OrderedFuture

acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>) - Method in class io.atomix.utils.concurrent.OrderedFuture

acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

Accumulator<T> - Interface in io.atomix.utils

Abstraction of an accumulator capable of collecting items and at some point in time triggers processing of all previously accumulated items.

acquire() - Method in interface io.atomix.utils.concurrent.ReferenceCounted

Acquires a reference.

acquire() - Method in class io.atomix.utils.concurrent.ReferencePool

Acquires a reference.

add(T) - Method in class io.atomix.utils.AbstractAccumulator

add(T) - Method in interface io.atomix.utils.Accumulator

Adds an item to the current batch.

add(String, Object) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, boolean) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, char) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, double) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, float) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, int) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

add(String, long) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds a name/value pair to the formatted output in name=value format.

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.

address() - Method in class io.atomix.utils.memory.HeapMemory

address(int) - Method in class io.atomix.utils.memory.HeapMemory

address() - Method in interface io.atomix.utils.memory.Memory

Returns the memory address.

address(int) - Method in interface io.atomix.utils.memory.Memory

Returns the memory address for the given offset.

address() - Method in class io.atomix.utils.memory.NativeMemory

address(int) - Method in class io.atomix.utils.memory.NativeMemory

addValue(Object) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(boolean) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(char) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(double) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(float) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(int) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

addValue(long) - Method in class io.atomix.utils.logging.LoggerContext.Builder

Adds an unnamed value to the formatted output.

allocate(int) - Static method in class io.atomix.utils.memory.DirectMemory

Allocates direct memory via DirectMemoryAllocator.

allocate(int) - Method in class io.atomix.utils.memory.DirectMemoryAllocator

allocate(int) - Static method in class io.atomix.utils.memory.HeapMemory

Allocates heap memory via HeapMemoryAllocator.

allocate(int) - Method in class io.atomix.utils.memory.HeapMemoryAllocator

allocate(File, int) - Static method in class io.atomix.utils.memory.MappedMemory

Allocates memory mapped to a file on disk.

allocate(File, FileChannel.MapMode, int) - Static method in class io.atomix.utils.memory.MappedMemory

Allocates memory mapped to a file on disk.

allocate(int) - Method in class io.atomix.utils.memory.MappedMemoryAllocator

allocate(int) - Method in interface io.atomix.utils.memory.MemoryAllocator

Allocates memory.

allocate(int) - Static method in class io.atomix.utils.memory.NativeMemory

Allocates native memory via DirectMemoryAllocator.

allocator() - Method in class io.atomix.utils.memory.HeapMemory

allocator() - Method in interface io.atomix.utils.memory.Memory

Returns the memory allocator that allocated this memory.

allocator() - Method in class io.atomix.utils.memory.NativeMemory

allOf(List<CompletableFuture<T>>) - Static method in class io.atomix.utils.concurrent.Futures

Returns a new CompletableFuture completed with a list of computed values when all of the given CompletableFuture complete.

allOf(List<CompletableFuture<T>>, BinaryOperator<T>, T) - Static method in class io.atomix.utils.concurrent.Futures

Returns a new CompletableFuture completed by reducing a list of computed values when all of the given CompletableFuture complete.

ANY - Static variable in class io.atomix.utils.Match

any() - Static method in class io.atomix.utils.Match

Returns a Match that matches any value including null.

apply(U) - Method in class io.atomix.utils.concurrent.RetryingFunction

applyToEither(CompletionStage<? extends T>, Function<? super T, U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

applyToEither(CompletionStage<? extends T>, Function<? super T, U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

array() - Method in class io.atomix.utils.memory.HeapMemory

Returns the underlying byte array.

ARRAY_BASE_OFFSET - Static variable in class io.atomix.utils.memory.HeapMemory

ArraysAsListSerializer - Class in io.atomix.utils.serializer.serializers

Kryo Serializer for Arrays.asList(Object...).

ArraysAsListSerializer() - Constructor for class io.atomix.utils.serializer.serializers.ArraysAsListSerializer

ArraySizeHashPrinter - Class in io.atomix.utils

Helper to print Object[] length and hashCode.

ArraySizeHashPrinter(Object[], Class<?>) - Constructor for class io.atomix.utils.ArraySizeHashPrinter

asVersion() - Method in class io.atomix.utils.time.LogicalTimestamp

Returns the timestamp as a version.

asyncFuture(CompletableFuture<T>, Executor) - Static method in class io.atomix.utils.concurrent.Futures

Returns a wrapped future that will be completed on the given executor.

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

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

AtomixThread - Class in io.atomix.utils.concurrent

Atomix thread.

AtomixThread(Runnable) - Constructor for class io.atomix.utils.concurrent.AtomixThread

AtomixThreadFactory - Class in io.atomix.utils.concurrent

Named thread factory.

AtomixThreadFactory() - Constructor for class io.atomix.utils.concurrent.AtomixThreadFactory

B

BASIC - Static variable in class io.atomix.utils.serializer.KryoNamespaces

BASIC - Static variable in class io.atomix.utils.serializer.serializers.DefaultSerializers

Basic serializer.

BASIC_MAX_SIZE - Static variable in class io.atomix.utils.serializer.KryoNamespaces

BEGIN_USER_CUSTOM_ID - Static variable in class io.atomix.utils.serializer.KryoNamespaces

Kryo registration Id for user custom registration.

BlockingAwareFuture<T> - Class in io.atomix.utils.concurrent

A CompletableFuture that tracks whether the future or one of its descendants has been blocked on a CompletableFuture.get() or CompletableFuture.join() call.

BlockingAwareFuture() - Constructor for class io.atomix.utils.concurrent.BlockingAwareFuture

blockingAwareFuture(CompletableFuture<T>, Executor) - Static method in class io.atomix.utils.concurrent.Futures

Returns a future that's completed using the given orderedExecutor if the future is not blocked or the given threadPoolExecutor if the future is blocked.

borrow() - Method in class io.atomix.utils.serializer.KryoNamespace

build() - Method in interface io.atomix.utils.Builder

Builds the object.

build() - Method in class io.atomix.utils.logging.LoggerContext.Builder

build() - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Builds a KryoNamespace instance.

build(String) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Builds a KryoNamespace instance.

Builder<T> - Interface in io.atomix.utils

Object builder.

builder(String) - Static method in class io.atomix.utils.logging.LoggerContext

Returns a new contextual logger builder.

builder(Class) - Static method in class io.atomix.utils.logging.LoggerContext

Returns a new contextual logger builder.

Builder(String) - Constructor for class io.atomix.utils.logging.LoggerContext.Builder

builder() - Static method in class io.atomix.utils.serializer.KryoNamespace

Creates a new KryoNamespace builder.

Builder() - Constructor for class io.atomix.utils.serializer.KryoNamespace.Builder

C

cancel() - Method in interface io.atomix.utils.concurrent.Scheduled

Cancels the scheduled task.

checkThread() - Method in interface io.atomix.utils.concurrent.ThreadContext

Checks that the current thread is the correct context thread.

clear() - Method in class io.atomix.utils.memory.HeapMemory

clear() - Method in interface io.atomix.utils.memory.Memory

Clears the memory.

clear() - Method in class io.atomix.utils.memory.NativeMemory

Clock<T extends Timestamp> - Interface in io.atomix.utils.time

Clock.

close() - Method in interface io.atomix.utils.concurrent.ReferenceCounted

Defines an exception free close implementation.

close() - Method in class io.atomix.utils.concurrent.ReferencePool

close() - Method in class io.atomix.utils.concurrent.SingleThreadContext

close() - Method in interface io.atomix.utils.concurrent.ThreadContext

Closes the context.

close() - Method in interface io.atomix.utils.concurrent.ThreadContextFactory

Closes the factory.

close() - Method in class io.atomix.utils.concurrent.ThreadPoolContext

close() - Method in class io.atomix.utils.concurrent.ThreadPoolContextFactory

close() - Method in class io.atomix.utils.memory.MappedMemory

close() - Method in class io.atomix.utils.memory.MappedMemoryAllocator

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

completedFuture(T) - Static method in class io.atomix.utils.concurrent.Futures

Creates a future that is synchronously completed.

completedFutureAsync(T, Executor) - Static method in class io.atomix.utils.concurrent.Futures

Creates a future that is asynchronously completed.

ComposableFuture<T> - Class in io.atomix.utils.concurrent

Special implementation of CompletableFuture with missing utility methods.

ComposableFuture() - Constructor for class io.atomix.utils.concurrent.ComposableFuture

ContextualLogger - Class in io.atomix.utils.logging

Contextual logger.

ContextualLogger(Logger, LoggerContext) - Constructor for class io.atomix.utils.logging.ContextualLogger

ContextualLoggerFactory - Class in io.atomix.utils.logging

Contextual logger factory.

copy() - Method in class io.atomix.utils.memory.HeapMemory

copy() - Method in interface io.atomix.utils.memory.Memory

Copies the memory to a distinct memory address.

copy() - Method in class io.atomix.utils.memory.NativeMemory

create() - Method in class io.atomix.utils.serializer.KryoNamespace

Creates a Kryo instance.

createContext() - Method in class io.atomix.utils.concurrent.SingleThreadContextFactory

createContext() - Method in interface io.atomix.utils.concurrent.ThreadContextFactory

Creates a new thread context.

createContext() - Method in class io.atomix.utils.concurrent.ThreadPoolContextFactory

createReference(ReferenceManager<T>) - Method in interface io.atomix.utils.concurrent.ReferenceFactory

Creates a new reference.

creationTime() - Method in class io.atomix.utils.time.Versioned

Returns the system time when this version was created.

currentContext() - Static method in interface io.atomix.utils.concurrent.ThreadContext

Returns the current thread context.

currentContextOrThrow() - Static method in interface io.atomix.utils.concurrent.ThreadContext

D

debug(String) - Method in class io.atomix.utils.logging.ContextualLogger

debug(String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

debug(String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

debug(String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

debug(String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

debug(Marker, String) - Method in class io.atomix.utils.logging.ContextualLogger

debug(Marker, String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

debug(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

debug(Marker, String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

debug(Marker, String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

debug(String) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(Marker, String) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(Marker, String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(Marker, String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

debug(Marker, String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

decode(byte[]) - Method in interface io.atomix.utils.serializer.Serializer

Deserialize the specified bytes.

DEFAULT - Static variable in class io.atomix.utils.serializer.KryoNamespace

Default Kryo namespace.

DEFAULT_BUFFER_SIZE - Static variable in class io.atomix.utils.serializer.KryoNamespace

Default buffer size used for serialization.

DEFAULT_BUFFER_SIZE - Static variable in interface io.atomix.utils.serializer.Namespace

DEFAULT_MAP_MODE - Static variable in class io.atomix.utils.memory.MappedMemoryAllocator

DefaultSerializers - Class in io.atomix.utils.serializer.serializers

Default serializers.

delay(int, int) - Static method in class io.atomix.utils.concurrent.Retries

Suspends the current thread for a specified number of millis and nanos.

DelegatingLogger - Class in io.atomix.utils.logging

Delegating logger.

DelegatingLogger(Logger) - Constructor for class io.atomix.utils.logging.DelegatingLogger

deserialize(byte[]) - Method in class io.atomix.utils.serializer.KryoNamespace

Deserializes given byte array to Object using Kryo instance in pool.

deserialize(ByteBuffer) - Method in class io.atomix.utils.serializer.KryoNamespace

Deserializes given byte buffer to Object using Kryo instance in pool.

deserialize(InputStream) - Method in class io.atomix.utils.serializer.KryoNamespace

Deserializes given InputStream to an Object using Kryo instance in pool.

deserialize(InputStream, int) - Method in class io.atomix.utils.serializer.KryoNamespace

Deserializes given InputStream to an Object using Kryo instance in pool.

deserialize(byte[]) - Method in interface io.atomix.utils.serializer.Namespace

Deserializes given byte array to Object using Kryo instance in pool.

deserialize(ByteBuffer) - Method in interface io.atomix.utils.serializer.Namespace

Deserializes given byte buffer to Object using Kryo instance in pool.

deserialize(InputStream) - Method in interface io.atomix.utils.serializer.Namespace

Deserializes given InputStream to an Object using Kryo instance in pool.

deserialize(InputStream, int) - Method in interface io.atomix.utils.serializer.Namespace

Deserializes given InputStream to an Object using Kryo instance in pool.

destroy() - Method in class io.atomix.utils.SlidingWindowCounter

Releases resources used by the SlidingWindowCounter.

DirectMemory - Class in io.atomix.utils.memory

Direct memory.

DirectMemory(long, int, DirectMemoryAllocator) - Constructor for class io.atomix.utils.memory.DirectMemory

DirectMemoryAllocator - Class in io.atomix.utils.memory

Direct memory allocator.

DirectMemoryAllocator() - Constructor for class io.atomix.utils.memory.DirectMemoryAllocator

E

encode(T) - Method in interface io.atomix.utils.serializer.Serializer

Serialize the specified object.

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.utils.AbstractIdentifier

Compares two device key identifiers for equality.

equals(Object) - Method in class io.atomix.utils.Match

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

error(String) - Method in class io.atomix.utils.logging.ContextualLogger

error(String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

error(String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

error(String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

error(String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

error(Marker, String) - Method in class io.atomix.utils.logging.ContextualLogger

error(Marker, String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

error(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

error(Marker, String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

error(Marker, String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

error(String) - Method in class io.atomix.utils.logging.DelegatingLogger

error(String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

error(String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

error(String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

error(String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

error(Marker, String) - Method in class io.atomix.utils.logging.DelegatingLogger

error(Marker, String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

error(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

error(Marker, String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

error(Marker, String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

Event<T,S> - Interface in io.atomix.utils.event

Abstraction of an of a time-stamped event pertaining to an arbitrary subject.

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.

EventSink<E extends Event> - Interface in io.atomix.utils.event

Abstraction of an event sink capable of processing the specified event types.

except(Consumer<Throwable>) - Method in class io.atomix.utils.concurrent.ComposableFuture

Sets a consumer to be called when the future is failed.

exceptAsync(Consumer<Throwable>) - Method in class io.atomix.utils.concurrent.ComposableFuture

Sets a consumer to be called asynchronously when the future is failed.

exceptAsync(Consumer<Throwable>, Executor) - Method in class io.atomix.utils.concurrent.ComposableFuture

Sets a consumer to be called asynchronously when the future is failed.

exceptionalFuture(Throwable) - Static method in class io.atomix.utils.concurrent.Futures

Creates a future that is synchronously completed exceptionally.

exceptionalFutureAsync(Throwable, Executor) - Static method in class io.atomix.utils.concurrent.Futures

Creates a future that is asynchronously completed exceptionally.

exceptionally(Function<Throwable, ? extends T>) - Method in class io.atomix.utils.concurrent.OrderedFuture

execute(Runnable) - Method in class io.atomix.utils.concurrent.OrderedExecutor

execute(Runnable) - Method in class io.atomix.utils.concurrent.SingleThreadContext

execute(Runnable) - Method in class io.atomix.utils.concurrent.ThreadPoolContext

F

factory(String, int, Logger) - Method in enum io.atomix.utils.concurrent.ThreadModel

Returns a thread context factory.

firstOf(List<CompletableFuture<T>>, Match<T>, T) - Static method in class io.atomix.utils.concurrent.Futures

Returns a new CompletableFuture completed by with the first positive result from a list of input CompletableFutures.

FLOATING_ID - Static variable in class io.atomix.utils.serializer.KryoNamespace

ID to use if this KryoNamespace does not define registration id.

flush() - Method in class io.atomix.utils.memory.MappedMemory

Flushes the mapped buffer to disk.

free() - Method in class io.atomix.utils.memory.HeapMemory

free() - Method in class io.atomix.utils.memory.MappedMemory

free() - Method in interface io.atomix.utils.memory.Memory

Frees the memory.

free() - Method in class io.atomix.utils.memory.NativeMemory

from(long) - Static method in class io.atomix.utils.time.WallClockTimestamp

Returns a new wall clock timestamp for the given unix timestamp.

Futures - Class in io.atomix.utils.concurrent

Utilities for creating completed and exceptional futures.

Futures() - Constructor for class io.atomix.utils.concurrent.Futures

G

get() - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

get(long, TimeUnit) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

get(int) - Method in class io.atomix.utils.SlidingWindowCounter

Gets the total count for the last N window slots.

getByte(int) - Method in class io.atomix.utils.memory.HeapMemory

getByte(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a byte from the given memory offset.

getByte(int) - Method in class io.atomix.utils.memory.NativeMemory

getChar(int) - Method in class io.atomix.utils.memory.HeapMemory

getChar(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a character from the given memory offset.

getChar(int) - Method in class io.atomix.utils.memory.NativeMemory

getContext() - Method in class io.atomix.utils.concurrent.AtomixThread

Returns the thread context.

getDouble(int) - Method in class io.atomix.utils.memory.HeapMemory

getDouble(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a double from the given memory offset.

getDouble(int) - Method in class io.atomix.utils.memory.NativeMemory

getFloat(int) - Method in class io.atomix.utils.memory.HeapMemory

getFloat(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a float from the given memory offset.

getFloat(int) - Method in class io.atomix.utils.memory.NativeMemory

getInt(int) - Method in class io.atomix.utils.memory.HeapMemory

getInt(int) - Method in interface io.atomix.utils.memory.Memory

Fetches an integer from the given memory offset.

getInt(int) - Method in class io.atomix.utils.memory.NativeMemory

getLocalTimestamp() - Method in class io.atomix.utils.time.VectorClock

Returns the local logical timestamp.

getLogger(String, LoggerContext) - Static method in class io.atomix.utils.logging.ContextualLoggerFactory

Returns a contextual logger.

getLogger(Class, LoggerContext) - Static method in class io.atomix.utils.logging.ContextualLoggerFactory

Returns a contextual logger.

getLong(int) - Method in class io.atomix.utils.memory.HeapMemory

getLong(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a long from the given memory offset.

getLong(int) - Method in class io.atomix.utils.memory.NativeMemory

getName() - Method in class io.atomix.utils.logging.DelegatingLogger

getShort(int) - Method in class io.atomix.utils.memory.HeapMemory

getShort(int) - Method in interface io.atomix.utils.memory.Memory

Fetches a short from the given memory offset.

getShort(int) - Method in class io.atomix.utils.memory.NativeMemory

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.

getTimestamps() - Method in class io.atomix.utils.time.VectorClock

Returns a collection of identifier-timestamp pairs.

H

handle(BiFunction<? super T, Throwable, ? extends U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

handle(BiFunction<? super T, Throwable, ? extends U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

handleAsync(BiFunction<? super T, Throwable, ? extends U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

handleAsync(BiFunction<? super T, Throwable, ? extends U>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

handleAsync(BiFunction<? super T, Throwable, ? extends U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

handleAsync(BiFunction<? super T, Throwable, ? extends U>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

hashCode() - Method in class io.atomix.utils.AbstractIdentifier

Returns the hashcode of the identifier.

hashCode() - Method in class io.atomix.utils.Match

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

HeapMemory - Class in io.atomix.utils.memory

Java heap memory.

HeapMemory(byte[], HeapMemoryAllocator) - Constructor for class io.atomix.utils.memory.HeapMemory

HeapMemoryAllocator - Class in io.atomix.utils.memory

Java heap memory allocator.

HeapMemoryAllocator() - Constructor for class io.atomix.utils.memory.HeapMemoryAllocator

I

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.

ifNotNull() - Static method in class io.atomix.utils.Match

Returns a Match that matches all non-null values.

ifNotValue(T) - Static method in class io.atomix.utils.Match

Returns a Match that matches any value except the specified value.

ifNull() - Static method in class io.atomix.utils.Match

Returns a Match that matches null values.

ifValue(T) - Static method in class io.atomix.utils.Match

Returns a Match that only matches the specified value.

ImmutableListSerializer - Class in io.atomix.utils.serializer.serializers

Creates ImmutableList serializer instance.

ImmutableListSerializer() - Constructor for class io.atomix.utils.serializer.serializers.ImmutableListSerializer

Creates ImmutableList serializer instance.

ImmutableMapSerializer - Class in io.atomix.utils.serializer.serializers

Kryo Serializer for ImmutableMap.

ImmutableMapSerializer() - Constructor for class io.atomix.utils.serializer.serializers.ImmutableMapSerializer

Creates ImmutableMap serializer instance.

ImmutableSetSerializer - Class in io.atomix.utils.serializer.serializers

Kryo Serializer for ImmutableSet.

ImmutableSetSerializer() - Constructor for class io.atomix.utils.serializer.serializers.ImmutableSetSerializer

Creates ImmutableSet serializer instance.

increment() - Method in class io.atomix.utils.time.LogicalClock

Increments the clock and returns the new timestamp.

incrementAndUpdate(LogicalTimestamp) - Method in class io.atomix.utils.time.LogicalClock

Increments the clock and updates it using the given timestamp.

incrementCount() - Method in class io.atomix.utils.SlidingWindowCounter

Increments the count of the current window slot by 1.

incrementCount(long) - Method in class io.atomix.utils.SlidingWindowCounter

Increments the count of the current window slot by the given value.

info(String) - Method in class io.atomix.utils.logging.ContextualLogger

info(String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

info(String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

info(String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

info(String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

info(Marker, String) - Method in class io.atomix.utils.logging.ContextualLogger

info(Marker, String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

info(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

info(Marker, String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

info(Marker, String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

info(String) - Method in class io.atomix.utils.logging.DelegatingLogger

info(String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

info(String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

info(String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

info(String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

info(Marker, String) - Method in class io.atomix.utils.logging.DelegatingLogger

info(Marker, String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

info(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

info(Marker, String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

info(Marker, String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

INITIAL_ID - Static variable in class io.atomix.utils.serializer.KryoNamespace

Smallest ID free to use for user defined registrations.

io.atomix.utils - package io.atomix.utils

io.atomix.utils.concurrent - package io.atomix.utils.concurrent

Generic utilities for managing object lifecycles.

io.atomix.utils.event - package io.atomix.utils.event

Atomix event services.

io.atomix.utils.logging - package io.atomix.utils.logging

io.atomix.utils.memory - package io.atomix.utils.memory

Provides interfaces for performing low-level on- and off-heap memory management.

io.atomix.utils.serializer - package io.atomix.utils.serializer

io.atomix.utils.serializer.serializers - package io.atomix.utils.serializer.serializers

io.atomix.utils.time - package io.atomix.utils.time

Atomix time utilities.

isBlocked() - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

Returns a boolean indicating whether the future is blocked.

isCurrentContext() - Method in interface io.atomix.utils.concurrent.ThreadContext

Returns a boolean indicating whether the current thread is in this context.

isDebugEnabled() - Method in class io.atomix.utils.logging.DelegatingLogger

isDebugEnabled(Marker) - Method in class io.atomix.utils.logging.DelegatingLogger

isErrorEnabled() - Method in class io.atomix.utils.logging.DelegatingLogger

isErrorEnabled(Marker) - Method in class io.atomix.utils.logging.DelegatingLogger

isInfoEnabled() - Method in class io.atomix.utils.logging.DelegatingLogger

isInfoEnabled(Marker) - Method in class io.atomix.utils.logging.DelegatingLogger

isNewerThan(Timestamp) - Method in interface io.atomix.utils.time.Timestamp

Tests if this timestamp is newer than the specified timestamp.

isOlderThan(Timestamp) - Method in interface io.atomix.utils.time.Timestamp

Tests if this timestamp is older than the specified timestamp.

isPow2(int) - Static method in class io.atomix.utils.memory.Memory.Util

Returns a boolean indicating whether the given count is a power of 2.

isReady() - Method in class io.atomix.utils.AbstractAccumulator

isReady() - Method in interface io.atomix.utils.Accumulator

Indicates whether the accumulator is ready to process items.

isRelevant(E) - Method in interface io.atomix.utils.event.EventFilter

Indicates whether the specified event is of interest or not.

isRunning() - Method in interface io.atomix.utils.Managed

Returns a boolean value indicating whether the managed object is running.

isTraceEnabled() - Method in class io.atomix.utils.logging.DelegatingLogger

isTraceEnabled(Marker) - Method in class io.atomix.utils.logging.DelegatingLogger

isWarnEnabled() - Method in class io.atomix.utils.logging.DelegatingLogger

isWarnEnabled(Marker) - Method in class io.atomix.utils.logging.DelegatingLogger

J

join() - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

K

KryoNamespace - Class in io.atomix.utils.serializer

Pool of Kryo instances, with classes pre-registered.

KryoNamespace.Builder - Class in io.atomix.utils.serializer

KryoNamespace builder.

KryoNamespaces - Class in io.atomix.utils.serializer

L

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.

load(Class<T>) - Static method in class io.atomix.utils.Services

Loads the service for the given service class.

LoggerContext - Class in io.atomix.utils.logging

Logger context.

LoggerContext(Supplier<String>) - Constructor for class io.atomix.utils.logging.LoggerContext

LoggerContext.Builder - Class in io.atomix.utils.logging

Contextual logger builder.

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

LogicalTimestamp - Class in io.atomix.utils.time

Timestamp based on logical sequence value.

LogicalTimestamp(long) - Constructor for class io.atomix.utils.time.LogicalTimestamp

M

Managed<T> - Interface in io.atomix.utils

Interface for types that can be asynchronously started and stopped.

map(Function<T, V>) - Method in class io.atomix.utils.Match

Maps this instance to a Match of another type.

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.

MappedMemory - Class in io.atomix.utils.memory

Mapped memory.

MappedMemory(MappedByteBuffer, MappedMemoryAllocator) - Constructor for class io.atomix.utils.memory.MappedMemory

MappedMemoryAllocator - Class in io.atomix.utils.memory

Mapped memory allocator.

MappedMemoryAllocator(File) - Constructor for class io.atomix.utils.memory.MappedMemoryAllocator

MappedMemoryAllocator(File, FileChannel.MapMode) - Constructor for class io.atomix.utils.memory.MappedMemoryAllocator

MappedMemoryAllocator(File, FileChannel.MapMode, long) - Constructor for class io.atomix.utils.memory.MappedMemoryAllocator

MappedMemoryAllocator(RandomAccessFile, FileChannel.MapMode, long) - Constructor for class io.atomix.utils.memory.MappedMemoryAllocator

Match<T> - Class in io.atomix.utils

Utility class for checking matching values.

matches(T) - Method in class io.atomix.utils.Match

Checks if this instance matches specified value.

MAX_BUFFER_SIZE - Static variable in class io.atomix.utils.serializer.KryoNamespace

MAX_BUFFER_SIZE - Static variable in interface io.atomix.utils.serializer.Namespace

MAX_SIZE - Static variable in class io.atomix.utils.memory.HeapMemory

MAX_SIZE - Static variable in class io.atomix.utils.memory.MappedMemory

maxBatchMillis() - Method in class io.atomix.utils.AbstractAccumulator

Returns the maximum number of millis allowed to expire since the first item before processing is triggered.

maxIdleMillis() - Method in class io.atomix.utils.AbstractAccumulator

Returns the maximum number of millis allowed to expire since the last item arrival before processing is triggered.

maxItems() - Method in class io.atomix.utils.AbstractAccumulator

Returns the maximum number of items allowed to accumulate before processing is triggered.

Memory - Interface in io.atomix.utils.memory

Memory allocator.

Memory.Util - Class in io.atomix.utils.memory

Memory utilities.

MemoryAllocator<T extends Memory> - Interface in io.atomix.utils.memory

Memory allocator.

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.

N

namedThreads(String, Logger) - Static method in class io.atomix.utils.concurrent.Threads

Returns a thread factory that produces threads named according to the supplied name pattern.

Namespace - Interface in io.atomix.utils.serializer

Serializer namespace.

NativeMemory - Class in io.atomix.utils.memory

Native memory.

newThread(Runnable) - Method in class io.atomix.utils.concurrent.AtomixThreadFactory

nextId(int) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Sets the next Kryo registration Id for following register entries.

NONE - Static variable in interface io.atomix.utils.serializer.Namespace

Empty namespace that throws exceptions on serialization.

NOT_NULL - Static variable in class io.atomix.utils.Match

NULL - Static variable in class io.atomix.utils.Match

O

of(byte[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given short[].

of(short[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given short[].

of(int[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given int[].

of(long[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given long[].

of(float[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given float[].

of(double[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given double[].

of(boolean[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given boolean[].

of(Object[]) - Static method in class io.atomix.utils.ArraySizeHashPrinter

Returns ByteArraySizeHashPrinter wrapping given Object[].

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.

of(long) - Static method in class io.atomix.utils.TimestampPrinter

Returns a new timestamp printer.

offset() - Method in class io.atomix.utils.memory.HeapMemory

Returns the array base offset.

omitNullValues() - Method in class io.atomix.utils.logging.LoggerContext.Builder

Configures the MoreObjects.ToStringHelper so Object.toString() will ignore properties with null value.

onEvent(E) - Method in interface io.atomix.utils.event.EventListener

Reacts to the specified event.

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

OrderedExecutor - Class in io.atomix.utils.concurrent

Executor that executes tasks in order on a shared thread pool.

OrderedExecutor(Executor) - Constructor for class io.atomix.utils.concurrent.OrderedExecutor

orderedFuture() - Static method in class io.atomix.utils.concurrent.Futures

Returns a future that completes callbacks in add order.

OrderedFuture<T> - Class in io.atomix.utils.concurrent

A CompletableFuture that ensures callbacks are called in FIFO order.

OrderedFuture() - Constructor for class io.atomix.utils.concurrent.OrderedFuture

P

populate(int) - Method in class io.atomix.utils.serializer.KryoNamespace

Populates the Kryo pool.

process(E) - Method in interface io.atomix.utils.event.EventSink

Processes the specified event.

process(E) - Method in class io.atomix.utils.event.ListenerRegistry

processItems(List<T>) - Method in interface io.atomix.utils.Accumulator

Processes the specified list of accumulated items.

putByte(int, byte) - Method in class io.atomix.utils.memory.HeapMemory

putByte(int, byte) - Method in interface io.atomix.utils.memory.Memory

Stores a byte at the given memory offset.

putByte(int, byte) - Method in class io.atomix.utils.memory.NativeMemory

putChar(int, char) - Method in class io.atomix.utils.memory.HeapMemory

putChar(int, char) - Method in interface io.atomix.utils.memory.Memory

Stores a character at the given memory offset.

putChar(int, char) - Method in class io.atomix.utils.memory.NativeMemory

putDouble(int, double) - Method in class io.atomix.utils.memory.HeapMemory

putDouble(int, double) - Method in interface io.atomix.utils.memory.Memory

Stores a double at the given memory offset.

putDouble(int, double) - Method in class io.atomix.utils.memory.NativeMemory

putFloat(int, float) - Method in class io.atomix.utils.memory.HeapMemory

putFloat(int, float) - Method in interface io.atomix.utils.memory.Memory

Stores a float at the given memory offset.

putFloat(int, float) - Method in class io.atomix.utils.memory.NativeMemory

putInt(int, int) - Method in class io.atomix.utils.memory.HeapMemory

putInt(int, int) - Method in interface io.atomix.utils.memory.Memory

Stores an integer at the given memory offset.

putInt(int, int) - Method in class io.atomix.utils.memory.NativeMemory

putLong(int, long) - Method in class io.atomix.utils.memory.HeapMemory

putLong(int, long) - Method in interface io.atomix.utils.memory.Memory

Stores a long at the given memory offset.

putLong(int, long) - Method in class io.atomix.utils.memory.NativeMemory

putShort(int, short) - Method in class io.atomix.utils.memory.HeapMemory

putShort(int, short) - Method in interface io.atomix.utils.memory.Memory

Stores a short at the given memory offset.

putShort(int, short) - Method in class io.atomix.utils.memory.NativeMemory

R

randomDelay(int) - Static method in class io.atomix.utils.concurrent.Retries

Suspends the current thread for a random number of millis between 0 and the indicated limit.

read(Kryo, Input, Class<List<?>>) - Method in class io.atomix.utils.serializer.serializers.ArraysAsListSerializer

read(Kryo, Input, Class<ImmutableList<?>>) - Method in class io.atomix.utils.serializer.serializers.ImmutableListSerializer

read(Kryo, Input, Class<ImmutableMap<?, ?>>) - Method in class io.atomix.utils.serializer.serializers.ImmutableMapSerializer

read(Kryo, Input, Class<ImmutableSet<?>>) - Method in class io.atomix.utils.serializer.serializers.ImmutableSetSerializer

reallocate(NativeMemory, int) - Method in class io.atomix.utils.memory.DirectMemoryAllocator

reallocate(HeapMemory, int) - Method in class io.atomix.utils.memory.HeapMemoryAllocator

reallocate(MappedMemory, int) - Method in class io.atomix.utils.memory.MappedMemoryAllocator

reallocate(T, int) - Method in interface io.atomix.utils.memory.MemoryAllocator

Reallocates the given memory.

ReferenceCounted<T> - Interface in io.atomix.utils.concurrent

Reference counting interface.

ReferenceFactory<T extends ReferenceCounted<?>> - Interface in io.atomix.utils.concurrent

Reference factory.

ReferenceManager<T> - Interface in io.atomix.utils.concurrent

Reference manager.

ReferencePool<T extends ReferenceCounted<?>> - Class in io.atomix.utils.concurrent

Pool of reference counted objects.

ReferencePool(ReferenceFactory<T>) - Constructor for class io.atomix.utils.concurrent.ReferencePool

references() - Method in interface io.atomix.utils.concurrent.ReferenceCounted

Returns the number of open references.

register(Class<?>...) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Registers classes to be serialized using Kryo default serializer.

register(Serializer<?>, Class<?>...) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Registers serializer for the given set of classes.

register(KryoNamespace) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Registers all the class registered to given KryoNamespace.

release() - Method in interface io.atomix.utils.concurrent.ReferenceCounted

Releases a reference.

release(T) - Method in interface io.atomix.utils.concurrent.ReferenceManager

Releases the given reference.

release(T) - Method in class io.atomix.utils.concurrent.ReferencePool

release(Kryo) - Method in class io.atomix.utils.serializer.KryoNamespace

removeListener(L) - Method in class io.atomix.utils.event.AbstractListenerManager

removeListener(L) - Method in class io.atomix.utils.event.ListenerRegistry

removeListener(L) - Method in interface io.atomix.utils.event.ListenerService

Removes the specified listener.

reset(byte[]) - Method in class io.atomix.utils.memory.HeapMemory

Resets the memory pointer.

Retries - Class in io.atomix.utils.concurrent

Retry utilities.

retryable(Function<U, V>, Class<? extends Throwable>, int, int) - Static method in class io.atomix.utils.concurrent.Retries

Returns a function that retries execution on failure.

retryable(Supplier<V>, Class<? extends Throwable>, int, int) - Static method in class io.atomix.utils.concurrent.Retries

Returns a Supplier that retries execution on failure.

RetryingFunction<U,V> - Class in io.atomix.utils.concurrent

Function that retries execution on failure.

RetryingFunction(Function<U, V>, Class<? extends Throwable>, int, int) - Constructor for class io.atomix.utils.concurrent.RetryingFunction

run(KryoCallback<T>) - Method in class io.atomix.utils.serializer.KryoNamespace

runAfterBoth(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterBoth(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

runAfterBothAsync(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterBothAsync(CompletionStage<?>, Runnable, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterBothAsync(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

runAfterBothAsync(CompletionStage<?>, Runnable, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

runAfterEither(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterEither(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

runAfterEitherAsync(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterEitherAsync(CompletionStage<?>, Runnable, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

runAfterEitherAsync(CompletionStage<?>, Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

runAfterEitherAsync(CompletionStage<?>, Runnable, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

S

schedule(long, TimeUnit, Runnable) - Method in interface io.atomix.utils.concurrent.Scheduler

Schedules a runnable after a delay.

schedule(Duration, Runnable) - Method in interface io.atomix.utils.concurrent.Scheduler

Schedules a runnable after a delay.

schedule(long, long, TimeUnit, Runnable) - Method in interface io.atomix.utils.concurrent.Scheduler

Schedules a runnable at a fixed rate.

schedule(Duration, Duration, Runnable) - Method in interface io.atomix.utils.concurrent.Scheduler

Schedules a runnable at a fixed rate.

schedule(Duration, Runnable) - Method in class io.atomix.utils.concurrent.SingleThreadContext

schedule(Duration, Duration, Runnable) - Method in class io.atomix.utils.concurrent.SingleThreadContext

schedule(Duration, Runnable) - Method in class io.atomix.utils.concurrent.ThreadPoolContext

schedule(Duration, Duration, Runnable) - Method in class io.atomix.utils.concurrent.ThreadPoolContext

Scheduled - Interface in io.atomix.utils.concurrent

Scheduled task.

Scheduler - Interface in io.atomix.utils.concurrent

Scheduler.

serialize(Object) - Method in class io.atomix.utils.serializer.KryoNamespace

Serializes given object to byte array using Kryo instance in pool.

serialize(Object, int) - Method in class io.atomix.utils.serializer.KryoNamespace

Serializes given object to byte array using Kryo instance in pool.

serialize(Object, ByteBuffer) - Method in class io.atomix.utils.serializer.KryoNamespace

Serializes given object to byte buffer using Kryo instance in pool.

serialize(Object, OutputStream) - Method in class io.atomix.utils.serializer.KryoNamespace

Serializes given object to OutputStream using Kryo instance in pool.

serialize(Object, OutputStream, int) - Method in class io.atomix.utils.serializer.KryoNamespace

Serializes given object to OutputStream using Kryo instance in pool.

serialize(Object) - Method in interface io.atomix.utils.serializer.Namespace

Serializes given object to byte array using Kryo instance in pool.

serialize(Object, int) - Method in interface io.atomix.utils.serializer.Namespace

Serializes given object to byte array using Kryo instance in pool.

serialize(Object, ByteBuffer) - Method in interface io.atomix.utils.serializer.Namespace

Serializes given object to byte buffer using Kryo instance in pool.

serialize(Object, OutputStream) - Method in interface io.atomix.utils.serializer.Namespace

Serializes given object to OutputStream using Kryo instance in pool.

serialize(Object, OutputStream, int) - Method in interface io.atomix.utils.serializer.Namespace

Serializes given object to OutputStream using Kryo instance in pool.

Serializer - Interface in io.atomix.utils.serializer

Interface for serialization of store artifacts.

Services - Class in io.atomix.utils

Service utilities.

setCompatible(boolean) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Sets whether backwards/forwards compatible versioned serialization is enabled.

setContext(ThreadContext) - Method in class io.atomix.utils.concurrent.AtomixThread

Sets the thread context.

setRegistrationRequired(boolean) - Method in class io.atomix.utils.serializer.KryoNamespace.Builder

Sets the registrationRequired flag.

SingleThreadContext - Class in io.atomix.utils.concurrent

Single threaded context.

SingleThreadContext(String) - Constructor for class io.atomix.utils.concurrent.SingleThreadContext

Creates a new single thread context.

SingleThreadContext(ThreadFactory) - Constructor for class io.atomix.utils.concurrent.SingleThreadContext

Creates a new single thread context.

SingleThreadContextFactory - Class in io.atomix.utils.concurrent

Single thread context factory.

SingleThreadContextFactory(String, Logger) - Constructor for class io.atomix.utils.concurrent.SingleThreadContextFactory

SingleThreadContextFactory(ThreadFactory) - Constructor for class io.atomix.utils.concurrent.SingleThreadContextFactory

size() - Method in class io.atomix.utils.memory.HeapMemory

size() - Method in interface io.atomix.utils.memory.Memory

Returns the memory count.

size() - Method in class io.atomix.utils.memory.NativeMemory

size() - Method in class io.atomix.utils.serializer.KryoNamespace

Gets the number of classes registered in this Kryo namespace.

SlidingWindowCounter - Class in io.atomix.utils

Maintains a sliding window of value counts.

SlidingWindowCounter(int, ThreadContext) - Constructor for class io.atomix.utils.SlidingWindowCounter

Creates a new sliding window counter with the given total number of window slots.

start() - Method in interface io.atomix.utils.Managed

Starts the managed object.

stop() - Method in interface io.atomix.utils.Managed

Stops the managed object.

subject() - Method in class io.atomix.utils.event.AbstractEvent

subject() - Method in interface io.atomix.utils.event.Event

Returns the subject of the event.

T

thenAccept(Consumer<? super T>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAccept(Consumer<? super T>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenAcceptAsync(Consumer<? super T>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAcceptAsync(Consumer<? super T>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAcceptAsync(Consumer<? super T>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenAcceptAsync(Consumer<? super T>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenAcceptBoth(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAcceptBoth(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenAcceptBothAsync(CompletionStage<? extends U>, BiConsumer<? super T, ? super U>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenApply(Function<? super T, ? extends U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenApply(Function<? super T, ? extends U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenApplyAsync(Function<? super T, ? extends U>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenApplyAsync(Function<? super T, ? extends U>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenApplyAsync(Function<? super T, ? extends U>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenApplyAsync(Function<? super T, ? extends U>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenCombine(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenCombine(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenCombineAsync(CompletionStage<? extends U>, BiFunction<? super T, ? super U, ? extends V>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenCompose(Function<? super T, ? extends CompletionStage<U>>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenCompose(Function<? super T, ? extends CompletionStage<U>>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenComposeAsync(Function<? super T, ? extends CompletionStage<U>>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenRun(Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenRun(Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenRunAsync(Runnable) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenRunAsync(Runnable, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

thenRunAsync(Runnable) - Method in class io.atomix.utils.concurrent.OrderedFuture

thenRunAsync(Runnable, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

ThreadContext - Interface in io.atomix.utils.concurrent

Thread context.

ThreadContextFactory - Interface in io.atomix.utils.concurrent

Thread context factory.

ThreadModel - Enum in io.atomix.utils.concurrent

Raft thread model.

ThreadPoolContext - Class in io.atomix.utils.concurrent

Thread pool context.

ThreadPoolContext(ScheduledExecutorService) - Constructor for class io.atomix.utils.concurrent.ThreadPoolContext

Creates a new thread pool context.

ThreadPoolContextFactory - Class in io.atomix.utils.concurrent

Thread pool context factory.

ThreadPoolContextFactory(String, int, Logger) - Constructor for class io.atomix.utils.concurrent.ThreadPoolContextFactory

ThreadPoolContextFactory(int, ThreadFactory) - Constructor for class io.atomix.utils.concurrent.ThreadPoolContextFactory

ThreadPoolContextFactory(ScheduledExecutorService) - Constructor for class io.atomix.utils.concurrent.ThreadPoolContextFactory

Threads - Class in io.atomix.utils.concurrent

Thread utilities.

Threads() - Constructor for class io.atomix.utils.concurrent.Threads

time() - Method in class io.atomix.utils.event.AbstractEvent

time() - Method in interface io.atomix.utils.event.Event

Returns the timestamp of when the event occurred, given in milliseconds since the start of epoch.

timer() - Method in class io.atomix.utils.AbstractAccumulator

Returns the backing timer.

Timestamp - Interface in io.atomix.utils.time

Opaque version structure.

TimestampPrinter - Class in io.atomix.utils

Timestamp printer.

TimestampPrinter(long) - Constructor for class io.atomix.utils.TimestampPrinter

toCompletableFuture() - Method in class io.atomix.utils.concurrent.OrderedFuture

toPow2(int) - Static method in class io.atomix.utils.memory.Memory.Util

Rounds the count to the nearest power of two.

toString() - Method in class io.atomix.utils.AbstractIdentifier

Returns a string representation of a DeviceKeyId.

toString() - Method in class io.atomix.utils.ArraySizeHashPrinter

toString() - Method in class io.atomix.utils.event.AbstractEvent

toString() - Method in class io.atomix.utils.logging.DelegatingLogger

toString() - Method in class io.atomix.utils.logging.LoggerContext

toString() - Method in class io.atomix.utils.Match

toString() - Method in class io.atomix.utils.serializer.KryoNamespace

toString() - Method in class io.atomix.utils.time.LogicalClock

toString() - Method in class io.atomix.utils.time.LogicalTimestamp

toString() - Method in class io.atomix.utils.time.MultiValuedTimestamp

toString() - Method in class io.atomix.utils.time.VectorClock

toString() - Method in class io.atomix.utils.time.VectorTimestamp

toString() - Method in class io.atomix.utils.time.Version

toString() - Method in class io.atomix.utils.time.Versioned

toString() - Method in class io.atomix.utils.time.WallClock

toString() - Method in class io.atomix.utils.time.WallClockTimestamp

toString() - Method in class io.atomix.utils.TimestampPrinter

trace(String) - Method in class io.atomix.utils.logging.ContextualLogger

trace(String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

trace(String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

trace(String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

trace(String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

trace(Marker, String) - Method in class io.atomix.utils.logging.ContextualLogger

trace(Marker, String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

trace(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

trace(Marker, String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

trace(Marker, String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

trace(String) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(Marker, String) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(Marker, String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(Marker, String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

trace(Marker, String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

type() - Method in class io.atomix.utils.event.AbstractEvent

type() - Method in interface io.atomix.utils.event.Event

Returns the type of the event.

U

unixTimestamp() - Method in class io.atomix.utils.time.WallClockTimestamp

Returns the unixTimestamp.

unsafe() - Method in class io.atomix.utils.memory.HeapMemory

Returns the native Unsafe memory object.

unsafe() - Method in class io.atomix.utils.memory.NativeMemory

Returns the underlying Unsafe instance.

update(LogicalTimestamp) - Method in class io.atomix.utils.time.LogicalClock

Updates the clock using the given timestamp.

update(VectorTimestamp<T>) - Method in class io.atomix.utils.time.VectorClock

Updates the given timestamp.

update(VectorClock<T>) - Method in class io.atomix.utils.time.VectorClock

Updates the vector clock.

using(Namespace) - Static method in interface io.atomix.utils.serializer.Serializer

Creates a new Serializer instance from a Namespace.

Util() - Constructor for class io.atomix.utils.memory.Memory.Util

V

value() - Method in class io.atomix.utils.time.LogicalTimestamp

Returns the sequence value.

value() - Method in class io.atomix.utils.time.Version

Returns the version.

value() - Method in class io.atomix.utils.time.Versioned

Returns the value.

value1() - Method in class io.atomix.utils.time.MultiValuedTimestamp

Returns the first value.

value2() - Method in class io.atomix.utils.time.MultiValuedTimestamp

Returns the second value.

valueOf(String) - Static method in enum io.atomix.utils.concurrent.ThreadModel

Returns the enum constant of this type with the specified name.

valueOrElse(Versioned<U>, U) - Static method in class io.atomix.utils.time.Versioned

Returns the value of the specified Versioned object if non-null or else returns a default value.

valueOrNull(Versioned<U>) - Static method in class io.atomix.utils.time.Versioned

Returns the value of the specified Versioned object if non-null or else returns null.

values() - Static method in enum io.atomix.utils.concurrent.ThreadModel

Returns an array containing the constants of this enum type, in the order they are declared.

VectorClock<T extends Identifier> - Class in io.atomix.utils.time

Vector clock.

VectorClock(T) - Constructor for class io.atomix.utils.time.VectorClock

VectorClock(VectorTimestamp<T>) - Constructor for class io.atomix.utils.time.VectorClock

VectorClock(VectorTimestamp<T>, Collection<VectorTimestamp<T>>) - Constructor for class io.atomix.utils.time.VectorClock

VectorTimestamp<T extends Identifier> - Class in io.atomix.utils.time

Vector clock timestamp.

VectorTimestamp(T, long) - Constructor for class io.atomix.utils.time.VectorTimestamp

Version - Class in io.atomix.utils.time

Logical timestamp for versions.

Version(long) - Constructor for class io.atomix.utils.time.Version

version() - Method in class io.atomix.utils.time.Versioned

Returns the version.

Versioned<V> - Class in io.atomix.utils.time

Versioned value.

Versioned(V, long, long) - Constructor for class io.atomix.utils.time.Versioned

Constructs a new versioned value.

Versioned(V, long) - Constructor for class io.atomix.utils.time.Versioned

Constructs a new versioned value.

W

WallClock - Class in io.atomix.utils.time

Wall clock.

WallClock() - Constructor for class io.atomix.utils.time.WallClock

WallClockTimestamp - Class in io.atomix.utils.time

A Timestamp that derives its value from the prevailing wallclock time on the controller where it is generated.

WallClockTimestamp() - Constructor for class io.atomix.utils.time.WallClockTimestamp

WallClockTimestamp(long) - Constructor for class io.atomix.utils.time.WallClockTimestamp

warn(String) - Method in class io.atomix.utils.logging.ContextualLogger

warn(String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

warn(String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

warn(String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

warn(String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

warn(Marker, String) - Method in class io.atomix.utils.logging.ContextualLogger

warn(Marker, String, Object) - Method in class io.atomix.utils.logging.ContextualLogger

warn(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.ContextualLogger

warn(Marker, String, Object...) - Method in class io.atomix.utils.logging.ContextualLogger

warn(Marker, String, Throwable) - Method in class io.atomix.utils.logging.ContextualLogger

warn(String) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(Marker, String) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(Marker, String, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(Marker, String, Object, Object) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(Marker, String, Object...) - Method in class io.atomix.utils.logging.DelegatingLogger

warn(Marker, String, Throwable) - Method in class io.atomix.utils.logging.DelegatingLogger

whenComplete(BiConsumer<? super T, ? super Throwable>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

whenComplete(BiConsumer<? super T, ? super Throwable>) - Method in class io.atomix.utils.concurrent.OrderedFuture

whenCompleteAsync(BiConsumer<? super T, ? super Throwable>) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

whenCompleteAsync(BiConsumer<? super T, ? super Throwable>, Executor) - Method in class io.atomix.utils.concurrent.BlockingAwareFuture

whenCompleteAsync(BiConsumer<? super T, ? super Throwable>) - Method in class io.atomix.utils.concurrent.OrderedFuture

whenCompleteAsync(BiConsumer<? super T, ? super Throwable>, Executor) - Method in class io.atomix.utils.concurrent.OrderedFuture

wrap(byte[]) - Static method in class io.atomix.utils.memory.HeapMemory

Wraps the given bytes in a HeapMemory object.

write(Kryo, Output, List<?>) - Method in class io.atomix.utils.serializer.serializers.ArraysAsListSerializer

write(Kryo, Output, ImmutableList<?>) - Method in class io.atomix.utils.serializer.serializers.ImmutableListSerializer

write(Kryo, Output, ImmutableMap<?, ?>) - Method in class io.atomix.utils.serializer.serializers.ImmutableMapSerializer

write(Kryo, Output, ImmutableSet<?>) - Method in class io.atomix.utils.serializer.serializers.ImmutableSetSerializer

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