All Classes and Interfaces
Class
Description
Exception thrown when an attempt is made to create a new tree node as a child with a name that already exists.
Simple class to automatically download remote objects in the background.
Pre-commit hook to automatically download remote objects, if the option to download all objects is enabled.
CachingObjectPersistentStore is a caching layer for the SerializingObjectPersistentStore
It stores the already deserialized objects in memory.
Protobuf type
dhfs.sync.CanDeleteReplyProtobuf type
dhfs.sync.CanDeleteReplyProtobuf type
dhfs.sync.CanDeleteRequestProtobuf type
dhfs.sync.CanDeleteRequestHelper class for generating and manipulating X.509 certificates.
ChunkData is a data structure that represents an immutable binary blob
Clock interface
An iterator over key-value pairs that can be closed and supports peek and skip operations, in both directions.
CombinedTimestamp is a record that represents a timestamp and a node ID, ordered first by timestamp and then by node ID.
Interface indicating that data is present.
Allows to lock arbitrary keys.
Simple implementation of the Data interface.
Periodically check for deadlocks in the JVM and log them if found.
Fallback handler for remote object updates, no conflict resolution.
Stores data about deferred invalidations.
Service to handle deferred invalidations.
Automatically deletes objects that are not referenced by anything else.
Actual filesystem implementation.
FUSE file system implementation.
A stub to allow clients to do synchronous rpc calls to service DhfsObjectSyncGrpc.
A stub to allow clients to do ListenableFuture-style rpc calls to service DhfsObjectSyncGrpc.
Base class for the server implementation of the service DhfsObjectSyncGrpc.
A stub to allow clients to do asynchronous rpc calls to service DhfsObjectSyncGrpc.
DirectoryNotEmptyException is thrown when a directory is not empty.
Interface for mapping between a remote object and its DTO representation.
Service for mapping between remote objects and their DTO representations.
File is a data structure that represents a file in the file system
FileDto is a data transfer object that contains a file and its chunks.
Helper class for working with files.
Handles synchronization of file objects.
GetattrRes is a record that represents the result of a getattr operation.
Protobuf type
dhfs.sync.GetObjectReplyProtobuf type
dhfs.sync.GetObjectReplyProtobuf type
dhfs.sync.GetObjectRequestProtobuf type
dhfs.sync.GetObjectRequestBlocking queue that delays the objects for a given time, and deduplicates them.
Information about a new version of a remote object, possibly with its data.
Allows to specify custom processing of initial synchronization/crash recovery for a specific object type.
Service to handle sending operations to remote peers.
Represents a peer address with an IP address and port.
Allows to specify initial positioning of the iterator relative to the requested key.
Simple Java object serializer.
JData is a marker interface for all objects that can be stored in the object store.
Good old boring object reference.
Protobuf type
dhfs.persistence.JDataPProtobuf type
dhfs.persistence.JDataPJDataRefs are used to store additional metadata about incoming references to objects for reference counting.
Interface for a reference counted object
Interface for a remote object.
Marker interface for a DTO class to be used when synchronizing some remote object.
Protobuf type
dhfs.persistence.JDataRemoteDtoPProtobuf type
dhfs.persistence.JDataRemoteDtoPAnnotation for eagerly pushed remote objects.
JDataVersionedWrapper is a wrapper for JData that contains its version number
(the id of the transaction that had changed it last)
Simple wrapper for an already-existing JData object with a version.
Lazy JDataVersionedWrapper implementation.
Serializer for JDataVersionedWrapper objects.
Automatically synchronized and persistent Kleppmann tree service.
KleppmannTree node implementation for JKleppmannTree
Separate reference counting from JKleppmannTreeNode
JKleppmannTreeNodeMetaDirectory is a record that represents a directory in the JKleppmann tree.
JKleppmannTreeNodeMetaFile is a record that represents a file in the JKleppmann tree.
Various persistent data for JKleppmannTree
Persistent-storage backed ordered map service.
Marker interface that allows an object to hold an ordered key-value map of object references.
This hook is used to delete all the entries of a map in a map holder when the holder is deleted.
Iterates over JMap entries of a given holder.
Marker interface for JMap keys.
A reference from a JMap object to some object.
JnrPtrByteOutput is a ByteOutput implementation that writes to a `jnr.ffi.Pointer`.
JObjectKey is an interface for object keys to be used in the object store.
A "real" implementation of JObjectKey, containing an underlying string, and a cached lazily created byte buffer.
JObjectKey implementation that compares greater than all other keys.
JObjectKey implementation that compares less than all other keys.
Protobuf type
dhfs.persistence.JObjectKeyPProtobuf type
dhfs.persistence.JObjectKeyPA key-value iterator that filters keys based on a predicate.
An implementation of a tree as described in A highly-available move operation for replicated trees
Utility class for list operations.
Persistent object storage using LMDB
Broadcasts information about this peer to the local network.
Listens for peer discovery packets from other peers on the local network.
LogEffect is a record that represents the effect of a log entry on a tree node.
Represents the old information about a node before it was moved.
LogInterface is an interface that allows accessing the log of operations
Represents a log record in the Kleppmann tree.
A mapping key-value iterator that transforms the values of a backing iterator using a specified function.
In-memory implementation of the ObjectPersistentStore interface.
A merging key-value iterator that combines multiple iterators into a single iterator.
A key-value iterator for a
NavigableMap.Represents metadata associated with a node in the Kleppmann tree.
Protobuf type
dhfs.persistence.ObjectChangelogProtobuf type
dhfs.persistence.ObjectChangelogProtobuf type
dhfs.persistence.ObjectChangelog.entries_EntryProtobuf type
dhfs.persistence.ObjectChangelog.entries_EntryInterface for a persistent store of objects.
Interface for serializing and deserializing objects.
Interface for handling remote updates of objects.
Represents a unit of information to be sent to another peer.
Interface for extracting operations from data objects.
Service for extracting operations from JData objects.
Interface for handling operations.
Service for handling operations.
Operation that moves a child node to a new parent node.
Protobuf type
dhfs.sync.OpPProtobuf type
dhfs.sync.OpPProtobuf type
dhfs.sync.OpPushReplyProtobuf type
dhfs.sync.OpPushReplyProtobuf type
dhfs.sync.OpPushRequestProtobuf type
dhfs.sync.OpPushRequestInterface to provide recording operations to be sent to peers asynchronously.
Peer address interface, can be used to represent different types of peer addresses, not only IP.
Helper class for parsing peer addresses from strings.
Listener for peer connected events.
Listener for peer disconnected events.
Peer discovery directory collects known peer addresses, and automatically cleans up old entries.
Protobuf type
dhfs.peerdiscovery.PeerDiscoveryInfoProtobuf type
dhfs.peerdiscovery.PeerDiscoveryInfoRepresents a peer ID
Type-safe wrapper for JObjectKey
Protobuf type
dhfs.persistence.PeerIdPProtobuf type
dhfs.persistence.PeerIdPRepresents information about a peer in the cluster
JDataRemotePush annotation is used, as invalidating a peer information by the peer itself might make it unreachable,
as it will not be possible to download it from the invalidated peer, so the peer information should be send with the notificationAutomatically refreshes certificates in the trust manager for peers when their info is updated.
Service for managing information about peers connected to the cluster.
Interface providing access to a list of known peers.
Periodically updates the last seen timestamp of reachable peers and increments the kick counter for unreachable peers.
Augments the security identity of peers that are members of the cluster.
Provides information about the peer publicly, without any authentication.
Allows to query peers about their information, even if peer isn't part of the cluster.
Interface providing a map of newest received timestamps for each peer.
Custom trust manager that trusts the certificates of peers in the cluster.
Customizes the HTTP server options to use the peer trust manager and the self-signed certificate.
Simple API for managing connected peers and manually specifying their addresses.
Handles various locally relevant persistent data related to peers,
such as local peer's UUID, certificate, and persistent peer addresses.
Notified PeerDiscoveryDirectory about manually added peer addresses.
Protobuf type
dhfs.sync.PingReplyProtobuf type
dhfs.sync.PingReplyProtobuf type
dhfs.sync.PingRequestProtobuf type
dhfs.sync.PingRequestHandles connections to known peers in the cluster.
Wrapper for remote object data.
Handles deletion of remote objects, asynchronously.
Metadata for remote objects.
Helper class for calling remote peers RPCs.
Transaction hook to automatically notify
InvalidationQueueService about changed objects.Helper class for working with remote objects.
A wrapper for a key-value iterator that iterates in reverse order.
Base class for a reversible key-value iterator.
Factory for creating gRPC channels
Factory for creating gRPC clients for object synchronization and other RPC calls.
Utility class for serialization and deserialization of objects.
Serializing wrapper for the ObjectPersistentStore.
This class checks if the application was shut down cleanly.
Interface for a snapshot of a database.
Notifies PeerDiscoveryDirectory about statically configured peer addresses.
A
StatusRuntimeException that does not fill in the stack trace.Storage interface for the Kleppmann tree.
Handles synchronization of remote objects.
Helper class for synchronizing objects.
Indicates that the value is a tombstone.
Simple implementation of the Tombstone interface.
A key-value iterator that skips tombstones.
Represents a node in the Kleppmann tree.
Utility class for creating uninitialized ByteBuffers, to avoid zeroing memory unnecessarily.
Provides access to the
Unsafe class and JavaNioAccess class.Web UI router for serving static files.
Asynchronous write cache of objects.