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

A

accept(T) - Method in interface net.dempsy.util.Functional.ConsumerThrows

ACQUIRE_STOP_REQUEST - Static variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

This value can be returned from RingBufferConsumerControl.availableTo() or RingBufferConsumerControl.tryAvailableTo() to inform the consumer that the published has called RingBufferControl.publishStop()

ApacheVfsPropertiesReader - Class in net.dempsy.distconfig.apahcevfs

ApacheVfsPropertiesReader(String, String) - Constructor for class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesReader

ApacheVfsPropertiesReader(String) - Constructor for class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesReader

ApacheVfsPropertiesStore - Class in net.dempsy.distconfig.apahcevfs

ApacheVfsPropertiesStore(String, String) - Constructor for class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesStore

ApacheVfsPropertiesStore(String) - Constructor for class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesStore

assertTrue(Supplier<String>, boolean) - Static method in class net.dempsy.utils.test.ConditionPoll

AutoDisposeSingleThreadScheduler - Class in net.dempsy.util.executor

This is a scheduler that will schedule a task to run in the future (or now) and when that task completes it shuts itself down.

AutoDisposeSingleThreadScheduler(String) - Constructor for class net.dempsy.util.executor.AutoDisposeSingleThreadScheduler

AutoDisposeSingleThreadScheduler.Cancelable - Class in net.dempsy.util.executor

This object is returned from AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit) and can be used to cancel the task - best effort.

available() - Method in class net.dempsy.util.io.MessageBufferInput

Returns the number of remaining bytes that can be read (or skipped over) from this input stream.

availableTo() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

RingBufferConsumerControl.availableTo() is a consumer side call that will block using the wait strategy until a value (or several) have been published.

availableTo(long) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

availableTo() - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

RingBufferControlMultiplexor.availableTo() is a consumer side call that will block until a value (or several) have been published to at least one of the underlying RingBufferControls.

B

baseTimeoutMillis - Static variable in class net.dempsy.utils.test.ConditionPoll

The default polling timeout.

begin() - Method in class net.dempsy.utils.test.SocketTimeout

buf - Variable in class net.dempsy.util.io.MessageBufferInput

An array of bytes that was provided by the creator of the stream.

buf - Variable in class net.dempsy.util.io.MessageBufferOutput

The buffer where data is stored.

bufferSize - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

C

cancel() - Method in class net.dempsy.util.executor.AutoDisposeSingleThreadScheduler.Cancelable

Attempt to cancel the Runnable that was submitted to AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit)

chain(T, Consumer<T>...) - Static method in class net.dempsy.util.Functional

This method allows for the chaining of calls that don't normally chain.

chainThrows(T, Functional.ConsumerThrows<T, E>...) - Static method in class net.dempsy.util.Functional

This method allows for the chaining of calls that don't normally chain but that also may throw.

claim(int) - Method in class net.dempsy.ringbuffer.RingBufferControl

This is used by the publishing thread to claim the given number of entries in the buffer.

claim(int) - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

This is used by the publishing thread to claim the given number of entries in the buffer all of the underlying RingBufferControls.

classname - Variable in class net.dempsy.serialization.kryo.Registration

ClasspathPropertiesReader - Class in net.dempsy.distconfig.classpath

ClasspathPropertiesReader(String, boolean) - Constructor for class net.dempsy.distconfig.classpath.ClasspathPropertiesReader

ClasspathPropertiesReader(String) - Constructor for class net.dempsy.distconfig.classpath.ClasspathPropertiesReader

ClassTracker - Class in net.dempsy.serialization.util

Some serializations (a.k.a, Kryo) can be made more efficient if you register classes that will be serialized and deserialized.

ClassTracker(Serializer) - Constructor for class net.dempsy.serialization.util.ClassTracker

cleanupAfterLastSession - Variable in class net.dempsy.cluster.local.LocalClusterSessionFactory

clear(String...) - Method in class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesStore

clear(String...) - Method in class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesStore

clear(String...) - Method in class net.dempsy.distconfig.PropertiesStore

This will clear the given properties by name.

clear() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

clear() - Method in class net.dempsy.ringbuffer.RingBufferControl

clear() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

The RingBufferControlWorkerPool can be cleared or "reset" so that it can be reused from scratch HOWEVER, the workers must be re-retrieved via newWorker(); none of the outstanding workers can be reused.

clear() - Method in class net.dempsy.util.io.MessageBufferInput

Causes the MessageBufferInput.available() to return 0.

clear() - Method in class net.dempsy.util.StupidHashMap

close() - Method in interface net.dempsy.cluster.ClusterInfoSession

default implementation of the AutoCloseable interface.

close() - Method in class net.dempsy.serialization.kryo.KryoSerializer.Holder

close() - Method in class net.dempsy.util.io.MessageBufferInput

Closing a ByteArrayInputStream has no effect.

close() - Method in class net.dempsy.util.io.MessageBufferOutput

Closing a ByteArrayOutputStream has no effect.

close() - Method in class net.dempsy.util.SpinLock.Guard

close() - Method in class net.dempsy.utils.test.SystemPropertyManager

ClusterInfoException - Exception in net.dempsy.cluster

ClusterInfoException(String) - Constructor for exception net.dempsy.cluster.ClusterInfoException

