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

A

AbstractCommandInterceptor<K,V> - Class in org.shoal.ha.cache.impl.interceptor

AbstractCommandInterceptor() - Constructor for class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

addCommand(Command<K, V>) - Method in class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitter

addCommand(Command<K, V>) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

B

backToAppendMode() - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

Note: This must be used only after a call to moveTo

BroadcastLoadRequestCommand<K,V> - Class in org.shoal.ha.cache.impl.command

BroadcastLoadRequestCommand() - Constructor for class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

BroadcastLoadRequestCommand(K) - Constructor for class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

bytesToInt(byte[], int) - Static method in class org.shoal.ha.cache.impl.util.Utility

Unmarshal a byte array to an integer.

bytesToLong(byte[], int) - Static method in class org.shoal.ha.cache.impl.util.Utility

C

CACHE_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_CONFIG - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_DATA_STORE - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_DATA_STORE_LOAD - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_DATA_STORE_REMOVE - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_DATA_STORE_SAVE - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_KEY_MAPPER - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_LOAD_REQUEST_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_LOAD_RESPONSE_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_REMOVE_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_REVEIVE_INTERCEPTOR - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_SAVE_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_TOUCH_COMMAND - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

CACHE_TRANSMIT_INTERCEPTOR - Static variable in class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

call() - Method in class org.shoal.ha.cache.impl.util.CommandResponse

close() - Method in interface org.shoal.ha.cache.api.DataStore

Close this datastore.

close() - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

close() - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

close() - Method in class org.shoal.ha.group.gms.GroupServiceProvider

close() - Method in interface org.shoal.ha.group.GroupService

Command<K,V> - Class in org.shoal.ha.cache.impl.command

Command(byte) - Constructor for class org.shoal.ha.cache.impl.command.Command

CommandHandlerInterceptor<K,V> - Class in org.shoal.ha.cache.impl.interceptor

CommandHandlerInterceptor() - Constructor for class org.shoal.ha.cache.impl.interceptor.CommandHandlerInterceptor

CommandManager<K,V> - Class in org.shoal.ha.cache.impl.command

CommandManager(DataStoreContext<K, V>) - Constructor for class org.shoal.ha.cache.impl.command.CommandManager

CommandMonitorInterceptor<K,V> - Class in org.shoal.ha.cache.impl.interceptor

CommandMonitorInterceptor() - Constructor for class org.shoal.ha.cache.impl.interceptor.CommandMonitorInterceptor

CommandResponse - Class in org.shoal.ha.cache.impl.util

CommandResponse(ResponseMediator) - Constructor for class org.shoal.ha.cache.impl.util.CommandResponse

createBackingStore(BackingStoreConfiguration<K, V>) - Method in class org.shoal.adapter.store.ReplicatedBackingStoreFactory

createBackingStoreTransaction() - Method in class org.shoal.adapter.store.ReplicatedBackingStoreFactory

createCommandResponse() - Method in class org.shoal.ha.cache.impl.util.ResponseMediator

createDataStore(String, String, String) - Static method in class org.shoal.ha.cache.api.DataStoreFactory

createDataStore(String, String, String, Class<K>, Class<V>, ClassLoader) - Static method in class org.shoal.ha.cache.api.DataStoreFactory

createDataStore(String, String, String, Class<K>, Class<V>, ClassLoader, DataStoreEntryHelper<K, V>, DataStoreKeyHelper<K>, KeyMapper) - Static method in class org.shoal.ha.cache.api.DataStoreFactory

createDataStore(DataStoreConfigurator<K, V>) - Static method in class org.shoal.ha.cache.api.DataStoreFactory

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.Command

createNewInstance(byte) - Method in class org.shoal.ha.cache.impl.command.CommandManager

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.LoadResponseCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.SaveCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

createNewInstance() - Method in class org.shoal.ha.cache.impl.command.UpdateDeltaCommand

createObjectInputStream(InputStream, ClassLoader) - Method in class org.shoal.ha.cache.api.DefaultObjectInputOutputStreamFactory

createObjectInputStream(InputStream, ClassLoader) - Method in interface org.shoal.ha.cache.api.ObjectInputOutputStreamFactory

createObjectOutputStream(OutputStream) - Method in class org.shoal.ha.cache.api.DefaultObjectInputOutputStreamFactory

