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(Throwable) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
abort() - Method in class org.reveno.atp.core.events.Event
 
abortIssue() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
AbstractClusterBuffer - Class in org.reveno.atp.clustering.core.components
 
AbstractClusterBuffer() - Constructor for class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
AbstractDynamicCommand - Class in org.reveno.atp.api.dynamic
 
AbstractDynamicCommand() - Constructor for class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
AbstractDynamicCommand(Map<String, Object>) - Constructor for class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
AbstractDynamicTransaction - Class in org.reveno.atp.api.dynamic
 
AbstractDynamicTransaction() - Constructor for class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
accept(T, boolean) - Method in interface org.reveno.atp.commons.BoolBiConsumer
 
accept(DefaultIdGenerator.NextIdTransaction, TransactionContext) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator
 
ackTimeoutNanos(long) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.TimeoutsConfiguration
 
ackTimeoutNanos(long) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
ackTimeoutNanos() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
add(TransactionStage, TransactionInterceptor) - Method in class org.reveno.atp.core.api.InterceptorCollection
 
addCommand(Object) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
addCommands(List<Object>) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
addOnBlocked(Runnable) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
addOnBlocked(Runnable) - Method in interface org.reveno.atp.core.api.FailoverManager
 
addOnBlocked(Runnable) - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
addOnUnblocked(Runnable) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
addOnUnblocked(Runnable) - Method in interface org.reveno.atp.core.api.FailoverManager
 
addOnUnblocked(Runnable) - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
addReceiver(Consumer<Message>) - Method in class org.reveno.atp.clustering.core.jgroups.JChannelReceiver
 
Address - Class in org.reveno.atp.clustering.api
In Reveno, Address is the basic abstraction on the notion of some another running instance of Reveno.
Address(String, IOMode, String) - Constructor for class org.reveno.atp.clustering.api.Address
 
address() - Method in class org.reveno.atp.clustering.api.message.Message
Returns address from which this message was originally sent.
address(Address) - Method in class org.reveno.atp.clustering.api.message.Message
 
addTransactions(List<Object>) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
addViewAcceptor(Consumer<View>) - Method in class org.reveno.atp.clustering.core.jgroups.JChannelReceiver
 
alwaysFlush() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
alwaysFlush(boolean) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
and(RepositorySnapshotter) - Method in interface org.reveno.atp.api.RevenoManager
 
andRestoreWithIt() - Method in interface org.reveno.atp.api.RevenoManager
This method does the same as RevenoManager.restoreWith(RepositorySnapshotter), but uses the last snapshotter, which was provided by RevenoManager.snapshotWith(RepositorySnapshotter) method call.
andThen(BoolBiConsumer<? super T>) - Method in interface org.reveno.atp.commons.BoolBiConsumer
 
arg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
arg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
arg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
arg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
args() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
args(Map<String, Object>) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
ASYNC_ERROR_FLAG - Static variable in class org.reveno.atp.core.events.EventPublisher
 
asyncEventExecutor() - Method in class org.reveno.atp.core.events.EventHandlersManager
 
asyncEventExecutors(int) - Method in interface org.reveno.atp.api.EventsManager
Defines the size of internal thread pool used for async Event handlers.
asyncEventExecutors(int) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
asyncEventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in interface org.reveno.atp.api.EventsManager
Event handler that will be eventually executed by the internal thread pool on event fired from Transaction Actions.
asyncEventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
atShutdown(boolean) - Method in interface org.reveno.atp.api.Configuration.SnapshotConfiguration
 
atShutdown(boolean) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoSnapshotConfiguration
 
atShutdown() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoSnapshotConfiguration
 
authToken(String) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
 
authToken(String) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
authToken() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
await() - Method in class org.reveno.atp.utils.SignalBarrier
Claim the SignalBarrier and block until signaled.
awaitNanos(long) - Method in class org.reveno.atp.utils.SignalBarrier
Claim the SignalBarrier and block until signaled or the timeout expires.

B

Barrier - Class in org.reveno.atp.core.events
Barrier class used for denoting end of async event execution flow of handlers.
Barrier(EventPublisher, long, boolean) - Constructor for class org.reveno.atp.core.events.Barrier
 
BarrierMessage - Class in org.reveno.atp.clustering.core.messages
 
BarrierMessage(String) - Constructor for class org.reveno.atp.clustering.core.messages.BarrierMessage
 
BarrierMessage() - Constructor for class org.reveno.atp.clustering.core.messages.BarrierMessage
 
BarrierPassed - Class in org.reveno.atp.clustering.core.messages
 
BarrierPassed(String) - Constructor for class org.reveno.atp.clustering.core.messages.BarrierPassed
 
BarrierPassed() - Constructor for class org.reveno.atp.clustering.core.messages.BarrierPassed
 
barrierTimeoutNanos(long) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.TimeoutsConfiguration
 
barrierTimeoutNanos(long) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
barrierTimeoutNanos() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
begin() - Method in interface org.reveno.atp.core.api.TxRepository
 
begin() - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
begin() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
begin() - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
BinaryUtils - Class in org.reveno.atp.utils
 
BinaryUtils() - Constructor for class org.reveno.atp.utils.BinaryUtils
 
Bits - Class in org.reveno.atp.clustering.util
 
Bits() - Constructor for class org.reveno.atp.clustering.util.Bits
 
block() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
bool(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
bool() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
bool(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
bool() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
BoolBiConsumer<T> - Interface in org.reveno.atp.commons
 
buffer() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
Buffer - Interface in org.reveno.atp.core.api.channel
 
BufferOutOfBoundsException - Exception in org.reveno.atp.api.exceptions
 
BufferOutOfBoundsException() - Constructor for exception org.reveno.atp.api.exceptions.BufferOutOfBoundsException
 
bufferSize(int) - Method in interface org.reveno.atp.api.Configuration.DisruptorConfiguration
 
bufferSize() - Method in class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
bufferSize() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
bufferSize(int) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoDisruptorConfiguration
 
bufferSize() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoDisruptorConfiguration
 
byteArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
byteArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
byteArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
byteArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
ByteSourceBuffer - Class in org.reveno.atp.clustering.core.fastcast
 
ByteSourceBuffer() - Constructor for class org.reveno.atp.clustering.core.fastcast.ByteSourceBuffer
 
bytesToInt(byte[]) - Static method in class org.reveno.atp.utils.BinaryUtils
 
bytesToLong(byte[]) - Static method in class org.reveno.atp.utils.BinaryUtils
 
BytezBufferWrapper - Class in org.reveno.atp.clustering.core.fastcast
 
BytezBufferWrapper() - Constructor for class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 

C

capacity() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
capacity() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
capacity() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
capacity() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
capacity() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
Channel - Interface in org.reveno.atp.core.api.channel
 
channel(String) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
channel(String) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
channel() - Method in class org.reveno.atp.core.channel.FileChannel
 
channel(String) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
ChannelBuffer - Class in org.reveno.atp.core.channel
 
ChannelBuffer(ByteBuffer) - Constructor for class org.reveno.atp.core.channel.ChannelBuffer
 
ChannelBuffer(ByteBuffer, Supplier<ByteBuffer>, Supplier<ByteBuffer>) - Constructor for class org.reveno.atp.core.channel.ChannelBuffer
 
ChannelOptions - Enum in org.reveno.atp.api
 
channelOptions(ChannelOptions) - Method in interface org.reveno.atp.api.Configuration.JournalingConfiguration
 
channelOptions(ChannelOptions) - Method in class org.reveno.atp.core.channel.FileChannel
 
channelOptions(ChannelOptions) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
channelOptions() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
ChannelReader - Class in org.reveno.atp.core.data
 
ChannelReader(List<Channel>) - Constructor for class org.reveno.atp.core.data.ChannelReader
 
charArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
charArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
charArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
charArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
checkArgument(boolean) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving one or more parameters to the calling method.
checkArgument(boolean, Object) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving one or more parameters to the calling method.
checkArgument(boolean, String, Object...) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving one or more parameters to the calling method.
checkElementIndex(int, int) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that index specifies a valid element in an array, list or string of size size.
checkElementIndex(int, int, String) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that index specifies a valid element in an array, list or string of size size.
checkLastTagWas(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
checkNotNull(T) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that an object reference passed as a parameter to the calling method is not null.
checkNotNull(T, Object) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that an object reference passed as a parameter to the calling method is not null.
checkNotNull(T, String, Object...) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that an object reference passed as a parameter to the calling method is not null.
checkPositionIndex(int, int) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that index specifies a valid position in an array, list or string of size size.
checkPositionIndex(int, int, String) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that index specifies a valid position in an array, list or string of size size.
checkPositionIndexes(int, int, int) - Static method in class org.reveno.atp.utils.Preconditions
Ensures that start and end specify a valid positions in an array, list or string of size size, and are in order.
checkState(boolean) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving the state of the calling instance, but not involving any parameters to the calling method.
checkState(boolean, Object) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving the state of the calling instance, but not involving any parameters to the calling method.
checkState(boolean, String, Object...) - Static method in class org.reveno.atp.utils.Preconditions
Ensures the truth of an expression involving the state of the calling instance, but not involving any parameters to the calling method.
classLoader() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
classLoader() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
classLoader(ClassLoader) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
clear() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
clear() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
clear() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
clear() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
clear() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
clear() - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
clear() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
clearAll() - Method in interface org.reveno.atp.core.api.ViewsStorage
 
clearAll() - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
cloneExtended(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
close() - Method in interface org.reveno.atp.core.api.channel.Channel
 
close() - Method in class org.reveno.atp.core.channel.FileChannel
 
close() - Method in class org.reveno.atp.core.data.DefaultInputProcessor
 
close() - Method in class org.reveno.atp.core.events.EventHandlersManager
 
close() - Method in class org.reveno.atp.metrics.impl.GraphiteSink
 
close() - Method in class org.reveno.atp.metrics.impl.PickledGraphite
 
close() - Method in class org.reveno.atp.metrics.impl.Slf4jSink
 
close() - Method in interface org.reveno.atp.metrics.Sink
 
cluster() - Method in interface org.reveno.atp.api.Reveno
Contains all configuration settings regarding usage of engine in cluster.
Cluster - Interface in org.reveno.atp.clustering.api
In Reveno, Cluster is an interface which denotes the notion of group of Reveno hosts, which works according to Master-Slave principle.
cluster() - Method in class org.reveno.atp.core.Engine
 
CLUSTER_NAME - Static variable in class org.reveno.atp.clustering.core.providers.JGroupsClusterProvider
 
ClusterBuffer - Interface in org.reveno.atp.clustering.api
Buffer is used as replication mechanism only, so it can be anything, while ClusterConnector is used only for failover inter-cluster communications.
ClusterBufferHeader() - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer.ClusterBufferHeader
 
ClusterConfiguration - Interface in org.reveno.atp.clustering.api
 
clusterConfiguration() - Method in class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterConfiguration.CommandsXmitTransport - Enum in org.reveno.atp.clustering.api
 
ClusterConfiguration.MulticastConfiguration - Interface in org.reveno.atp.clustering.api
 
ClusterConfiguration.SyncConfiguration - Interface in org.reveno.atp.clustering.api
 
ClusterConfiguration.TimeoutsConfiguration - Interface in org.reveno.atp.clustering.api
 
ClusterConfiguration.UnicastConfiguration - Interface in org.reveno.atp.clustering.api
 
ClusterConnector - Interface in org.reveno.atp.clustering.api
Cluster gateway interface, which can be used for internal communication between Reveno nodes.
ClusterEngine - Class in org.reveno.atp.clustering.core
 
ClusterEngine(FoldersStorage, JournalsStorage, SnapshotStorage, ClassLoader) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(String, ClassLoader) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(File, ClassLoader) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(File, ClassLoader, ClusterProvider) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(File) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(String) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(String, ClusterProvider) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(FoldersStorage, JournalsStorage, SnapshotStorage, ClassLoader, ClusterProvider) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEngine(FoldersStorage, JournalsStorage, SnapshotStorage, ClassLoader, ClusterProvider, StorageTransferServer) - Constructor for class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterEvent - Enum in org.reveno.atp.clustering.api
 
ClusterExecutor<R,ContextType> - Interface in org.reveno.atp.clustering.core.api
 
ClusterFailoverManager - Class in org.reveno.atp.clustering.core
 
ClusterFailoverManager(TransactionInfoSerializer, ClusterBuffer) - Constructor for class org.reveno.atp.clustering.core.ClusterFailoverManager
 
ClusterManager - Interface in org.reveno.atp.api
 
ClusterMessageHeader() - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.ClusterMessageHeader
 
ClusterProvider - Interface in org.reveno.atp.clustering.core.buffer
Factory for the two major (and possibly distinct in implementation) things - Cluster and ClusterBuffer.
ClusterState - Class in org.reveno.atp.clustering.core.api
 
ClusterState(boolean, long, Optional<NodeState>) - Constructor for class org.reveno.atp.clustering.core.api.ClusterState
 
clusterStateCollector(ClusterExecutor<ClusterState, Void>) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
ClusterStateInfo - Interface in org.reveno.atp.clustering.api
 
clusterStateInfo() - Method in class org.reveno.atp.clustering.core.ClusterEngine
 
ClusterView - Class in org.reveno.atp.clustering.api
Represents the View of the cluster at some given period of time.
ClusterView(long, List<Address>) - Constructor for class org.reveno.atp.clustering.api.ClusterView
 
command(BiFunction<AbstractDynamicCommand, CommandContext, Object>) - Method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
command() - Method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
command(Class<C>, Class<U>, BiFunction<C, CommandContext, U>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
command(Class<C>, BiConsumer<C, CommandContext>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
CommandContext - Interface in org.reveno.atp.api.commands
 
commandResult() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
commandResult(Object) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
CommandsManager - Class in org.reveno.atp.core.engine.components
 
CommandsManager() - Constructor for class org.reveno.atp.core.engine.components.CommandsManager
 
commandsManager() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
commandsManager() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
commandsManager(CommandsManager) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
commandsXmitTransport(ClusterConfiguration.CommandsXmitTransport) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Denotes the style of network communication which will be used between all nodes in cluster to transfer commands from Master to Slaves.
commandsXmitTransport(ClusterConfiguration.CommandsXmitTransport) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
commandsXmitTransport() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
commandType() - Method in class org.reveno.atp.api.dynamic.DynamicCommand
 
commit() - Method in interface org.reveno.atp.core.api.TxRepository
 
commit() - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
commit() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
commit() - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
commitAsyncError(boolean, long) - Method in class org.reveno.atp.core.events.EventPublisher
 
commitInfo() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
compareTo(LongRange) - Method in class org.reveno.atp.commons.LongRange
 
compareTo(FoldersStorage.Folder) - Method in class org.reveno.atp.core.api.storage.FoldersStorage.Folder
 
compareTo(FoldersStorage.FolderItem) - Method in class org.reveno.atp.core.api.storage.FoldersStorage.FolderItem
 
compareTo(JournalsStorage.JournalStore) - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
compensate(Object, TransactionContext) - Method in class org.reveno.atp.core.engine.components.TransactionsManager
 
ConcurrentMapOfMap() - Constructor for class org.reveno.atp.utils.MapUtils.ConcurrentMapOfMap
 
ConcurrentMapOfMap(int, float) - Constructor for class org.reveno.atp.utils.MapUtils.ConcurrentMapOfMap
 
concurrentRepositoryMap() - Static method in class org.reveno.atp.utils.MapUtils
 
concurrentRepositoryMap(int, float) - Static method in class org.reveno.atp.utils.MapUtils
 
conditionalCommand(BiFunction<AbstractDynamicCommand, CommandContext, Boolean>) - Method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
config() - Method in interface org.reveno.atp.api.Reveno
Regular configuration of an engine, things like model type, snapshotting frequency, CPU consumption and etc.
config() - Method in class org.reveno.atp.core.Engine
 
config() - Method in class org.reveno.atp.metrics.RevenoMetrics
 
Configuration - Interface in org.reveno.atp.api
 
configuration() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
configuration() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
configuration(RevenoConfiguration) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
Configuration - Interface in org.reveno.atp.metrics
 
Configuration.CpuConsumption - Enum in org.reveno.atp.api
 
Configuration.DisruptorConfiguration - Interface in org.reveno.atp.api
 
Configuration.JournalingConfiguration - Interface in org.reveno.atp.api
 
Configuration.ModelType - Enum in org.reveno.atp.api
 
Configuration.MutableModelFailover - Enum in org.reveno.atp.api
 
Configuration.SnapshotConfiguration - Interface in org.reveno.atp.api
 
ConfigurationImpl - Class in org.reveno.atp.metrics
 
ConfigurationImpl() - Constructor for class org.reveno.atp.metrics.ConfigurationImpl
 
connect() - Method in interface org.reveno.atp.clustering.api.Cluster
Connects to the current Reveno group of nodes.
connect() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
connect() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
connect() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
connect() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
connect() - Method in class org.reveno.atp.metrics.impl.PickledGraphite
 
contains(long) - Method in class org.reveno.atp.commons.LongRange
 
containsKey(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
containsValue(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
context(CommandContext) - Method in interface org.reveno.atp.core.api.IdGenerator
 
context(CommandContext) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator
 
convertVolumeToStore(JournalsStorage.JournalStore) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
convertVolumeToStore(JournalsStorage.JournalStore, long) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
convertVolumeToStore(JournalsStorage.JournalStore) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
convertVolumeToStore(JournalsStorage.JournalStore, long) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
Counter - Interface in org.reveno.atp.metrics.meter
 
cpuConsumption(Configuration.CpuConsumption) - Method in interface org.reveno.atp.api.Configuration
 
cpuConsumption() - Method in class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
cpuConsumption() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
cpuConsumption(Configuration.CpuConsumption) - Method in class org.reveno.atp.core.RevenoConfiguration
 
cpuConsumption() - Method in class org.reveno.atp.core.RevenoConfiguration
 
crc32(byte[]) - Static method in class org.reveno.atp.clustering.util.Bits
 
create(long, long, long) - Method in interface org.reveno.atp.core.api.EventsCommitInfo.Builder
 
create() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo.Builder
 
create(Optional<RepositoryData>) - Method in interface org.reveno.atp.core.api.TxRepositoryFactory
 
create(long, long, long) - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl.PojoBuilder
 
create() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl.PojoBuilder
 
createItem(FoldersStorage.Folder, String) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
createItem(FoldersStorage.Folder, String) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
currentChannel() - Method in interface org.reveno.atp.core.api.Journaler
 
currentChannel() - Method in class org.reveno.atp.core.data.DefaultJournaler
 
currentHandler - Variable in class org.reveno.atp.core.views.ViewsProcessor
 
currentId(long) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
currentNodeAddress(String, String, String) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
The network address of the current node and unique Node ID.
currentNodeAddress(String, String, String, IOMode) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
The network address of the current node and unique Node ID.
currentNodeAddress(Address) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Abstract Address which identifies current node in cluster.
currentNodeAddress(String, String, String) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
currentNodeAddress(String, String, String, IOMode) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
currentNodeAddress(Address) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
currentNodeAddress() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
currentOffset() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
currentTransactionId - Variable in class org.reveno.atp.clustering.core.api.ClusterState
 
currentTransactionId(long) - Method in interface org.reveno.atp.core.api.RestoreableEventBus
 
currentTransactionId(long) - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
currentView() - Method in interface org.reveno.atp.clustering.api.ClusterStateInfo
 
currentViewType(Class<?>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 

D

data - Variable in class org.reveno.atp.api.domain.RepositoryData
 
data() - Method in interface org.reveno.atp.api.transaction.TransactionContext
 
datagramSize() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
datagramSize(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
datagramSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
dataSync() - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Data Synchronization configurations.
dataSync() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
debug(Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
debug(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
debug(String, Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
decode(Buffer, Buffer) - Method in interface org.reveno.atp.core.api.Decoder
 
decodeNestedMessageAsGroup - Variable in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
Decoder<T> - Interface in org.reveno.atp.core.api
 
defaultEventBus() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
DefaultIdGenerator - Class in org.reveno.atp.core.engine.components
 
DefaultIdGenerator() - Constructor for class org.reveno.atp.core.engine.components.DefaultIdGenerator
 
DefaultIdGenerator.IdsBundle - Class in org.reveno.atp.core.engine.components
 
DefaultIdGenerator.NextIdTransaction - Class in org.reveno.atp.core.engine.components
 
DefaultIdGenerator.Object2LongMapEx<T> - Interface in org.reveno.atp.core.engine.components
 
DefaultIdGenerator.Object2LongOpenHashMapEx<T> - Class in org.reveno.atp.core.engine.components
 
DefaultInputProcessor - Class in org.reveno.atp.core.data
 
DefaultInputProcessor(JournalsStorage) - Constructor for class org.reveno.atp.core.data.DefaultInputProcessor
 
DefaultJavaSerializer - Class in org.reveno.atp.core.serialization
 
DefaultJavaSerializer() - Constructor for class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
DefaultJavaSerializer(ClassLoader) - Constructor for class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
DefaultJavaSerializer.ObjectInputStreamEx - Class in org.reveno.atp.core.serialization
 
DefaultJournaler - Class in org.reveno.atp.core.data
 
DefaultJournaler() - Constructor for class org.reveno.atp.core.data.DefaultJournaler
 
DefaultSnapshotter - Class in org.reveno.atp.core.snapshots
 
DefaultSnapshotter(SnapshotStorage, RepositoryDataSerializer) - Constructor for class org.reveno.atp.core.snapshots.DefaultSnapshotter
 
DefaultSystemStateRestorer - Class in org.reveno.atp.core.restore
 
DefaultSystemStateRestorer(JournalsStorage, EngineWorkflowContext, EngineEventsContext, WorkflowEngine) - Constructor for class org.reveno.atp.core.restore.DefaultSystemStateRestorer
 
deleteStore(JournalsStorage.JournalStore) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
deleteStore(JournalsStorage.JournalStore) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
deserialize(EventsCommitInfo.Builder, Buffer) - Method in interface org.reveno.atp.core.api.serialization.EventsInfoSerializer
 
deserialize(Buffer) - Method in interface org.reveno.atp.core.api.serialization.RepositoryDataSerializer
 
deserialize(TransactionCommitInfo.Builder, Buffer) - Method in interface org.reveno.atp.core.api.serialization.TransactionInfoSerializer
 
deserialize(TransactionCommitInfo.Builder, Buffer) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
deserialize(TransactionCommitInfo.Builder, Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
deserialize(Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
deserialize(TransactionCommitInfo.Builder, Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
deserialize(Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
deserialize(EventsCommitInfo.Builder, Buffer) - Method in class org.reveno.atp.core.serialization.SimpleEventsSerializer
 
deserializeCommands(Buffer) - Method in interface org.reveno.atp.core.api.serialization.TransactionInfoSerializer
 
deserializeCommands(Buffer) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
deserializeCommands(Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
deserializeCommands(Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
deserializeObject(Buffer) - Method in interface org.reveno.atp.core.api.serialization.Serializer
 
deserializeObject(Buffer) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
deserializeObject(Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
deserializeObject(Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
destroy() - Method in interface org.reveno.atp.core.api.Destroyable
 
destroy() - Method in interface org.reveno.atp.core.api.Journaler
 
destroy() - Method in class org.reveno.atp.core.data.DefaultJournaler
 
destroy() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
destroy() - Method in class org.reveno.atp.core.engine.components.SnapshottingInterceptor
 
destroy() - Method in class org.reveno.atp.core.engine.InputHandlers
 
destroy() - Method in class org.reveno.atp.core.events.Event
 
destroy() - Method in class org.reveno.atp.core.JournalsManager
 
destroy() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
destroy() - Method in class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
destroy() - Method in class org.reveno.atp.metrics.MetricsInterceptor
 
Destroyable - Interface in org.reveno.atp.core.api
 
destroyDirectBuffer(ByteBuffer) - Static method in class org.reveno.atp.utils.UnsafeUtils
 
DirectTransactionBuilder - Class in org.reveno.atp.api.dynamic
 
DirectTransactionBuilder(String, BiConsumer<AbstractDynamicTransaction, TransactionContext>, SerializersChain, TransactionsManager, CommandsManager, ClassLoader) - Constructor for class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
disconnect() - Method in interface org.reveno.atp.clustering.api.Cluster
Marks itself as detached from the cluster, and frees all allocated resources and connections for it.
disconnect() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
disconnect() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
disconnect() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
disconnect() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
disruptor() - Method in interface org.reveno.atp.api.Configuration
 
disruptor() - Method in class org.reveno.atp.core.RevenoConfiguration
 
DisruptorEventPipeProcessor - Class in org.reveno.atp.core.disruptor
 
DisruptorEventPipeProcessor(Configuration.CpuConsumption, int, ExecutorService) - Constructor for class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
DisruptorPipeProcessor<T extends Destroyable> - Class in org.reveno.atp.core.disruptor
 
DisruptorPipeProcessor() - Constructor for class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
DisruptorTransactionPipeProcessor - Class in org.reveno.atp.core.disruptor
 
DisruptorTransactionPipeProcessor(TransactionCommitInfo.Builder, Configuration.CpuConsumption, int, ExecutorService) - Constructor for class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
domain() - Method in interface org.reveno.atp.api.Reveno
Contains all required operations for managing of domain space of engine.
domain() - Method in class org.reveno.atp.core.Engine
 
doubleArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
doubleArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
doubleArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
doubleArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
DynamicCommand - Class in org.reveno.atp.api.dynamic
 
DynamicCommand(Class<? extends AbstractDynamicCommand>, Class<? extends AbstractDynamicTransaction>) - Constructor for class org.reveno.atp.api.dynamic.DynamicCommand
 

E

ElectionResult - Class in org.reveno.atp.clustering.core.api
 
ElectionResult(boolean, boolean) - Constructor for class org.reveno.atp.clustering.core.api.ElectionResult
 
electionTimeouts() - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Timeouts which are used during Leadership Election process, which is started usually by membership changes, or some unexpected critical situations.
electionTimeouts() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
EMPTY_RESULT - Static variable in class org.reveno.atp.core.engine.InputHandlers
 
EMPTY_VIEW - Static variable in class org.reveno.atp.clustering.api.ClusterView
 
EmptyResult - Class in org.reveno.atp.api.commands
 
EmptyResult() - Constructor for class org.reveno.atp.api.commands.EmptyResult
 
EmptyResult(Throwable) - Constructor for class org.reveno.atp.api.commands.EmptyResult
 
end - Variable in class org.reveno.atp.commons.LongRange
 
Engine - Class in org.reveno.atp.core
 
Engine(FoldersStorage, JournalsStorage, SnapshotStorage, ClassLoader) - Constructor for class org.reveno.atp.core.Engine
 
Engine(File) - Constructor for class org.reveno.atp.core.Engine
 
Engine(File, ClassLoader) - Constructor for class org.reveno.atp.core.Engine
 
Engine(String) - Constructor for class org.reveno.atp.core.Engine
 
Engine(String, ClassLoader) - Constructor for class org.reveno.atp.core.Engine
 
EngineEventsContext - Class in org.reveno.atp.core
 
EngineEventsContext() - Constructor for class org.reveno.atp.core.EngineEventsContext
 
EngineWorkflowContext - Class in org.reveno.atp.core
 
EngineWorkflowContext() - Constructor for class org.reveno.atp.core.EngineWorkflowContext
 
entityType - Variable in class org.reveno.atp.core.engine.components.DefaultIdGenerator.NextIdTransaction
 
entrySet() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
equals(Object) - Method in class org.reveno.atp.clustering.api.Address
 
equals(Object) - Method in class org.reveno.atp.clustering.api.ClusterView
 
equals(Object) - Method in class org.reveno.atp.clustering.api.InetAddress
 
equals(Object) - Method in class org.reveno.atp.commons.LongRange
 
erase() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
Clear all unprocessed data.
erase() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
erase() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
erase() - Method in class org.reveno.atp.core.views.ViewsProcessor
 
Event - Class in org.reveno.atp.core.events
 
Event() - Constructor for class org.reveno.atp.core.events.Event
 
EventBus - Interface in org.reveno.atp.api.transaction
 
eventBus() - Method in interface org.reveno.atp.api.transaction.TransactionContext
 
eventBus() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
eventBus(RestoreableEventBus) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
eventFactory() - Method in class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
eventFactory() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
eventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in interface org.reveno.atp.api.EventsManager
Event handler that will be eventually executed by single thread with guaranteed ordering from Transaction Actions.
eventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
EventHandlersManager - Class in org.reveno.atp.core.events
 
EventHandlersManager() - Constructor for class org.reveno.atp.core.events.EventHandlersManager
 
EventMetadata(boolean, long) - Constructor for class org.reveno.atp.api.EventsManager.EventMetadata
 
eventMetadata() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
eventMetadata(EventsManager.EventMetadata) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
eventMetadata() - Method in class org.reveno.atp.core.events.Event
 
eventMetadata(EventsManager.EventMetadata) - Method in class org.reveno.atp.core.events.Event
 
eventPublisher() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
eventPublisher() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
eventPublisher(EventPublisher) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
EventPublisher - Class in org.reveno.atp.core.events
 
EventPublisher(PipeProcessor<Event>, EventsContext) - Constructor for class org.reveno.atp.core.events.EventPublisher
 
events() - Method in interface org.reveno.atp.api.Reveno
Allows to register custom event handlers for different event types.
EVENTS - Static variable in class org.reveno.atp.clustering.core.components.StorageTransferModelSync
 
events() - Method in class org.reveno.atp.core.Engine
 
events() - Method in class org.reveno.atp.core.events.Event
 
events(Object[]) - Method in class org.reveno.atp.core.events.Event
 
eventsCommitBuilder() - Method in class org.reveno.atp.core.EngineEventsContext
 
eventsCommitBuilder(EventsCommitInfo.Builder) - Method in class org.reveno.atp.core.EngineEventsContext
 
eventsCommitBuilder() - Method in interface org.reveno.atp.core.events.EventsContext
 
EventsCommitInfo - Interface in org.reveno.atp.core.api
Contains basic info about events execution result, which were issued in some transaction.
EventsCommitInfo.Builder - Interface in org.reveno.atp.core.api
 
EventsCommitInfoImpl - Class in org.reveno.atp.core.impl
 
EventsCommitInfoImpl() - Constructor for class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
EventsCommitInfoImpl.PojoBuilder - Class in org.reveno.atp.core.impl
 
EventsContext - Interface in org.reveno.atp.core.events
 
EventsInfoSerializer - Interface in org.reveno.atp.core.api.serialization
 
eventsJournaler() - Method in class org.reveno.atp.core.EngineEventsContext
 
eventsJournaler(Journaler) - Method in class org.reveno.atp.core.EngineEventsContext
 
eventsJournaler() - Method in interface org.reveno.atp.core.events.EventsContext
 
EventsManager - Interface in org.reveno.atp.api
 
EventsManager.EventMetadata - Class in org.reveno.atp.api
 
eventsPublishing(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
eventsSize() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
every(long) - Method in interface org.reveno.atp.api.Configuration.SnapshotConfiguration
 
every(long) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoSnapshotConfiguration
 
every() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoSnapshotConfiguration
 
ex(ProcessorContext, boolean, boolean, BoolBiConsumer<ProcessorContext>) - Method in class org.reveno.atp.core.engine.InputHandlers
 
Examples - Class in org.reveno.atp.examples.clustering
 
Examples() - Constructor for class org.reveno.atp.examples.clustering.Examples
 
Exceptions - Class in org.reveno.atp.utils
 
Exceptions() - Constructor for class org.reveno.atp.utils.Exceptions
 
execute(DynamicCommand, Map<String, Object>) - Method in interface org.reveno.atp.api.Reveno
 
execute(String, Map<String, Object>) - Method in interface org.reveno.atp.api.Reveno
 
execute(String) - Method in interface org.reveno.atp.api.Reveno
 
execute(ClusterView, ContextType) - Method in interface org.reveno.atp.clustering.core.api.ClusterExecutor
 
execute(ClusterView) - Method in interface org.reveno.atp.clustering.core.api.ClusterExecutor
 
execute(ClusterView, Void) - Method in class org.reveno.atp.clustering.core.components.MessagingClusterStateCollector
 
execute(ClusterView, Void) - Method in class org.reveno.atp.clustering.core.components.MessagingMasterSlaveElector
 
execute(ClusterView, StorageTransferModelSync.TransferContext) - Method in class org.reveno.atp.clustering.core.components.StorageTransferModelSync
 
execute(Object) - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
execute(Object, CommandContext) - Method in class org.reveno.atp.core.engine.components.CommandsManager
 
execute(Object, TransactionContext) - Method in class org.reveno.atp.core.engine.components.TransactionsManager
 
execute(DynamicCommand, Map<String, Object>) - Method in class org.reveno.atp.core.Engine
 
execute(String, Map<String, Object>) - Method in class org.reveno.atp.core.Engine
 
execute(String) - Method in class org.reveno.atp.core.Engine
 
execute(Object) - Method in interface org.reveno.atp.core.engine.processor.TransactionPipeProcessor
 
executeCommand(Object) - Method in interface org.reveno.atp.api.Reveno
This is one the core methods of engine.
executeCommand(Object) - Method in class org.reveno.atp.core.Engine
 
executeCommands(ProcessorContext, WorkflowContext) - Method in class org.reveno.atp.core.engine.components.TransactionExecutor
 
executeRestore(RestoreableEventBus, TransactionCommitInfo) - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
executeRestore(RestoreableEventBus, TransactionCommitInfo) - Method in interface org.reveno.atp.core.engine.processor.TransactionPipeProcessor
 
executeSync(Object) - Method in interface org.reveno.atp.api.Reveno
 
executeSync(DynamicCommand, Map<String, Object>) - Method in interface org.reveno.atp.api.Reveno
 
executeSync(String, Map<String, Object>) - Method in interface org.reveno.atp.api.Reveno
 
executeSync(String) - Method in interface org.reveno.atp.api.Reveno
 
executeSync(DynamicCommand, Map<String, Object>) - Method in class org.reveno.atp.core.Engine
 
executeSync(Object) - Method in class org.reveno.atp.core.Engine
 
executeSync(String, Map<String, Object>) - Method in class org.reveno.atp.core.Engine
 
executeSync(String) - Method in class org.reveno.atp.core.Engine
 
executeTransaction(Object) - Method in interface org.reveno.atp.api.commands.CommandContext
 
executor() - Method in class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
executor() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
extendDelta(int) - Method in class org.reveno.atp.core.channel.FileChannel
 

F

fail() - Method in class org.reveno.atp.core.events.Barrier
 
failed - Variable in class org.reveno.atp.clustering.core.api.ClusterState
 
failed - Variable in class org.reveno.atp.clustering.core.api.ElectionResult
 
FailoverAbortedException - Exception in org.reveno.atp.clustering.exceptions
 
FailoverAbortedException(String) - Constructor for exception org.reveno.atp.clustering.exceptions.FailoverAbortedException
 
FailoverAbortedException(String, Throwable) - Constructor for exception org.reveno.atp.clustering.exceptions.FailoverAbortedException
 
FailoverExecutor - Class in org.reveno.atp.clustering.core
 
FailoverExecutor(Cluster, JournalsManager, ClusterFailoverManager, StorageTransferServer, RevenoClusterConfiguration) - Constructor for class org.reveno.atp.clustering.core.FailoverExecutor
 
failoverListener(Runnable) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
FailoverManager - Interface in org.reveno.atp.core.api
 
failoverManager() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
failoverManager() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
failoverManager(FailoverManager) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
failoverNotifier(Consumer<ClusterEvent>) - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
failoverNotifier(Consumer<ClusterEvent>) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
failoverNotifier(Consumer<ClusterEvent>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
FailoverRulesException - Exception in org.reveno.atp.api.exceptions
 
FailoverRulesException(String) - Constructor for exception org.reveno.atp.api.exceptions.FailoverRulesException
 
FastCastBuffer - Class in org.reveno.atp.clustering.core.fastcast
fast-cast ClusterBuffer implementation, which is based on reliable message multicasting.
FastCastBuffer(FastCastConfiguration) - Constructor for class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
FastCastConfiguration - Class in org.reveno.atp.clustering.core.fastcast
 
FastCastConfiguration() - Constructor for class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
FastCastConfiguration.SocketConfiguration - Class in org.reveno.atp.clustering.core.fastcast
 
FastCastEx - Class in org.reveno.atp.clustering.core.fastcast
 
FastCastEx() - Constructor for class org.reveno.atp.clustering.core.fastcast.FastCastEx
 
FastCastSlf4jLogger - Class in org.reveno.atp.clustering.core.fastcast
 
FastCastSlf4jLogger() - Constructor for class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
fastRepo() - Static method in class org.reveno.atp.utils.MapUtils
 
fastRepo(int, float) - Static method in class org.reveno.atp.utils.MapUtils
 
fastSetRepo() - Static method in class org.reveno.atp.utils.MapUtils
 
fatal(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
fatal(String, Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
FileChannel - Class in org.reveno.atp.core.channel
 
FileChannel(File) - Constructor for class org.reveno.atp.core.channel.FileChannel
 
FileNotFoundException - Exception in org.reveno.atp.api.exceptions
 
FileNotFoundException(File, Throwable) - Constructor for exception org.reveno.atp.api.exceptions.FileNotFoundException
 
FileStorageTransferServer - Class in org.reveno.atp.clustering.core.components
 
FileStorageTransferServer(RevenoClusterConfiguration, FileSystemStorage) - Constructor for class org.reveno.atp.clustering.core.components.FileStorageTransferServer
Protocol: 1st byte - SyncMode 2nd byte - 1b - Transactions, 2b - Events 3-10 bytes - from transaction id rest - payload
FileSystemStorage - Class in org.reveno.atp.core.storage
 
FileSystemStorage(File, RevenoConfiguration.RevenoJournalingConfiguration) - Constructor for class org.reveno.atp.core.storage.FileSystemStorage
 
filter() - Method in interface org.reveno.atp.clustering.core.api.MessagesReceiver
 
find(Class<V>, long) - Method in interface org.reveno.atp.api.query.QueryManager
 
find(Class<View>, long) - Method in interface org.reveno.atp.core.api.ViewsStorage
 
find(Class<V>, long) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
findO(Class<V>, long) - Method in interface org.reveno.atp.api.query.QueryManager
 
finish() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
fixJournals(ClusterView) - Method in interface org.reveno.atp.clustering.core.api.StorageTransferServer
 
fixJournals(ClusterView) - Method in class org.reveno.atp.clustering.core.components.FileStorageTransferServer
 
Flag - Enum in org.reveno.atp.clustering.api
 
flag() - Method in interface org.reveno.atp.core.api.EventsCommitInfo
Some flag of events commit for internal handling or restore process.
flag() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
flag(long) - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
flag(long) - Method in class org.reveno.atp.core.events.Event
 
flag() - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
flag() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
flag(long) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
floatArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
floatArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
floatArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
floatArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
flush() - Method in class org.reveno.atp.metrics.impl.PickledGraphite
 
Folder(String, String) - Constructor for class org.reveno.atp.core.api.storage.FoldersStorage.Folder
 
FolderItem(String, String) - Constructor for class org.reveno.atp.core.api.storage.FoldersStorage.FolderItem
 
FoldersStorage - Interface in org.reveno.atp.core.api.storage
 
FoldersStorage.Folder - Class in org.reveno.atp.core.api.storage
 
FoldersStorage.FolderItem - Class in org.reveno.atp.core.api.storage
 
ForceElectionProcess - Class in org.reveno.atp.clustering.core.messages
 
ForceElectionProcess() - Constructor for class org.reveno.atp.clustering.core.messages.ForceElectionProcess
 
future() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
future(CompletableFuture) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 

G

gateway() - Method in interface org.reveno.atp.clustering.api.Cluster
Provides gateway instance which provides with communication ability between nodes via sending Messages to each other.
gateway() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
gb(int) - Static method in class org.reveno.atp.utils.MeasureUtils
 
get(Class<T>, long) - Method in interface org.reveno.atp.api.domain.Repository
Retrieves entity from repository.
get(Class<V>, long) - Method in interface org.reveno.atp.api.query.MappingContext
 
get(byte) - Static method in enum org.reveno.atp.clustering.api.SyncMode
 
get(long) - Method in class org.reveno.atp.clustering.core.fastcast.ByteSourceBuffer
 
get(Class<?>) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator.IdsBundle
 
get(Class<T>, long) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
get(Class<T>, long) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
get(Class<T>, long) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
get(Class<T>, long) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
get(Class<T>, long) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
get(Class<V>, long) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
get(Object) - Method in class org.reveno.atp.utils.MapUtils.ConcurrentMapOfMap
 
get(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfList
 
get(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfMap
 
get(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
get(Object) - Method in class org.reveno.atp.utils.MapUtils.SimpleMap
 
getAddressType() - Method in class org.reveno.atp.clustering.api.Address
Type of the IO mode of connection, that will be open to node at given Address.
getAll() - Method in class org.reveno.atp.core.snapshots.SnapshottersManager
 
getAllStores() - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
getAllStores() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getAsyncHandlers(Class<?>) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
getBaseDir() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getBuffer() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
getBuffers() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
getBytez() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
getByType(byte) - Static method in enum org.reveno.atp.core.repository.MutableModelRepository.EntityRecoveryState
 
getClean(Class<T>, long) - Method in interface org.reveno.atp.api.domain.Repository
Gets entity from repository without marking it as dirty, hence no view mapping will happen after transaction, in which this method is invoked.
getClean(Class<T>, long) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
getClean(Class<T>, long) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
getClean(Class<T>, long) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
getClean(Class<T>, long) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
getClean(Class<T>, long) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
getCommands() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
getConnectionString() - Method in class org.reveno.atp.clustering.api.Address
Connection String, which allows current node to perform network (or other transport) communications.
getCurrentNode() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
getData() - Method in interface org.reveno.atp.api.domain.Repository
Snapshot all data from the repository.
getData() - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
getData() - Method in class org.reveno.atp.core.repository.HashMapRepository
 
getData() - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
getData() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
getData() - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
getEntities(Class<?>) - Method in interface org.reveno.atp.api.domain.Repository
 
getEntities(Class<?>) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
getEntities(Class<?>) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
getEntities(Class<?>) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
getEntities(Class<?>) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
getEntities(Class<?>) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
getEntitiesClean(Class<?>) - Method in interface org.reveno.atp.api.domain.Repository
 
getEntitiesClean(Class<?>) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
getEntitiesClean(Class<?>) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
getEntitiesClean(Class<?>) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
getEntitiesClean(Class<?>) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
getEntitiesClean(Class<?>) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
getEntityTypes() - Method in interface org.reveno.atp.api.domain.Repository
All entity types registered in that repository.
getEntityTypes() - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
getEntityTypes() - Method in class org.reveno.atp.core.repository.HashMapRepository
 
getEntityTypes() - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
getEntityTypes() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
getEntityTypes() - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
getEventHandlers(Class<?>) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
getEvents() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
getEventsCommitsAddress() - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
getEventsJournaler() - Method in class org.reveno.atp.core.JournalsManager
 
getException() - Method in class org.reveno.atp.api.commands.Result
 
getFailures() - Method in class org.reveno.atp.metrics.impl.PickledGraphite
 
getFileDate() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
getFlag() - Method in class org.reveno.atp.core.events.Event
 
getFreePorts(int) - Static method in class org.reveno.atp.clustering.util.Utils
 
getGroupAddress() - Method in class org.reveno.atp.core.api.storage.FoldersStorage.Folder
 
getHost() - Method in class org.reveno.atp.clustering.api.InetAddress
 
getInterceptors(TransactionStage) - Method in class org.reveno.atp.core.api.InterceptorCollection
 
getItem(String, FoldersStorage.Folder) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
getItem(String, FoldersStorage.Folder) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getItemAddress() - Method in class org.reveno.atp.core.api.storage.FoldersStorage.FolderItem
 
getItems(FoldersStorage.Folder) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
getItems(FoldersStorage.Folder) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getLastFolder(String) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
getLastFolder(String) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getLastSnapshotStore() - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
getLastSnapshotStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getLastStores() - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
getLastStores() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
getLastTag() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
getLastTransactionId() - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
getLastTransactionId() - Method in class org.reveno.atp.core.api.SystemStateRestorer.SystemState
 
getLastTransactionId() - Method in class org.reveno.atp.core.engine.WorkflowEngine
 
getMarkedRecords() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
getName() - Method in class org.reveno.atp.core.api.storage.FoldersStorage.FolderItem
 
getName() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
getNodeAddresses() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
getNodeId() - Method in class org.reveno.atp.clustering.api.Address
Unique Node Identificator among cluster of Reveno nodes.
getO(Class<T>, long) - Method in interface org.reveno.atp.api.domain.Repository
 
getO(Class<V>, long) - Method in interface org.reveno.atp.api.query.MappingContext
 
getObject() - Method in class org.reveno.atp.commons.LockFreeQueue
Gets an object from the beginning of the queue.
getOrDefault(T, long) - Method in interface org.reveno.atp.core.engine.components.DefaultIdGenerator.Object2LongMapEx
 
getOrDefault(T, long) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator.Object2LongOpenHashMapEx
 
getPipe() - Method in class org.reveno.atp.core.engine.WorkflowEngine
 
getPipe() - Method in class org.reveno.atp.core.events.EventPublisher
 
getPort() - Method in class org.reveno.atp.clustering.api.InetAddress
 
getPrefix() - Method in class org.reveno.atp.core.api.storage.FoldersStorage.Folder
 
getPrefix() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
getRest() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
getResult() - Method in class org.reveno.atp.api.commands.Result
 
getSerializerType() - Method in interface org.reveno.atp.core.api.serialization.Serializer
 
getSerializerType() - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
getSerializerType() - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
getSerializerType() - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
getSnapshotPath() - Method in class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 
getStoreVersion() - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
getTime() - Method in interface org.reveno.atp.api.RepositorySnapshotter.SnapshotIdentifier
 
getTime() - Method in class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 
getTransactionCommitsAddress() - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
getTransactions() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
getTransactionsJournaler() - Method in class org.reveno.atp.core.JournalsManager
 
getTransactionTime() - Method in class org.reveno.atp.api.EventsManager.EventMetadata
Time at which transaction was executed and journaled in millis.
getType() - Method in interface org.reveno.atp.api.RepositorySnapshotter.SnapshotIdentifier
 
getType() - Method in enum org.reveno.atp.api.transaction.TransactionStage
 
getType() - Method in enum org.reveno.atp.clustering.api.SyncMode
 
getType() - Method in class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 
getType() - Method in enum org.reveno.atp.core.repository.MutableModelRepository.EntityRecoveryState
 
getUnpublishedEvents() - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
getUnsafe() - Static method in class org.reveno.atp.utils.UnsafeUtils
 
getVal1() - Method in class org.reveno.atp.clustering.util.Tuple
 
getVal2() - Method in class org.reveno.atp.clustering.util.Tuple
 
getVersion() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
getVolumes() - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
getVolumes() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
graphitePort(int) - Method in interface org.reveno.atp.metrics.Configuration
 
graphitePort() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
graphitePort(int) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
graphiteServer(String) - Method in interface org.reveno.atp.metrics.Configuration
 
graphiteServer() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
graphiteServer(String) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
GraphiteSink - Class in org.reveno.atp.metrics.impl
 
GraphiteSink(String, int) - Constructor for class org.reveno.atp.metrics.impl.GraphiteSink
 
GroupBarrier - Class in org.reveno.atp.clustering.core.components
Cluster barrier used to wait until all nodes in particular View came into a single point.
GroupBarrier(Cluster, ClusterView, String, long) - Constructor for class org.reveno.atp.clustering.core.components.GroupBarrier
 

H

handle(T, boolean) - Method in interface org.reveno.atp.core.engine.processor.ProcessorHandler
 
handleUnknownField(int, Schema<T>) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
has(Class<T>, long) - Method in interface org.reveno.atp.api.domain.Repository
 
has(Class<T>, long) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
has(Class<T>, long) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
has(Class<T>, long) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
has(Class<T>, long) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
has(Class<T>, long) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
hasAny() - Method in interface org.reveno.atp.api.RepositorySnapshotter
Checks is there any available snapshot to be loaded.
hasAny() - Method in class org.reveno.atp.core.snapshots.DefaultSnapshotter
 
hasEntityMap(Class<?>) - Method in class org.reveno.atp.core.views.ViewsManager
 
hashCode() - Method in class org.reveno.atp.clustering.api.Address
 
hashCode() - Method in class org.reveno.atp.clustering.api.ClusterView
 
hashCode() - Method in class org.reveno.atp.clustering.api.InetAddress
 
hashCode() - Method in class org.reveno.atp.commons.LongRange
 
hashCode() - Method in class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
hashCode() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
HashMapRepository - Class in org.reveno.atp.core.repository
 
HashMapRepository(int, float) - Constructor for class org.reveno.atp.core.repository.HashMapRepository
 
hasResult() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
higher(long) - Method in class org.reveno.atp.commons.LongRange
 
Histogram - Interface in org.reveno.atp.metrics.meter
 
HistogramType - Enum in org.reveno.atp.metrics.meter
 
host(String) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Multicast host.
host(String) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
host() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
hostName(String) - Method in interface org.reveno.atp.metrics.Configuration
 
hostName() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
hostName(String) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 

I

id(Class<?>) - Method in interface org.reveno.atp.api.commands.CommandContext
 
id() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
id(Class<?>) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
ID - Static variable in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer.ClusterBufferHeader
 
ID - Static variable in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.ClusterMessageHeader
 
id - Variable in class org.reveno.atp.clustering.core.messages.BarrierMessage
 
id - Variable in class org.reveno.atp.clustering.core.messages.BarrierPassed
 
id - Variable in class org.reveno.atp.core.engine.components.DefaultIdGenerator.NextIdTransaction
 
IdGenerator - Interface in org.reveno.atp.core.api
Used for generating unique ID of entities across current domain model.
idGenerator() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
idGenerator() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
idGenerator(IdGenerator) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
IdsBundle() - Constructor for class org.reveno.atp.core.engine.components.DefaultIdGenerator.IdsBundle
 
IllegalFileName - Exception in org.reveno.atp.api.exceptions
 
IllegalFileName(String, Throwable) - Constructor for exception org.reveno.atp.api.exceptions.IllegalFileName
 
immutableModel() - Method in interface org.reveno.atp.api.Configuration
 
immutableModel() - Method in class org.reveno.atp.core.RevenoConfiguration
 
ImmutableModelRepository - Class in org.reveno.atp.core.repository
ImmutableModelRepository(WriteableRepository) - Constructor for class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
inc(long) - Method in interface org.reveno.atp.metrics.meter.Counter
 
inc(int) - Method in interface org.reveno.atp.metrics.meter.Counter
 
inc() - Method in interface org.reveno.atp.metrics.meter.Counter
 
inc(long) - Method in class org.reveno.atp.metrics.meter.impl.SimpleCounter
 
inc(int) - Method in class org.reveno.atp.metrics.meter.impl.SimpleCounter
 
inc() - Method in class org.reveno.atp.metrics.meter.impl.SimpleCounter
 
InetAddress - Class in org.reveno.atp.clustering.api
 
InetAddress(String, String) - Constructor for class org.reveno.atp.clustering.api.InetAddress
Default constructor.
InetAddress(String, IOMode) - Constructor for class org.reveno.atp.clustering.api.InetAddress
 
InetAddress(String, String, IOMode) - Constructor for class org.reveno.atp.clustering.api.InetAddress
 
info(Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
info(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
info(String, Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
init() - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
init() - Method in class org.reveno.atp.core.channel.FileChannel
 
init() - Method in class org.reveno.atp.core.engine.WorkflowEngine
 
init() - Method in class org.reveno.atp.metrics.impl.GraphiteSink
 
init() - Method in class org.reveno.atp.metrics.impl.Slf4jSink
 
init() - Method in class org.reveno.atp.metrics.MetricsInterceptor
 
init() - Method in interface org.reveno.atp.metrics.Sink
 
initialize(RevenoClusterConfiguration) - Method in interface org.reveno.atp.clustering.core.buffer.ClusterProvider
 
initialize(RevenoClusterConfiguration) - Method in class org.reveno.atp.clustering.core.providers.JGroupsClusterProvider
 
InputHandlers - Class in org.reveno.atp.core.engine
 
InputHandlers(WorkflowContext, LongSupplier) - Constructor for class org.reveno.atp.core.engine.InputHandlers
 
InputProcessor - Interface in org.reveno.atp.core.api
Previosly we used to use Journaler for both reading and writing.
InputProcessor.JournalType - Enum in org.reveno.atp.core.api
 
insert(long, View) - Method in interface org.reveno.atp.core.api.ViewsStorage
 
insert(long, View) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
instanceName(String) - Method in interface org.reveno.atp.metrics.Configuration
 
instanceName() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
instanceName(String) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
intArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
intArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
intArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
intArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
intercept(long, long, WriteableRepository, TransactionStage) - Method in interface org.reveno.atp.api.transaction.TransactionInterceptor
 
intercept(long, long, WriteableRepository, TransactionStage) - Method in class org.reveno.atp.core.engine.components.SnapshottingInterceptor
 
intercept(long, long, WriteableRepository, TransactionStage) - Method in class org.reveno.atp.metrics.MetricsInterceptor
 
InterceptorCollection - Class in org.reveno.atp.core.api
 
InterceptorCollection() - Constructor for class org.reveno.atp.core.api.InterceptorCollection
 
interceptorCollection() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
interceptorCollection() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
interceptorCollection(InterceptorCollection) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
interceptors() - Method in class org.reveno.atp.core.Engine
 
interestedTypes() - Method in interface org.reveno.atp.clustering.core.api.MessagesReceiver
 
interestedTypes() - Method in class org.reveno.atp.clustering.core.components.MessagingClusterStateCollector
 
interestedTypes() - Method in class org.reveno.atp.clustering.core.components.MessagingMasterSlaveElector
 
intlongToBytes(int, long, byte[]) - Static method in class org.reveno.atp.utils.BinaryUtils
 
intToBytes(int) - Static method in class org.reveno.atp.clustering.util.Bits
 
intToBytes(int) - Static method in class org.reveno.atp.utils.BinaryUtils
 
IOMode - Enum in org.reveno.atp.clustering.api
Used to denote, in which mode failover will happen on particular node: either sync, async or unreliable async - no nak, rsvp etc.
isAborted() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
isAborted() - Method in class org.reveno.atp.core.events.Event
 
isAvailable() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
isAvailable() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
isAvailable() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
isAvailable() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
isAvailable() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
isAvailable() - Method in class org.reveno.atp.metrics.impl.GraphiteSink
 
isAvailable() - Method in class org.reveno.atp.metrics.impl.Slf4jSink
 
isAvailable() - Method in interface org.reveno.atp.metrics.Sink
 
isBlocked() - Method in interface org.reveno.atp.clustering.api.ClusterStateInfo
 
isBlocked() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
isBlocked() - Method in interface org.reveno.atp.core.api.FailoverManager
 
isBlocked() - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
isConnected() - Method in interface org.reveno.atp.clustering.api.Cluster
Checks whether current node is included in current group of hosts.
isConnected() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
isConnected() - Method in class org.reveno.atp.metrics.impl.PickledGraphite
 
isCurrentFieldPacked() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
isElectedInCluster() - Method in class org.reveno.atp.clustering.core.ClusterEngine
 
isEmpty() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
isMaster() - Method in interface org.reveno.atp.clustering.api.ClusterStateInfo
 
isMaster - Variable in class org.reveno.atp.clustering.core.api.ElectionResult
 
isMaster() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
isMaster() - Method in interface org.reveno.atp.core.api.FailoverManager
 
isMaster() - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
isNullOrEmpty(String) - Static method in class org.reveno.atp.clustering.util.Utils
 
isOpen() - Method in interface org.reveno.atp.core.api.channel.Channel
 
isOpen() - Method in class org.reveno.atp.core.channel.FileChannel
 
isOpen() - Method in class org.reveno.atp.core.events.Barrier
 
isPreallocated(boolean) - Method in class org.reveno.atp.core.channel.FileChannel
 
isPreallocated() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
isReadAvailable() - Method in interface org.reveno.atp.core.api.channel.Channel
 
isReadAvailable() - Method in class org.reveno.atp.core.channel.FileChannel
 
isReady() - Method in interface org.reveno.atp.metrics.meter.Histogram
 
isReady() - Method in class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
isRegistered(Class<?>) - Method in interface org.reveno.atp.core.api.serialization.Serializer
 
isRegistered(Class<?>) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
isRegistered(Class<?>) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
isRegistered(Class<?>) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
isReplay() - Method in class org.reveno.atp.core.events.Event
 
isReplicated() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
isReplicated() - Method in class org.reveno.atp.core.events.Event
 
isRestore() - Method in class org.reveno.atp.api.EventsManager.EventMetadata
Identifies whether it's the first time event is fired.
isRestore() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
isRolling() - Method in class org.reveno.atp.core.JournalsManager
 
isSingleNode() - Method in interface org.reveno.atp.core.api.FailoverManager
 
isSingleNode() - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
isStarted() - Method in interface org.reveno.atp.api.Reveno
Checks whether the engine was started or now.
isStarted() - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
isStarted() - Method in class org.reveno.atp.core.Engine
 
isStarted() - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
isSuccess() - Method in class org.reveno.atp.api.commands.Result
 
iterator() - Method in class org.reveno.atp.commons.LongRange
 
iterator() - Method in class org.reveno.atp.core.data.ChannelReader
 

J

JChannelHelper - Class in org.reveno.atp.clustering.core.jgroups
 
JChannelHelper() - Constructor for class org.reveno.atp.clustering.core.jgroups.JChannelHelper
 
JChannelReceiver - Class in org.reveno.atp.clustering.core.jgroups
 
JChannelReceiver() - Constructor for class org.reveno.atp.clustering.core.jgroups.JChannelReceiver
 
JGroupsBuffer - Class in org.reveno.atp.clustering.core.jgroups
JGroups implementation of ClusterBuffer.
JGroupsBuffer(RevenoClusterConfiguration, JChannel) - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
JGroupsBuffer(RevenoClusterConfiguration, JChannel, Optional<IOMode>) - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
JGroupsBuffer.ClusterBufferHeader - Class in org.reveno.atp.clustering.core.jgroups
 
JGroupsCluster - Class in org.reveno.atp.clustering.core.jgroups
 
JGroupsCluster(RevenoClusterConfiguration, JChannel) - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
JGroupsCluster.ClusterMessageHeader - Class in org.reveno.atp.clustering.core.jgroups
 
JGroupsCluster.JGroupsConnector - Class in org.reveno.atp.clustering.core.jgroups
 
JGroupsClusterProvider - Class in org.reveno.atp.clustering.core.providers
Abstract provider where Cluster implementation is always used as JGroups, and ClusterBuffer may vary.
JGroupsClusterProvider() - Constructor for class org.reveno.atp.clustering.core.providers.JGroupsClusterProvider
 
JGroupsConnector() - Constructor for class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
Journaler - Interface in org.reveno.atp.core.api
 
journaling() - Method in interface org.reveno.atp.api.Configuration
 
journaling(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
journaling() - Method in class org.reveno.atp.core.RevenoConfiguration
 
journalsManager() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
journalsManager() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
journalsManager(JournalsManager) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
JournalsManager - Class in org.reveno.atp.core
 
JournalsManager(JournalsStorage, RevenoConfiguration.RevenoJournalingConfiguration) - Constructor for class org.reveno.atp.core.JournalsManager
 
JournalsStorage - Interface in org.reveno.atp.core.api.storage
 
JournalsStorage.JournalStore - Class in org.reveno.atp.core.api.storage
 
JournalStore(String, String, String, long) - Constructor for class org.reveno.atp.core.api.storage.JournalsStorage.JournalStore
 
JsonMarshaller - Class in org.reveno.atp.clustering.core.marshallers
Json Message marshaller.
JsonMarshaller() - Constructor for class org.reveno.atp.clustering.core.marshallers.JsonMarshaller
 

K

kb(int) - Static method in class org.reveno.atp.utils.MeasureUtils
 
keySet() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 

L

lastTransactionId(Supplier<Long>) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
lastTransactionId - Variable in class org.reveno.atp.core.api.SystemInfo
 
lastVersionedFile(File, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
lastVersionFile(File, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
lastView() - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
latestNode - Variable in class org.reveno.atp.clustering.core.api.ClusterState
 
latestNode - Variable in class org.reveno.atp.clustering.core.components.StorageTransferModelSync.TransferContext
 
leaderElector(ClusterExecutor<ElectionResult, Void>) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
length() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
length() - Method in class org.reveno.atp.clustering.core.fastcast.ByteSourceBuffer
 
length() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
length() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
length() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
length() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
limit() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
limit() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
limit() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
limit() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
limit() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
limitNext(int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
limitNext(int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
limitNext(int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
limitNext(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
limitNext(int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
link(long[], Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
link(Stream<Long>, Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
link(LongCollection, Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
link(Class<V>, long) - Method in interface org.reveno.atp.api.query.MappingContext
 
link(long[], Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
link(Stream<Long>, Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
link(LongCollection, Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
link(Class<V>, long) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
linkedFastRepo() - Static method in class org.reveno.atp.utils.MapUtils
 
linkSet(long[], Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
linkSet(Stream<Long>, Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
linkSet(LongCollection, Class<V>) - Method in interface org.reveno.atp.api.query.MappingContext
 
linkSet(long[], Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
linkSet(Stream<Long>, Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
linkSet(LongCollection, Class<V>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
listen(Engine) - Method in class org.reveno.atp.metrics.RevenoMetrics
 
listenEvents(Consumer<ClusterEvent>) - Method in interface org.reveno.atp.clustering.api.Cluster
Subscribes to the set of events, which can eventually be issued, reflecting some changes in membership, etc.
listenEvents(Consumer<ClusterEvent>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
listFiles(File, String, boolean) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
listFolders(File, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
listVersioned(File, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
load(Map<Class<?>, Map<Long, Object>>) - Method in interface org.reveno.atp.api.domain.WriteableRepository
 
load() - Method in interface org.reveno.atp.api.RepositorySnapshotter
Loads last snapshot into RepositoryData
load(Map<Class<?>, Map<Long, Object>>) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
load(Map<Class<?>, Map<Long, Object>>) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
load(Map<Class<?>, Map<Long, Object>>) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
load(Map<Class<?>, Map<Long, Object>>) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
load(Map<Class<?>, Map<Long, Object>>) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
load() - Method in class org.reveno.atp.core.snapshots.DefaultSnapshotter
 
loadExistedCommand(String, ClassLoader) - Static method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
loadResource(File, Properties) - Static method in class org.reveno.atp.clustering.util.ResourceLoader
 
loadResource(InputStream, Properties) - Static method in class org.reveno.atp.clustering.util.ResourceLoader
 
loadXMLFromString(String) - Static method in class org.reveno.atp.clustering.util.ResourceLoader
 
LockFreeQueue<T> - Class in org.reveno.atp.commons
 
LockFreeQueue() - Constructor for class org.reveno.atp.commons.LockFreeQueue
 
lockIncoming() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
Reject all incoming data.
lockIncoming() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
lockIncoming() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
longArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
longArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
longArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
longArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
LongRange - Class in org.reveno.atp.commons
Range of two long numbers.
LongRange(long, long) - Constructor for class org.reveno.atp.commons.LongRange
 
LongRange(long) - Constructor for class org.reveno.atp.commons.LongRange
 
longToBytes(long, byte[]) - Static method in class org.reveno.atp.utils.BinaryUtils
 

M

main(String[]) - Static method in class org.reveno.atp.examples.clustering.Examples
 
manager() - Method in class org.reveno.atp.core.EngineEventsContext
 
manager(EventHandlersManager) - Method in class org.reveno.atp.core.EngineEventsContext
 
manager() - Method in interface org.reveno.atp.core.events.EventsContext
 
map(long, Entity, MappingContext) - Method in interface org.reveno.atp.api.query.ViewsMapper
 
map(Map<Class<?>, Long2ObjectLinkedOpenHashMap<Object>>) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
map(Object...) - Static method in class org.reveno.atp.utils.MapUtils
 
mapCapacity(int) - Method in interface org.reveno.atp.api.Configuration
 
mapCapacity(int) - Method in class org.reveno.atp.core.RevenoConfiguration
 
mapCapacity() - Method in class org.reveno.atp.core.RevenoConfiguration
 
mapLoadFactor(float) - Method in interface org.reveno.atp.api.Configuration
 
mapLoadFactor(float) - Method in class org.reveno.atp.core.RevenoConfiguration
 
mapLoadFactor() - Method in class org.reveno.atp.core.RevenoConfiguration
 
MapOfList() - Constructor for class org.reveno.atp.utils.MapUtils.MapOfList
 
MapOfMap() - Constructor for class org.reveno.atp.utils.MapUtils.MapOfMap
 
MapOfSet() - Constructor for class org.reveno.atp.utils.MapUtils.MapOfSet
 
MapOfSet(Supplier<Set<U>>, Map<T, Set<U>>) - Constructor for class org.reveno.atp.utils.MapUtils.MapOfSet
 
mapper - Variable in class org.reveno.atp.core.views.ViewsManager.ViewHandlerHolder
 
MappingContext - Interface in org.reveno.atp.api.query
 
MapUtils - Class in org.reveno.atp.utils
 
MapUtils() - Constructor for class org.reveno.atp.utils.MapUtils
 
MapUtils.ConcurrentMapOfMap<T,U,M> - Class in org.reveno.atp.utils
 
MapUtils.MapOfList<T,U> - Class in org.reveno.atp.utils
 
MapUtils.MapOfMap<T,U,M> - Class in org.reveno.atp.utils
 
MapUtils.MapOfSet<T,U> - Class in org.reveno.atp.utils
 
MapUtils.SimpleMap<K,V> - Class in org.reveno.atp.utils
 
marked(Map<Class<?>, Long2ObjectLinkedOpenHashMap<Object>>) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
markReader() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
markReader() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
markReader() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
markReader() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
markReader() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
markSize() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
Might be called with N depth
markSize() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
markSize() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
markSize() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
markSize() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
markWriter() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
markWriter() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
markWriter() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
markWriter() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
markWriter() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
marshall(Buffer, Message) - Method in interface org.reveno.atp.clustering.api.message.Marshaller
Marshals given message to specified buffer.
marshall(Buffer, Message) - Method in class org.reveno.atp.clustering.core.marshallers.JsonMarshaller
 
marshall(Buffer, Message) - Method in class org.reveno.atp.clustering.core.marshallers.NativeMarshaller
 
Marshaller - Interface in org.reveno.atp.clustering.api.message
Used to marshall and unmarshall messages for internal communication in Reveno.
marshaller(Marshaller) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
marshallWith(Marshaller) - Method in interface org.reveno.atp.clustering.api.Cluster
Sets the marshaller instance, which will be used to marshall/unmarshall all incoming/outgoing messages.
marshallWith(Marshaller) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
MathUtils - Class in org.reveno.atp.utils
 
MathUtils() - Constructor for class org.reveno.atp.utils.MathUtils
 
MAX_VALUE - Static variable in class org.reveno.atp.core.channel.FileChannel
 
maxObjectSize(int) - Method in interface org.reveno.atp.api.Configuration.JournalingConfiguration
 
maxObjectSize(int) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
maxObjectSize() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
maxReadBatchMessages(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Max number of messages a read will try to read from the socket.
maxReadBatchMessages(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
maxReadBatchMessages() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
maxReceiveThreads(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Maximum number of threads to be used for messages handling.
maxReceiveThreads(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
maxReceiveThreads() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
maxRetransmitTimeMillis(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Max number of milliseconds we try to retransmit a message to any given member.
maxRetransmitTimeMillis(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
maxRetransmitTimeMillis() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
mb(int) - Static method in class org.reveno.atp.utils.MeasureUtils
 
mcastHost(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
mcastHost() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
mcastPort(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
mcastPort() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
MeasureUtils - Class in org.reveno.atp.utils
 
MeasureUtils() - Constructor for class org.reveno.atp.utils.MeasureUtils
 
members() - Method in class org.reveno.atp.clustering.api.ClusterView
 
mergeObject(T, Schema<T>) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
mergeStores(JournalsStorage.JournalStore[], JournalsStorage.JournalStore) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
mergeStores(JournalsStorage.JournalStore[], JournalsStorage.JournalStore) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
Message - Class in org.reveno.atp.clustering.api.message
General message instance which is used solely for internal communications in Reveno, primarily in leadership election process.
Message() - Constructor for class org.reveno.atp.clustering.api.message.Message
 
messageNotifier(TransactionInfoSerializer, Consumer<List<Object>>) - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
messageNotifier(TransactionInfoSerializer, Consumer<List<Object>>) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
messageNotifier(TransactionInfoSerializer, Consumer<List<Object>>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
MessagesReceiver - Interface in org.reveno.atp.clustering.core.api
 
MessagingClusterStateCollector - Class in org.reveno.atp.clustering.core.components
 
MessagingClusterStateCollector(Cluster, Supplier<Long>, RevenoClusterConfiguration) - Constructor for class org.reveno.atp.clustering.core.components.MessagingClusterStateCollector
 
MessagingMasterSlaveElector - Class in org.reveno.atp.clustering.core.components
 
MessagingMasterSlaveElector(Cluster, RevenoClusterConfiguration) - Constructor for class org.reveno.atp.clustering.core.components.MessagingMasterSlaveElector
 
metricBufferSize(int) - Method in interface org.reveno.atp.metrics.Configuration
 
metricBufferSize() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
metricBufferSize(int) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
MetricsInterceptor - Class in org.reveno.atp.metrics
 
MetricsInterceptor(ConfigurationImpl) - Constructor for class org.reveno.atp.metrics.MetricsInterceptor
 
minReceiveThreads(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Minimum number of threads to be used for messages handling.
minReceiveThreads(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
minReceiveThreads() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
minVolumes(int) - Method in interface org.reveno.atp.api.Configuration.JournalingConfiguration
 
minVolumes(int) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
minVolumes() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
mode(SyncMode) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.SyncConfiguration
A mode in which two nodes will perform synchronization during Leadership Election.
mode(SyncMode) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
mode() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
modelSynchronizer(ClusterExecutor<Boolean, StorageTransferModelSync.TransferContext>) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
modelType(Configuration.ModelType) - Method in interface org.reveno.atp.api.Configuration
 
modelType() - Method in class org.reveno.atp.core.RevenoConfiguration
 
move(SnapshotStorage.SnapshotStore, SnapshotStorage.SnapshotStore) - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
move(SnapshotStorage.SnapshotStore, SnapshotStorage.SnapshotStore) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
multicast() - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Multicast configurations, which will be used in case of ClusterConfiguration.commandsXmitTransport(CommandsXmitTransport) was set to MULTICAST.
multicast() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
multicast(ClusterEngine[]) - Static method in class org.reveno.atp.examples.clustering.Examples
 
MulticastAllProvider - Class in org.reveno.atp.clustering.core.providers
 
MulticastAllProvider() - Constructor for class org.reveno.atp.clustering.core.providers.MulticastAllProvider
 
MulticastAllProvider(FastCastConfiguration) - Constructor for class org.reveno.atp.clustering.core.providers.MulticastAllProvider
 
MulticastAllProvider(FastCastConfiguration, String) - Constructor for class org.reveno.atp.clustering.core.providers.MulticastAllProvider
 
MulticastAllProvider(String) - Constructor for class org.reveno.atp.clustering.core.providers.MulticastAllProvider
 
mutableModel() - Method in interface org.reveno.atp.api.Configuration
 
mutableModel() - Method in class org.reveno.atp.core.RevenoConfiguration
 
mutableModelFailover(Configuration.MutableModelFailover) - Method in interface org.reveno.atp.api.Configuration
 
mutableModelFailover(Configuration.MutableModelFailover) - Method in class org.reveno.atp.core.RevenoConfiguration
 
mutableModelFailover() - Method in class org.reveno.atp.core.RevenoConfiguration
 
MutableModelRepository - Class in org.reveno.atp.core.repository
 
MutableModelRepository(WriteableRepository, Serializer) - Constructor for class org.reveno.atp.core.repository.MutableModelRepository
 
MutableModelRepository(WriteableRepository, Serializer, ClassLoader) - Constructor for class org.reveno.atp.core.repository.MutableModelRepository
 
MutableModelRepository.EntityRecoveryState - Enum in org.reveno.atp.core.repository
 

N

NamedThreadFactory - Class in org.reveno.atp.commons
ThreadFactory with the ability to set the thread name prefix.
NamedThreadFactory(String) - Constructor for class org.reveno.atp.commons.NamedThreadFactory
Creates a new ThreadFactory where threads are created with a name prefix of prefix.
NativeMarshaller - Class in org.reveno.atp.clustering.core.marshallers
 
NativeMarshaller() - Constructor for class org.reveno.atp.clustering.core.marshallers.NativeMarshaller
 
net(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
netInterface(String) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Network interface to be used by Multicast socket.
netInterface(String) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
netInterface() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
NettyBasedBuffer - Class in org.reveno.atp.core.channel
 
NettyBasedBuffer() - Constructor for class org.reveno.atp.core.channel.NettyBasedBuffer
 
NettyBasedBuffer(boolean) - Constructor for class org.reveno.atp.core.channel.NettyBasedBuffer
 
NettyBasedBuffer(int, boolean) - Constructor for class org.reveno.atp.core.channel.NettyBasedBuffer
 
NettyBasedBuffer(int, int, boolean) - Constructor for class org.reveno.atp.core.channel.NettyBasedBuffer
 
networkInterface(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
networkInterface() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
newCommand(Map<String, Object>) - Method in class org.reveno.atp.api.dynamic.DynamicCommand
 
newMessage(List<Object>) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
Must always be called by single thread only.
newThread(Runnable) - Method in class org.reveno.atp.commons.NamedThreadFactory
 
next(Class<?>) - Method in interface org.reveno.atp.core.api.IdGenerator
 
next(Class<?>) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator
 
next2n(int) - Static method in class org.reveno.atp.utils.MathUtils
 
nextFolder(String) - Method in interface org.reveno.atp.core.api.storage.FoldersStorage
 
nextFolder(String) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
NextIdTransaction(Class<?>, long) - Constructor for class org.reveno.atp.core.engine.components.DefaultIdGenerator.NextIdTransaction
 
nextSnapshotStore() - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
nextSnapshotStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nextStore() - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
nextStore(long) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
nextStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nextStore(long) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nextTempSnapshotStore() - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
nextTempSnapshotStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nextTempStore() - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
nextTempStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nextVersionFile(File, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
nextVersionFile(File, String, long) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
nextVersionFile(File, String, String, long) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
nextVersionFile(File, String, String, String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
nextVolume(long, long) - Method in interface org.reveno.atp.core.api.storage.JournalsStorage
 
nextVolume(long, long) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
nodesAddresses(List<Address>) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
List of other parties addresses.
nodesAddresses(List<Address>) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
nodesAddresses() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
nodesInetAddresses(List<InetAddress>) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
List of other parties network addresses.
nodesInetAddresses(List<InetAddress>) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
NodeState - Class in org.reveno.atp.clustering.core.messages
 
NodeState(long, long, byte, int) - Constructor for class org.reveno.atp.clustering.core.messages.NodeState
 
NodeState() - Constructor for class org.reveno.atp.clustering.core.messages.NodeState
 

O

Object2LongOpenHashMapEx() - Constructor for class org.reveno.atp.core.engine.components.DefaultIdGenerator.Object2LongOpenHashMapEx
 
ObjectInputStreamEx(InputStream, ClassLoader) - Constructor for class org.reveno.atp.core.serialization.DefaultJavaSerializer.ObjectInputStreamEx
 
OnDemandViewsContext - Class in org.reveno.atp.core.views
 
OnDemandViewsContext(ViewsProcessor, ViewsStorage, ViewsManager) - Constructor for class org.reveno.atp.core.views.OnDemandViewsContext
 
onMessage(Message) - Method in interface org.reveno.atp.clustering.core.api.MessagesReceiver
 
onMessage(Message) - Method in class org.reveno.atp.clustering.core.components.MessagingClusterStateCollector
 
onMessage(Message) - Method in class org.reveno.atp.clustering.core.components.MessagingMasterSlaveElector
 
onReplicationMessage(Consumer<List<Object>>) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
onReplicationMessage(Consumer<List<Object>>) - Method in interface org.reveno.atp.core.api.FailoverManager
 
onReplicationMessage(Consumer<List<Object>>) - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
onView(ClusterView) - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
onView(ClusterView) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
onView(ClusterView) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
oob() - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
opArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
open() - Method in class org.reveno.atp.core.events.Barrier
 
org.reveno.atp.api - package org.reveno.atp.api
 
org.reveno.atp.api.commands - package org.reveno.atp.api.commands
 
org.reveno.atp.api.domain - package org.reveno.atp.api.domain
 
org.reveno.atp.api.dynamic - package org.reveno.atp.api.dynamic
 
org.reveno.atp.api.exceptions - package org.reveno.atp.api.exceptions
 
org.reveno.atp.api.query - package org.reveno.atp.api.query
 
org.reveno.atp.api.transaction - package org.reveno.atp.api.transaction
 
org.reveno.atp.clustering.api - package org.reveno.atp.clustering.api
 
org.reveno.atp.clustering.api.message - package org.reveno.atp.clustering.api.message
 
org.reveno.atp.clustering.core - package org.reveno.atp.clustering.core
 
org.reveno.atp.clustering.core.api - package org.reveno.atp.clustering.core.api
 
org.reveno.atp.clustering.core.buffer - package org.reveno.atp.clustering.core.buffer
 
org.reveno.atp.clustering.core.components - package org.reveno.atp.clustering.core.components
 
org.reveno.atp.clustering.core.fastcast - package org.reveno.atp.clustering.core.fastcast
 
org.reveno.atp.clustering.core.jgroups - package org.reveno.atp.clustering.core.jgroups
 
org.reveno.atp.clustering.core.marshallers - package org.reveno.atp.clustering.core.marshallers
 
org.reveno.atp.clustering.core.messages - package org.reveno.atp.clustering.core.messages
 
org.reveno.atp.clustering.core.providers - package org.reveno.atp.clustering.core.providers
 
org.reveno.atp.clustering.exceptions - package org.reveno.atp.clustering.exceptions
 
org.reveno.atp.clustering.util - package org.reveno.atp.clustering.util
 
org.reveno.atp.commons - package org.reveno.atp.commons
 
org.reveno.atp.core - package org.reveno.atp.core
 
org.reveno.atp.core.api - package org.reveno.atp.core.api
 
org.reveno.atp.core.api.channel - package org.reveno.atp.core.api.channel
 
org.reveno.atp.core.api.serialization - package org.reveno.atp.core.api.serialization
 
org.reveno.atp.core.api.storage - package org.reveno.atp.core.api.storage
 
org.reveno.atp.core.channel - package org.reveno.atp.core.channel
 
org.reveno.atp.core.data - package org.reveno.atp.core.data
 
org.reveno.atp.core.disruptor - package org.reveno.atp.core.disruptor
 
org.reveno.atp.core.engine - package org.reveno.atp.core.engine
 
org.reveno.atp.core.engine.components - package org.reveno.atp.core.engine.components
 
org.reveno.atp.core.engine.processor - package org.reveno.atp.core.engine.processor
 
org.reveno.atp.core.events - package org.reveno.atp.core.events
 
org.reveno.atp.core.impl - package org.reveno.atp.core.impl
 
org.reveno.atp.core.repository - package org.reveno.atp.core.repository
 
org.reveno.atp.core.restore - package org.reveno.atp.core.restore
 
org.reveno.atp.core.serialization - package org.reveno.atp.core.serialization
 
org.reveno.atp.core.serialization.protostuff - package org.reveno.atp.core.serialization.protostuff
 
org.reveno.atp.core.snapshots - package org.reveno.atp.core.snapshots
 
org.reveno.atp.core.storage - package org.reveno.atp.core.storage
 
org.reveno.atp.core.views - package org.reveno.atp.core.views
 
org.reveno.atp.examples.clustering - package org.reveno.atp.examples.clustering
 
org.reveno.atp.metrics - package org.reveno.atp.metrics
 
org.reveno.atp.metrics.impl - package org.reveno.atp.metrics.impl
 
org.reveno.atp.metrics.meter - package org.reveno.atp.metrics.meter
 
org.reveno.atp.metrics.meter.impl - package org.reveno.atp.metrics.meter.impl
 
org.reveno.atp.utils - package org.reveno.atp.utils
 

P

packetSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
For lowest latency choose a packet size slightly lower than netork MTU.
packetSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
packetsPerSecond(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Limits the amount of packets per seconds that might be sent to multicast socket directly.
packetsPerSecond() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
packetsPerSecond(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
packetsPerSecond(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
packetsPerSecond() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
parallelSelect(Class<V>, Predicate<V>) - Method in interface org.reveno.atp.api.query.QueryManager
 
parallelSelect(Class<V>, Predicate<V>) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
parseVersionedFile(String) - Static method in class org.reveno.atp.utils.VersionedFileUtils
 
performCommands(List<Object>) - Method in interface org.reveno.atp.api.Reveno
Same as Reveno.executeCommand(Object), but allows to execute a batch of commands as a single atomic transaction.
performCommands(List<Object>) - Method in class org.reveno.atp.core.Engine
 
physicalAddress(JChannel, RevenoClusterConfiguration, Address) - Static method in class org.reveno.atp.clustering.core.jgroups.JChannelHelper
 
PickledGraphite - Class in org.reveno.atp.metrics.impl
A client to a Carbon server that sends all metrics after they have been pickled in configurable sized batches
PickledGraphite(InetSocketAddress) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address using the default SocketFactory.
PickledGraphite(InetSocketAddress, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address using the default SocketFactory.
PickledGraphite(InetSocketAddress, SocketFactory, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address and socket factory.
PickledGraphite(InetSocketAddress, SocketFactory, Charset, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address and socket factory using the given character set.
PickledGraphite(String, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address using the default SocketFactory.
PickledGraphite(String, int, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address using the default SocketFactory.
PickledGraphite(String, int, SocketFactory, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address and socket factory.
PickledGraphite(String, int, SocketFactory, Charset, int) - Constructor for class org.reveno.atp.metrics.impl.PickledGraphite
Creates a new client which connects to the given address and socket factory using the given character set.
pingTimeoutMillis(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Timeout for ping heartbeat and discovery requests.
pingTimeoutMillis(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
pingTimeoutMillis() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
pipe(ProcessorHandler<T>...) - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
pipe(ProcessorHandler<T>...) - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
PipeProcessor<T extends Destroyable> - Interface in org.reveno.atp.core.engine.processor
 
PojoBuilder() - Constructor for class org.reveno.atp.core.impl.EventsCommitInfoImpl.PojoBuilder
 
PojoBuilder() - Constructor for class org.reveno.atp.core.impl.TransactionCommitInfoImpl.PojoBuilder
 
port(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Multicast port.
port(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.SyncConfiguration
Port on which Sync Server will be listening.
port(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
port() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
port(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
port() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
position() - Method in interface org.reveno.atp.core.api.channel.Channel
 
position() - Method in class org.reveno.atp.core.channel.FileChannel
 
Preconditions - Class in org.reveno.atp.utils
Static convenience methods that help a method or constructor check whether it was invoked correctly (whether its preconditions have been met).
preferBatchingToLatency(boolean) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Setting that denotes whether to flush every on every Command processed or to buffer it until max packet size is reached.
preferBatchingToLatency(boolean) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
preferBatchingToLatency() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
prepare() - Method in interface org.reveno.atp.api.RepositorySnapshotter
Prepares SnapshotIdentifier pointer, using which snapshot can be writen in particular way.
prepare() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
prepare() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
prepare() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
prepare() - Method in class org.reveno.atp.core.snapshots.DefaultSnapshotter
 
priority - Variable in class org.reveno.atp.clustering.core.messages.VoteMessage
 
priorityInCluster(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Priority in cluster, which allows to effectively foresee next elected Masters in case of failure of previous ones.
priorityInCluster(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
priorityInCluster() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
process(Consumer<Buffer>, InputProcessor.JournalType) - Method in interface org.reveno.atp.core.api.InputProcessor
 
process(Consumer<Buffer>, InputProcessor.JournalType) - Method in class org.reveno.atp.core.data.DefaultInputProcessor
 
process(BiConsumer<T, CompletableFuture<R>>) - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
process(List<Object>) - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
process(BiConsumer<T, CompletableFuture<R>>) - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
process(List<Object>) - Method in interface org.reveno.atp.core.engine.processor.TransactionPipeProcessor
 
process(Repository) - Method in class org.reveno.atp.core.views.ViewsProcessor
 
process(Map<Class<?>, Long2ObjectLinkedOpenHashMap<Object>>) - Method in class org.reveno.atp.core.views.ViewsProcessor
 
processNextEvent(EventsCommitInfo) - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
ProcessorContext - Class in org.reveno.atp.core.disruptor
 
ProcessorContext(TransactionCommitInfo) - Constructor for class org.reveno.atp.core.disruptor.ProcessorContext
 
ProcessorHandler<T> - Interface in org.reveno.atp.core.engine.processor
 
processPendingMessages() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
processPendingMessages() - Method in interface org.reveno.atp.core.api.FailoverManager
 
processPendingMessages() - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
PROPERTIES_REGEX - Static variable in class org.reveno.atp.clustering.util.ResourceLoader
 
ProtostuffSerializer - Class in org.reveno.atp.core.serialization
 
ProtostuffSerializer() - Constructor for class org.reveno.atp.core.serialization.ProtostuffSerializer
 
ProtostuffSerializer(ClassLoader) - Constructor for class org.reveno.atp.core.serialization.ProtostuffSerializer
 
publishEvent(Object) - Method in interface org.reveno.atp.api.transaction.EventBus
 
publishEvent(Object) - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
publishEvents(boolean, long, EventsManager.EventMetadata, Object[]) - Method in class org.reveno.atp.core.events.EventPublisher
 
put(T, Set<U>) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
putAll(Map<? extends T, ? extends Set<U>>) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
putObject(T) - Method in class org.reveno.atp.commons.LockFreeQueue
Puts an object at the end of the queue.

Q

query() - Method in interface org.reveno.atp.api.Reveno
The query side of system, which is managed by view model.
query() - Method in class org.reveno.atp.core.Engine
 
QueryManager - Interface in org.reveno.atp.api.query
 

R

read(Buffer) - Method in class org.reveno.atp.clustering.api.message.Message
Provides an ability to deserialize current message instance data from the given buffer
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.BarrierMessage
 
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.BarrierPassed
 
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.ForceElectionProcess
 
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.NodeState
 
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.VoteAck
 
read(Buffer) - Method in class org.reveno.atp.clustering.core.messages.VoteMessage
 
read() - Method in interface org.reveno.atp.core.api.channel.Channel
 
read() - Method in class org.reveno.atp.core.api.channel.RevenoBufferInputStream
 
read() - Method in class org.reveno.atp.core.channel.FileChannel
 
readBool() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readByte() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readByte() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readByte() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readByte() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readByte() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readByteArray() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readByteBuffer() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readBytes(int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readBytes(byte[], int, int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readBytes(int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readBytes(byte[], int, int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readBytes(int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readBytes(byte[], int, int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readBytes(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readBytes(byte[], int, int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readBytes(int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readBytes(byte[], int, int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readBytes() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readDouble() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readEnum() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readerPosition() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readerPosition() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readerPosition() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readerPosition() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readerPosition() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readFieldNumber(Schema<T>) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readFixed32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readFixed64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readFloat() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readFrom(DataInput) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer.ClusterBufferHeader
 
readFrom(DataInput) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.ClusterMessageHeader
 
readInt() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readInt() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readInt(byte, byte, byte, byte) - Static method in class org.reveno.atp.clustering.util.Bits
 
readInt() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readInt() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readInt() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readInt32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readInt64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readLong() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readLong() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readLong(byte, byte, byte, byte, byte, byte, byte, byte) - Static method in class org.reveno.atp.clustering.util.Bits
 
readLong() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readLong() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readLong() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readNullable(Buffer) - Static method in class org.reveno.atp.utils.BinaryUtils
 
readRawLittleEndian32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readRawLittleEndian64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readRawVarint32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readRawVarint64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readSFixed32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readSFixed64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readShort() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
readShort() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
readShort(byte, byte) - Static method in class org.reveno.atp.clustering.util.Bits
 
readShort() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
readShort() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
readShort() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
readSInt32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readSInt64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readString() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readTag() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readUInt32() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
readUInt64() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
receive(int, Consumer<T>) - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
receive(int, Predicate<T>, Consumer<T>) - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
receive(Message) - Method in class org.reveno.atp.clustering.core.jgroups.JChannelReceiver
 
receive(int, Consumer<T>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
receive(int, Predicate<T>, Consumer<T>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
receiveBufferSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Socket receive buffer size.
receiveBufferSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Socket receive buffer size.
receiveBufferSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
receiveBufferSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
receiveBufferSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
receiveBufferSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
receiveQueueMaxSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
The size of the queue which will be used when all handling threads are busy.
receiveQueueMaxSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
receiveQueueMaxSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
RecordingRepository - Class in org.reveno.atp.core.engine.components
Used for recording which entities were modified on stage of Transaction execution, since we will want that info on next step where we updating Views mappings.
RecordingRepository() - Constructor for class org.reveno.atp.core.engine.components.RecordingRepository
 
register(Class<T>, Class<U>, BiFunction<T, CommandContext, U>) - Method in class org.reveno.atp.core.engine.components.CommandsManager
 
register(Class<T>, BiConsumer<T, CommandContext>) - Method in class org.reveno.atp.core.engine.components.CommandsManager
 
register(Class<E>, Class<V>, ViewsMapper<E, V>) - Method in class org.reveno.atp.core.views.ViewsManager
 
registerSnapshotter(RepositorySnapshotter) - Method in class org.reveno.atp.core.snapshots.SnapshottersManager
 
registerTransaction(Class<T>, BiConsumer<T, TransactionContext>) - Method in class org.reveno.atp.core.engine.components.TransactionsManager
 
registerTransaction(Class<T>, BiConsumer<T, TransactionContext>, boolean) - Method in class org.reveno.atp.core.engine.components.TransactionsManager
 
registerTransactionType(Class<?>) - Method in interface org.reveno.atp.core.api.serialization.Serializer
 
registerTransactionType(Class<?>) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
registerTransactionType(Class<?>) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
registerTransactionType(Class<?>) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
release() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
release() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
release() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
release() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
release() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
remaining() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
remaining() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
remaining() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
remaining() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
remaining() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
remove(Class<?>, long) - Method in interface org.reveno.atp.api.domain.WriteableRepository
 
remove(Class<View>, long) - Method in interface org.reveno.atp.core.api.ViewsStorage
 
remove(Class<?>, long) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
remove(Class<?>, long) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
remove(Class<?>, long) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
remove(Class<?>, long) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
remove(Class<?>, long) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
remove(Class<View>, long) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
remove(Object) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
removeEventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in interface org.reveno.atp.api.EventsManager
 
removeEventHandler(Class<E>, BiConsumer<E, EventsManager.EventMetadata>) - Method in class org.reveno.atp.core.events.EventHandlersManager
 
removeLastSnapshotStore() - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
removeLastSnapshotStore() - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
removeSnapshotStore(SnapshotStorage.SnapshotStore) - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
removeSnapshotStore(SnapshotStorage.SnapshotStore) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
replay(boolean) - Method in class org.reveno.atp.core.events.Event
 
replayer(Supplier<Long>) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
replicate() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
Send all written data down to endpoint.
replicate(Consumer<Buffer>) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
replicate() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
replicate() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
replicate(Consumer<Buffer>) - Method in interface org.reveno.atp.core.api.FailoverManager
 
replicate() - Method in class org.reveno.atp.core.events.Event
 
replicate(Consumer<Buffer>) - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
replicated() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
replicateEvents(long) - Method in class org.reveno.atp.core.events.EventPublisher
 
replication(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
ReplicationFailedException - Exception in org.reveno.atp.api.exceptions
 
ReplicationFailedException() - Constructor for exception org.reveno.atp.api.exceptions.ReplicationFailedException
 
repo() - Method in interface org.reveno.atp.api.commands.CommandContext
 
repo() - Method in interface org.reveno.atp.api.transaction.TransactionContext
 
Repository - Interface in org.reveno.atp.api.domain
 
repository() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
repository() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
repository(TxRepository) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
RepositoryCorruptedException - Exception in org.reveno.atp.api.exceptions
 
RepositoryCorruptedException() - Constructor for exception org.reveno.atp.api.exceptions.RepositoryCorruptedException
 
RepositoryData - Class in org.reveno.atp.api.domain
 
RepositoryData(Map<Class<?>, Map<Long, Object>>) - Constructor for class org.reveno.atp.api.domain.RepositoryData
 
RepositoryDataSerializer - Interface in org.reveno.atp.core.api.serialization
 
repositoryLinkedSet() - Static method in class org.reveno.atp.utils.MapUtils
 
repositoryList() - Static method in class org.reveno.atp.utils.MapUtils
 
repositoryMap() - Static method in class org.reveno.atp.utils.MapUtils
 
repositorySet() - Static method in class org.reveno.atp.utils.MapUtils
 
RepositorySnapshotter - Interface in org.reveno.atp.api
Snapshotter is the instrument
RepositorySnapshotter.SnapshotIdentifier - Interface in org.reveno.atp.api
 
repositorySource(Repository) - Method in class org.reveno.atp.core.views.OnDemandViewsContext
 
reset() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
reset() - Method in class org.reveno.atp.core.events.Event
 
resetNextLimit() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
resetNextLimit() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
resetNextLimit() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
resetNextLimit() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
resetNextLimit() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
resetReader() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
resetReader() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
resetReader() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
resetReader() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
resetReader() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
resetSnapshotters() - Method in interface org.reveno.atp.api.RevenoManager
Removes all snapshotters from chain.
resetSnapshotters() - Method in class org.reveno.atp.core.snapshots.SnapshottersManager
 
resetWriter() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
resetWriter() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
resetWriter() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
resetWriter() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
resetWriter() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
resolveEntity(Class<?>) - Method in class org.reveno.atp.core.views.ViewsManager
 
resolveEntityType(Class<?>) - Method in class org.reveno.atp.core.views.ViewsManager
 
ResourceLoader - Class in org.reveno.atp.clustering.util
 
ResourceLoader() - Constructor for class org.reveno.atp.clustering.util.ResourceLoader
 
restore(TxRepository) - Method in interface org.reveno.atp.core.api.SystemStateRestorer
 
restore() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
restore(TxRepository) - Method in class org.reveno.atp.core.restore.DefaultSystemStateRestorer
Reads all journals and restores all previous system mode state from them into the given repository.
RestoreableEventBus - Interface in org.reveno.atp.core.api
 
RestorerEventBus - Class in org.reveno.atp.core.restore
Special EventBus implementation, which is used on restoration process.
RestorerEventBus() - Constructor for class org.reveno.atp.core.restore.RestorerEventBus
 
restoreWith(RepositorySnapshotter) - Method in interface org.reveno.atp.api.RevenoManager
Despite the fact that you can provide multiple snapshotters, for now you can use only one for restoration of domain model state, which should be specified by calling that method.
Result<ResultType> - Class in org.reveno.atp.api.commands
 
Result(ResultType) - Constructor for class org.reveno.atp.api.commands.Result
 
Result(Throwable) - Constructor for class org.reveno.atp.api.commands.Result
 
Result(boolean, ResultType, Throwable) - Constructor for class org.reveno.atp.api.commands.Result
 
result(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
retransmissionPacketHistory() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
retransmissionPacketHistory(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
retransmitIntervalMillis(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Interval (in milliseconds) at which messages in the send windows are resent.
retransmitIntervalMillis(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
retransmitIntervalMillis() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
retransmitPacketsHistory(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
The number of packets which will be persistently stored in offheap memory for NAK retransmition purpose.
retransmitPacketsHistory(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
retransmitPacketsHistory() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
retries(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.SyncConfiguration
Number of retries to transmit state data until it fails.
retries(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
retries() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
retrieveBuffer() - Method in interface org.reveno.atp.clustering.core.buffer.ClusterProvider
 
retrieveBuffer() - Method in class org.reveno.atp.clustering.core.providers.JGroupsClusterProvider
 
retrieveCluster() - Method in interface org.reveno.atp.clustering.core.buffer.ClusterProvider
 
retrieveCluster() - Method in class org.reveno.atp.clustering.core.providers.JGroupsClusterProvider
 
returnsIdOf(Class<?>) - Method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
Reveno - Interface in org.reveno.atp.api
Core engine interface.
RevenoBufferInputStream - Class in org.reveno.atp.core.api.channel
Not used in core processing as such approach is very inefficient.
RevenoBufferInputStream(Buffer) - Constructor for class org.reveno.atp.core.api.channel.RevenoBufferInputStream
 
RevenoBufferOutputStream - Class in org.reveno.atp.core.api.channel
Not used in core processing as such approach is very inefficient.
RevenoBufferOutputStream(Buffer) - Constructor for class org.reveno.atp.core.api.channel.RevenoBufferOutputStream
 
RevenoClusterConfiguration - Class in org.reveno.atp.clustering.core
 
RevenoClusterConfiguration() - Constructor for class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
RevenoClusterConfiguration.RevenoMulticastConfiguration - Class in org.reveno.atp.clustering.core
 
RevenoClusterConfiguration.RevenoSyncConfiguration - Class in org.reveno.atp.clustering.core
 
RevenoClusterConfiguration.RevenoTimeoutsConfiguration - Class in org.reveno.atp.clustering.core
 
RevenoClusterConfiguration.RevenoUnicastConfiguration - Class in org.reveno.atp.clustering.core
 
RevenoConfiguration - Class in org.reveno.atp.core
 
RevenoConfiguration() - Constructor for class org.reveno.atp.core.RevenoConfiguration
 
RevenoConfiguration.RevenoDisruptorConfiguration - Class in org.reveno.atp.core
 
RevenoConfiguration.RevenoJournalingConfiguration - Class in org.reveno.atp.core
 
RevenoConfiguration.RevenoSnapshotConfiguration - Class in org.reveno.atp.core
 
revenoDataSync() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
revenoDisruptor() - Method in class org.reveno.atp.core.RevenoConfiguration
 
RevenoDisruptorConfiguration() - Constructor for class org.reveno.atp.core.RevenoConfiguration.RevenoDisruptorConfiguration
 
revenoElectionTimeouts() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
RevenoException - Exception in org.reveno.atp.api.exceptions
 
RevenoException() - Constructor for exception org.reveno.atp.api.exceptions.RevenoException
 
revenoJournaling() - Method in class org.reveno.atp.core.RevenoConfiguration
 
RevenoJournalingConfiguration() - Constructor for class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
RevenoManager - Interface in org.reveno.atp.api
Contains all required operations for managing of domain space of engine.
RevenoMetrics - Class in org.reveno.atp.metrics
 
RevenoMetrics() - Constructor for class org.reveno.atp.metrics.RevenoMetrics
 
revenoMulticast() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
RevenoMulticastConfiguration() - Constructor for class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
RevenoSnapshotConfiguration() - Constructor for class org.reveno.atp.core.RevenoConfiguration.RevenoSnapshotConfiguration
 
revenoSnapshotting() - Method in class org.reveno.atp.core.RevenoConfiguration
 
RevenoSyncConfiguration() - Constructor for class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
RevenoTimeoutsConfiguration() - Constructor for class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
revenoUnicast() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
RevenoUnicastConfiguration() - Constructor for class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
roll(Channel, Runnable) - Method in interface org.reveno.atp.core.api.Journaler
 
roll(Channel, Runnable) - Method in class org.reveno.atp.core.data.DefaultJournaler
 
roll(long) - Method in class org.reveno.atp.core.JournalsManager
 
roll(long, Runnable) - Method in class org.reveno.atp.core.JournalsManager
 
roll(long, Supplier<Boolean>) - Method in class org.reveno.atp.core.JournalsManager
 
roll(long, Runnable, Supplier<Boolean>, JournalsStorage.JournalStore) - Method in class org.reveno.atp.core.JournalsManager
 
rollback() - Method in interface org.reveno.atp.core.api.TxRepository
 
rollback() - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
rollback() - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
rollback() - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
rollFrom(JournalsStorage.JournalStore, long) - Method in class org.reveno.atp.core.JournalsManager
 
rollTemp() - Method in class org.reveno.atp.core.JournalsManager
 
rsvp() - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
run() - Method in class org.reveno.atp.core.events.Barrier
 
runtime(Throwable) - Static method in class org.reveno.atp.utils.Exceptions
 

S

safeGet(T) - Method in class org.reveno.atp.utils.MapUtils.ConcurrentMapOfMap
 
safeGet(T) - Method in class org.reveno.atp.utils.MapUtils.MapOfList
 
safeGet(T) - Method in class org.reveno.atp.utils.MapUtils.MapOfMap
 
safeGet(T) - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
safeGet(K) - Method in class org.reveno.atp.utils.MapUtils.SimpleMap
 
sec(int) - Static method in class org.reveno.atp.utils.MeasureUtils
 
seed - Variable in class org.reveno.atp.clustering.core.messages.VoteMessage
 
select(Class<V>) - Method in interface org.reveno.atp.api.query.QueryManager
 
select(Class<V>, Predicate<V>) - Method in interface org.reveno.atp.api.query.QueryManager
 
select(Class<V>) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
select(Class<V>, Predicate<V>) - Method in class org.reveno.atp.core.views.ViewsDefaultStorage
 
send(List<Address>, Message) - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
send(List<Address>, Message, Set<Flag>) - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
send(List<Address>, Message) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
send(List<Address>, Message, Set<Flag>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
send(String, String, long) - Method in class org.reveno.atp.metrics.impl.GraphiteSink
 
send(String, String, long) - Method in class org.reveno.atp.metrics.impl.PickledGraphite
Convert the metric to a python tuple of the form:

(timestamp, (name, value))

And add it to the list of metrics.

send(String, String, long) - Method in class org.reveno.atp.metrics.impl.Slf4jSink
 
send(String, String, long) - Method in interface org.reveno.atp.metrics.Sink
 
sendBufferSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Socket send buffer size.
sendBufferSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.UnicastConfiguration
Socket send buffer size.
sendBufferSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
sendBufferSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
sendBufferSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
sendBufferSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoUnicastConfiguration
 
sendRetries(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
An amount of retries to send in case of PPS limit reached, send buffers full, or initialization is not yet fully happend.
sendRetries() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
sendRetries(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
sendRetries(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
sendRetries() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
sendTo(List<Sink>, boolean) - Method in class org.reveno.atp.metrics.meter.impl.SimpleCounter
 
sendTo(List<Sink>, boolean) - Method in class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
sendTo(List<Sink>, boolean) - Method in interface org.reveno.atp.metrics.meter.Sinkable
Sends the last snapshot of metrics to some list of Sink.
sendToGraphite(boolean) - Method in interface org.reveno.atp.metrics.Configuration
 
sendToGraphite() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
sendToGraphite(boolean) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
sendToLog(boolean) - Method in interface org.reveno.atp.metrics.Configuration
 
sendToLog() - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
sendToLog(boolean) - Method in class org.reveno.atp.metrics.ConfigurationImpl
 
serialize(EventsCommitInfo, Buffer) - Method in interface org.reveno.atp.core.api.serialization.EventsInfoSerializer
 
serialize(RepositoryData, Buffer) - Method in interface org.reveno.atp.core.api.serialization.RepositoryDataSerializer
 
serialize(TransactionCommitInfo, Buffer) - Method in interface org.reveno.atp.core.api.serialization.TransactionInfoSerializer
 
serialize(TransactionCommitInfo, Buffer) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
serialize(TransactionCommitInfo, Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
serialize(RepositoryData, Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
serialize(TransactionCommitInfo, Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
serialize(RepositoryData, Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
serialize(EventsCommitInfo, Buffer) - Method in class org.reveno.atp.core.serialization.SimpleEventsSerializer
 
serializeCommands(List<Object>, Buffer) - Method in interface org.reveno.atp.core.api.serialization.TransactionInfoSerializer
 
serializeCommands(List<Object>, Buffer) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
serializeCommands(List<Object>, Buffer) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
serializeCommands(List<Object>, Buffer) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
serializeObject(Buffer, Object) - Method in interface org.reveno.atp.core.api.serialization.Serializer
 
serializeObject(Buffer, Object) - Method in class org.reveno.atp.core.engine.components.SerializersChain
 
serializeObject(Buffer, Object) - Method in class org.reveno.atp.core.serialization.DefaultJavaSerializer
 
serializeObject(Buffer, Object) - Method in class org.reveno.atp.core.serialization.ProtostuffSerializer
 
Serializer - Interface in org.reveno.atp.core.api.serialization
 
serializer() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
serializer() - Method in class org.reveno.atp.core.EngineEventsContext
 
serializer(EventsInfoSerializer) - Method in class org.reveno.atp.core.EngineEventsContext
 
serializer() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
serializer() - Method in interface org.reveno.atp.core.events.EventsContext
 
SerializerException - Exception in org.reveno.atp.api.exceptions
 
SerializerException(SerializerException.Action, Class<?>, Throwable) - Constructor for exception org.reveno.atp.api.exceptions.SerializerException
 
SerializerException.Action - Enum in org.reveno.atp.api.exceptions
 
serializers(SerializersChain) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
SerializersChain - Class in org.reveno.atp.core.engine.components
 
SerializersChain(ClassLoader) - Constructor for class org.reveno.atp.core.engine.components.SerializersChain
 
SerializersChain(List<TransactionInfoSerializer>) - Constructor for class org.reveno.atp.core.engine.components.SerializersChain
 
serializeWith(List<TransactionInfoSerializer>) - Method in interface org.reveno.atp.api.RevenoManager
Allows to provide custom TransactionInfoSerializer chain, with which all the transactions states will be serialized and journaled.
setBuffer(Buffer) - Method in class org.reveno.atp.clustering.core.fastcast.ByteSourceBuffer
 
setBytez(Bytez, long, int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
setCurrentNode(Address) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
setFlag(long) - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
setLastTransactionId(long) - Method in class org.reveno.atp.core.engine.WorkflowEngine
 
setLimit(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
setMaster(boolean) - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
setNodeAddresses(List<Address>) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
setNodeId(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastEx
 
setReaderPosition(int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
setReaderPosition(int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
setReaderPosition(int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
setReaderPosition(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
setReaderPosition(int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
setTime(long) - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
setTransactionId(long) - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
setVal1(V1) - Method in class org.reveno.atp.clustering.util.Tuple
 
setVal2(V2) - Method in class org.reveno.atp.clustering.util.Tuple
 
setWriterPosition(int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
setWriterPosition(int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
setWriterPosition(int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
setWriterPosition(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
setWriterPosition(int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
severe(String, Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
shortArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
shortArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicCommand
 
shortArg(String) - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
shortArg() - Method in class org.reveno.atp.api.dynamic.AbstractDynamicTransaction
 
shutdown() - Method in interface org.reveno.atp.api.Reveno
Shuts down an engine, gently stopping all processing, closing all channels.
shutdown() - Method in interface org.reveno.atp.clustering.core.api.StorageTransferServer
 
shutdown() - Method in class org.reveno.atp.clustering.core.ClusterEngine
 
shutdown() - Method in class org.reveno.atp.clustering.core.components.FileStorageTransferServer
 
shutdown() - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
shutdown() - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
shutdown() - Method in class org.reveno.atp.core.Engine
 
shutdown() - Method in class org.reveno.atp.core.engine.WorkflowEngine
 
shutdown() - Method in class org.reveno.atp.metrics.MetricsInterceptor
 
shutdown(Engine) - Method in class org.reveno.atp.metrics.RevenoMetrics
 
signal() - Method in class org.reveno.atp.utils.SignalBarrier
Signal the owner that the barrier is ready.
SignalBarrier - Class in org.reveno.atp.utils
A simple barrier for awaiting a signal.
SignalBarrier() - Constructor for class org.reveno.atp.utils.SignalBarrier
Create a new SignalBarrier without an owner.
SimpleCounter - Class in org.reveno.atp.metrics.meter.impl
 
SimpleCounter(String) - Constructor for class org.reveno.atp.metrics.meter.impl.SimpleCounter
 
SimpleEventsSerializer - Class in org.reveno.atp.core.serialization
 
SimpleEventsSerializer() - Constructor for class org.reveno.atp.core.serialization.SimpleEventsSerializer
 
SimpleMap(int, float, Supplier<V>) - Constructor for class org.reveno.atp.utils.MapUtils.SimpleMap
 
SimpleMap(Supplier<V>) - Constructor for class org.reveno.atp.utils.MapUtils.SimpleMap
 
Sink - Interface in org.reveno.atp.metrics
 
Sinkable - Interface in org.reveno.atp.metrics.meter
 
size() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer.ClusterBufferHeader
 
size() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.ClusterMessageHeader
 
size() - Method in interface org.reveno.atp.core.api.channel.Channel
 
size() - Method in class org.reveno.atp.core.channel.FileChannel
 
size() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
size() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
sizeMarkPosition() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
sizeMarkPosition() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
sizeMarkPosition() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
sizeMarkPosition() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
sizeMarkPosition() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
skipField(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
skipMessage() - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
Slf4jSink - Class in org.reveno.atp.metrics.impl
 
Slf4jSink() - Constructor for class org.reveno.atp.metrics.impl.Slf4jSink
 
snapshot(RepositoryData, RepositorySnapshotter.SnapshotIdentifier) - Method in interface org.reveno.atp.api.RepositorySnapshotter
Performs snapshotting of RepositoryData to some SnapshotStorage
snapshot(RepositoryData, RepositorySnapshotter.SnapshotIdentifier) - Method in class org.reveno.atp.core.snapshots.DefaultSnapshotter
 
SnapshotBasedModelRepository - Class in org.reveno.atp.core.repository
 
SnapshotBasedModelRepository(WriteableRepository) - Constructor for class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
snapshotChannel(String) - Method in interface org.reveno.atp.core.api.storage.SnapshotStorage
 
snapshotChannel(String) - Method in class org.reveno.atp.core.storage.FileSystemStorage
 
snapshotMaker(Runnable) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
snapshotsManager() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
snapshotsManager() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
snapshotsManager(SnapshottersManager) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
SnapshotStorage - Interface in org.reveno.atp.core.api.storage
 
SnapshotStorage.SnapshotStore - Class in org.reveno.atp.core.api.storage
 
SnapshotStore(String, long) - Constructor for class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 
SnapshottersManager - Class in org.reveno.atp.core.snapshots
 
SnapshottersManager(SnapshotStorage, RepositoryDataSerializer) - Constructor for class org.reveno.atp.core.snapshots.SnapshottersManager
 
snapshotting() - Method in interface org.reveno.atp.api.Configuration
 
snapshotting() - Method in class org.reveno.atp.core.RevenoConfiguration
 
SnapshottingInterceptor - Class in org.reveno.atp.core.engine.components
 
SnapshottingInterceptor(RevenoConfiguration, SnapshottersManager, SnapshotStorage, JournalsManager, RepositoryDataSerializer) - Constructor for class org.reveno.atp.core.engine.components.SnapshottingInterceptor
 
snapshotWith(RepositorySnapshotter) - Method in interface org.reveno.atp.api.RevenoManager
Specifies some RepositorySnapshotter object which is responsible for creating some snapshot of current state of domain model from Repository, and storing it with either SnapshotStorage or creating custom storage structure with FoldersStorage.
socketConfiguration() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
SocketConfiguration() - Constructor for class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
socketReceiveBufferSize() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
socketReceiveBufferSize(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
socketSendBufferSize() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
socketSendBufferSize(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
spinLoopMicros(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Microseconds during which busy spin loop awaiting new packets will be performed.
spinLoopMicros() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
spinLoopMicros(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
spinLoopMicros(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
spinLoopMicros() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
split(long) - Method in class org.reveno.atp.commons.LongRange
 
start - Variable in class org.reveno.atp.commons.LongRange
 
start() - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
start() - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
startElectionProcess() - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
startup() - Method in interface org.reveno.atp.api.Reveno
Performs startup of the engine.
startup() - Method in interface org.reveno.atp.clustering.core.api.StorageTransferServer
 
startup() - Method in class org.reveno.atp.clustering.core.ClusterEngine
 
startup() - Method in class org.reveno.atp.clustering.core.components.FileStorageTransferServer
 
startup() - Method in class org.reveno.atp.core.Engine
 
startupInterceptor() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
startWriting(Channel) - Method in interface org.reveno.atp.core.api.Journaler
 
startWriting(Channel) - Method in class org.reveno.atp.core.data.DefaultJournaler
 
stop() - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
stop() - Method in class org.reveno.atp.core.disruptor.DisruptorPipeProcessor
 
stop() - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
stopWriting() - Method in interface org.reveno.atp.core.api.Journaler
 
stopWriting() - Method in class org.reveno.atp.core.data.DefaultJournaler
 
StorageTransferModelSync - Class in org.reveno.atp.clustering.core.components
 
StorageTransferModelSync(RevenoClusterConfiguration, JournalsStorage, SnapshotStorage) - Constructor for class org.reveno.atp.clustering.core.components.StorageTransferModelSync
 
StorageTransferModelSync.TransferContext - Class in org.reveno.atp.clustering.core.components
 
StorageTransferServer - Interface in org.reveno.atp.clustering.core.api
 
store(long, T) - Method in interface org.reveno.atp.api.domain.WriteableRepository
 
store(long, Class<? super T>, T) - Method in interface org.reveno.atp.api.domain.WriteableRepository
 
store(Class<?>, long) - Method in class org.reveno.atp.core.engine.components.DefaultIdGenerator.IdsBundle
 
store(long, T) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
store(long, Class<? super T>, T) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
store(long, T) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
store(long, Class<? super T>, T) - Method in class org.reveno.atp.core.repository.HashMapRepository
 
store(long, T) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
store(long, Class<? super T>, T) - Method in class org.reveno.atp.core.repository.ImmutableModelRepository
Deprecated.
 
store(long, T) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
store(long, Class<? super T>, T) - Method in class org.reveno.atp.core.repository.MutableModelRepository
 
store(long, T) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
store(long, Class<? super T>, T) - Method in class org.reveno.atp.core.repository.SnapshotBasedModelRepository
 
subscribe(MessagesReceiver...) - Method in class org.reveno.atp.clustering.core.FailoverExecutor
 
switchNext(boolean) - Method in class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
sync() - Method in class org.reveno.atp.core.disruptor.DisruptorEventPipeProcessor
 
sync() - Method in class org.reveno.atp.core.disruptor.DisruptorTransactionPipeProcessor
 
sync() - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
SYNC_FLAG - Static variable in class org.reveno.atp.core.events.EventPublisher
 
syncBarrierTimeoutNanos(long) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.TimeoutsConfiguration
 
syncBarrierTimeoutNanos(long) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
syncBarrierTimeoutNanos() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
syncFuture() - Method in class org.reveno.atp.core.events.Event
 
syncFuture(CompletableFuture<?>) - Method in class org.reveno.atp.core.events.Event
 
SyncMode - Enum in org.reveno.atp.clustering.api
 
syncMode - Variable in class org.reveno.atp.clustering.core.messages.NodeState
 
syncPort - Variable in class org.reveno.atp.clustering.core.messages.NodeState
 
syncTimeoutNanos(long) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.TimeoutsConfiguration
 
syncTimeoutNanos(long) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
syncTimeoutNanos() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
SystemInfo - Class in org.reveno.atp.core.api
 
SystemInfo(long) - Constructor for class org.reveno.atp.core.api.SystemInfo
 
SystemState(long) - Constructor for class org.reveno.atp.core.api.SystemStateRestorer.SystemState
 
SystemStateRestorer - Interface in org.reveno.atp.core.api
 
SystemStateRestorer.SystemState - Class in org.reveno.atp.core.api
 

T

tag() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
tag(long) - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
tag() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
tag(long) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
then(ProcessorHandler<T>...) - Method in interface org.reveno.atp.core.engine.processor.PipeProcessor
 
threadParkMicros(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Microseconds during which LockSupport.parkNanos() will be called in busy spin loop.
threadParkMicros() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
threadParkMicros(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
threadParkMicros(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
threadParkMicros() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
threadPoolSize(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.SyncConfiguration
Thread pool size of Sync Server, which handles synchronization requests and sends appropriate data.
threadPoolSize(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
threadPoolSize() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
time() - Method in interface org.reveno.atp.core.api.EventsCommitInfo
The time of events execution.
time() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
time(long) - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
time() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
time(long) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
time() - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
time() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
time(long) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
topicName(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
topicName() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
toString() - Method in class org.reveno.atp.clustering.api.ClusterView
 
toString() - Method in class org.reveno.atp.clustering.api.InetAddress
 
toString() - Method in class org.reveno.atp.clustering.core.messages.NodeState
 
toString() - Method in class org.reveno.atp.clustering.core.messages.VoteAck
 
toString() - Method in class org.reveno.atp.clustering.core.messages.VoteMessage
 
toString() - Method in class org.reveno.atp.clustering.util.Tuple
 
toString() - Method in class org.reveno.atp.commons.LongRange
 
toString() - Method in class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 
toString() - Method in class org.reveno.atp.core.channel.FileChannel
 
toString() - Method in class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
transaction(String, BiConsumer<AbstractDynamicTransaction, TransactionContext>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
transactionAction(Class<T>, BiConsumer<T, TransactionContext>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
transactionCommitBuilder() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
transactionCommitBuilder() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
transactionCommitBuilder(TransactionCommitInfo.Builder) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
TransactionCommitInfo - Interface in org.reveno.atp.core.api
 
TransactionCommitInfo.Builder - Interface in org.reveno.atp.core.api
 
TransactionCommitInfoImpl - Class in org.reveno.atp.core.impl
 
TransactionCommitInfoImpl() - Constructor for class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
TransactionCommitInfoImpl.PojoBuilder - Class in org.reveno.atp.core.impl
 
transactionCommits() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
transactionCommits(List<Object>) - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
transactionCommits() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
transactionCommits(List<Object>) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
TransactionContext - Interface in org.reveno.atp.api.transaction
 
transactionExecution(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
TransactionExecutor - Class in org.reveno.atp.core.engine.components
 
TransactionExecutor() - Constructor for class org.reveno.atp.core.engine.components.TransactionExecutor
 
transactionId - Variable in class org.reveno.atp.clustering.core.components.StorageTransferModelSync.TransferContext
 
transactionId - Variable in class org.reveno.atp.clustering.core.messages.NodeState
 
transactionId() - Method in interface org.reveno.atp.core.api.EventsCommitInfo
Transaction ID, in which events were executed.
transactionId() - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
transactionId(long) - Method in interface org.reveno.atp.core.api.TransactionCommitInfo
 
transactionId() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
transactionId(long) - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
transactionId() - Method in class org.reveno.atp.core.events.Event
 
transactionId(long) - Method in class org.reveno.atp.core.events.Event
 
transactionId() - Method in class org.reveno.atp.core.impl.EventsCommitInfoImpl
 
transactionId() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
transactionId(long) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
TransactionInfoSerializer - Interface in org.reveno.atp.core.api.serialization
 
TransactionInterceptor - Interface in org.reveno.atp.api.transaction
 
transactionJournaler() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
transactionJournaler() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
transactionJournaler(Journaler) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
TransactionPipeProcessor<T extends Destroyable> - Interface in org.reveno.atp.core.engine.processor
 
TRANSACTIONS - Static variable in class org.reveno.atp.clustering.core.components.StorageTransferModelSync
 
TransactionsManager - Class in org.reveno.atp.core.engine.components
 
TransactionsManager() - Constructor for class org.reveno.atp.core.engine.components.TransactionsManager
 
transactionsManager() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
transactionsManager() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
transactionsManager(TransactionsManager) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
TransactionStage - Enum in org.reveno.atp.api.transaction
 
transactionType() - Method in class org.reveno.atp.api.dynamic.DynamicCommand
 
transactionWithCompensatingAction(Class<T>, BiConsumer<T, TransactionContext>, BiConsumer<T, TransactionContext>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
transferByteRangeTo(Output, boolean, int, boolean) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
TransferContext(long, NodeState) - Constructor for class org.reveno.atp.clustering.core.components.StorageTransferModelSync.TransferContext
 
transportName(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
transportName() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration
 
ttl(int) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.MulticastConfiguration
Milticast transport TTL (Time to live).
ttl() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
ttl(int) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastConfiguration.SocketConfiguration
 
ttl(int) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
ttl() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoMulticastConfiguration
 
Tuple<V1,V2> - Class in org.reveno.atp.clustering.util
 
Tuple(V1, V2) - Constructor for class org.reveno.atp.clustering.util.Tuple
 
TwoBufferHistogram - Class in org.reveno.atp.metrics.meter.impl
 
TwoBufferHistogram(String, int) - Constructor for class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
TwoBufferHistogram(String, int, HistogramType) - Constructor for class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
TxRepository - Interface in org.reveno.atp.core.api
 
TxRepositoryFactory - Interface in org.reveno.atp.core.api
 
txSize() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
type() - Method in class org.reveno.atp.clustering.api.message.Message
Unique message type in the system.
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.BarrierMessage
 
type() - Method in class org.reveno.atp.clustering.core.messages.BarrierMessage
 
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.BarrierPassed
 
type() - Method in class org.reveno.atp.clustering.core.messages.BarrierPassed
 
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.ForceElectionProcess
 
type() - Method in class org.reveno.atp.clustering.core.messages.ForceElectionProcess
 
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.NodeState
 
type() - Method in class org.reveno.atp.clustering.core.messages.NodeState
 
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.VoteAck
 
type() - Method in class org.reveno.atp.clustering.core.messages.VoteAck
 
TYPE - Static variable in class org.reveno.atp.clustering.core.messages.VoteMessage
 
type() - Method in class org.reveno.atp.clustering.core.messages.VoteMessage
 
TYPE - Static variable in class org.reveno.atp.core.api.storage.SnapshotStorage.SnapshotStore
 

U

unblock() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
UnclusteredFailoverManager - Class in org.reveno.atp.core
 
UnclusteredFailoverManager() - Constructor for class org.reveno.atp.core.UnclusteredFailoverManager
 
underlying(WriteableRepository) - Method in class org.reveno.atp.core.engine.components.RecordingRepository
 
underlyingEventBus(EventBus) - Method in interface org.reveno.atp.core.api.RestoreableEventBus
 
underlyingEventBus(EventBus) - Method in class org.reveno.atp.core.restore.RestorerEventBus
 
unicast() - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration
Unicast configrations, which will be used in cast of ClusterConfiguration.commandsXmitTransport(CommandsXmitTransport) was set to UNICAST.
unicast() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration
 
unicast(ClusterEngine[]) - Static method in class org.reveno.atp.examples.clustering.Examples
 
UnicastAllProvider - Class in org.reveno.atp.clustering.core.providers
 
UnicastAllProvider() - Constructor for class org.reveno.atp.clustering.core.providers.UnicastAllProvider
 
UnicastAllProvider(String) - Constructor for class org.reveno.atp.clustering.core.providers.UnicastAllProvider
 
uniqueIdFor(Class<?>...) - Method in class org.reveno.atp.api.dynamic.DirectTransactionBuilder
 
unlockIncoming() - Method in interface org.reveno.atp.clustering.api.ClusterBuffer
 
unlockIncoming() - Method in class org.reveno.atp.clustering.core.fastcast.FastCastBuffer
 
unlockIncoming() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer
 
unmarshall(Buffer) - Method in interface org.reveno.atp.clustering.api.message.Marshaller
Reads message from provided buffer.
unmarshall(Buffer) - Method in class org.reveno.atp.clustering.core.marshallers.JsonMarshaller
 
unmarshall(Buffer) - Method in class org.reveno.atp.clustering.core.marshallers.NativeMarshaller
 
unprocessedCount() - Method in class org.reveno.atp.clustering.core.ClusterFailoverManager
 
unprocessedCount() - Method in interface org.reveno.atp.core.api.FailoverManager
 
unprocessedCount() - Method in class org.reveno.atp.core.UnclusteredFailoverManager
 
UnsafeUtils - Class in org.reveno.atp.utils
 
UnsafeUtils() - Constructor for class org.reveno.atp.utils.UnsafeUtils
 
unsubscribe(int, Consumer<T>) - Method in interface org.reveno.atp.clustering.api.ClusterConnector
 
unsubscribe(int, Consumer<T>) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.JGroupsConnector
 
update(long) - Method in interface org.reveno.atp.metrics.meter.Histogram
 
update(long) - Method in class org.reveno.atp.metrics.meter.impl.TwoBufferHistogram
 
Utils - Class in org.reveno.atp.clustering.util
 
Utils() - Constructor for class org.reveno.atp.clustering.util.Utils
 

V

valueOf(String) - Static method in enum org.reveno.atp.api.ChannelOptions
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.api.Configuration.CpuConsumption
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.api.Configuration.ModelType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.api.Configuration.MutableModelFailover
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.api.exceptions.SerializerException.Action
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.api.transaction.TransactionStage
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.clustering.api.ClusterConfiguration.CommandsXmitTransport
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.clustering.api.ClusterEvent
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.clustering.api.Flag
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.clustering.api.IOMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.clustering.api.SyncMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.core.api.InputProcessor.JournalType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.core.repository.MutableModelRepository.EntityRecoveryState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.reveno.atp.metrics.meter.HistogramType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.reveno.atp.api.ChannelOptions
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.api.Configuration.CpuConsumption
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.api.Configuration.ModelType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.api.Configuration.MutableModelFailover
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.api.exceptions.SerializerException.Action
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.api.transaction.TransactionStage
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.clustering.api.ClusterConfiguration.CommandsXmitTransport
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.clustering.api.ClusterEvent
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.clustering.api.Flag
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.clustering.api.IOMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.clustering.api.SyncMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.core.api.InputProcessor.JournalType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.core.repository.MutableModelRepository.EntityRecoveryState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.reveno.atp.metrics.meter.HistogramType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class org.reveno.atp.utils.MapUtils.MapOfSet
 
version() - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
version(int) - Method in class org.reveno.atp.core.impl.TransactionCommitInfoImpl
 
VersionedFile(String, String, Calendar, long, String[]) - Constructor for class org.reveno.atp.utils.VersionedFileUtils.VersionedFile
 
VersionedFileUtils - Class in org.reveno.atp.utils
 
VersionedFileUtils() - Constructor for class org.reveno.atp.utils.VersionedFileUtils
 
VersionedFileUtils.VersionedFile - Class in org.reveno.atp.utils
 
view() - Method in interface org.reveno.atp.clustering.api.Cluster
Returns the current Reveno Cluster View.
view() - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster
 
viewAccepted(View) - Method in class org.reveno.atp.clustering.core.jgroups.JChannelReceiver
 
ViewHandlerHolder(Class<V>, ViewsMapper<E, V>) - Constructor for class org.reveno.atp.core.views.ViewsManager.ViewHandlerHolder
 
viewId() - Method in class org.reveno.atp.clustering.api.ClusterView
 
viewId - Variable in class org.reveno.atp.clustering.core.messages.NodeState
 
viewId - Variable in class org.reveno.atp.clustering.core.messages.VoteAck
 
viewId - Variable in class org.reveno.atp.clustering.core.messages.VoteMessage
 
viewMapper(Class<E>, Class<V>, ViewsMapper<E, V>) - Method in interface org.reveno.atp.api.RevenoManager
TODO
ViewsDefaultStorage - Class in org.reveno.atp.core.views
Not efficient version, consider for changing it.
ViewsDefaultStorage(int, float) - Constructor for class org.reveno.atp.core.views.ViewsDefaultStorage
 
ViewsManager - Class in org.reveno.atp.core.views
 
ViewsManager() - Constructor for class org.reveno.atp.core.views.ViewsManager
 
ViewsManager.ViewHandlerHolder<E,V> - Class in org.reveno.atp.core.views
 
ViewsMapper<Entity,View> - Interface in org.reveno.atp.api.query
 
viewsProcessor() - Method in interface org.reveno.atp.core.engine.WorkflowContext
 
viewsProcessor() - Method in class org.reveno.atp.core.EngineWorkflowContext
 
viewsProcessor(ViewsProcessor) - Method in class org.reveno.atp.core.EngineWorkflowContext
 
ViewsProcessor - Class in org.reveno.atp.core.views
 
ViewsProcessor(ViewsManager, ViewsStorage) - Constructor for class org.reveno.atp.core.views.ViewsProcessor
 
ViewsStorage - Interface in org.reveno.atp.core.api
 
viewsUpdate(ProcessorContext, boolean) - Method in class org.reveno.atp.core.engine.InputHandlers
 
viewType - Variable in class org.reveno.atp.core.views.ViewsManager.ViewHandlerHolder
 
volumes(int) - Method in interface org.reveno.atp.api.Configuration.JournalingConfiguration
 
volumes(int) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
volumes() - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
volumesSize(long, long) - Method in interface org.reveno.atp.api.Configuration.JournalingConfiguration
 
volumesSize(long, long) - Method in class org.reveno.atp.core.RevenoConfiguration.RevenoJournalingConfiguration
 
VoteAck - Class in org.reveno.atp.clustering.core.messages
 
VoteAck(long) - Constructor for class org.reveno.atp.clustering.core.messages.VoteAck
 
VoteAck() - Constructor for class org.reveno.atp.clustering.core.messages.VoteAck
 
VoteMessage - Class in org.reveno.atp.clustering.core.messages
 
VoteMessage(long, int, long) - Constructor for class org.reveno.atp.clustering.core.messages.VoteMessage
 
VoteMessage() - Constructor for class org.reveno.atp.clustering.core.messages.VoteMessage
 
voteTimeoutNanos(long) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.TimeoutsConfiguration
 
voteTimeoutNanos(long) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 
voteTimeoutNanos() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoTimeoutsConfiguration
 

W

waitAllNodesSync(boolean) - Method in interface org.reveno.atp.clustering.api.ClusterConfiguration.SyncConfiguration
The synchronization process lasts during global Leadership Election process, which means no node during it can operate on production.
waitAllNodesSync(boolean) - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
waitAllNodesSync() - Method in class org.reveno.atp.clustering.core.RevenoClusterConfiguration.RevenoSyncConfiguration
 
waitFor(Supplier<Boolean>, long) - Static method in class org.reveno.atp.clustering.util.Utils
 
waitOn() - Method in class org.reveno.atp.clustering.core.components.GroupBarrier
 
warn(Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
warn(String) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
warn(String, Throwable) - Method in class org.reveno.atp.clustering.core.fastcast.FastCastSlf4jLogger
 
withBuffer(Buffer) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
withResult() - Method in class org.reveno.atp.core.disruptor.ProcessorContext
 
WorkflowContext - Interface in org.reveno.atp.core.engine
 
WorkflowEngine - Class in org.reveno.atp.core.engine
 
WorkflowEngine(TransactionPipeProcessor<ProcessorContext>, WorkflowContext, Configuration.ModelType) - Constructor for class org.reveno.atp.core.engine.WorkflowEngine
 
write(Buffer) - Method in class org.reveno.atp.clustering.api.message.Message
Provides an ability to serialize current message instance data down to buffer.
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.BarrierMessage
 
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.BarrierPassed
 
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.ForceElectionProcess
 
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.NodeState
 
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.VoteAck
 
write(Buffer) - Method in class org.reveno.atp.clustering.core.messages.VoteMessage
 
write(String, File) - Static method in class org.reveno.atp.clustering.util.Utils
 
write(Consumer<Buffer>, boolean) - Method in interface org.reveno.atp.core.api.channel.Channel
 
write(int) - Method in class org.reveno.atp.core.api.channel.RevenoBufferOutputStream
 
write(Consumer<Buffer>, boolean) - Method in class org.reveno.atp.core.channel.FileChannel
 
WriteableRepository - Interface in org.reveno.atp.api.domain
 
writeByte(byte) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeByte(byte) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeByte(byte) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeByte(byte) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeByte(byte) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeByte(byte) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeByteArray(byte[], int, int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeByteBuffer(ByteBuffer) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeBytes(byte[]) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeBytes(byte[], int, int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeBytes(byte[]) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeBytes(byte[], int, int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeBytes(byte[]) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeBytes(byte[], int, int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeBytes(byte[]) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeBytes(byte[], int, int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeBytes(byte[]) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeBytes(byte[], int, int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeData(Consumer<Buffer>, boolean) - Method in interface org.reveno.atp.core.api.Journaler
 
writeData(Consumer<Buffer>, boolean) - Method in class org.reveno.atp.core.data.DefaultJournaler
 
writeFromBuffer(ByteBuffer) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeFromBuffer(ByteBuffer) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeFromBuffer(ByteBuffer) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeFromBuffer(ByteBuffer) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeFromBuffer(ByteBuffer) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeInt(int) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeInt(int) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeInt(int) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeInt(int) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeInt(int) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeInt16(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeInt16LE(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeInt32(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeInt32LE(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeInt64(long) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeInt64LE(long) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeLong(long) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeLong(long) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeLong(long) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeLong(long) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeLong(long) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeNullable(long, Buffer) - Static method in class org.reveno.atp.utils.BinaryUtils
 
writerPosition() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writerPosition() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writerPosition() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writerPosition() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writerPosition() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeShort(short) - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeShort(short) - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeShort(short) - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeShort(short) - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeShort(short) - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeSize() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeSize() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeSize() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeSize() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeSize() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeTo(DataOutput) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsBuffer.ClusterBufferHeader
 
writeTo(DataOutput) - Method in class org.reveno.atp.clustering.core.jgroups.JGroupsCluster.ClusterMessageHeader
 
writeToBuffer() - Method in class org.reveno.atp.clustering.core.components.AbstractClusterBuffer
 
writeToBuffer() - Method in class org.reveno.atp.clustering.core.fastcast.BytezBufferWrapper
 
writeToBuffer() - Method in interface org.reveno.atp.core.api.channel.Buffer
 
writeToBuffer() - Method in class org.reveno.atp.core.channel.ChannelBuffer
 
writeToBuffer() - Method in class org.reveno.atp.core.channel.NettyBasedBuffer
 
writeVarInt32(int) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
writeVarInt64(long) - Method in class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 

Z

ZeroCopyBufferInput - Class in org.reveno.atp.core.serialization.protostuff
Some customized implementation of ZeroCopyInput, most parts of it is kindly taken from Protostuff source code.
ZeroCopyBufferInput(Buffer, boolean) - Constructor for class org.reveno.atp.core.serialization.protostuff.ZeroCopyBufferInput
 
ZeroCopyLinkBuffer - Class in org.reveno.atp.core.serialization.protostuff
 
ZeroCopyLinkBuffer() - Constructor for class org.reveno.atp.core.serialization.protostuff.ZeroCopyLinkBuffer
 
A B C D E F G H I J K L M N O P Q R S T U V W Z 
Skip navigation links

Copyright © 2015 Artem Dmitriev. All Rights Reserved.