ClusterInfoException(String, Throwable) - Constructor for exception net.dempsy.cluster.ClusterInfoException

ClusterInfoException.NoNodeException - Exception in net.dempsy.cluster

ClusterInfoException.NoParentException - Exception in net.dempsy.cluster

ClusterInfoPropertiesReader - Class in net.dempsy.distconfig.clusterinfo

ClusterInfoPropertiesReader(ClusterInfoSession, String) - Constructor for class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesReader

ClusterInfoPropertiesStore - Class in net.dempsy.distconfig.clusterinfo

ClusterInfoPropertiesStore(ClusterInfoSession, String) - Constructor for class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesStore

ClusterInfoSession - Interface in net.dempsy.cluster

This is the main interface for the dempsy-cluster.api abstraction.

ClusterInfoSessionFactory - Interface in net.dempsy.cluster

ClusterInfoWatcher - Interface in net.dempsy.cluster

Implementations of this interface are used for notifications when changes happen.

completeReset() - Static method in class net.dempsy.cluster.local.LocalClusterSessionFactory

computeIfAbsent(K, Supplier<V>) - Method in class net.dempsy.util.StupidHashMap

conditionMet(T) - Method in interface net.dempsy.utils.test.ConditionPoll.Condition

Return whether or not the condition we are polling for has been met yet.

ConditionPoll - Class in net.dempsy.utils.test

Multi threaded tests are notoriously difficult to write.

ConditionPoll() - Constructor for class net.dempsy.utils.test.ConditionPoll

ConditionPoll.Condition<T> - Interface in net.dempsy.utils.test

This is the interface that serves as the root for anonymous classes passed to the poll call.

Config - Class in net.dempsy.distconfig

Config() - Constructor for class net.dempsy.distconfig.Config

connectString - Variable in class net.dempsy.cluster.zookeeper.ZookeeperSession

consumeAsIterable(T[]) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

consumeAsIterator(T[]) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

containsKey(Object) - Method in class net.dempsy.util.StupidHashMap

containsValue(Object) - Method in class net.dempsy.util.StupidHashMap

count - Variable in class net.dempsy.util.io.MessageBufferInput

The index one greater than the last valid character in the input stream buffer.

createSession() - Method in interface net.dempsy.cluster.ClusterInfoSessionFactory

createSession() - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory

createSession() - Method in class net.dempsy.cluster.zookeeper.ZookeeperSessionFactory

currentSessions - Static variable in class net.dempsy.cluster.local.LocalClusterSessionFactory

D

deserialize(MessageBufferInput, Class<T>) - Method in class net.dempsy.serialization.jackson.JsonSerializer

deserialize(MessageBufferInput, Class<T>) - Method in class net.dempsy.serialization.java.JavaSerializer

deserialize(MessageBufferInput, Class<T>) - Method in class net.dempsy.serialization.kryo.KryoSerializer

deserialize(MessageBufferInput, Class<T>) - Method in class net.dempsy.serialization.Serializer

deserialize(byte[], Class<T>) - Method in class net.dempsy.serialization.Serializer

deserialize(MessageBufferInput, Class<T>) - Method in class net.dempsy.serialization.util.ClassTracker

DirMode - Enum in net.dempsy.cluster

This enum represents a bit field.

disrupt() - Method in interface net.dempsy.cluster.DisruptibleSession

disrupt() - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

disrupt() - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

disrupt() - Method in class net.dempsy.utils.test.SocketTimeout

disrupted() - Method in class net.dempsy.utils.test.SocketTimeout

This checks, then clears, the disrupted flag.

DisruptibleSession - Interface in net.dempsy.cluster

This interface is used in tests.

doNotifyProcessed(long) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

dumpResults() - Static method in class net.dempsy.serialization.util.ClassTracker

E

end() - Method in class net.dempsy.utils.test.SocketTimeout

entrySet() - Method in class net.dempsy.util.StupidHashMap

equals(Object) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession.WatcherProxy

equals(String, String) - Static method in class net.dempsy.util.SafeString

exists(String, ClusterInfoWatcher) - Method in interface net.dempsy.cluster.ClusterInfoSession

Check if a path has already been created.

