All Classes Interface Summary Class Summary Enum Summary Exception Summary
| Class |
Description |
| AbstractKahaDBMetaData<T> |
|
| AbstractKahaDBStore |
|
| BTreeIndex<Key,Value> |
BTreeIndex represents a Variable Magnitude B+Tree in a Page File.
|
| BTreeIndex.Prefixer<Key> |
Interface used to determine the simple prefix of two keys.
|
| BTreeIndex.StringPrefixer |
StringPrefixer is a Prefixer implementation that works on strings.
|
| BTreeNode<Key,Value> |
The BTreeNode class represents a node in the BTree object graph.
|
| BTreeNode.Marshaller<Key,Value> |
The Marshaller is used to store and load the data in the BTreeNode into a Page.
|
| BTreeVisitor<Key,Value> |
Interface used to selectively visit the entries in a BTree.
|
| BTreeVisitor.AndVisitor<Key,Value> |
|
| BTreeVisitor.BetweenVisitor<Key extends Comparable<Key>,Value> |
|
| BTreeVisitor.GTEVisitor<Key extends Comparable<Key>,Value> |
|
| BTreeVisitor.GTVisitor<Key extends Comparable<Key>,Value> |
|
| BTreeVisitor.LTEVisitor<Key extends Comparable<Key>,Value> |
|
| BTreeVisitor.LTVisitor<Key extends Comparable<Key>,Value> |
|
| BTreeVisitor.OrVisitor<Key,Value> |
|
| BTreeVisitor.Predicate<Key> |
|
| BTreeVisitor.PredicateVisitor<Key,Value> |
|
| BytesMarshaller |
Implementation of a Marshaller for byte arrays
|
| CommandLineSupport |
Support utility that can be used to set the properties on any object
using command line arguments.
|
| DataByteArrayInputStream |
Optimized ByteArrayInputStream that can be used more than once
|
| DataByteArrayOutputStream |
Optimized ByteArrayOutputStream
|
| DataFile |
DataFile
|
| DataFileAccessorPool |
Used to pool DataFileAccessors.
|
| DiskBenchmark |
This class is used to get a benchmark the raw disk performance.
|
| DiskBenchmark.Report |
|
| FileAppender |
|
| FilteredKahaDBPersistenceAdapter |
|
| HashIndex<Key,Value> |
BTree implementation
|
| Index<Key,Value> |
Simpler than a Map
|
| IntegerMarshaller |
Implementation of a Marshaller for a Integer
|
| JobImpl |
|
| JobSchedulerImpl |
|
| JobSchedulerKahaDBMetaData |
The KahaDB MetaData used to house the Index data for the KahaDB implementation
of a JobSchedulerStore.
|
| JobSchedulerStoreImpl |
|
| Journal |
Manages DataFiles
|
| Journal.DataFileRemovedListener |
|
| Journal.JournalDiskSyncStrategy |
|
| Journal.PreallocationScope |
|
| Journal.PreallocationStrategy |
|
| Journal.WriteCommand |
|
| Journal.WriteKey |
|
| JournalCommand<T> |
|
| KahaAckMessageFileMapCommand |
|
| KahaAddMessageCommand |
|
| KahaAddScheduledJobCommand |
|
| KahaCommitCommand |
|
| KahaDBMetaData<T> |
Interface for the store meta data used to hold the index value and other needed
information to manage a KahaDB store instance.
|
| KahaDBPersistenceAdapter |
An implementation of PersistenceAdapter designed for use with
KahaDB - Embedded Lightweight Non-Relational Database |
| KahaDBStore |
|
| KahaDBStore.StoreTask |
|
| KahaDBTransactionStore |
Provides a TransactionStore implementation that can create transaction aware
MessageStore objects from non transaction aware MessageStore objects.
|
| KahaDestination |
|
| KahaDestination.DestinationType |
|
| KahaDestroySchedulerCommand |
|
| KahaEntryType |
|
| KahaLocalTransactionId |
|
| KahaLocation |
|
| KahaPrepareCommand |
|
| KahaProducerAuditCommand |
|
| KahaRemoveDestinationCommand |
|
| KahaRemoveMessageCommand |
|
| KahaRemoveScheduledJobCommand |
|
| KahaRemoveScheduledJobsCommand |
|
| KahaRescheduleJobCommand |
|
| KahaRewrittenDataFileCommand |
|
| KahaRollbackCommand |
|
| KahaSubscriptionCommand |
|
| KahaTraceCommand |
|
| KahaTransactionInfo |
|
| KahaUpdateMessageCommand |
|
| KahaXATransactionId |
|
| LegacyStoreReplayer |
Used to upgrade a Legacy Job Scheduler store to the latest version this class
loads a found legacy scheduler store and generates new add commands for all
jobs currently in the store.
|
| LFUCache<Key,Value> |
LFU cache implementation based on http://dhruvbird.com/lfu.pdf, with some notable differences:
Frequency list is stored as an array with no next/prev pointers between nodes: looping over the array should be faster and more CPU-cache friendly than
using an ad-hoc linked-pointers structure.
|
| LinkedNode<T extends LinkedNode<T>> |
Provides a base class for you to extend when you want object to maintain a
doubly linked list to other objects without using a collection class.
|
| LinkedNodeList<T extends LinkedNode<T>> |
Provides a list of LinkedNode objects.
|
| ListIndex<Key,Value> |
|
| ListNode<Key,Value> |
The ListNode class represents a node in the List object graph.
|
| ListNode.NodeMarshaller<Key,Value> |
The Marshaller is used to store and load the data in the ListNode into a Page.
|
| Location |
Used as a location in the data store.
|
| LocationMarshaller |
|
| LongMarshaller |
Implementation of a Marshaller for a Long
|
| Marshaller<T> |
|
| MessageDatabase |
|
| MessageDatabase.PurgeRecoveredXATransactionStrategy |
|
| MultiKahaDBPersistenceAdapter |
An implementation of PersistenceAdapter that supports
distribution of destinations across multiple kahaDB persistence adapters |
| MultiKahaDBTransactionStore |
|
| Page<T> |
A Page within a file.
|
| PageFile |
A PageFile provides you random access to fixed sized disk pages.
|
| PageFile.MetaData |
The MetaData object hold the persistent data associated with a PageFile object.
|
| PListImpl |
|
| PListStoreImpl |
|
| ReadOnlyDataFile |
Allows you to open a data file in read only mode.
|
| ReadOnlyJournal |
An AsyncDataManager that works in read only mode against multiple data directories.
|
| RecoverableRandomAccessFile |
|
| ReplicationTarget |
|
| Scheduler |
|
| SchedulerTimerTask |
A TimeTask for a Runnable object
|
| Sequence |
Represents a range of numbers.
|
| Sequence.Closure<T extends Throwable> |
|
| SequenceSet |
Keeps track of a added long values.
|
| SequenceSet.Marshaller |
|
| StringMarshaller |
Implementation of a Marshaller for Strings
|
| TargetedDataFileAppender |
File Appender instance that performs batched writes in the thread where the write is
queued.
|
| TempKahaDBStore |
|
| TempMessageDatabase |
|
| TempMessageDatabase.MessageKeysMarshaller |
|
| Transaction |
The class used to read/update a PageFile object.
|
| Transaction.CallableClosure<R,T extends Throwable> |
This closure interface is intended for the end user implement callbacks for the Transaction.exectue() method.
|
| Transaction.Closure<T extends Throwable> |
This closure interface is intended for the end user implement callbacks for the Transaction.exectue() method.
|
| TransactionIdConversion |
|
| UnknownStoreVersionException |
|
| VariableMarshaller<T> |
Convenience base class for Marshaller implementations which do not deepCopy and
which use variable size encodings.
|
| Visitor |
|