createObjectOutputStream(OutputStream) - Method in interface org.shoal.ha.cache.api.ObjectInputOutputStreamFactory

D

DataStore<K,V> - Interface in org.shoal.ha.cache.api

A DataStore allows (#{Serializable} / #{Storable}) objects to be placed in the cache.

DataStoreConfigurator<K,V> - Class in org.shoal.ha.cache.api

DataStoreConfigurator() - Constructor for class org.shoal.ha.cache.api.DataStoreConfigurator

DataStoreContext<K,V> - Class in org.shoal.ha.cache.api

DataStoreContext(String, GroupService, ClassLoader) - Constructor for class org.shoal.ha.cache.api.DataStoreContext

DataStoreEntry<K,V> - Class in org.shoal.ha.cache.api

DataStoreEntry() - Constructor for class org.shoal.ha.cache.api.DataStoreEntry

DataStoreEntryEvaluator<K,V> - Interface in org.shoal.ha.cache.api

DataStoreEntryEvaluator.Opcode - Enum in org.shoal.ha.cache.api

DataStoreEntryHelper<K,V> - Interface in org.shoal.ha.cache.api

DataStoreException - Exception in org.shoal.ha.cache.api

DataStoreException() - Constructor for exception org.shoal.ha.cache.api.DataStoreException

DataStoreException(String) - Constructor for exception org.shoal.ha.cache.api.DataStoreException

DataStoreException(String, Throwable) - Constructor for exception org.shoal.ha.cache.api.DataStoreException

DataStoreException(Throwable) - Constructor for exception org.shoal.ha.cache.api.DataStoreException

DataStoreFactory - Class in org.shoal.ha.cache.api

DataStoreFactory() - Constructor for class org.shoal.ha.cache.api.DataStoreFactory

DataStoreKeyHelper<K> - Interface in org.shoal.ha.cache.api

DataStoreShell - Class in org.shoal.ha.cache.impl.util

DataStoreShell() - Constructor for class org.shoal.ha.cache.impl.util.DataStoreShell

DefaultDataStoreEntryHelper<K,V> - Class in org.shoal.ha.cache.impl.util

DefaultDataStoreEntryHelper(ObjectInputOutputStreamFactory, ClassLoader, long) - Constructor for class org.shoal.ha.cache.impl.util.DefaultDataStoreEntryHelper

DefaultKeyMapper<K> - Class in org.shoal.ha.cache.impl.util

DefaultKeyMapper(String, String) - Constructor for class org.shoal.ha.cache.impl.util.DefaultKeyMapper

DefaultObjectInputOutputStreamFactory - Class in org.shoal.ha.cache.api

DefaultObjectInputOutputStreamFactory() - Constructor for class org.shoal.ha.cache.api.DefaultObjectInputOutputStreamFactory

deserialize(ClassLoader, byte[], int) - Static method in class org.shoal.ha.cache.impl.util.SimpleSerializer

deserializeString(byte[], int) - Static method in class org.shoal.ha.cache.impl.util.SimpleSerializer

destroy() - Method in class org.shoal.adapter.store.ReplicatedBackingStore

dsc - Variable in class org.shoal.ha.cache.impl.command.Command

dsc - Variable in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

E

eval(DataStoreEntry<K, V>) - Method in interface org.shoal.ha.cache.api.DataStoreEntryEvaluator

execute(String) - Method in class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.Command

execute(Command<K, V>) - Method in class org.shoal.ha.cache.impl.command.CommandManager

execute(String) - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.LoadResponseCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.SaveCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

execute(String) - Method in class org.shoal.ha.cache.impl.command.UpdateDeltaCommand

executeCommand(Command<K, V>, boolean, String) - Method in class org.shoal.ha.cache.impl.command.CommandManager

F

find(DataStoreEntryEvaluator<K, V>) - Method in interface org.shoal.ha.cache.api.DataStore

Finds / Retrieves values that satisfy a criteria as dictated by the evaluator.

find(DataStoreEntryEvaluator<K, V>) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

findReplicaInstance(String, K) - Method in class org.shoal.ha.cache.impl.util.DefaultKeyMapper

findReplicaInstance(String, K) - Method in interface org.shoal.ha.mapper.KeyMapper

G

get(K) - Method in interface org.shoal.ha.cache.api.DataStore

Returns the value to which the specified key is mapped in this cache.

get(K) - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

get(K) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

getBuffer() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

getClassLoader() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getCommandManager() - Method in class org.shoal.ha.cache.api.DataStoreContext

getCommandManager() - Method in class org.shoal.ha.cache.impl.command.Command

getCommandManager() - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

getCommandResponse(long) - Method in class org.shoal.ha.cache.impl.util.ResponseMediator

getCommands() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getCurrentCoreMembers() - Method in class org.shoal.ha.group.gms.GroupServiceProvider

getCurrentCoreMembers() - Method in interface org.shoal.ha.group.GroupService

getDataStoreContext() - Method in class org.shoal.ha.cache.impl.command.Command

getDataStoreContext() - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

getDataStoreContext() - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

getDataStoreEntryHelper() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getDataStoreEntryHelper() - Method in class org.shoal.ha.cache.api.DataStoreContext

getDataStoreKeyHelper() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getDataStoreKeyHelper() - Method in class org.shoal.ha.cache.api.DataStoreContext

getEntry(K) - Method in class org.shoal.ha.cache.impl.store.ReplicaStore

getFrameCommand() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getFuture() - Method in class org.shoal.ha.cache.impl.util.CommandResponse

getGroupName() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getGroupName() - Method in class org.shoal.ha.cache.api.DataStoreContext

getGroupName() - Method in class org.shoal.ha.group.gms.GroupServiceProvider

getGroupName() - Method in interface org.shoal.ha.group.GroupService

getGroupService() - Method in class org.shoal.ha.cache.api.DataStoreContext

getGroupService(String, String, boolean) - Method in class org.shoal.ha.group.GroupServiceFactory

getHashKey() - Method in interface org.shoal.ha.cache.api.HashableKey

getInstance() - Static method in class org.shoal.ha.group.GroupServiceFactory

getInstanceName() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getInstanceName() - Method in class org.shoal.ha.cache.api.DataStoreContext

getKey() - Method in class org.shoal.ha.cache.api.DataStoreEntry

getKey() - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

getKey() - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

getKey() - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

getKeyClazz() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getKeyMapper() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getKeyMapper() - Method in class org.shoal.ha.cache.api.DataStoreContext

getMappedInstance(String, K) - Method in class org.shoal.ha.cache.impl.util.DefaultKeyMapper

getMappedInstance(String, K) - Method in interface org.shoal.ha.mapper.KeyMapper

getMaxOutstandingPacketNumber() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getMemberName() - Method in class org.shoal.ha.group.gms.GroupServiceProvider

getMemberName() - Method in interface org.shoal.ha.group.GroupService

getMinOutstandingPacketNumber() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getNext() - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

getObjectInputOutputStreamFactory() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getObjectInputOutputStreamFactory() - Static method in class org.shoal.ha.cache.api.ObjectInputOutputStreamFactoryRegistry

getOpcode() - Method in class org.shoal.ha.cache.impl.command.Command

getPrev() - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

getReceiveCount() - Method in class org.shoal.ha.cache.impl.interceptor.CommandMonitorInterceptor

getReplicaInstanceName() - Method in class org.shoal.ha.cache.api.DataStoreEntry

getReplicaStore() - Method in class org.shoal.ha.cache.api.DataStoreContext

getResponseMediator() - Method in class org.shoal.ha.cache.api.DataStoreContext

getResult(long, TimeUnit) - Method in class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

getResult() - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

getSeqNo() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getSerializedData() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getServiceName() - Method in class org.shoal.ha.cache.api.DataStoreContext

getSourceInstanceName() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getStaleTargetName() - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

getState() - Method in class org.shoal.ha.cache.api.DataStoreEntry

getStoreName() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getTargetInstanceName() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

getTargetName() - Method in class org.shoal.ha.cache.impl.command.Command

getTokenId() - Method in class org.shoal.ha.cache.impl.util.CommandResponse

getTransmitCount() - Method in class org.shoal.ha.cache.impl.interceptor.CommandMonitorInterceptor

getV(DataStoreEntry<K, V>) - Method in interface org.shoal.ha.cache.api.DataStoreEntryHelper

getV(K) - Method in class org.shoal.ha.cache.impl.store.ReplicaStore

getV(DataStoreEntry<K, V>) - Method in class org.shoal.ha.cache.impl.util.DefaultDataStoreEntryHelper

getValueClazz() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

getWindowLen() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

GroupEventListener - Class in org.shoal.ha.cache.impl.util

Created by IntelliJ IDEA.

GroupEventListener() - Constructor for class org.shoal.ha.cache.impl.util.GroupEventListener

GroupMemberEventListener - Interface in org.shoal.ha.group

GroupService - Interface in org.shoal.ha.group

The minimal methods that a GS must implement to be used by the replication service.

GroupServiceFactory - Class in org.shoal.ha.group

GroupServiceProvider - Class in org.shoal.ha.group.gms

GroupServiceProvider(String, String, boolean) - Constructor for class org.shoal.ha.group.gms.GroupServiceProvider

H

handleMessage(String, String, byte[]) - Method in class org.shoal.ha.cache.impl.command.CommandManager

handleMessage(String, String, byte[]) - Method in class org.shoal.ha.cache.impl.util.MessageReceiver

HashableKey - Interface in org.shoal.ha.cache.api

I

initialize(BackingStoreConfiguration<K, V>) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

initialize(DataStoreContext<K, V>) - Method in class org.shoal.ha.cache.impl.command.Command

initialize(String, DataStoreContext<K, V>) - Method in class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitter

initialize(DataStoreContext<K, V>) - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

intToBytes(int) - Static method in class org.shoal.ha.cache.impl.util.Utility

Marshal an integer to a byte array.

intToBytes(int, byte[], int) - Static method in class org.shoal.ha.cache.impl.util.Utility

isCacheLocally() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

isCacheLocally() - Method in class org.shoal.ha.cache.api.DataStoreContext

isStartGMS() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

K

KeyMapper<K> - Interface in org.shoal.ha.mapper

L

load(K, String) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

LOAD_REQUEST - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

LOAD_RESPONSE - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

loader - Variable in class org.shoal.ha.cache.api.ObjectInputStreamWithLoader

loader - Variable in class org.shoal.ha.cache.impl.util.ObjectInputStreamWithLoader

LoadRequestCommand<K,V> - Class in org.shoal.ha.cache.impl.command

LoadRequestCommand() - Constructor for class org.shoal.ha.cache.impl.command.LoadRequestCommand

LoadRequestCommand(K) - Constructor for class org.shoal.ha.cache.impl.command.LoadRequestCommand

LoadResponseCommand<K,V> - Class in org.shoal.ha.cache.impl.command

LoadResponseCommand(K, V, long) - Constructor for class org.shoal.ha.cache.impl.command.LoadResponseCommand

longToBytes(long) - Static method in class org.shoal.ha.cache.impl.util.Utility

Unmarshal a byte array to an long.

longToBytes(long, byte[], int) - Static method in class org.shoal.ha.cache.impl.util.Utility

Marshal an long to a byte array.

M

main(String[]) - Static method in class org.shoal.ha.cache.impl.util.DataStoreShell

main(String[]) - Static method in class org.shoal.ha.group.GroupServiceFactory

mark() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

mark() - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

MessageReceiver - Class in org.shoal.ha.cache.impl.util

MessageReceiver(String) - Constructor for class org.shoal.ha.cache.impl.util.MessageReceiver

moveTo(int) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

O

ObjectInputOutputStreamFactory - Interface in org.shoal.ha.cache.api

ObjectInputOutputStreamFactoryRegistry - Class in org.shoal.ha.cache.api

ObjectInputOutputStreamFactoryRegistry() - Constructor for class org.shoal.ha.cache.api.ObjectInputOutputStreamFactoryRegistry

ObjectInputStreamWithLoader - Class in org.shoal.ha.cache.api

This subclass of ObjectInputStream delegates loading of classes to an existing ClassLoader.

ObjectInputStreamWithLoader(InputStream, ClassLoader) - Constructor for class org.shoal.ha.cache.api.ObjectInputStreamWithLoader

Loader must be non-null;

ObjectInputStreamWithLoader - Class in org.shoal.ha.cache.impl.util

This subclass of ObjectInputStream delegates loading of classes to an existing ClassLoader.

ObjectInputStreamWithLoader(InputStream, ClassLoader) - Constructor for class org.shoal.ha.cache.impl.util.ObjectInputStreamWithLoader

Loader must be non-null;

ObjectKeyHelper<K> - Class in org.shoal.ha.cache.api

ObjectKeyHelper(ClassLoader, ObjectInputOutputStreamFactory) - Constructor for class org.shoal.ha.cache.api.ObjectKeyHelper

onReceive(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

onReceive(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.interceptor.CommandHandlerInterceptor

onReceive(Command, String) - Method in class org.shoal.ha.cache.impl.interceptor.CommandMonitorInterceptor

onTransmit(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitterManager

onTransmit(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

onTransmit(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.interceptor.CommandHandlerInterceptor

onTransmit(Command, String) - Method in class org.shoal.ha.cache.impl.interceptor.CommandMonitorInterceptor

onTransmit(Command<K, V>, String) - Method in class org.shoal.ha.cache.impl.interceptor.TransmitInterceptor

onViewChange(String, Collection<String>, Collection<String>, boolean) - Method in class org.shoal.ha.cache.impl.util.DefaultKeyMapper

onViewChange(String, Collection<String>, Collection<String>, boolean) - Method in interface org.shoal.ha.group.GroupMemberEventListener

org.shoal.adapter.store - package org.shoal.adapter.store

org.shoal.ha.cache.api - package org.shoal.ha.cache.api

org.shoal.ha.cache.impl.command - package org.shoal.ha.cache.impl.command

org.shoal.ha.cache.impl.interceptor - package org.shoal.ha.cache.impl.interceptor

org.shoal.ha.cache.impl.store - package org.shoal.ha.cache.impl.store

org.shoal.ha.cache.impl.util - package org.shoal.ha.cache.impl.util

org.shoal.ha.group - package org.shoal.ha.group

org.shoal.ha.group.gms - package org.shoal.ha.group.gms

org.shoal.ha.mapper - package org.shoal.ha.mapper

P

prepareToExecute(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.Command

prepareTransmit(DataStoreContext<K, V>) - Method in class org.shoal.ha.cache.impl.command.Command

printMemberStates(String) - Method in class org.shoal.ha.cache.impl.util.DefaultKeyMapper

processNotification(Signal) - Method in class org.shoal.ha.cache.impl.util.MessageReceiver

processNotification(Signal) - Method in class org.shoal.ha.group.gms.GroupServiceProvider

put(K, V) - Method in interface org.shoal.ha.cache.api.DataStore

Creates or Replaces the object associated with key k.

put(K, V, String) - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

put(K, Object) - Method in class org.shoal.ha.cache.impl.store.ReplicaStore

put(K, V) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

R

readBoolean() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.Command

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.LoadResponseCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.SaveCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

readCommandPayload(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.command.UpdateDeltaCommand

readInt() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

readKey(ReplicationInputStream) - Method in interface org.shoal.ha.cache.api.DataStoreKeyHelper

readKey(ReplicationInputStream) - Method in class org.shoal.ha.cache.api.ObjectKeyHelper

readKey(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.util.StringKeyHelper

readLengthPrefixedBytes() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

readLengthPrefixedString() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

readLong() - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

readObject(ReplicationInputStream) - Method in interface org.shoal.ha.cache.api.DataStoreEntryHelper

readObject(ReplicationInputStream) - Method in class org.shoal.ha.cache.impl.util.DefaultDataStoreEntryHelper

readState(byte[], int) - Method in interface org.shoal.ha.cache.impl.util.Replicable

registerCommand(Command<K, V>) - Method in class org.shoal.ha.cache.impl.command.CommandManager

registerExecutionInterceptor(AbstractCommandInterceptor<K, V>) - Method in class org.shoal.ha.cache.impl.command.CommandManager

registerGroupMemberEventListener(GroupMemberEventListener) - Method in class org.shoal.ha.group.gms.GroupServiceProvider

registerGroupMemberEventListener(GroupMemberEventListener) - Method in interface org.shoal.ha.group.GroupService

registerGroupMessageReceiver(String, MessageReceiver) - Method in class org.shoal.ha.group.gms.GroupServiceProvider

registerGroupMessageReceiver(String, MessageReceiver) - Method in interface org.shoal.ha.group.GroupService

remove(K) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

remove(K) - Method in interface org.shoal.ha.cache.api.DataStore

Removes the mapping between the key and the object.

REMOVE - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

remove(K) - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

remove(K) - Method in class org.shoal.ha.cache.impl.store.ReplicaStore

remove(K) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

REMOVE_EXPIRED - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

RemoveCommand<K,V> - Class in org.shoal.ha.cache.impl.command

RemoveCommand() - Constructor for class org.shoal.ha.cache.impl.command.RemoveCommand

removeCommandResponse(long) - Method in class org.shoal.ha.cache.impl.util.ResponseMediator

removeExpired(long) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

removeGroupMemberEventListener(GroupMemberEventListener) - Method in class org.shoal.ha.group.gms.GroupServiceProvider

removeGroupMemberEventListener(GroupMemberEventListener) - Method in interface org.shoal.ha.group.GroupService

removeIdleEntries(long) - Method in interface org.shoal.ha.cache.api.DataStore

Removes all entries that were not accessed for more than 'idlefor' millis

removeIdleEntries(long) - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

removeIdleEntries(long) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

Replicable - Interface in org.shoal.ha.cache.impl.util

ReplicaLocationHolder<K,V> - Class in org.shoal.ha.cache.impl.store

ReplicaLocationHolder(DataStoreConfigurator<K, V>, DataStoreContext<K, V>) - Constructor for class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

ReplicaStore<K,V> - Class in org.shoal.ha.cache.impl.store

ReplicaStore(DataStoreContext<K, V>) - Constructor for class org.shoal.ha.cache.impl.store.ReplicaStore

ReplicatedBackingStore<K extends java.io.Serializable,V extends java.io.Serializable> - Class in org.shoal.adapter.store

ReplicatedBackingStore() - Constructor for class org.shoal.adapter.store.ReplicatedBackingStore

ReplicatedBackingStoreFactory - Class in org.shoal.adapter.store

ReplicatedBackingStoreFactory() - Constructor for class org.shoal.adapter.store.ReplicatedBackingStoreFactory

ReplicatedBackingStoreFactory(Properties) - Constructor for class org.shoal.adapter.store.ReplicatedBackingStoreFactory

ReplicatedBackingStoreFactory2 - Class in org.shoal.adapter.store

ReplicatedBackingStoreFactory2(Properties) - Constructor for class org.shoal.adapter.store.ReplicatedBackingStoreFactory2

ReplicatedDataStore<K,V> - Class in org.shoal.ha.cache.impl.store

ReplicatedDataStore(DataStoreConfigurator<K, V>, GroupService) - Constructor for class org.shoal.ha.cache.impl.store.ReplicatedDataStore

REPLICATION_FRAME_PAYLOAD - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

ReplicationCommandOpcode - Class in org.shoal.ha.cache.impl.command

ReplicationCommandOpcode() - Constructor for class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

ReplicationCommandTransmitter<K,V> - Class in org.shoal.ha.cache.impl.command

ReplicationCommandTransmitter() - Constructor for class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitter

ReplicationCommandTransmitterManager<K,V> - Class in org.shoal.ha.cache.impl.command

ReplicationCommandTransmitterManager() - Constructor for class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitterManager

ReplicationFrame<K,V> - Class in org.shoal.ha.cache.impl.command

ReplicationFrame(byte, int, String) - Constructor for class org.shoal.ha.cache.impl.command.ReplicationFrame

ReplicationFrame(byte, String) - Constructor for class org.shoal.ha.cache.impl.command.ReplicationFrame

ReplicationFramePayloadCommand<K,V> - Class in org.shoal.ha.cache.impl.command

ReplicationFramePayloadCommand() - Constructor for class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

ReplicationInputStream - Class in org.shoal.ha.cache.impl.util

ReplicationInputStream(byte[]) - Constructor for class org.shoal.ha.cache.impl.util.ReplicationInputStream

ReplicationInputStream(byte[], int, int) - Constructor for class org.shoal.ha.cache.impl.util.ReplicationInputStream

ReplicationOutputStream - Class in org.shoal.ha.cache.impl.util

ReplicationOutputStream() - Constructor for class org.shoal.ha.cache.impl.util.ReplicationOutputStream

resolveClass(ObjectStreamClass) - Method in class org.shoal.ha.cache.api.ObjectInputStreamWithLoader

Use the given ClassLoader rather than using the system class

resolveClass(ObjectStreamClass) - Method in class org.shoal.ha.cache.impl.util.ObjectInputStreamWithLoader

Use the given ClassLoader rather than using the system class

ResponseMediator - Class in org.shoal.ha.cache.impl.util

Created by IntelliJ IDEA.

ResponseMediator() - Constructor for class org.shoal.ha.cache.impl.util.ResponseMediator

reWrite(int, byte[]) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

run() - Method in class org.shoal.ha.cache.impl.command.ReplicationCommandTransmitter

run() - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

S

save(K, V, boolean) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

SAVE - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

SAVE_DELTA - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

SaveCommand<K,V> - Class in org.shoal.ha.cache.impl.command

SaveCommand() - Constructor for class org.shoal.ha.cache.impl.command.SaveCommand

SaveCommand(K, V) - Constructor for class org.shoal.ha.cache.impl.command.SaveCommand

sendMessage(String, String, byte[]) - Method in class org.shoal.ha.group.gms.GroupServiceProvider

sendMessage(String, String, byte[]) - Method in interface org.shoal.ha.group.GroupService

serialize(ReplicationOutputStream, Object) - Static method in class org.shoal.ha.cache.impl.util.SimpleSerializer

serializeString(ReplicationOutputStream, String) - Static method in class org.shoal.ha.cache.impl.util.SimpleSerializer

setCacheLocally(boolean) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setCacheLocally(boolean) - Method in class org.shoal.ha.cache.api.DataStoreContext

setClassLoader(ClassLoader) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setDataStoreEntryHelper(DataStoreEntryHelper<K, V>) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setDataStoreEntryHelper(DataStoreEntryHelper<K, V>) - Method in class org.shoal.ha.cache.api.DataStoreContext

setDataStoreKeyHelper(DataStoreKeyHelper<K>) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setDataStoreKeyHelper(DataStoreKeyHelper<K>) - Method in class org.shoal.ha.cache.api.DataStoreContext

setException(Exception) - Method in class org.shoal.ha.cache.impl.util.CommandResponse

setGroupName(String) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setInstanceName(String) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setKey(K) - Method in class org.shoal.ha.cache.api.DataStoreEntry

setKey(K) - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

setKey(K) - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

setKey(K) - Method in class org.shoal.ha.cache.impl.command.SaveCommand

setKey(K) - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

setKeyClazz(Class<K>) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setKeyMapper(KeyMapper) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setKeyMapper(KeyMapper<K>) - Method in class org.shoal.ha.cache.api.DataStoreContext

setMaxOutstandingPacketNumber(int) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

setMinOutstandingPacketNumber(int) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

setNext(AbstractCommandInterceptor<K, V>) - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

setObjectInputOutputStreamFactory(ObjectInputOutputStreamFactory) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setOriginatingInstance(String) - Method in class org.shoal.ha.cache.impl.command.LoadResponseCommand

setPrev(AbstractCommandInterceptor<K, V>) - Method in class org.shoal.ha.cache.impl.interceptor.AbstractCommandInterceptor

setReplicaInstanceName(String) - Method in class org.shoal.ha.cache.api.DataStoreEntry

setReplicationFrame(ReplicationFrame<K, V>) - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

setResult(Object) - Method in class org.shoal.ha.cache.impl.util.CommandResponse

setSeqNo(int) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

setStaleTargetName(String) - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

setStartGMS(boolean) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setState(Object) - Method in class org.shoal.ha.cache.api.DataStoreEntry

setStoreName(String) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setTargetInstanceName(String) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

setTargetName(String) - Method in class org.shoal.ha.cache.impl.command.Command

setValue(V) - Method in class org.shoal.ha.cache.impl.command.SaveCommand

setValueClazz(Class<V>) - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

setWindowLen(int) - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

ShoalCacheLoggerConstants - Class in org.shoal.ha.cache.api

ShoalCacheLoggerConstants() - Constructor for class org.shoal.ha.cache.api.ShoalCacheLoggerConstants

shutdown() - Method in class org.shoal.ha.group.gms.GroupServiceProvider

shutdown(String, String) - Method in class org.shoal.ha.group.GroupServiceFactory

SimpleSerializer - Class in org.shoal.ha.cache.impl.util

SimpleSerializer() - Constructor for class org.shoal.ha.cache.impl.util.SimpleSerializer

size() - Method in class org.shoal.adapter.store.ReplicatedBackingStore

size() - Method in class org.shoal.ha.cache.impl.store.ReplicaStore

skipTo(int) - Method in class org.shoal.ha.cache.impl.util.ReplicationInputStream

STALE_REMOVE - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

StaleCopyRemoveCommand<K,V> - Class in org.shoal.ha.cache.impl.command

StaleCopyRemoveCommand() - Constructor for class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

StringKeyHelper - Class in org.shoal.ha.cache.impl.util

StringKeyHelper() - Constructor for class org.shoal.ha.cache.impl.util.StringKeyHelper

T

toByteArray() - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

toReplicationFrame(DataStoreContext<K, V>, ReplicationInputStream) - Static method in class org.shoal.ha.cache.impl.command.ReplicationFrame

toString() - Method in class org.shoal.ha.cache.api.DataStoreConfigurator

toString() - Method in class org.shoal.ha.cache.impl.command.ReplicationFrame

toString() - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

touch(K, long, long, long) - Method in interface org.shoal.ha.cache.api.DataStore

Updates the timestamp associated with this entry.

TOUCH - Static variable in class org.shoal.ha.cache.impl.command.ReplicationCommandOpcode

touch(K, long, long, long, String) - Method in class org.shoal.ha.cache.impl.store.ReplicaLocationHolder

touch(K, long, long, long) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

TransmitInterceptor<K,V> - Class in org.shoal.ha.cache.impl.interceptor

TransmitInterceptor() - Constructor for class org.shoal.ha.cache.impl.interceptor.TransmitInterceptor

U

update(DataStoreEntryEvaluator<K, V>) - Method in interface org.shoal.ha.cache.api.DataStore

Updates all existing values associated with a key using the evaluator.

update(DataStoreEntryEvaluator<K, V>) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

updateDelta(K, V) - Method in interface org.shoal.ha.cache.api.DataStore

Performs an incremental update of the value associated with this key.

updateDelta(K, V) - Method in class org.shoal.ha.cache.impl.store.ReplicatedDataStore

UpdateDeltaCommand<K,V> - Class in org.shoal.ha.cache.impl.command

UpdateDeltaCommand(K, V) - Constructor for class org.shoal.ha.cache.impl.command.UpdateDeltaCommand

updateState(K, DataStoreEntry<K, V>, Object) - Method in interface org.shoal.ha.cache.api.DataStoreEntryHelper

updateState(K, DataStoreEntry<K, V>, Object) - Method in class org.shoal.ha.cache.impl.util.DefaultDataStoreEntryHelper

updateTimestamp(K, long) - Method in class org.shoal.adapter.store.ReplicatedBackingStore

Utility - Class in org.shoal.ha.cache.impl.util

Utility() - Constructor for class org.shoal.ha.cache.impl.util.Utility

V

valueOf(String) - Static method in enum org.shoal.ha.cache.api.DataStoreEntryEvaluator.Opcode

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

values() - Static method in enum org.shoal.ha.cache.api.DataStoreEntryEvaluator.Opcode

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

W

write(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.Command

writeBoolean(boolean) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.BroadcastLoadRequestCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.Command

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.LoadRequestCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.LoadResponseCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.RemoveCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.ReplicationFramePayloadCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.SaveCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

writeCommandPayload(ReplicationOutputStream) - Method in class org.shoal.ha.cache.impl.command.UpdateDeltaCommand

writeInt(int) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

writeKey(ReplicationOutputStream, K) - Method in interface org.shoal.ha.cache.api.DataStoreKeyHelper

writeKey(ReplicationOutputStream, K) - Method in class org.shoal.ha.cache.api.ObjectKeyHelper

writeKey(ReplicationOutputStream, String) - Method in class org.shoal.ha.cache.impl.util.StringKeyHelper

writeLengthPrefixedBytes(byte[]) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

writeLengthPrefixedString(String) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

writeLong(long) - Method in class org.shoal.ha.cache.impl.util.ReplicationOutputStream

writeObject(ReplicationOutputStream, Object) - Method in interface org.shoal.ha.cache.api.DataStoreEntryHelper

writeObject(ReplicationOutputStream, Object) - Method in class org.shoal.ha.cache.impl.util.DefaultDataStoreEntryHelper

writeState(ReplicationOutputStream) - Method in interface org.shoal.ha.cache.impl.util.Replicable

_

_logger - Static variable in class org.shoal.ha.cache.impl.command.RemoveCommand

_logger - Static variable in class org.shoal.ha.cache.impl.command.StaleCopyRemoveCommand

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