exists(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

exists(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

F

flag - Variable in enum net.dempsy.cluster.DirMode

Functional - Class in net.dempsy.util

A series of utilities to help with Java 8 functional operations.

Functional() - Constructor for class net.dempsy.util.Functional

Functional.ConsumerThrows<T,E extends Exception> - Interface in net.dempsy.util

A functional interface that analogous to a Consumer that throws a checked Exception

Functional.RunnableThrows<E extends Exception> - Interface in net.dempsy.util

A functional interface that analogous to a Runnable that throws a checked Exception

Functional.SupplierThrows<T,E extends Exception> - Interface in net.dempsy.util

A functional interface that analogous to a Supplier that throws a checked Exception

Functional.UncheckingExcpetion - Exception in net.dempsy.util

Wrapper class that encapsulates a checked exception in an unchecked exception

G

get(int) - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

This will retrieve the RingBufferControl that corresponds to the index given.

get(int) - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

This will retrieve the RingBufferControl that corresponds to the index given.

get() - Method in interface net.dempsy.util.Functional.SupplierThrows

get(Object) - Method in class net.dempsy.util.StupidHashMap

getBuffer() - Method in class net.dempsy.util.io.MessageBufferInput

Returns the underlying byte[]

getBuffer() - Method in class net.dempsy.util.io.MessageBufferOutput

Returns the underlying byte[]

getBufferSize() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

getControlled(int) - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

This will retrieve the corresponding resource that's being controlled by the RingBufferControl selected by that index.

getCurrentControlled() - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

Given that the RingBufferControlMultiplexor.availableTo() or RingBufferControlMultiplexor.tryAvailableTo() has returned a valid sequence, this method will return the current managed resource that corresponds to the RingBufferControl that has consumer data pending on it.

getCurrentIndex() - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

Given that the RingBufferControlMultiplexor.availableTo() or RingBufferControlMultiplexor.tryAvailableTo() has returned a valid sequence, this method will return the current RingBufferControl index that the sequence is for.

getData(String, ClusterInfoWatcher) - Method in interface net.dempsy.cluster.ClusterInfoSession

If data is stored at the node indicated by the path, then the data will be returned.

getData(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

getData(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

getIterators() - Method in class net.dempsy.ringbuffer.RingBufferConsumerIterator

getKryoHolder() - Method in class net.dempsy.serialization.kryo.KryoSerializer

getLimit() - Method in class net.dempsy.util.io.MessageBufferInput

getNumEntries() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

This is an estimate of the number of entries currently in the RingBuffer.

getPosition() - Method in class net.dempsy.util.io.MessageBufferInput

Returns the current position in the buffer where the next byte will be read from.

getPosition() - Method in class net.dempsy.util.io.MessageBufferOutput

Returns the current position in the buffer where the next byte will be written to.

getSubdirs(String, ClusterInfoWatcher) - Method in interface net.dempsy.cluster.ClusterInfoSession

Show all of the subdirectories of the given directory.

getSubdirs(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

getSubdirs(String, ClusterInfoWatcher) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

getTail() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

grow() - Method in class net.dempsy.util.io.MessageBufferOutput

Doubles the internal buffer size while preserving the data

grow(int) - Method in class net.dempsy.util.io.MessageBufferOutput

Doubles the internal buffer size, or sets to the capacity provided if that's higher, while preserving the data

Guard() - Constructor for class net.dempsy.util.SpinLock.Guard

guardedWait() - Method in class net.dempsy.util.SpinLock

H

hashCode() - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession.WatcherProxy

hashCode(String) - Static method in class net.dempsy.util.SafeString

I

id - Variable in class net.dempsy.serialization.kryo.Registration

index(long) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

This method will convert the sequence to an index of a ring buffer.

index(long) - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

This method will convert the sequence to an index of a ring buffer.

index(long) - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

This method will convert the sequence to an index of a ring buffer.

index(long) - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

This method will convert the sequence to an index of a ring buffer.

indexMask - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

INITIAL_CURSOR_VALUE - Static variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Set to -1 as sequence starting point

input - Variable in class net.dempsy.serialization.kryo.KryoSerializer.Holder

isDone() - Method in class net.dempsy.util.executor.AutoDisposeSingleThreadScheduler.Cancelable

Is the Runnable that was submitted to AutoDisposeSingleThreadScheduler.schedule(Runnable, long, TimeUnit) comleted?

isEmpty() - Method in class net.dempsy.util.StupidHashMap

isEphemeral() - Method in enum net.dempsy.cluster.DirMode

isReset() - Static method in class net.dempsy.cluster.local.LocalClusterSessionFactory

isSequential() - Method in enum net.dempsy.cluster.DirMode

isShutdown() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

Once the publisher calls RingBufferControl.publishStop() and the consumer acquires it this method will return true.

isShutdown() - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

Once the publisher calls RingBufferControl.publishStop() and the consumer acquires it this method will return true.

isShutdown() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

Once the publisher calls RingBufferControl.publishStop() and the consumer acquires it this method will return true.

iter - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

J

JavaSerializer - Class in net.dempsy.serialization.java

JavaSerializer() - Constructor for class net.dempsy.serialization.java.JavaSerializer

JsonSerializer - Class in net.dempsy.serialization.jackson

JsonSerializer() - Constructor for class net.dempsy.serialization.jackson.JsonSerializer

K

keySet() - Method in class net.dempsy.util.StupidHashMap

kryo - Variable in class net.dempsy.serialization.kryo.KryoSerializer.Holder

KRYO_REGISTRATION_FILE - Static variable in class net.dempsy.serialization.kryo.KryoSerializer

KryoOptimizer - Interface in net.dempsy.serialization.kryo

If you want to optimize the Kryo performance you can implement this class and give it to the KryoSerializer.

KryoSerializer - Class in net.dempsy.serialization.kryo

This is the implementation of the Kryo based serialization for Dempsy.

KryoSerializer() - Constructor for class net.dempsy.serialization.kryo.KryoSerializer

KryoSerializer(boolean) - Constructor for class net.dempsy.serialization.kryo.KryoSerializer

Create an unconfigured default KryoSerializer with no registered classes.

KryoSerializer(boolean, Registration...) - Constructor for class net.dempsy.serialization.kryo.KryoSerializer

Create an KryoSerializer with the provided registrations.

KryoSerializer(boolean, KryoOptimizer, Registration...) - Constructor for class net.dempsy.serialization.kryo.KryoSerializer

Create an KryoSerializer with the provided registrations and Application specific Optimizer.

KryoSerializer.Holder - Class in net.dempsy.serialization.kryo

L

length - Variable in class net.dempsy.util.io.MessageBufferOutput

This is a cache for the length of the underlying byte[] to avoid constant dereferencing.

load(String) - Method in class net.dempsy.utils.test.SystemPropertyManager

LocalClusterSessionFactory - Class in net.dempsy.cluster.local

This class is for running all cluster management from within the same vm, and for the same vm.

LocalClusterSessionFactory(boolean) - Constructor for class net.dempsy.cluster.local.LocalClusterSessionFactory

LocalClusterSessionFactory() - Constructor for class net.dempsy.cluster.local.LocalClusterSessionFactory

LocalClusterSessionFactory.LocalSession - Class in net.dempsy.cluster.local

LocalSession() - Constructor for class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

M

main(String[]) - Static method in class net.dempsy.distconfig.Config

makeWatcherProxy(ClusterInfoWatcher) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

makeZooKeeperClient(String, int) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

This is defined here to be overridden in a test.

mapChecked(Functional.SupplierThrows<T, Ein>, Function<Ein, Eout>) - Static method in class net.dempsy.util.Functional

This method allows for the automapping mapping of lambda's that throw checked exceptions to other (checked or unchecked) exceptions.

mapChecked(Functional.RunnableThrows<Ein>, Function<Ein, Eout>) - Static method in class net.dempsy.util.Functional

This method allows for the automapping mapping of lambda's that throw checked exceptions to other (checked or unchecked) exceptions.

mark - Variable in class net.dempsy.util.io.MessageBufferInput

The currently marked position in the stream.

mark(int) - Method in class net.dempsy.util.io.MessageBufferInput

Set the current marked position in the stream.

markSupported() - Method in class net.dempsy.util.io.MessageBufferInput

Tests if this InputStream supports mark/reset.

merge(Properties) - Method in class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesStore

merge(Properties) - Method in class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesStore

merge(Properties) - Method in class net.dempsy.distconfig.PropertiesStore

This will merge the new properties with the old properties overwriting where there are clashes.

MessageBufferInput - Class in net.dempsy.util.io

This is literally a copy of the ByteArrayInputStream from the runtime library except it's been modified in the following ways:

MessageBufferInput(byte[]) - Constructor for class net.dempsy.util.io.MessageBufferInput

Creates a MessageBufferInput so that it uses buf as its buffer array.

MessageBufferInput(byte[], int, int) - Constructor for class net.dempsy.util.io.MessageBufferInput

Creates ByteArrayInputStream that uses buf as its buffer array.

MessageBufferOutput - Class in net.dempsy.util.io

This is literally a copy of the ByteArrayOutputStream from the runtime library except it's been modified in the following ways:

MessageBufferOutput() - Constructor for class net.dempsy.util.io.MessageBufferOutput

Creates a new byte array output stream.

MessageBufferOutput(int) - Constructor for class net.dempsy.util.io.MessageBufferOutput

Creates a new byte array output stream, with a buffer capacity of the specified size, in bytes.

mkdir(String, Object, DirMode) - Method in interface net.dempsy.cluster.ClusterInfoSession

This will create a node at the given path.

mkdir(String, Object, DirMode) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

mkdir(String, Object, DirMode) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

N

net.dempsy.cluster - package net.dempsy.cluster

net.dempsy.cluster.local - package net.dempsy.cluster.local

net.dempsy.cluster.zookeeper - package net.dempsy.cluster.zookeeper

net.dempsy.distconfig - package net.dempsy.distconfig

net.dempsy.distconfig.apahcevfs - package net.dempsy.distconfig.apahcevfs

net.dempsy.distconfig.classpath - package net.dempsy.distconfig.classpath

net.dempsy.distconfig.clusterinfo - package net.dempsy.distconfig.clusterinfo

net.dempsy.ringbuffer - package net.dempsy.ringbuffer

net.dempsy.serialization - package net.dempsy.serialization

net.dempsy.serialization.jackson - package net.dempsy.serialization.jackson

net.dempsy.serialization.java - package net.dempsy.serialization.java

net.dempsy.serialization.kryo - package net.dempsy.serialization.kryo

net.dempsy.serialization.util - package net.dempsy.serialization.util

net.dempsy.util - package net.dempsy.util

net.dempsy.util.executor - package net.dempsy.util.executor

net.dempsy.util.io - package net.dempsy.util.io

net.dempsy.utils.test - package net.dempsy.utils.test

newWorker() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

next() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

This is used by the publishing thread to claim the given number of entries in the buffer all of the underlying RingBufferControls.

NoNodeException(String) - Constructor for exception net.dempsy.cluster.ClusterInfoException.NoNodeException

NoNodeException(String, Throwable) - Constructor for exception net.dempsy.cluster.ClusterInfoException.NoNodeException

NoParentException(String) - Constructor for exception net.dempsy.cluster.ClusterInfoException.NoParentException

NoParentException(String, Throwable) - Constructor for exception net.dempsy.cluster.ClusterInfoException.NoParentException

notifyProcessed() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

This method must be called by the consumer once the consumer is finished with the currently published results.

notifyProcessed() - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

This method must be called by the consumer once the consumer is finished with the currently published results.

O

objectDescription(Object) - Static method in class net.dempsy.util.SafeString

output - Variable in class net.dempsy.serialization.kryo.KryoSerializer.Holder

P

p1 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

p2 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

p3 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

p4 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

p5 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

p6 - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Making this public avoids it being optimized away

poll(long, T, ConditionPoll.Condition<T>) - Static method in class net.dempsy.utils.test.ConditionPoll

Poll for a given condition for timeoutMillis milliseconds.

poll(T, ConditionPoll.Condition<T>) - Static method in class net.dempsy.utils.test.ConditionPoll

Poll for a given condition for ConditionPoll.baseTimeoutMillis milliseconds.

poll(ConditionPoll.Condition) - Static method in class net.dempsy.utils.test.ConditionPoll

Poll for a given condition for ConditionPoll.baseTimeoutMillis milliseconds.

pos - Variable in class net.dempsy.util.io.MessageBufferInput

The index of the next character to read from the input stream buffer.

position - Variable in class net.dempsy.util.io.MessageBufferOutput

The number of valid bytes in the buffer.

postRegister(Kryo) - Method in interface net.dempsy.serialization.kryo.KryoOptimizer

The implementor should provide whatever additional class specific optimizations they would like to make.

preemptWorkerAndWait() - Method in class net.dempsy.util.executor.RunningEventSwitch

The main thread uses this method when it needs to preempt the worker and wait for the worker to finish before continuing.

preRegister(Kryo) - Method in interface net.dempsy.serialization.kryo.KryoOptimizer

The implementor should provide whatever class specific optimizations they would like to make.

process() - Method in interface net.dempsy.cluster.ClusterInfoWatcher

process(WatchedEvent) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession.WatcherProxy

process(WatchedEvent) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession.ZkWatcher

propertiesChanged() - Method in interface net.dempsy.distconfig.PropertiesWatcher

PropertiesReader - Interface in net.dempsy.distconfig

Implementations of this interface can be used to retrieve a set of properties while optionally registering for updates when properties change.

PropertiesReader.VersionedProperties - Class in net.dempsy.distconfig

Stored Properties along with the version number.

PropertiesStore - Class in net.dempsy.distconfig

This is a abstraction for storing/sharing distributed properties.

PropertiesStore() - Constructor for class net.dempsy.distconfig.PropertiesStore

PropertiesWatcher - Interface in net.dempsy.distconfig

Callback interface used to register for changes to the current distributed properties.

proxied - Variable in class net.dempsy.serialization.util.ClassTracker

publish(long) - Method in class net.dempsy.ringbuffer.RingBufferControl

Once the publisher has readied the buffer entries that were claimed, this method allows the consumer to be notified that they are ready.

publish(long) - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

Once the publisher has readied the buffer entries that were claimed, this method allows the subscribers to be notified that they are ready.

publish(long) - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

Once the publisher has readied the buffer entries that were claimed, this method allows the subscribers to be notified that they are ready.

publishCursor - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

publishStop() - Method in class net.dempsy.ringbuffer.RingBufferControl

The RingBufferControl can ONLY be stopped from the publish side.

publishStop() - Method in class net.dempsy.ringbuffer.RingBufferControlMulticaster

The RingBufferControl can ONLY be stopped from the publish side.

publishStop() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

The RingBufferControl can ONLY be stopped from the publish side.

push(Properties) - Method in class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesStore

push(Properties) - Method in class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesStore

push(Properties) - Method in class net.dempsy.distconfig.PropertiesStore

This will basically clear the existing properties and replace them with the new set.

put(K, V) - Method in class net.dempsy.util.StupidHashMap

putAll(Map<? extends K, ? extends V>) - Method in class net.dempsy.util.StupidHashMap

putIfAbsent(K, V) - Method in class net.dempsy.util.StupidHashMap

Q

qpoll(T, ConditionPoll.Condition<T>) - Static method in class net.dempsy.utils.test.ConditionPoll

R

read(PropertiesWatcher) - Method in class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesReader

read(PropertiesWatcher) - Method in class net.dempsy.distconfig.classpath.ClasspathPropertiesReader

read(PropertiesWatcher) - Method in class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesReader

read(PropertiesWatcher) - Method in interface net.dempsy.distconfig.PropertiesReader

Retrieves the latest Properties file that's been registered.

read() - Method in class net.dempsy.util.io.MessageBufferInput

Reads the next byte of data from this input stream.

read(byte[], int, int) - Method in class net.dempsy.util.io.MessageBufferInput

Reads up to len bytes of data into an array of bytes from this input stream.

readByteArray() - Method in class net.dempsy.util.io.MessageBufferInput

readShort() - Method in class net.dempsy.util.io.MessageBufferInput

recheck(Supplier<T>) - Static method in class net.dempsy.util.Functional

This assumes there's a Functional.uncheck(SupplierThrows) call nested within the provided supplier.

recheck(Runnable) - Static method in class net.dempsy.util.Functional

This assumes there's a Functional.uncheck(SupplierThrows) call nested within the provided supplier.

recheck(Supplier<T>, Class<E>) - Static method in class net.dempsy.util.Functional

Alternate form of Functional.recheck(Supplier) that doesn't require the explicit generic and allows for the use of a static import.

recheck(Runnable, Class<E>) - Static method in class net.dempsy.util.Functional

Alternate form of Functional.recheck(Runnable) that doesn't require the explicit generic and allows for the use of a static import.

recursiveMkdir(String, Object, DirMode, DirMode) - Method in interface net.dempsy.cluster.ClusterInfoSession

Registration - Class in net.dempsy.serialization.kryo

This class holds Kryo class registration information.

Registration(String, int) - Constructor for class net.dempsy.serialization.kryo.Registration

Use this constructor to assign a class an id in a Kryo registration.

Registration(String) - Constructor for class net.dempsy.serialization.kryo.Registration

Use this constructor to register a class but let Kryo assign the id.

release() - Method in class net.dempsy.util.SpinLock

remove(Object) - Method in class net.dempsy.util.StupidHashMap

removeWorker(RingBufferConsumerControl) - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

replace(byte[]) - Method in class net.dempsy.util.io.MessageBufferOutput

Completely replace the underlying buffer.

reset() - Static method in class net.dempsy.cluster.local.LocalClusterSessionFactory

reset() - Method in class net.dempsy.util.io.MessageBufferInput

Resets the buffer to the marked position.

reset() - Method in class net.dempsy.util.io.MessageBufferOutput

Resets the count field of this byte array output stream to zero, so that all currently accumulated output in the output stream is discarded.

resetDelay - Variable in class net.dempsy.cluster.zookeeper.ZookeeperSession

reverseRange(int, int) - Static method in class net.dempsy.util.Functional

Create's an IntStream that runs in reverse.

RingBufferConsumerControl - Class in net.dempsy.ringbuffer

This code is substantially based on the ingenious work done by Martin Thompson on what he calls "Mechanical Sympathy." It leans heavily on the source code from version 3.0.0.beta2 of the LMAX-exchange Disruptor but has been completely refactored in order to invert separate the control mechanism from what is being controlled and to simplify the API.

RingBufferConsumerControl(int, RingBufferConsumerControl.ConsumerWaitStrategy, Sequence) - Constructor for class net.dempsy.ringbuffer.RingBufferConsumerControl

RingBufferConsumerControl(int, RingBufferConsumerControl.ConsumerWaitStrategy, Sequence, PaddedLong) - Constructor for class net.dempsy.ringbuffer.RingBufferConsumerControl

RingBufferConsumerControl.ConsumerWaitStrategy - Interface in net.dempsy.ringbuffer

This interface can be implemented to provide various custom wait strategies for the consumer side of the control.

RingBufferConsumerIterator<T> - Class in net.dempsy.ringbuffer

RingBufferConsumerIterator(Iterator<T>, int, int) - Constructor for class net.dempsy.ringbuffer.RingBufferConsumerIterator

RingBufferConsumerIterator(Iterator<T>, RingBufferConsumerIterator.Consumer<T>[], int, boolean) - Constructor for class net.dempsy.ringbuffer.RingBufferConsumerIterator

RingBufferConsumerIterator.Consumer<R> - Interface in net.dempsy.ringbuffer

RingBufferControl - Class in net.dempsy.ringbuffer

This code is substantially based on the ingenious work done by Martin Thompson on what he calls "Mechanical Sympathy." It leans heavily on the source code from version 3.0.0.beta2 of the LMAX-exchange Disruptor but has been completely refactored in order to invert separate the control mechanism from what is being controlled and to simplify the API.

RingBufferControl(int) - Constructor for class net.dempsy.ringbuffer.RingBufferControl

Creates a RingBufferControl with a RingBufferConsumerControl.yield consumer wait strategy.

RingBufferControl(int, RingBufferConsumerControl.ConsumerWaitStrategy) - Constructor for class net.dempsy.ringbuffer.RingBufferControl

Creates a RingBufferControl with the given wait strategy.

RingBufferControlMulticaster - Class in net.dempsy.ringbuffer

This is a helper class for managing a set of RingBufferControls for use in a "single-publisher to multi-consumer" thread configuration where everything published is "multicast" to all consumers.

RingBufferControlMulticaster(int, int) - Constructor for class net.dempsy.ringbuffer.RingBufferControlMulticaster

RingBufferControlMultiplexor - Class in net.dempsy.ringbuffer

This is a helper class for managing a set of RingBufferControls for use in a "multiple-publisher to single-consumer" thread configuration.

RingBufferControlMultiplexor(int, int) - Constructor for class net.dempsy.ringbuffer.RingBufferControlMultiplexor

Instantiate a RingBufferControlMultiplexor with a given number of publishers and a given buffer size for each RingBufferControl.

RingBufferControlMultiplexor(int, Object...) - Constructor for class net.dempsy.ringbuffer.RingBufferControlMultiplexor

Instantiate a RingBufferControlMultiplexor with a given set of actual buffers being controlled and a given buffer size for each RingBufferControl.

RingBufferControlWorkerPool - Class in net.dempsy.ringbuffer

This is a helper class for managing a set of RingBufferControls for use in a "single-publisher to multi-consumer" thread configuration where the consumers are workers reading from the queued data.

RingBufferControlWorkerPool(int) - Constructor for class net.dempsy.ringbuffer.RingBufferControlWorkerPool

RingBufferControlWorkerPool(int, RingBufferConsumerControl.ConsumerWaitStrategy) - Constructor for class net.dempsy.ringbuffer.RingBufferControlWorkerPool

rmdir(String) - Method in interface net.dempsy.cluster.ClusterInfoSession

This will remove the directory stored at the path.

rmdir(String) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

rmdir(String) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

run(Iterator<R>) - Method in interface net.dempsy.ringbuffer.RingBufferConsumerIterator.Consumer

run() - Method in class net.dempsy.util.executor.AutoDisposeSingleThreadScheduler.Cancelable

run() - Method in interface net.dempsy.util.Functional.RunnableThrows

run() - Method in class net.dempsy.utils.test.SocketTimeout

RunningEventSwitch - Class in net.dempsy.util.executor

This is a helper class for coordinating a "restartable" job.

RunningEventSwitch(AtomicBoolean) - Constructor for class net.dempsy.util.executor.RunningEventSwitch

RunningEventSwitch() - Constructor for class net.dempsy.util.executor.RunningEventSwitch

S

SafeString - Class in net.dempsy.util

SafeString() - Constructor for class net.dempsy.util.SafeString

schedule(Runnable, long, TimeUnit) - Method in class net.dempsy.util.executor.AutoDisposeSingleThreadScheduler

Schedule the given Runnable to run at the given time period from now.

serialize(T, MessageBufferOutput) - Method in class net.dempsy.serialization.jackson.JsonSerializer

serialize(T, MessageBufferOutput) - Method in class net.dempsy.serialization.java.JavaSerializer

serialize(T, MessageBufferOutput) - Method in class net.dempsy.serialization.kryo.KryoSerializer

serialize(T, MessageBufferOutput) - Method in class net.dempsy.serialization.Serializer

serialize(T) - Method in class net.dempsy.serialization.Serializer

serialize(T, MessageBufferOutput) - Method in class net.dempsy.serialization.util.ClassTracker

Serializer - Class in net.dempsy.serialization

In order to support pluggable serialization, Dempsy (the container and the distributor) can be configured with a serialization scheme.

Serializer() - Constructor for class net.dempsy.serialization.Serializer

sessionTimeout - Variable in class net.dempsy.cluster.zookeeper.ZookeeperSession

set(String, String) - Method in class net.dempsy.utils.test.SystemPropertyManager

setData(String, Object) - Method in interface net.dempsy.cluster.ClusterInfoSession

Set the data associated with the tree node identified by the path.

setData(String, Object) - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

setData(String, Object) - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

setIfAbsent(String, String) - Method in class net.dempsy.utils.test.SystemPropertyManager

setKryoOptimizer(KryoOptimizer) - Method in class net.dempsy.serialization.kryo.KryoSerializer

Set the optimizer.

setKryoRegistrationRequired(boolean) - Method in class net.dempsy.serialization.kryo.KryoSerializer

You can require Kryo to serialize only registered classes by passing 'true' to setKryoRegistrationRequired.

setPosition(int) - Method in class net.dempsy.util.io.MessageBufferInput

Explicitly set the current position in the buffer.

setPosition(int) - Method in class net.dempsy.util.io.MessageBufferOutput

Explicitly set the current position in the buffer.

size() - Method in class net.dempsy.util.StupidHashMap

skip(long) - Method in class net.dempsy.util.io.MessageBufferInput

Skips n bytes of input from this input stream.

SocketTimeout - Class in net.dempsy.utils.test

Use this class with blocking IO in order to force writes or reads to throw an interrupted or socket exception once a certain amount of time has passed.

SocketTimeout(Socket, long) - Constructor for class net.dempsy.utils.test.SocketTimeout

spin - Static variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Using this strategy provides 'spin' approach to waiting for data to be available for the consumer.

SPIN_TRIES - Static variable in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

The number of spin tried before the RingBufferControlMultiplexor.availableTo() backs down to using Thread.yield().

SPIN_TRIES - Static variable in class net.dempsy.util.SpinLock

SpinLock - Class in net.dempsy.util

SpinLock() - Constructor for class net.dempsy.util.SpinLock

SpinLock.Guard - Class in net.dempsy.util

stop() - Method in interface net.dempsy.cluster.ClusterInfoSession

Stop the session.

stop() - Method in class net.dempsy.cluster.local.LocalClusterSessionFactory.LocalSession

stop() - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession

stop - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

stop() - Method in class net.dempsy.utils.test.SocketTimeout

stopIsCommon - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

StupidHashMap<K,V> - Class in net.dempsy.util

StupidHashMap(int) - Constructor for class net.dempsy.util.StupidHashMap

StupidHashMap() - Constructor for class net.dempsy.util.StupidHashMap

sumPaddingToPreventOptimisation() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

supportsNotification() - Method in class net.dempsy.distconfig.apahcevfs.ApacheVfsPropertiesReader

supportsNotification() - Method in class net.dempsy.distconfig.classpath.ClasspathPropertiesReader

supportsNotification() - Method in class net.dempsy.distconfig.clusterinfo.ClusterInfoPropertiesReader

supportsNotification() - Method in interface net.dempsy.distconfig.PropertiesReader

SYS_PROP_REGISTRAION_RESOURCE - Static variable in class net.dempsy.serialization.kryo.KryoSerializer

SystemPropertyManager - Class in net.dempsy.utils.test

This class allows the setting and then unsetting of System properties within the scope of a test.

SystemPropertyManager() - Constructor for class net.dempsy.utils.test.SystemPropertyManager

T

tail - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

toByteArray() - Method in class net.dempsy.util.io.MessageBufferOutput

Creates a newly allocated byte array.

toString() - Method in class net.dempsy.cluster.zookeeper.ZookeeperSession.WatcherProxy

toString() - Method in class net.dempsy.util.io.MessageBufferOutput

Converts the buffer's contents into a string decoding bytes using the platform's default character set.

toString(String) - Method in class net.dempsy.util.io.MessageBufferOutput

Converts the buffer's contents into a string by decoding the bytes using the specified Charset name.

tryAvailableTo() - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

This method allows the consumer side to poll for publishing events.

tryAvailableTo(long) - Method in class net.dempsy.ringbuffer.RingBufferConsumerControl

tryAvailableTo() - Method in class net.dempsy.ringbuffer.RingBufferControlMultiplexor

This method allows the consumer side to poll for publishing events on ANY of the managed RingBufferControl.

tryNext() - Method in class net.dempsy.ringbuffer.RingBufferControlWorkerPool

This is used by the publishing thread to claim the next entry in the buffer all of the underlying RingBufferControls.

U

UNAVAILABLE - Static variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

This value can be returned from RingBufferConsumerControl.tryAvailableTo() to indicate that there are no pending published values available.

uncheck(Functional.SupplierThrows<T, E>) - Static method in class net.dempsy.util.Functional

This method allows the use of lambda's that throw exceptions in standard java 8 Stream operations by converting those exceptions to an unchecked exception.

uncheck(Functional.RunnableThrows<E>) - Static method in class net.dempsy.util.Functional

This method allows the use of lambda's that throw exceptions in standard java 8 Stream operations by converting those exceptions to an unchecked exception.

V

valueOf(String) - Static method in enum net.dempsy.cluster.DirMode

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

valueOf(Object) - Static method in class net.dempsy.util.SafeString

valueOfClass(Object) - Static method in class net.dempsy.util.SafeString

values() - Static method in enum net.dempsy.cluster.DirMode

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

values() - Method in class net.dempsy.util.StupidHashMap

version - Variable in class net.dempsy.distconfig.PropertiesReader.VersionedProperties

Version of the corresponding properties.

VersionedProperties(int, Properties) - Constructor for class net.dempsy.distconfig.PropertiesReader.VersionedProperties

W

waitFor(long, Sequence) - Method in interface net.dempsy.ringbuffer.RingBufferConsumerControl.ConsumerWaitStrategy

waitForCompletion() - Method in class net.dempsy.ringbuffer.RingBufferConsumerIterator

waitForLock() - Method in class net.dempsy.util.SpinLock

waitForPublishToComplete() - Method in class net.dempsy.ringbuffer.RingBufferConsumerIterator

waitForWorkerToStart() - Method in class net.dempsy.util.executor.RunningEventSwitch

This allows the main thread to wait until the worker is started in order to continue.

waitStrategy - Variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

wasPreempted() - Method in class net.dempsy.util.executor.RunningEventSwitch

The worker thread can use this method to check if it's been explicitly preempted.

WatcherProxy(ClusterInfoWatcher) - Constructor for class net.dempsy.cluster.zookeeper.ZookeeperSession.WatcherProxy

workerFinished() - Method in class net.dempsy.util.executor.RunningEventSwitch

The worker thread should indicate that it's done in a finally clause on it's way out.

workerRunning() - Method in class net.dempsy.util.executor.RunningEventSwitch

This is called from the worker thread to notify the fact that it's been started.

write(int) - Method in class net.dempsy.util.io.MessageBufferOutput

Writes the specified byte to this byte array output stream.

write(byte[], int, int) - Method in class net.dempsy.util.io.MessageBufferOutput

Writes len bytes from the specified byte array starting at offset off to this byte array output stream.

writeInt(int) - Method in class net.dempsy.util.io.MessageBufferOutput

Writes an int to the underlying buffer as four bytes, high byte first.

writeShort(short) - Method in class net.dempsy.util.io.MessageBufferOutput

writeTo(OutputStream) - Method in class net.dempsy.util.io.MessageBufferOutput

Writes the complete contents of this byte array output stream to the specified output stream argument, as if by calling the output stream's write method using out.write(buf, 0, count).

Y

yield - Static variable in class net.dempsy.ringbuffer.RingBufferConsumerControl

Using this strategy provides 'yield' approach to waiting for data to be available for the consumer.

Z

ZkWatcher() - Constructor for class net.dempsy.cluster.zookeeper.ZookeeperSession.ZkWatcher

ZookeeperSession - Class in net.dempsy.cluster.zookeeper

ZookeeperSession(Serializer, String, int) - Constructor for class net.dempsy.cluster.zookeeper.ZookeeperSession

ZookeeperSession.WatcherProxy - Class in net.dempsy.cluster.zookeeper

ZookeeperSession.ZkWatcher - Class in net.dempsy.cluster.zookeeper

ZookeeperSessionFactory - Class in net.dempsy.cluster.zookeeper

ZookeeperSessionFactory(String, int, Serializer) - Constructor for class net.dempsy.cluster.zookeeper.ZookeeperSessionFactory

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