Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- acceptExternalOp(PeerId, Op) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Accept an external operation from the given peer.
- add(JObjectKey) - Method in class com.usatiuk.dhfs.autosync.AutosyncProcessor
-
Adds an object to the queue to be downloaded.
- add(T) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Adds the object to the queue if it doesn't exist.
- addAllEntries(Iterable<? extends ObjectChangelog.entries_Entry>) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addAllMsg(Iterable<? extends OpP>) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addAllReferrers(Iterable<? extends JObjectKeyP>) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addEntries(int, ObjectChangelog.entries_Entry) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addEntries(int, ObjectChangelog.entries_Entry.Builder) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addEntries(ObjectChangelog.entries_Entry) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addEntries(ObjectChangelog.entries_Entry.Builder) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addEntriesBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addEntriesBuilder(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- addMsg(int, OpP) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addMsg(int, OpP.Builder) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addMsg(OpP) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addMsg(OpP.Builder) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addMsgBuilder() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addMsgBuilder(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- addNoDelay(T) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Adds the object to the queue with no delay.
- addPeer(String, KnownPeerPut) - Method in class com.usatiuk.dhfs.webapi.PeerManagementApi
- addPeerAddress(String, String) - Method in class com.usatiuk.dhfs.webapi.PersistentPeerAddressApi
- addPersistentPeerAddress(PeerId, IpPeerAddress) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- addReferrers(int, JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addReferrers(int, JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addReferrers(JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addReferrers(JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addReferrersBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addReferrersBuilder(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- addRemoteHost(PeerId, String) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Adds the given peer to the cluster.
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- address() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns the value of the
address
record component. - address() - Method in record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Returns the value of the
address
record component. - allocate(int) - Static method in class com.usatiuk.utils.UninitializedByteBuffer
-
Allocates a new uninitialized ByteBuffer of the specified capacity.
- AlreadyExistsException - Exception Class in com.usatiuk.kleppmanntree
-
Exception thrown when an attempt is made to create a new tree node as a child with a name that already exists.
- AlreadyExistsException(String) - Constructor for exception class com.usatiuk.kleppmanntree.AlreadyExistsException
- ApiPeerInfo - Record Class in com.usatiuk.dhfs.peersync.api
- ApiPeerInfo(String, String) - Constructor for record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Creates an instance of a
ApiPeerInfo
record class. - apply(PeerId, DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub) - Method in interface com.usatiuk.dhfs.rpc.RpcClientFactory.ObjectSyncClientFunction
- applyExternalOp(PeerIdT, OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Apply an external operation from a remote peer
- asyncFence(long, Runnable) - Method in class com.usatiuk.objects.stores.WritebackObjectPersistentStore
-
Run a given callback after the transaction with id txId is committed.
- augment(SecurityIdentity, AuthenticationRequestContext) - Method in class com.usatiuk.dhfs.peertrust.PeerRolesAugmentor
- AutoCloseableNoThrow - Interface in com.usatiuk.utils
- AutosyncProcessor - Class in com.usatiuk.dhfs.autosync
-
Simple class to automatically download remote objects in the background.
- AutosyncProcessor() - Constructor for class com.usatiuk.dhfs.autosync.AutosyncProcessor
- AutosyncTxHook - Class in com.usatiuk.dhfs.autosync
-
Pre-commit hook to automatically download remote objects, if the option to download all objects is enabled.
- AutosyncTxHook() - Constructor for class com.usatiuk.dhfs.autosync.AutosyncTxHook
- available() - Method in record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Returns the value of the
available
record component. - availablePeers() - Method in class com.usatiuk.dhfs.webapi.PeerManagementApi
B
- begin() - Method in interface com.usatiuk.objects.transaction.TransactionManager
- begin() - Method in class com.usatiuk.objects.transaction.TransactionManagerImpl
- bindService() - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- bindService() - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- bindService(DhfsObjectSyncGrpcGrpc.AsyncService) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- broadcast() - Method in class com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryBroadcaster
- broadcast() - Method in interface com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryConfig
- build() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- build() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- build() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- build() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- build() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- build() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- build() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- build() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- build() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- build() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- build() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- build(Channel, CallOptions) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub
- build(Channel, CallOptions) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub
- build(Channel, CallOptions) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub
- build(Channel, CallOptions) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub
- buildPartial() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- buildPartial() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- bundleId() - Method in record class com.usatiuk.objects.stores.PendingDelete
-
Returns the value of the
bundleId
record component. - bundleId() - Method in record class com.usatiuk.objects.stores.PendingWrite
-
Returns the value of the
bundleId
record component. - bundleId() - Method in interface com.usatiuk.objects.stores.PendingWriteEntry
C
- CachingObjectPersistentStore - Class in com.usatiuk.objects.stores
-
CachingObjectPersistentStore is a caching layer for the SerializingObjectPersistentStore It stores the already deserialized objects in memory.
- CachingObjectPersistentStore(int) - Constructor for class com.usatiuk.objects.stores.CachingObjectPersistentStore
- canDelete(PeerId, CanDeleteRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- canDelete(CanDeleteRequest) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpc
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcBean
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub
- canDelete(CanDeleteRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- canDelete(CanDeleteRequest, StreamObserver<CanDeleteReply>) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.AsyncService
- canDelete(CanDeleteRequest, StreamObserver<CanDeleteReply>) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub
- canDelete(Collection<PeerId>, JObjectKey) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceClient
-
Ask given peers if they can delete the object with the given key.
- CanDeleteReply - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.CanDeleteReply
- CanDeleteReply.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.CanDeleteReply
- CanDeleteReplyOrBuilder - Interface in com.usatiuk.dhfs.repository
- CanDeleteRequest - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.CanDeleteRequest
- CanDeleteRequest.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.CanDeleteRequest
- CanDeleteRequestOrBuilder - Interface in com.usatiuk.dhfs.repository
- cert() - Method in record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Returns the value of the
cert
record component. - cert() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns the value of the
cert
record component. - cert() - Method in record class com.usatiuk.dhfs.webapi.KnownPeerPut
-
Returns the value of the
cert
record component. - cert() - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Returns the value of the
cert
record component. - cert() - Method in record class com.usatiuk.dhfs.webapi.SelfInfo
-
Returns the value of the
cert
record component. - certFromBytes(byte[]) - Static method in class com.usatiuk.dhfs.peertrust.CertificateTools
-
Converts a byte array to an X.509 certificate.
- CertificateTools - Class in com.usatiuk.dhfs.peertrust
-
Helper class for generating and manipulating X.509 certificates.
- CertificateTools() - Constructor for class com.usatiuk.dhfs.peertrust.CertificateTools
- changelog() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Returns the value of the
changelog
record component. - changelog() - Method in record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Returns the value of the
changelog
record component. - changelog() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
changelog
record component. - CHANGELOG_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.GetObjectReply
- checkClientTrusted(X509Certificate[], String) - Method in class com.usatiuk.dhfs.peertrust.PeerTrustManager
- checkServerTrusted(X509Certificate[], String) - Method in class com.usatiuk.dhfs.peertrust.PeerTrustManager
- childId() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns the value of the
childId
record component. - childId() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns the value of the
childId
record component. - children() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns the value of the
children
record component. - children() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the children of this node.
- chmod(JObjectKey, long) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Change the mode of a file or directory.
- chmod(String, long) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- chown(String, long, long) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- ChunkData - Record Class in com.usatiuk.dhfsfs.objects
-
ChunkData is a data structure that represents an immutable binary blob
- ChunkData(JObjectKey, ByteString) - Constructor for record class com.usatiuk.dhfsfs.objects.ChunkData
-
Creates an instance of a
ChunkData
record class. - chunks() - Method in record class com.usatiuk.dhfsfs.objects.FileDto
-
Returns the value of the
chunks
record component. - clear() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- clear() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- clear() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- clearChangelog() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- clearDeletionCandidate() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
bool deletionCandidate = 2;
- clearEntries() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- clearId() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- clearKey() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- clearMsg() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- clearName() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
-
string name = 1;
- clearName() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- clearName() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- clearPort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 port = 2;
- clearPushedData() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- clearReferrers() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- clearSecurePort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 securePort = 3;
- clearSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
-
bytes serializedData = 1;
- clearSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
-
bytes serializedData = 1;
- clearSerializedData() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
-
bytes serializedData = 1;
- clearUuid() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
string uuid = 1;
- clearValue() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
int64 value = 2;
- clock() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
clock
record component. - Clock<TimestampT> - Interface in com.usatiuk.kleppmanntree
-
Clock interface
- clone() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- clone() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- clone() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- close() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- close() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
- close() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- close() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- close() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- close() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- close() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- close() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- close() - Method in interface com.usatiuk.objects.snapshot.Snapshot
- close() - Method in interface com.usatiuk.utils.AutoCloseableNoThrow
- close() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Closes the queue and returns all objects in it.
- CloseableKvIterator<K,
V> - Interface in com.usatiuk.objects.iterators -
An iterator over key-value pairs that can be closed and supports peek and skip operations, in both directions.
- collectRefsTo() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- collectRefsTo() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- collectRefsTo() - Method in interface com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeMeta
- collectRefsTo() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- collectRefsTo() - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
- collectRefsTo() - Method in interface com.usatiuk.dhfs.refcount.JDataRefcounted
-
Collect outgoing references to other objects.
- collectRefsTo() - Method in interface com.usatiuk.dhfs.remoteobj.JDataRemote
-
Collect outgoing references to other objects.
- collectRefsTo() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- collectRefsTo() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- collectRefsTo() - Method in record class com.usatiuk.dhfsfs.objects.File
- collectRefsTo() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
- collectRefsTo() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
- com.usatiuk.dhfs - package com.usatiuk.dhfs
- com.usatiuk.dhfs.autosync - package com.usatiuk.dhfs.autosync
- com.usatiuk.dhfs.invalidation - package com.usatiuk.dhfs.invalidation
- com.usatiuk.dhfs.jkleppmanntree - package com.usatiuk.dhfs.jkleppmanntree
- com.usatiuk.dhfs.jkleppmanntree.structs - package com.usatiuk.dhfs.jkleppmanntree.structs
- com.usatiuk.dhfs.jmap - package com.usatiuk.dhfs.jmap
- com.usatiuk.dhfs.peerdiscovery - package com.usatiuk.dhfs.peerdiscovery
- com.usatiuk.dhfs.peerdiscovery.local - package com.usatiuk.dhfs.peerdiscovery.local
- com.usatiuk.dhfs.peersync - package com.usatiuk.dhfs.peersync
- com.usatiuk.dhfs.peersync.api - package com.usatiuk.dhfs.peersync.api
- com.usatiuk.dhfs.peersync.structs - package com.usatiuk.dhfs.peersync.structs
- com.usatiuk.dhfs.peertrust - package com.usatiuk.dhfs.peertrust
- com.usatiuk.dhfs.persistence - package com.usatiuk.dhfs.persistence
- com.usatiuk.dhfs.refcount - package com.usatiuk.dhfs.refcount
- com.usatiuk.dhfs.remoteobj - package com.usatiuk.dhfs.remoteobj
- com.usatiuk.dhfs.repository - package com.usatiuk.dhfs.repository
- com.usatiuk.dhfs.rpc - package com.usatiuk.dhfs.rpc
- com.usatiuk.dhfs.syncmap - package com.usatiuk.dhfs.syncmap
- com.usatiuk.dhfs.webapi - package com.usatiuk.dhfs.webapi
- com.usatiuk.dhfs.webui - package com.usatiuk.dhfs.webui
- com.usatiuk.dhfsfs.objects - package com.usatiuk.dhfsfs.objects
- com.usatiuk.dhfsfs.service - package com.usatiuk.dhfsfs.service
- com.usatiuk.dhfsfuse - package com.usatiuk.dhfsfuse
- com.usatiuk.kleppmanntree - package com.usatiuk.kleppmanntree
- com.usatiuk.objects - package com.usatiuk.objects
- com.usatiuk.objects.iterators - package com.usatiuk.objects.iterators
- com.usatiuk.objects.snapshot - package com.usatiuk.objects.snapshot
- com.usatiuk.objects.stores - package com.usatiuk.objects.stores
- com.usatiuk.objects.transaction - package com.usatiuk.objects.transaction
- com.usatiuk.utils - package com.usatiuk.utils
- CombinedTimestamp<TimestampT,
PeerIdT> - Record Class in com.usatiuk.kleppmanntree -
CombinedTimestamp is a record that represents a timestamp and a node ID, ordered first by timestamp and then by node ID.
- CombinedTimestamp(TimestampT, PeerIdT) - Constructor for record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Creates an instance of a
CombinedTimestamp
record class. - commit() - Method in interface com.usatiuk.objects.transaction.TransactionManager
- commit() - Method in class com.usatiuk.objects.transaction.TransactionManagerImpl
- commit(TransactionImpl) - Method in class com.usatiuk.objects.transaction.TransactionService
- commitOpForHost(PeerId, Op) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Mark the operation as committed for the given host.
- commitTx(TxManifestObj<? extends JDataVersionedWrapper>, long) - Method in class com.usatiuk.objects.stores.CachingObjectPersistentStore
-
Commit the transaction to the underlying store and update the cache.
- commitTx(TxManifestRaw, long) - Method in class com.usatiuk.objects.stores.LmdbObjectPersistentStore
- commitTx(TxManifestRaw, long) - Method in class com.usatiuk.objects.stores.MemoryObjectPersistentStore
- commitTx(TxManifestRaw, long) - Method in interface com.usatiuk.objects.stores.ObjectPersistentStore
-
Commit a transaction to the persistent store.
- commitTx(Collection<TxRecord.TxObjectRecord<?>>) - Method in class com.usatiuk.objects.stores.WritebackObjectPersistentStore
-
Commit a transaction to the persistent store.
- compareChangelogs(PMap<PeerId, Long>, PMap<PeerId, Long>) - Static method in class com.usatiuk.dhfs.remoteobj.SyncHelper
-
Compares two changelogs.
- compareTo(JMapKey) - Method in record class com.usatiuk.dhfs.jmap.JMapLongKey
- compareTo(PeerId) - Method in record class com.usatiuk.dhfs.peersync.PeerId
- compareTo(JDataRef) - Method in record class com.usatiuk.dhfs.jmap.JMapRef
- compareTo(JDataRef) - Method in record class com.usatiuk.dhfs.refcount.JDataNormalRef
- compareTo(CombinedTimestamp<TimestampT, PeerIdT>) - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
- compareTo(JObjectKey) - Method in interface com.usatiuk.objects.JObjectKey
- compareTo(JObjectKey) - Method in class com.usatiuk.objects.JObjectKeyImpl
- compareTo(JObjectKey) - Method in record class com.usatiuk.objects.JObjectKeyMax
- compareTo(JObjectKey) - Method in record class com.usatiuk.objects.JObjectKeyMin
- confirmedDeletes() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
confirmedDeletes
record component. - CONFLICT - Enum constant in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
- containsKey(CombinedTimestamp<TimestampT, PeerIdT>) - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Checks if the log contains the given timestamp.
- create(String, long) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Create a new file with the given name and mode.
- create(String, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- createNewNode(JObjectKey, JObjectKey, JKleppmannTreeNodeMeta) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- createNewNode(NodeIdT, NodeIdT, MetaT) - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Create a new node with the specified key, parent, and metadata.
- createTransaction() - Method in class com.usatiuk.objects.transaction.TransactionService
- ctime() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns the value of the
ctime
record component. - cTime() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns the value of the
cTime
record component. - current() - Method in interface com.usatiuk.objects.transaction.TransactionManager
- current() - Method in class com.usatiuk.objects.transaction.TransactionManagerImpl
- CurrentTransaction - Class in com.usatiuk.objects.transaction
- CurrentTransaction() - Constructor for class com.usatiuk.objects.transaction.CurrentTransaction
- customizeHttpsServer(HttpServerOptions) - Method in class com.usatiuk.dhfs.peertrust.PeerTrustServerCustomizer
D
- data() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Returns the value of the
data
record component. - data() - Method in record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Returns the value of the
data
record component. - data() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns the value of the
data
record component. - data() - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
-
Returns the value of the
data
record component. - data() - Method in interface com.usatiuk.objects.JDataVersionedWrapper
-
Returns the wrapped object.
- data() - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Returns the value of the
data
record component. - data() - Method in class com.usatiuk.objects.JDataVersionedWrapperLazy
- data() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
-
Returns the value of the
data
record component. - Data<V> - Interface in com.usatiuk.objects.iterators
-
Interface indicating that data is present.
- dataKey() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- DataLocker - Class in com.usatiuk.utils
-
Allows to lock arbitrary keys.
- DataLocker() - Constructor for class com.usatiuk.utils.DataLocker
- DataWrapper<V> - Record Class in com.usatiuk.objects.iterators
-
Simple implementation of the Data interface.
- DataWrapper(V) - Constructor for record class com.usatiuk.objects.iterators.DataWrapper
-
Creates an instance of a
DataWrapper
record class. - DeadlockDetector - Class in com.usatiuk.dhfs
-
Periodically check for deadlocks in the JVM and log them if found.
- DeadlockDetector() - Constructor for class com.usatiuk.dhfs.DeadlockDetector
- DefaultObjSyncHandler - Class in com.usatiuk.dhfs.remoteobj
-
Fallback handler for remote object updates, no conflict resolution.
- DefaultObjSyncHandler() - Constructor for class com.usatiuk.dhfs.remoteobj.DefaultObjSyncHandler
- DeferredInvalidationQueueData - Class in com.usatiuk.dhfs.invalidation
-
Stores data about deferred invalidations.
- DeferredInvalidationQueueData() - Constructor for class com.usatiuk.dhfs.invalidation.DeferredInvalidationQueueData
- DeferredInvalidationQueueService - Class in com.usatiuk.dhfs.invalidation
-
Service to handle deferred invalidations.
- DeferredInvalidationQueueService() - Constructor for class com.usatiuk.dhfs.invalidation.DeferredInvalidationQueueService
- deferredInvalidations - Variable in class com.usatiuk.dhfs.invalidation.DeferredInvalidationQueueData
- delete(JMapHolder<K>, K) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Delete an entry from the map of a given holder.
- delete(JObjectKey) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- delete(JObjectKey) - Method in interface com.usatiuk.objects.transaction.Transaction
- deleteAll(JMapHolder<K>) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Delete all entries from the map of a given holder.
- deleted() - Method in record class com.usatiuk.objects.stores.TxManifestObj
-
Returns the value of the
deleted
record component. - deleted() - Method in record class com.usatiuk.objects.stores.TxManifestRaw
-
Returns the value of the
deleted
record component. - deletePeer(String) - Method in class com.usatiuk.dhfs.webapi.PeerManagementApi
- deletePeerAddress(String) - Method in class com.usatiuk.dhfs.webapi.PersistentPeerAddressApi
- DeleterTxHook - Class in com.usatiuk.dhfs.refcount
-
Automatically deletes objects that are not referenced by anything else.
- DeleterTxHook() - Constructor for class com.usatiuk.dhfs.refcount.DeleterTxHook
- DELETIONCANDIDATE_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.CanDeleteReply
- deserialize(byte[]) - Static method in class com.usatiuk.utils.SerializationHelper
- deserialize(byte[], int) - Static method in class com.usatiuk.utils.SerializationHelper
- deserialize(JDataRemoteDtoP) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectSerializer
- deserialize(JObjectKeyP) - Method in class com.usatiuk.dhfs.JObjectKeyProtoSerializer
- deserialize(GetObjectReply) - Method in class com.usatiuk.dhfs.rpc.ReceivedObjectSerializer
- deserialize(OpP) - Method in class com.usatiuk.dhfs.OpSerializer
- deserialize(InputStream) - Static method in class com.usatiuk.utils.SerializationHelper
- deserialize(ByteBuffer) - Method in class com.usatiuk.objects.JavaDataSerializer
- deserialize(ByteBuffer) - Method in class com.usatiuk.objects.JDataVersionedWrapperSerializer
-
Deserializes a JDataVersionedWrapper object from a ByteBuffer.
- deserialize(ByteBuffer) - Method in interface com.usatiuk.objects.ObjectSerializer
-
Deserialize an object from a ByteBuffer.
- deserialize(M) - Method in interface com.usatiuk.dhfs.ProtoSerializer
- DhfsFileService - Class in com.usatiuk.dhfsfs.service
-
Actual filesystem implementation.
- DhfsFileService() - Constructor for class com.usatiuk.dhfsfs.service.DhfsFileService
- DhfsFuse - Class in com.usatiuk.dhfsfuse
-
FUSE file system implementation.
- DhfsFuse() - Constructor for class com.usatiuk.dhfsfuse.DhfsFuse
- DhfsObjectPeerDiscoveryApi - Class in com.usatiuk.dhfs.peerdiscovery
- DhfsObjectPersistence - Class in com.usatiuk.dhfs.persistence
- DhfsObjectSyncApi - Class in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpc - Interface in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpcBean - Class in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpcClient - Class in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpcClient(String, Channel, BiFunction<String, MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub, MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub>) - Constructor for class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- DhfsObjectSyncGrpcGrpc - Class in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpcGrpc.AsyncService - Interface in com.usatiuk.dhfs.repository
- DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub - Class in com.usatiuk.dhfs.repository
-
A stub to allow clients to do synchronous rpc calls to service DhfsObjectSyncGrpc.
- DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub - Class in com.usatiuk.dhfs.repository
-
A stub to allow clients to do ListenableFuture-style rpc calls to service DhfsObjectSyncGrpc.
- DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase - Class in com.usatiuk.dhfs.repository
-
Base class for the server implementation of the service DhfsObjectSyncGrpc.
- DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub - Class in com.usatiuk.dhfs.repository
-
A stub to allow clients to do asynchronous rpc calls to service DhfsObjectSyncGrpc.
- DhfsObjectSyncGrpcImplBase() - Constructor for class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- DhfsObjectSyncGrpcImplBase() - Constructor for class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- DhfsStorageServerApp() - Constructor for class com.usatiuk.dhfsfuse.Main.DhfsStorageServerApp
- DIRECTORY - Enum constant in enum class com.usatiuk.dhfsfs.service.GetattrType
- DirectoryNotEmptyException - Exception Class in com.usatiuk.dhfsfs.service
-
DirectoryNotEmptyException is thrown when a directory is not empty.
- DirectoryNotEmptyException() - Constructor for exception class com.usatiuk.dhfsfs.service.DirectoryNotEmptyException
- discoverPeers() - Method in class com.usatiuk.dhfs.peerdiscovery.PersistentStaticPeerDiscovery
- discoverPeers() - Method in class com.usatiuk.dhfs.peerdiscovery.StaticPeerDiscovery
- doInitialSync(PeerId) - Method in class com.usatiuk.dhfs.remoteobj.SyncHandler
-
Do initial sync for a newly connected (or reconnected) peer.
- dtoClass() - Method in interface com.usatiuk.dhfs.remoteobj.JDataRemote
-
Returns the class of DTO of this object that should be used for remote synchronization.
- dtoClass() - Method in record class com.usatiuk.dhfsfs.objects.File
- DtoMapper<F,
D> - Interface in com.usatiuk.dhfs.syncmap -
Interface for mapping between a remote object and its DTO representation.
- DtoMapperService - Class in com.usatiuk.dhfs.syncmap
-
Service for mapping between remote objects and their DTO representations.
- DtoMapperService(Instance<DtoMapper<?, ?>>) - Constructor for class com.usatiuk.dhfs.syncmap.DtoMapperService
E
- effectiveOp() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns the value of the
effectiveOp
record component. - effects() - Method in record class com.usatiuk.kleppmanntree.LogRecord
-
Returns the value of the
effects
record component. - ENTRIES_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.ObjectChangelog
- EQUAL - Enum constant in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
- equals(Object) - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jmap.JMapLongKey
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.jmap.JMapRef
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.PeerId
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.JDataP
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- equals(Object) - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- equals(Object) - Method in record class com.usatiuk.dhfs.refcount.JDataNormalRef
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- equals(Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- equals(Object) - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- equals(Object) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- equals(Object) - Method in class com.usatiuk.dhfs.repository.OpP
- equals(Object) - Method in class com.usatiuk.dhfs.repository.OpPushReply
- equals(Object) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- equals(Object) - Method in class com.usatiuk.dhfs.repository.PingReply
- equals(Object) - Method in class com.usatiuk.dhfs.repository.PingRequest
- equals(Object) - Method in record class com.usatiuk.dhfs.webapi.KnownPeerPut
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfs.webapi.SelfInfo
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.objects.File
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.objects.FileDto
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.kleppmanntree.LogRecord
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.iterators.DataWrapper
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.iterators.TombstoneImpl
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.usatiuk.objects.JObjectKeyImpl
- equals(Object) - Method in record class com.usatiuk.objects.JObjectKeyMax
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.JObjectKeyMin
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.stores.PendingDelete
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.stores.PendingWrite
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.stores.TxManifestObj
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.stores.TxManifestRaw
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordDeleted
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
-
Indicates whether some other object is "equal to" this one.
- estimateSize() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- estimateSize() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- estimateSize() - Method in interface com.usatiuk.dhfs.remoteobj.JDataRemote
-
Returns the estimated size of this remote object in bytes.
- estimateSize() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- estimateSize() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- estimateSize() - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
- estimateSize() - Method in record class com.usatiuk.dhfsfs.objects.File
- estimateSize() - Method in interface com.usatiuk.objects.JData
-
Returns the estimated size of the object in bytes.
- estimateSize() - Method in interface com.usatiuk.objects.JDataVersionedWrapper
-
Returns the estimated size of the object in bytes.
- estimateSize() - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
- estimateSize() - Method in class com.usatiuk.objects.JDataVersionedWrapperLazy
- executeTx(Runnable) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- executeTx(Supplier<T>) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- existsPeer(PeerId) - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Checks if the peer with the given ID is known to the cluster.
- extractOps(JKleppmannTreePersistentData, PeerId) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpExtractor
- extractOps(RemoteObjectMeta, PeerId) - Method in class com.usatiuk.dhfs.invalidation.RemoteObjectMetaOpExtractor
- extractOps(JData, PeerId) - Method in class com.usatiuk.dhfs.invalidation.OpExtractorService
-
Extract operations from the given JData object.
- extractOps(T, PeerId) - Method in interface com.usatiuk.dhfs.invalidation.OpExtractor
-
Extract operations from the given data object.
F
- file() - Method in record class com.usatiuk.dhfsfs.objects.FileDto
-
Returns the value of the
file
record component. - File - Record Class in com.usatiuk.dhfsfs.objects
-
File is a data structure that represents a file in the file system
- File(JObjectKey, long, long, long, boolean) - Constructor for record class com.usatiuk.dhfsfs.objects.File
-
Creates an instance of a
File
record class. - FILE - Enum constant in enum class com.usatiuk.dhfsfs.service.GetattrType
- FileDto - Record Class in com.usatiuk.dhfsfs.objects
-
FileDto is a data transfer object that contains a file and its chunks.
- FileDto(File, List<Pair<Long, JObjectKey>>) - Constructor for record class com.usatiuk.dhfsfs.objects.FileDto
-
Creates an instance of a
FileDto
record class. - FileDtoMapper - Class in com.usatiuk.dhfsfs.objects
- FileDtoMapper() - Constructor for class com.usatiuk.dhfsfs.objects.FileDtoMapper
- FileHelper - Class in com.usatiuk.dhfsfs.objects
-
Helper class for working with files.
- FileHelper() - Constructor for class com.usatiuk.dhfsfs.objects.FileHelper
- fileIno() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Returns the value of the
fileIno
record component. - FileSyncHandler - Class in com.usatiuk.dhfsfs.objects
-
Handles synchronization of file objects.
- FileSyncHandler() - Constructor for class com.usatiuk.dhfsfs.objects.FileSyncHandler
- fillInStackTrace() - Method in exception class com.usatiuk.dhfsfs.service.DirectoryNotEmptyException
- fillInStackTrace() - Method in exception class com.usatiuk.kleppmanntree.AlreadyExistsException
- fillInStackTrace() - Method in exception class com.usatiuk.utils.StatusRuntimeExceptionNoStacktrace
- findParent(Function<TreeNode<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>, Boolean>) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Get the parent of a node that matches the given predicate.
- findParent(Function<TreeNode<TimestampT, PeerIdT, MetaT, NodeIdT>, Boolean>) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Find the parent of a node that matches the given predicate
- first() - Static method in interface com.usatiuk.objects.JObjectKey
-
Returns a JObjectKey that compares less than all other keys.
- from() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Returns the value of the
from
record component. - fromByteBuffer(ByteBuffer) - Static method in interface com.usatiuk.objects.JObjectKey
-
Creates a new JObjectKey from a ByteBuffer.
- fromBytes(byte[]) - Static method in interface com.usatiuk.objects.JObjectKey
-
Creates a new JObjectKey from a byte array.
- fromDto(FileDto) - Method in class com.usatiuk.dhfsfs.objects.FileDtoMapper
- fromDto(D) - Method in interface com.usatiuk.dhfs.syncmap.DtoMapper
-
Converts a DTO to its corresponding remote object.
- fromDto(D, Class<F>) - Method in class com.usatiuk.dhfs.syncmap.DtoMapperService
-
Converts a DTO to its corresponding remote object.
- frozen() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Returns the value of the
frozen
record component. - frozen() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
frozen
record component. - frozen() - Method in interface com.usatiuk.dhfs.refcount.JDataRefcounted
-
Returns whether this object is frozen or not.
- frozen() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns the value of the
frozen
record component. - frozen() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
frozen
record component.
G
- GE - Enum constant in enum class com.usatiuk.objects.iterators.IteratorStart
- generateCertificate(KeyPair, String) - Static method in class com.usatiuk.dhfs.peertrust.CertificateTools
-
Generates an X.509 certificate using the provided key pair and subject name.
- generateKeyPair() - Static method in class com.usatiuk.dhfs.peertrust.CertificateTools
-
Generates a random RSA key pair.
- get() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets the object from the queue, waiting for it if necessary.
- get(long) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets the object from the queue, waiting for it if necessary.
- get(JMapHolder<K>, K) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Get an entry from the map of a given holder.
- get(Class<T>, JObjectKey) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- get(Class<T>, JObjectKey) - Method in interface com.usatiuk.objects.transaction.Transaction
- getAcceptedIssuers() - Method in class com.usatiuk.dhfs.peertrust.PeerTrustManager
- getAddress(PeerId) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Gets the address of the given host.
- getAddress(ByteBuffer) - Static method in class com.usatiuk.utils.UninitializedByteBuffer
-
Gets the address of the given ByteBuffer.
- getAll() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Return all the log entries
- getAll() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets all objects from the queue that are ready to be processed.
- getAllPeers() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeerInterface
- getAllPeers() - Method in interface com.usatiuk.kleppmanntree.PeerInterface
-
Returns a collection of all known peers.
- getAllWait() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets all objects from the queue, waiting for them if necessary.
- getAllWait(int) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets all objects from the queue, waiting for them if necessary.
- getAllWait(int, long) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Gets all objects from the queue, waiting for them if necessary.
- getattr(JObjectKey) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Get the attributes of a file or directory.
- getattr(String, FileStat) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- GetattrRes - Record Class in com.usatiuk.dhfsfs.service
-
GetattrRes is a record that represents the result of a getattr operation.
- GetattrRes(long, long, long, GetattrType) - Constructor for record class com.usatiuk.dhfsfs.service.GetattrRes
-
Creates an instance of a
GetattrRes
record class. - GetattrType - Enum Class in com.usatiuk.dhfsfs.service
- getAvailableHosts() - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Gets the ids of all reachable hosts.
- getById(JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getById(NodeIdT) - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the node by its ID.
- getCanDeleteMethod() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- getChangelog() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelog() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelog() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelogBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelogOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelogOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChangelogOrBuilder() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- getChunks(File) - Method in class com.usatiuk.dhfsfs.objects.FileHelper
-
Get the chunks of a file.
- getData(Class<T>, JObjectKey) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Get the data of a remote object with the given key.
- getDataLocal(Class<T>, JObjectKey) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Get the data of a remote object with the given key.
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.JDataP
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.OpP
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.PingReply
- getDefaultInstance() - Static method in class com.usatiuk.dhfs.repository.PingRequest
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JDataP
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpP
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.PingReply
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- getDefaultInstanceForType() - Method in class com.usatiuk.dhfs.repository.PingRequest
- getDelay() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
- getDeletionCandidate() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
bool deletionCandidate = 2;
- getDeletionCandidate() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
bool deletionCandidate = 2;
- getDeletionCandidate() - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
bool deletionCandidate = 2;
- getDescriptor() - Static method in class com.usatiuk.dhfs.peerdiscovery.DhfsObjectPeerDiscoveryApi
- getDescriptor() - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.DhfsObjectPersistence
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JDataP
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncApi
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpP.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpP
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.PingReply.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.PingReply
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- getDescriptor() - Static method in class com.usatiuk.dhfs.repository.PingRequest
- getDescriptorForType() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- getDescriptorForType() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- getEntries(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntries(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntries(int) - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelogOrBuilder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesBuilder(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesBuilderList() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesCount() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesCount() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesCount() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelogOrBuilder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesList() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesList() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesList() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelogOrBuilder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilder(int) - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelogOrBuilder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilderList() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilderList() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEntriesOrBuilderList() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelogOrBuilder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- getEscapedRefs() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
- getEscapedRefs() - Method in interface com.usatiuk.dhfs.invalidation.Op
-
Returns the keys of the objects that are referenced in this op.
- getEscapedRefs() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
- getEscapedRefs() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
- getForPeer(PeerId) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryDirectory
-
Returns a collection of addresses for a given peer.
- getForPeer(PeerIdT) - Method in interface com.usatiuk.kleppmanntree.PeerTimestampLogInterface
-
Get the timestamp for a specific peer.
- getFreeSpace() - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Get the free space on the filesystem.
- getFreeSpace() - Method in class com.usatiuk.objects.stores.LmdbObjectPersistentStore
- getFreeSpace() - Method in class com.usatiuk.objects.stores.MemoryObjectPersistentStore
- getFreeSpace() - Method in interface com.usatiuk.objects.stores.ObjectPersistentStore
-
Get the free space of the persistent store.
- getGetObjectMethod() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- getHostStateSnapshot() - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Gets a snapshot of current state of the connected (and not connected) peers
- getId() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- getId() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
-
.dhfs.persistence.JObjectKeyP id = 1;
- getId() - Method in interface com.usatiuk.dhfs.persistence.PeerIdPOrBuilder
-
.dhfs.persistence.JObjectKeyP id = 1;
- getIdBuilder() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- getIdOrBuilder() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- getIdOrBuilder() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
-
.dhfs.persistence.JObjectKeyP id = 1;
- getIdOrBuilder() - Method in interface com.usatiuk.dhfs.persistence.PeerIdPOrBuilder
-
.dhfs.persistence.JObjectKeyP id = 1;
- getIterator(JMapHolder<K>) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Get an iterator for the map of a given holder.
- getIterator(JMapHolder<K>, IteratorStart, K) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Get an iterator for the map of a given holder.
- getIterator(IteratorStart, JObjectKey) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- getIterator(IteratorStart, JObjectKey) - Method in interface com.usatiuk.objects.transaction.Transaction
- getIterator(IteratorStart, K) - Method in interface com.usatiuk.objects.snapshot.Snapshot
-
Get a list of iterators representing the snapshot.
- getIterator(JObjectKey) - Method in interface com.usatiuk.objects.transaction.Transaction
- getKey() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- getKey() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
-
.dhfs.persistence.PeerIdP key = 1;
- getKey() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelog.entries_EntryOrBuilder
-
.dhfs.persistence.PeerIdP key = 1;
- getKeyBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- getKeyOrBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- getKeyOrBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
-
.dhfs.persistence.PeerIdP key = 1;
- getKeyOrBuilder() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelog.entries_EntryOrBuilder
-
.dhfs.persistence.PeerIdP key = 1;
- getLog() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getLog() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the log interface.
- getLostFoundId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getLostFoundId() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the lost and found node ID.
- getMeta(JObjectKey) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Get metadata for the object with the given key.
- getMsg(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsg(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
-
repeated .dhfs.sync.OpP msg = 2;
- getMsg(int) - Method in interface com.usatiuk.dhfs.repository.OpPushRequestOrBuilder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgBuilder(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgBuilderList() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgCount() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgCount() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgCount() - Method in interface com.usatiuk.dhfs.repository.OpPushRequestOrBuilder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgList() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgList() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgList() - Method in interface com.usatiuk.dhfs.repository.OpPushRequestOrBuilder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilder(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilder(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilder(int) - Method in interface com.usatiuk.dhfs.repository.OpPushRequestOrBuilder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilderList() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilderList() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
-
repeated .dhfs.sync.OpP msg = 2;
- getMsgOrBuilderList() - Method in interface com.usatiuk.dhfs.repository.OpPushRequestOrBuilder
-
repeated .dhfs.sync.OpP msg = 2;
- getName() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
-
string name = 1;
- getName() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
-
string name = 1;
- getName() - Method in interface com.usatiuk.dhfs.persistence.JObjectKeyPOrBuilder
-
string name = 1;
- getName() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getName() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- getName() - Method in interface com.usatiuk.dhfs.repository.CanDeleteRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getName() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getName() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- getName() - Method in interface com.usatiuk.dhfs.repository.GetObjectRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameBytes() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
-
string name = 1;
- getNameBytes() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
-
string name = 1;
- getNameBytes() - Method in interface com.usatiuk.dhfs.persistence.JObjectKeyPOrBuilder
-
string name = 1;
- getNameOrBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameOrBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameOrBuilder() - Method in interface com.usatiuk.dhfs.repository.CanDeleteRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNameOrBuilder() - Method in interface com.usatiuk.dhfs.repository.GetObjectRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- getNewNodeId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Get a new node id.
- getNewNodeId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getNewNodeId() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the new node ID.
- getObject(PeerId, GetObjectRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- getObject(GetObjectRequest) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpc
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcBean
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub
- getObject(GetObjectRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- getObject(GetObjectRequest, StreamObserver<GetObjectReply>) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.AsyncService
- getObject(GetObjectRequest, StreamObserver<GetObjectReply>) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub
- getObject(JObjectKey, Function<Pair<PeerId, ReceivedObject>, Boolean>) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceClient
-
Download a specific object from some reachable peer.
- GetObjectReply - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.GetObjectReply
- GetObjectReply.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.GetObjectReply
- GetObjectReplyOrBuilder - Interface in com.usatiuk.dhfs.repository
- GetObjectRequest - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.GetObjectRequest
- GetObjectRequest.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.GetObjectRequest
- GetObjectRequestOrBuilder - Interface in com.usatiuk.dhfs.repository
- getOpPushMethod() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- getParserForType() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.JDataP
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- getParserForType() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- getParserForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- getParserForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- getParserForType() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- getParserForType() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- getParserForType() - Method in class com.usatiuk.dhfs.repository.OpP
- getParserForType() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- getParserForType() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- getParserForType() - Method in class com.usatiuk.dhfs.repository.PingReply
- getParserForType() - Method in class com.usatiuk.dhfs.repository.PingRequest
- getPeerAddress(String) - Method in class com.usatiuk.dhfs.webapi.PersistentPeerAddressApi
- getPeerAddresses() - Method in class com.usatiuk.dhfs.webapi.PersistentPeerAddressApi
- getPeerInfo(PeerId) - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Gets the information about the peer with the given ID.
- getPeers() - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Gets the information about all peers in the cluster.
- getPeersNoSelf() - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Gets the information about all peers in the cluster, excluding the current peer.
- getPeerTimestampLog() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getPeerTimestampLog() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the peer timestamp log interface.
- getPendingOpsForHost(PeerId, int) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Get the pending operations for the given peer.
- getPeriodicPushOp() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Create a dummy operation that contains the timestamp of the last operation, to move causality threshold forward even without any real operations.
- getPersistentPeerAddress(PeerId) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- getPersistentPeerAddresses() - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- getPingMethod() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- getPort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 port = 2;
- getPort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
-
uint32 port = 2;
- getPort() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfoOrBuilder
-
uint32 port = 2;
- getPriority() - Method in class com.usatiuk.dhfs.autosync.AutosyncTxHook
- getPriority() - Method in class com.usatiuk.dhfs.refcount.DeleterTxHook
- getPriority() - Method in class com.usatiuk.dhfs.refcount.RefcounterTxHook
- getPriority() - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjPusherTxHook
- getPriority() - Method in interface com.usatiuk.objects.transaction.PreCommitTxHook
- getPushedData() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedData() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedData() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedDataBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedDataOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedDataOrBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getPushedDataOrBuilder() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- getReachablePeers() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryDirectory
-
Returns a collection of reachable peers.
- getReferrers(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrers(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrers(int) - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersBuilder(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersBuilderList() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersCount() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersCount() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersCount() - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersList() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersList() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersList() - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilder(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilder(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilder(int) - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilderList() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilderList() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getReferrersOrBuilderList() - Method in interface com.usatiuk.dhfs.repository.CanDeleteReplyOrBuilder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- getRootId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getRootId() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the root node ID.
- getSecurePort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 securePort = 3;
- getSecurePort() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
-
uint32 securePort = 3;
- getSecurePort() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfoOrBuilder
-
uint32 securePort = 3;
- getSeenButNotAddedHosts() - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Gets the information about all reachable peers that are not added to the cluster.
- getSelfCertificate() - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- getSelfId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeerInterface
- getSelfId() - Method in interface com.usatiuk.kleppmanntree.PeerInterface
-
Returns the ID of the current peer.
- getSelfInfo() - Method in class com.usatiuk.dhfs.peersync.api.PeerSyncApi
- getSelfInfo() - Method in interface com.usatiuk.dhfs.peersync.api.PeerSyncApiClient
- getSelfInfo(PeerAddress) - Method in class com.usatiuk.dhfs.peersync.api.PeerSyncApiClientDynamic
-
Queries peer about its information.
- getSelfKeypair() - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- getSelfUuid() - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- getSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
-
bytes serializedData = 1;
- getSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataP
-
bytes serializedData = 1;
- getSerializedData() - Method in interface com.usatiuk.dhfs.persistence.JDataPOrBuilder
-
bytes serializedData = 1;
- getSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
-
bytes serializedData = 1;
- getSerializedData() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
-
bytes serializedData = 1;
- getSerializedData() - Method in interface com.usatiuk.dhfs.persistence.JDataRemoteDtoPOrBuilder
-
bytes serializedData = 1;
- getSerializedData() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
-
bytes serializedData = 1;
- getSerializedData() - Method in class com.usatiuk.dhfs.repository.OpP
-
bytes serializedData = 1;
- getSerializedData() - Method in interface com.usatiuk.dhfs.repository.OpPOrBuilder
-
bytes serializedData = 1;
- getSerializedSize() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.JDataP
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- getSerializedSize() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.OpP
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.PingReply
- getSerializedSize() - Method in class com.usatiuk.dhfs.repository.PingRequest
- getServiceDescriptor() - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- getSnapshot() - Method in class com.usatiuk.objects.stores.CachingObjectPersistentStore
-
Get a snapshot of underlying store and the cache.
- getSnapshot() - Method in class com.usatiuk.objects.stores.LmdbObjectPersistentStore
-
Get a snapshot of the database.
- getSnapshot() - Method in class com.usatiuk.objects.stores.MemoryObjectPersistentStore
- getSnapshot() - Method in interface com.usatiuk.objects.stores.ObjectPersistentStore
-
Get a snapshot of the persistent store.
- getSnapshot() - Method in class com.usatiuk.objects.stores.SerializingObjectPersistentStore
-
Get a snapshot of the persistent store, with deserialized objects.
- getSnapshot() - Method in class com.usatiuk.objects.stores.WritebackObjectPersistentStore
-
Get a snapshot of the persistent store, including the pending writes.
- getSpecificObject(JObjectKey, PeerId) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceClient
-
Download a specific object from a specific peer.
- getStub() - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- getSynchronizedPeers() - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Gets the information about all synchronized peers in the cluster.
- getSynchronizedPeersNoSelf() - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Gets the information about all synchronized peers in the cluster, excluding the current peer.
- getTimestamp() - Method in interface com.usatiuk.kleppmanntree.Clock
-
Increment and get the current timestamp.
- getTotalSpace() - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Get the total space on the filesystem.
- getTotalSpace() - Method in class com.usatiuk.objects.stores.LmdbObjectPersistentStore
- getTotalSpace() - Method in class com.usatiuk.objects.stores.MemoryObjectPersistentStore
- getTotalSpace() - Method in interface com.usatiuk.objects.stores.ObjectPersistentStore
-
Get the size of the persistent store.
- getTrashId() - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- getTrashId() - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Get the trash node ID.
- getTree(JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager
-
Get a tree with the given name.
- getTree(JObjectKey, Supplier<JKleppmannTreeNodeMeta>) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager
-
Get or create a tree with the given name.
- getUuid() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
string uuid = 1;
- getUuid() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
-
string uuid = 1;
- getUuid() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfoOrBuilder
-
string uuid = 1;
- getUuidBytes() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
string uuid = 1;
- getUuidBytes() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
-
string uuid = 1;
- getUuidBytes() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfoOrBuilder
-
string uuid = 1;
- getValue() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
int64 value = 2;
- getValue() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
-
int64 value = 2;
- getValue() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelog.entries_EntryOrBuilder
-
int64 value = 2;
- GT - Enum constant in enum class com.usatiuk.objects.iterators.IteratorStart
H
- handle(RoutingContext) - Method in class com.usatiuk.dhfs.webui.WebUiRouter
- handleConnectionError(PeerId) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
- handleCrash(JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeInitialSyncProcessor
- handleCrash(JObjectKey) - Method in interface com.usatiuk.dhfs.peersync.InitialSyncProcessor
-
Called when the system had crashed (and the object needs to probably be re-synced).
- handleCrash(JObjectKey) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjectInitialSyncProcessor
- handleOp(PeerId, IndexUpdateOp) - Method in class com.usatiuk.dhfs.remoteobj.IndexUpdateOpHandler
- handleOp(PeerId, Op) - Method in class com.usatiuk.dhfs.invalidation.OpHandlerService
-
Handle the given operation.
- handleOp(PeerId, JKleppmannTreeOpWrapper) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpHandler
- handleOp(PeerId, JKleppmannTreePeriodicPushOp) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicOpHandler
- handleOp(PeerId, T) - Method in interface com.usatiuk.dhfs.invalidation.OpHandler
-
Handles the given operation.
- handlePeerConnected(PeerId) - Method in class com.usatiuk.dhfs.invalidation.DeferredInvalidationQueueService
- handlePeerConnected(PeerId) - Method in interface com.usatiuk.dhfs.peersync.PeerConnectedEventListener
-
Called when a peer is connected.
- handlePeerDisconnected(PeerId) - Method in interface com.usatiuk.dhfs.peersync.PeerDisconnectedEventListener
-
Called when a peer is disconnected.
- handlePeerDisconnected(PeerId) - Method in class com.usatiuk.dhfs.rpc.RpcClientFactory
- handleRemoteUpdate(PeerId, JObjectKey, PMap<PeerId, Long>, PeerInfo) - Method in class com.usatiuk.dhfs.peersync.PeerInfoSyncHandler
- handleRemoteUpdate(PeerId, JObjectKey, PMap<PeerId, Long>, JDataRemote) - Method in class com.usatiuk.dhfs.remoteobj.DefaultObjSyncHandler
- handleRemoteUpdate(PeerId, JObjectKey, PMap<PeerId, Long>, FileDto) - Method in class com.usatiuk.dhfsfs.objects.FileSyncHandler
- handleRemoteUpdate(PeerId, JObjectKey, PMap<PeerId, Long>, D) - Method in interface com.usatiuk.dhfs.remoteobj.ObjSyncHandler
-
Handles a remote update of an object.
- handleRemoteUpdate(PeerId, JObjectKey, PMap<PeerId, Long>, D) - Method in class com.usatiuk.dhfs.remoteobj.SyncHandler
-
Handles remote update of an object.
- hasChangelog() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- hasChangelog() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- hasChangelog() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- hashCode() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jmap.JMapLongKey
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.jmap.JMapRef
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns a hash code value for this object.
- hashCode() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.PeerId
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Returns a hash code value for this object.
- hashCode() - Method in class com.usatiuk.dhfs.persistence.JDataP
- hashCode() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- hashCode() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- hashCode() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- hashCode() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- hashCode() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- hashCode() - Method in record class com.usatiuk.dhfs.refcount.JDataNormalRef
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns a hash code value for this object.
- hashCode() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- hashCode() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- hashCode() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- hashCode() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- hashCode() - Method in class com.usatiuk.dhfs.repository.OpP
- hashCode() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- hashCode() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- hashCode() - Method in class com.usatiuk.dhfs.repository.PingReply
- hashCode() - Method in class com.usatiuk.dhfs.repository.PingRequest
- hashCode() - Method in record class com.usatiuk.dhfs.webapi.KnownPeerPut
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfs.webapi.SelfInfo
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.objects.FileDto
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.kleppmanntree.LogRecord
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.iterators.DataWrapper
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.iterators.TombstoneImpl
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Returns a hash code value for this object.
- hashCode() - Method in class com.usatiuk.objects.JObjectKeyImpl
- hashCode() - Method in record class com.usatiuk.objects.JObjectKeyMax
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.JObjectKeyMin
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.stores.PendingDelete
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.stores.PendingWrite
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.stores.TxManifestObj
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.stores.TxManifestRaw
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordDeleted
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
-
Returns a hash code value for this object.
- HashSetDelayedBlockingQueue<T> - Class in com.usatiuk.utils
-
Blocking queue that delays the objects for a given time, and deduplicates them.
- HashSetDelayedBlockingQueue(long) - Constructor for class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Creates a new HashSetDelayedBlockingQueue with the specified delay.
- hasId() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- hasId() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
-
.dhfs.persistence.JObjectKeyP id = 1;
- hasId() - Method in interface com.usatiuk.dhfs.persistence.PeerIdPOrBuilder
-
.dhfs.persistence.JObjectKeyP id = 1;
- hasImmediate() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Checks if the queue has an object that is ready to be processed.
- hasImpl() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- hasImpl() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- hasImpl() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- hasImpl() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
Checks if there is a next element in the iterator, depending on the current direction.
- hasImpl() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- hasKey() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- hasKey() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
-
.dhfs.persistence.PeerIdP key = 1;
- hasKey() - Method in interface com.usatiuk.dhfs.persistence.ObjectChangelog.entries_EntryOrBuilder
-
.dhfs.persistence.PeerIdP key = 1;
- hasLocalData() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
hasLocalData
record component. - hasName() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasName() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasName() - Method in interface com.usatiuk.dhfs.repository.CanDeleteRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasName() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasName() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasName() - Method in interface com.usatiuk.dhfs.repository.GetObjectRequestOrBuilder
-
.dhfs.persistence.JObjectKeyP name = 2;
- hasNext() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- hasNext() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- hasNext() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- hasNext() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- hasPendingOpsForHost(PeerId) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Check if there are any pending operations for the given peer.
- hasPrev() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- hasPrev() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Checks if there is a previous element in the reverse direction.
- hasPrev() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- hasPrev() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- hasPrev() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- hasPushedData() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- hasPushedData() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- hasPushedData() - Method in interface com.usatiuk.dhfs.repository.GetObjectReplyOrBuilder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- holder() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns the value of the
holder
record component. - holder() - Method in record class com.usatiuk.dhfs.jmap.JMapRef
-
Returns the value of the
holder
record component. - HostStateSnapshot(Collection<PeerId>, Collection<PeerId>) - Constructor for record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Creates an instance of a
HostStateSnapshot
record class.
I
- id() - Method in record class com.usatiuk.dhfs.peersync.PeerId
-
Returns the value of the
id
record component. - id() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns the value of the
id
record component. - id() - Method in interface com.usatiuk.objects.snapshot.Snapshot
-
Get the ID of the snapshot.
- ID_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.PeerIdP
- IndexUpdateOp - Record Class in com.usatiuk.dhfs.invalidation
-
Information about a new version of a remote object, possibly with its data.
- IndexUpdateOp(JObjectKey, PMap<PeerId, Long>, JDataRemoteDto) - Constructor for record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Creates an instance of a
IndexUpdateOp
record class. - IndexUpdateOpHandler - Class in com.usatiuk.dhfs.remoteobj
- IndexUpdateOpHandler() - Constructor for class com.usatiuk.dhfs.remoteobj.IndexUpdateOpHandler
- initialSyncDone() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns the value of the
initialSyncDone
record component. - InitialSyncProcessor<T> - Interface in com.usatiuk.dhfs.peersync
-
Allows to specify custom processing of initial synchronization/crash recovery for a specific object type.
- inoToParent(JObjectKey) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Get the parent directory of a file or directory.
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JDataP
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpP
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.PingReply
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- internalGetFieldAccessorTable() - Method in class com.usatiuk.dhfs.repository.PingRequest
- interval() - Method in interface com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryConfig
- InvalidationQueueEntry - Record Class in com.usatiuk.dhfs.invalidation
- InvalidationQueueEntry(PeerId, JObjectKey) - Constructor for record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Creates an instance of a
InvalidationQueueEntry
record class. - InvalidationQueueService - Class in com.usatiuk.dhfs.invalidation
-
Service to handle sending operations to remote peers.
- InvalidationQueueService(int) - Constructor for class com.usatiuk.dhfs.invalidation.InvalidationQueueService
- IpPeerAddress - Record Class in com.usatiuk.dhfs.peerdiscovery
-
Represents a peer address with an IP address and port.
- IpPeerAddress(PeerId, PeerAddressType, InetAddress, int, int) - Constructor for record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Creates an instance of a
IpPeerAddress
record class. - isEmpty() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Checks if the log is empty.
- isInitialized() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JDataP
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- isInitialized() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- isInitialized() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- isInitialized() - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- isInitialized() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpP
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- isInitialized() - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.PingReply
- isInitialized() - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- isInitialized() - Method in class com.usatiuk.dhfs.repository.PingRequest
- isInitialSyncDone(PeerId) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- isReachable(PeerId) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Checks if the given host is reachable.
- isReachable(PeerInfo) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Checks if the given host is reachable.
- IteratorStart - Enum Class in com.usatiuk.objects.iterators
-
Allows to specify initial positioning of the iterator relative to the requested key.
J
- JavaDataSerializer - Class in com.usatiuk.objects
-
Simple Java object serializer.
- JavaDataSerializer() - Constructor for class com.usatiuk.objects.JavaDataSerializer
- JData - Interface in com.usatiuk.objects
-
JData is a marker interface for all objects that can be stored in the object store.
- JDataNormalRef - Record Class in com.usatiuk.dhfs.refcount
-
Good old boring object reference.
- JDataNormalRef(JObjectKey) - Constructor for record class com.usatiuk.dhfs.refcount.JDataNormalRef
-
Creates an instance of a
JDataNormalRef
record class. - JDataP - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JDataP
- JDataP.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JDataP
- JDataPOrBuilder - Interface in com.usatiuk.dhfs.persistence
- JDataRef - Interface in com.usatiuk.dhfs.refcount
-
JDataRefs are used to store additional metadata about incoming references to objects for reference counting.
- JDataRefcounted - Interface in com.usatiuk.dhfs.refcount
-
Interface for a reference counted object
- JDataRemote - Interface in com.usatiuk.dhfs.remoteobj
-
Interface for a remote object.
- JDataRemoteDto - Interface in com.usatiuk.dhfs.remoteobj
-
Marker interface for a DTO class to be used when synchronizing some remote object.
- JDataRemoteDtoP - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JDataRemoteDtoP
- JDataRemoteDtoP.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JDataRemoteDtoP
- JDataRemoteDtoPOrBuilder - Interface in com.usatiuk.dhfs.persistence
- JDataRemotePush - Annotation Interface in com.usatiuk.dhfs.remoteobj
-
Annotation for eagerly pushed remote objects.
- JDataVersionedWrapper - Interface in com.usatiuk.objects
-
JDataVersionedWrapper is a wrapper for JData that contains its version number (the id of the transaction that had changed it last)
- JDataVersionedWrapperImpl - Record Class in com.usatiuk.objects
-
Simple wrapper for an already-existing JData object with a version.
- JDataVersionedWrapperImpl(JData, long) - Constructor for record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Creates an instance of a
JDataVersionedWrapperImpl
record class. - JDataVersionedWrapperLazy - Class in com.usatiuk.objects
-
Lazy JDataVersionedWrapper implementation.
- JDataVersionedWrapperLazy(long, int, Supplier<JData>) - Constructor for class com.usatiuk.objects.JDataVersionedWrapperLazy
-
Creates a new JDataVersionedWrapperLazy object.
- JDataVersionedWrapperSerializer - Class in com.usatiuk.objects
-
Serializer for JDataVersionedWrapper objects.
- JDataVersionedWrapperSerializer() - Constructor for class com.usatiuk.objects.JDataVersionedWrapperSerializer
- JKleppmannTreeInitialSyncProcessor - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreeInitialSyncProcessor() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeInitialSyncProcessor
- JKleppmannTreeManager - Class in com.usatiuk.dhfs.jkleppmanntree
-
Automatically synchronized and persistent Kleppmann tree service.
- JKleppmannTreeManager() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager
- JKleppmannTreeManager.JKleppmannTree - Class in com.usatiuk.dhfs.jkleppmanntree
-
Kleppmann tree wrapper, automatically synchronized and persistent.
- JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreeNode - Record Class in com.usatiuk.dhfs.jkleppmanntree.structs
-
KleppmannTree node implementation for JKleppmannTree
- JKleppmannTreeNode(JObjectKey, JObjectKey, JKleppmannTreeNodeMeta) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- JKleppmannTreeNode(JObjectKey, JObjectKey, OpMove<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>, JKleppmannTreeNodeMeta, PMap<String, JObjectKey>) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Creates an instance of a
JKleppmannTreeNode
record class. - JKleppmannTreeNodeHolder - Record Class in com.usatiuk.dhfs.jkleppmanntree.structs
-
Separate reference counting from JKleppmannTreeNode
- JKleppmannTreeNodeHolder(JKleppmannTreeNode) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- JKleppmannTreeNodeHolder(JKleppmannTreeNode, boolean) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- JKleppmannTreeNodeHolder(PCollection<JDataRef>, boolean, JKleppmannTreeNode) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Creates an instance of a
JKleppmannTreeNodeHolder
record class. - JKleppmannTreeNodeMeta - Interface in com.usatiuk.dhfs.jkleppmanntree.structs
- JKleppmannTreeNodeMetaDirectory - Record Class in com.usatiuk.dhfsfs.objects
-
JKleppmannTreeNodeMetaDirectory is a record that represents a directory in the JKleppmann tree.
- JKleppmannTreeNodeMetaDirectory(String) - Constructor for record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
-
Creates an instance of a
JKleppmannTreeNodeMetaDirectory
record class. - JKleppmannTreeNodeMetaFile - Record Class in com.usatiuk.dhfsfs.objects
-
JKleppmannTreeNodeMetaFile is a record that represents a file in the JKleppmann tree.
- JKleppmannTreeNodeMetaFile(String, JObjectKey) - Constructor for record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Creates an instance of a
JKleppmannTreeNodeMetaFile
record class. - JKleppmannTreeNodeMetaPeer - Record Class in com.usatiuk.dhfs.peersync.structs
- JKleppmannTreeNodeMetaPeer(PeerId) - Constructor for record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
- JKleppmannTreeNodeMetaPeer(String, JObjectKey) - Constructor for record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Creates an instance of a
JKleppmannTreeNodeMetaPeer
record class. - JKleppmannTreeOpExtractor - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreeOpExtractor() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpExtractor
- JKleppmannTreeOpHandler - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreeOpHandler() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpHandler
- JKleppmannTreeOpWrapper - Record Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreeOpWrapper(JObjectKey, OpMove<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Creates an instance of a
JKleppmannTreeOpWrapper
record class. - JKleppmannTreePeerInterface - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreePeerInterface() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeerInterface
- JKleppmannTreePeriodicOpHandler - Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreePeriodicOpHandler() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicOpHandler
- JKleppmannTreePeriodicPushOp - Record Class in com.usatiuk.dhfs.jkleppmanntree
- JKleppmannTreePeriodicPushOp(JObjectKey, PeerId, long) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Creates an instance of a
JKleppmannTreePeriodicPushOp
record class. - JKleppmannTreePersistentData - Record Class in com.usatiuk.dhfs.jkleppmanntree.structs
-
Various persistent data for JKleppmannTree
- JKleppmannTreePersistentData(JObjectKey, PCollection<JDataRef>, boolean, long, PMap<PeerId, PSortedMap<CombinedTimestamp<Long, PeerId>, OpMove<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>>>, PMap<PeerId, Long>, PSortedMap<CombinedTimestamp<Long, PeerId>, LogRecord<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>>) - Constructor for record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Creates an instance of a
JKleppmannTreePersistentData
record class. - JKleppmannTreeStorageInterface() - Constructor for class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- JMapEntry<K> - Record Class in com.usatiuk.dhfs.jmap
- JMapEntry(JObjectKey, JObjectKey, K, JObjectKey) - Constructor for record class com.usatiuk.dhfs.jmap.JMapEntry
-
Creates an instance of a
JMapEntry
record class. - JMapEntry(JObjectKey, K, JObjectKey) - Constructor for record class com.usatiuk.dhfs.jmap.JMapEntry
- JMapHelper - Class in com.usatiuk.dhfs.jmap
-
Persistent-storage backed ordered map service.
- JMapHelper() - Constructor for class com.usatiuk.dhfs.jmap.JMapHelper
- JMapHolder<K> - Interface in com.usatiuk.dhfs.jmap
-
Marker interface that allows an object to hold an ordered key-value map of object references.
- JMapHolderRefcounterTxHook - Class in com.usatiuk.dhfs.jmap
-
This hook is used to delete all the entries of a map in a map holder when the holder is deleted.
- JMapHolderRefcounterTxHook() - Constructor for class com.usatiuk.dhfs.jmap.JMapHolderRefcounterTxHook
- JMapIterator<K> - Class in com.usatiuk.dhfs.jmap
-
Iterates over JMap entries of a given holder.
- JMapIterator(CloseableKvIterator<JObjectKey, JData>, JMapHolder<K>) - Constructor for class com.usatiuk.dhfs.jmap.JMapIterator
- JMapKey - Interface in com.usatiuk.dhfs.jmap
-
Marker interface for JMap keys.
- JMapLongKey - Record Class in com.usatiuk.dhfs.jmap
- JMapLongKey(long) - Constructor for record class com.usatiuk.dhfs.jmap.JMapLongKey
-
Creates an instance of a
JMapLongKey
record class. - JMapRef - Record Class in com.usatiuk.dhfs.jmap
-
A reference from a JMap object to some object.
- JMapRef(JObjectKey, JMapKey) - Constructor for record class com.usatiuk.dhfs.jmap.JMapRef
-
Creates an instance of a
JMapRef
record class. - JMapRefcounterTxHook - Class in com.usatiuk.dhfs.jmap
- JMapRefcounterTxHook() - Constructor for class com.usatiuk.dhfs.jmap.JMapRefcounterTxHook
- JnrPtrByteOutput - Class in com.usatiuk.dhfsfuse
-
JnrPtrByteOutput is a ByteOutput implementation that writes to a `jnr.ffi.Pointer`.
- JnrPtrByteOutput(Pointer, long) - Constructor for class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- JObjectKey - Interface in com.usatiuk.objects
-
JObjectKey is an interface for object keys to be used in the object store.
- JObjectKeyImpl - Class in com.usatiuk.objects
-
A "real" implementation of JObjectKey, containing an underlying string, and a cached lazily created byte buffer.
- JObjectKeyImpl(byte[]) - Constructor for class com.usatiuk.objects.JObjectKeyImpl
- JObjectKeyImpl(String) - Constructor for class com.usatiuk.objects.JObjectKeyImpl
- JObjectKeyMax - Record Class in com.usatiuk.objects
-
JObjectKey implementation that compares greater than all other keys.
- JObjectKeyMax() - Constructor for record class com.usatiuk.objects.JObjectKeyMax
-
Creates an instance of a
JObjectKeyMax
record class. - JObjectKeyMin - Record Class in com.usatiuk.objects
-
JObjectKey implementation that compares less than all other keys.
- JObjectKeyMin() - Constructor for record class com.usatiuk.objects.JObjectKeyMin
-
Creates an instance of a
JObjectKeyMin
record class. - JObjectKeyP - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JObjectKeyP
- JObjectKeyP.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.JObjectKeyP
- JObjectKeyPOrBuilder - Interface in com.usatiuk.dhfs.persistence
- JObjectKeyProtoSerializer - Class in com.usatiuk.dhfs
- JObjectKeyProtoSerializer() - Constructor for class com.usatiuk.dhfs.JObjectKeyProtoSerializer
K
- key() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- key() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.jmap.JMapLongKey
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
- key() - Method in interface com.usatiuk.dhfs.remoteobj.JDataRemote
-
Returns the key of this remote object.
- key() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns the value of the
key
record component. - key() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the ID of the node.
- key() - Method in interface com.usatiuk.objects.JData
-
Returns the key of the object.
- key() - Method in record class com.usatiuk.objects.stores.PendingDelete
-
Returns the value of the
key
record component. - key() - Method in interface com.usatiuk.objects.transaction.TxRecord.TxObjectRecord
- key() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordDeleted
-
Returns the value of the
key
record component. - key() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
- KEY - Static variable in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
- KEY_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- KeyPredicateKvIterator<K,
V> - Class in com.usatiuk.objects.iterators -
A key-value iterator that filters keys based on a predicate.
- KeyPredicateKvIterator(CloseableKvIterator<K, V>, IteratorStart, K, Function<K, Boolean>) - Constructor for class com.usatiuk.objects.iterators.KeyPredicateKvIterator
-
Constructs a KeyPredicateKvIterator with the specified backing iterator, start position, and filter.
- keyToKey(JObjectKey) - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- kickCounter() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns the value of the
kickCounter
record component. - kickCounterSum() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
- KleppmannTree<TimestampT,
PeerIdT, - Class in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
An implementation of a tree as described in A highly-available move operation for replicated trees
- KleppmannTree(StorageInterface<TimestampT, PeerIdT, MetaT, NodeIdT>, PeerInterface<PeerIdT>, Clock<TimestampT>, OpRecorder<TimestampT, PeerIdT, MetaT, NodeIdT>) - Constructor for class com.usatiuk.kleppmanntree.KleppmannTree
-
Constructor with all the dependencies
- knownAddress() - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Returns the value of the
knownAddress
record component. - KnownPeerPut - Record Class in com.usatiuk.dhfs.webapi
- KnownPeerPut(String) - Constructor for record class com.usatiuk.dhfs.webapi.KnownPeerPut
-
Creates an instance of a
KnownPeerPut
record class. - knownPeers() - Method in class com.usatiuk.dhfs.webapi.PeerManagementApi
- knownRemoteVersions() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
knownRemoteVersions
record component. - knownType() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
knownType
record component.
L
- LAN - Enum constant in enum class com.usatiuk.dhfs.peerdiscovery.PeerAddressType
- last() - Static method in interface com.usatiuk.objects.JObjectKey
-
Returns a JObjectKey that compares greater than all other keys.
- lastEffectiveOp() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns the value of the
lastEffectiveOp
record component. - lastEffectiveOp() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the last effective operation that moved this node.
- lastSeenTimestamp() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns the value of the
lastSeenTimestamp
record component. - lastShutdownClean() - Method in class com.usatiuk.dhfs.ShutdownChecker
- LE - Enum constant in enum class com.usatiuk.objects.iterators.IteratorStart
- ListUtils - Class in com.usatiuk.utils
-
Utility class for list operations.
- ListUtils() - Constructor for class com.usatiuk.utils.ListUtils
- LmdbObjectPersistentStore - Class in com.usatiuk.objects.stores
-
Persistent object storage using LMDB
- LmdbObjectPersistentStore(String) - Constructor for class com.usatiuk.objects.stores.LmdbObjectPersistentStore
- LocalPeerDiscoveryBroadcaster - Class in com.usatiuk.dhfs.peerdiscovery.local
-
Broadcasts information about this peer to the local network.
- LocalPeerDiscoveryBroadcaster() - Constructor for class com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryBroadcaster
- LocalPeerDiscoveryClient - Class in com.usatiuk.dhfs.peerdiscovery.local
-
Listens for peer discovery packets from other peers on the local network.
- LocalPeerDiscoveryClient() - Constructor for class com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryClient
- LocalPeerDiscoveryConfig - Interface in com.usatiuk.dhfs.peerdiscovery.local
- lock(Object) - Method in class com.usatiuk.utils.DataLocker
-
Locks the data and returns an AutoCloseable that unlocks it when closed.
- log() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
log
record component. - LogEffect<TimestampT,
PeerIdT, - Record Class in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
LogEffect is a record that represents the effect of a log entry on a tree node.
- LogEffect(LogEffectOld<TimestampT, PeerIdT, MetaT, NodeIdT>, OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>, NodeIdT, MetaT, NodeIdT) - Constructor for record class com.usatiuk.kleppmanntree.LogEffect
-
Creates an instance of a
LogEffect
record class. - LogEffectOld<TimestampT,
PeerIdT, - Record Class in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Represents the old information about a node before it was moved.
- LogEffectOld(OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>, NodeIdT, MetaT) - Constructor for record class com.usatiuk.kleppmanntree.LogEffectOld
-
Creates an instance of a
LogEffectOld
record class. - LogInterface<TimestampT,
PeerIdT, - Interface in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
LogInterface is an interface that allows accessing the log of operations
- LogRecord<TimestampT,
PeerIdT, - Record Class in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Represents a log record in the Kleppmann tree.
- LogRecord(OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>, List<LogEffect<TimestampT, PeerIdT, MetaT, NodeIdT>>) - Constructor for record class com.usatiuk.kleppmanntree.LogRecord
-
Creates an instance of a
LogRecord
record class. - LT - Enum constant in enum class com.usatiuk.objects.iterators.IteratorStart
M
- main(String...) - Static method in class com.usatiuk.dhfsfuse.Main
- Main - Class in com.usatiuk.dhfsfuse
- Main() - Constructor for class com.usatiuk.dhfsfuse.Main
- Main.DhfsStorageServerApp - Class in com.usatiuk.dhfsfuse
- map(List<T>, Function<T, T_V>) - Static method in class com.usatiuk.utils.ListUtils
-
Maps a list using a provided function.
- mapKey() - Method in record class com.usatiuk.dhfs.jmap.JMapRef
-
Returns the value of the
mapKey
record component. - MappingKvIterator<K,
V, - Class in com.usatiuk.objects.iteratorsV_T> -
A mapping key-value iterator that transforms the values of a backing iterator using a specified function.
- MappingKvIterator(CloseableKvIterator<K, V>, Function<V, V_T>) - Constructor for class com.usatiuk.objects.iterators.MappingKvIterator
-
Constructs a MappingKvIterator with the specified backing iterator and transformer function.
- markInitialSyncDone(PeerId) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- max() - Static method in record class com.usatiuk.dhfs.jmap.JMapLongKey
- MAX - Static variable in interface com.usatiuk.objects.JObjectKey
- MaybeTombstone<T> - Interface in com.usatiuk.objects.iterators
- MemoryObjectPersistentStore - Class in com.usatiuk.objects.stores
-
In-memory implementation of the ObjectPersistentStore interface.
- MemoryObjectPersistentStore() - Constructor for class com.usatiuk.objects.stores.MemoryObjectPersistentStore
- merge(T, Function<T, T>) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Merges the object with the old one.
- mergeChangelog(ObjectChangelog) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- mergeFrom(Message) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- mergeFrom(PeerDiscoveryInfo) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- mergeFrom(JDataP) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- mergeFrom(JDataRemoteDtoP) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- mergeFrom(JObjectKeyP) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- mergeFrom(ObjectChangelog) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- mergeFrom(ObjectChangelog.entries_Entry) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- mergeFrom(PeerIdP) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- mergeFrom(CanDeleteReply) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- mergeFrom(CanDeleteRequest) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- mergeFrom(GetObjectReply) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- mergeFrom(GetObjectRequest) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- mergeFrom(OpP) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- mergeFrom(OpPushReply) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- mergeFrom(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- mergeFrom(PingReply) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- mergeFrom(PingRequest) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- mergeId(JObjectKeyP) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- mergeKey(PeerIdP) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- mergeName(JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- mergeName(JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- mergePushedData(JDataRemoteDtoP) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- MergingKvIterator<K,
V> - Class in com.usatiuk.objects.iterators -
A merging key-value iterator that combines multiple iterators into a single iterator.
- MergingKvIterator(IteratorStart, K, CloseableKvIterator<K, V>...) - Constructor for class com.usatiuk.objects.iterators.MergingKvIterator
-
Constructs a MergingKvIterator with the specified start type, start key, and array of iterators.
- MergingKvIterator(IteratorStart, K, List<CloseableKvIterator<K, V>>) - Constructor for class com.usatiuk.objects.iterators.MergingKvIterator
-
Constructs a MergingKvIterator with the specified start type, start key, and list of iterators.
- meta() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns the value of the
meta
record component. - meta() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the metadata stored in this node.
- MIN - Static variable in interface com.usatiuk.objects.JObjectKey
- mkdir(String, long) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Create a new directory with the given name and mode.
- mkdir(String, long) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- mode() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns the value of the
mode
record component. - mode() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns the value of the
mode
record component. - move(JObjectKey, JKleppmannTreeNodeMeta, JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Move a node to a new parent.
- move(NodeIdT, LocalMetaT, NodeIdT) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Move a node to a new parent with new metadata
- move(NodeIdT, MetaT, NodeIdT, boolean) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Move a node to a new parent with new metadata
- MSG_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.OpPushRequest
- mtime() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns the value of the
mtime
record component. - mTime() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns the value of the
mTime
record component. - MutinyDhfsObjectSyncGrpcGrpc - Class in com.usatiuk.dhfs.repository
- MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase - Class in com.usatiuk.dhfs.repository
- MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub - Class in com.usatiuk.dhfs.repository
N
- name() - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Returns the value of the
name
record component. - name() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
-
Returns the value of the
name
record component. - name() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Returns the value of the
name
record component. - name() - Method in interface com.usatiuk.kleppmanntree.NodeMeta
-
Returns the name of the node.
- name() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the name of the node.
- NAME_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.JObjectKeyP
- NAME_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.CanDeleteRequest
- NAME_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.GetObjectRequest
- NavigableMapKvIterator<K,
V> - Class in com.usatiuk.objects.iterators -
A key-value iterator for a
NavigableMap
. - NavigableMapKvIterator(NavigableMap<K, ? extends V>, IteratorStart, K) - Constructor for class com.usatiuk.objects.iterators.NavigableMapKvIterator
-
Constructs a NavigableMapKvIterator with the specified map, start type, and start key.
- newBlockingStub(Channel) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
-
Creates a new blocking-style stub that supports unary and streaming output calls on the service
- newBuilder() - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.JDataP
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- newBuilder() - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.OpP
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.PingReply
- newBuilder() - Static method in class com.usatiuk.dhfs.repository.PingRequest
- newBuilder(PeerDiscoveryInfo) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- newBuilder(JDataP) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- newBuilder(JDataRemoteDtoP) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- newBuilder(JObjectKeyP) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- newBuilder(ObjectChangelog) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- newBuilder(ObjectChangelog.entries_Entry) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- newBuilder(PeerIdP) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- newBuilder(CanDeleteReply) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- newBuilder(CanDeleteRequest) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- newBuilder(GetObjectReply) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- newBuilder(GetObjectRequest) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- newBuilder(OpP) - Static method in class com.usatiuk.dhfs.repository.OpP
- newBuilder(OpPushReply) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- newBuilder(OpPushRequest) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- newBuilder(PingReply) - Static method in class com.usatiuk.dhfs.repository.PingReply
- newBuilder(PingRequest) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- newBuilderForType() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.JDataP
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- newBuilderForType() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.OpP
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.PingReply
- newBuilderForType() - Method in class com.usatiuk.dhfs.repository.PingRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.JDataP
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.OpP
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.OpPushReply
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.PingReply
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.usatiuk.dhfs.repository.PingRequest
- NEWER - Enum constant in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
- newestSlice(CombinedTimestamp<TimestampT, PeerIdT>, boolean) - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Return all log entries that are newer than the given timestamp.
- newFutureStub(Channel) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
-
Creates a new ListenableFuture-style stub that supports unary calls on the service
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.JDataP
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.OpP
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.OpPushReply
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.PingReply
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class com.usatiuk.dhfs.repository.PingRequest
- newInstanceWithStub(MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- newMeta() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns the value of the
newMeta
record component. - newMeta() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns the value of the
newMeta
record component. - newMutinyStub(Channel) - Static method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc
- newName() - Method in record class com.usatiuk.kleppmanntree.LogEffect
- newName() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns the new name of the node: name extracted from the new metadata if available, otherwise the child ID converted to string.
- newParentId() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns the value of the
newParentId
record component. - newParentId() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns the value of the
newParentId
record component. - newStub(Channel) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
-
Creates a new async stub that supports all call types for the service
- next() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- next() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- next() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- next() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- nextImpl() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- nextImpl() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- nextImpl() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- nextImpl() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
Returns the next element in the iterator, depending on the current direction.
- nextImpl() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- NIO - Static variable in class com.usatiuk.utils.UnsafeAccessor
- node() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Returns the value of the
node
record component. - nodeId() - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Returns the value of the
nodeId
record component. - nodeIdToPeerId(JObjectKey) - Static method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
- NodeMeta - Interface in com.usatiuk.kleppmanntree
-
Represents metadata associated with a node in the Kleppmann tree.
- notifyAddr(PeerAddress) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryDirectory
-
Notifies the directory about a new address for a peer.
O
- obj() - Method in record class com.usatiuk.dhfs.jmap.JMapRef
- obj() - Method in record class com.usatiuk.dhfs.refcount.JDataNormalRef
-
Returns the value of the
obj
record component. - obj() - Method in interface com.usatiuk.dhfs.refcount.JDataRef
- objClass() - Method in interface com.usatiuk.dhfs.remoteobj.JDataRemoteDto
-
Returns the class of the remote object that this DTO represents.
- objClass() - Method in record class com.usatiuk.dhfsfs.objects.FileDto
- ObjectChangelog - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.ObjectChangelog
- ObjectChangelog.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.ObjectChangelog
- ObjectChangelog.entries_Entry - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.ObjectChangelog.entries_Entry
- ObjectChangelog.entries_Entry.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.ObjectChangelog.entries_Entry
- ObjectChangelog.entries_EntryOrBuilder - Interface in com.usatiuk.dhfs.persistence
- ObjectChangelogOrBuilder - Interface in com.usatiuk.dhfs.persistence
- ObjectPersistentStore - Interface in com.usatiuk.objects.stores
-
Interface for a persistent store of objects.
- ObjectSerializer<T> - Interface in com.usatiuk.objects
-
Interface for serializing and deserializing objects.
- ObjSyncHandler<T,
D> - Interface in com.usatiuk.dhfs.remoteobj -
Interface for handling remote updates of objects.
- of(long) - Static method in record class com.usatiuk.dhfs.jmap.JMapLongKey
- of(String) - Static method in record class com.usatiuk.dhfs.peersync.PeerId
- of(String) - Static method in interface com.usatiuk.objects.JObjectKey
-
Creates a new JObjectKey from a string value.
- ofDataKey(JObjectKey) - Static method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- ofMetaKey(JObjectKey) - Static method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- oldEffectiveMove() - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Returns the value of the
oldEffectiveMove
record component. - OLDER - Enum constant in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
- oldInfo() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns the value of the
oldInfo
record component. - oldMeta() - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Returns the value of the
oldMeta
record component. - oldName() - Method in record class com.usatiuk.kleppmanntree.LogEffect
- oldParent() - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Returns the value of the
oldParent
record component. - onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.autosync.AutosyncTxHook
- onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.jmap.JMapRefcounterTxHook
- onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.peertrust.PeerInfoCertUpdateTxHook
- onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.refcount.DeleterTxHook
- onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.refcount.RefcounterTxHook
- onChange(JObjectKey, JData, JData) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjPusherTxHook
- onChange(JObjectKey, JData, JData) - Method in interface com.usatiuk.objects.transaction.PreCommitTxHook
- onCommit(Runnable) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- onCommit(Runnable) - Method in interface com.usatiuk.objects.transaction.Transaction
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.autosync.AutosyncTxHook
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.jmap.JMapRefcounterTxHook
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.peertrust.PeerInfoCertUpdateTxHook
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.refcount.DeleterTxHook
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.refcount.RefcounterTxHook
- onCreate(JObjectKey, JData) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjPusherTxHook
- onCreate(JObjectKey, JData) - Method in interface com.usatiuk.objects.transaction.PreCommitTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.autosync.AutosyncTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.jmap.JMapHolderRefcounterTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.jmap.JMapRefcounterTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.peertrust.PeerInfoCertUpdateTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.refcount.DeleterTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.refcount.RefcounterTxHook
- onDelete(JObjectKey, JData) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjPusherTxHook
- onDelete(JObjectKey, JData) - Method in interface com.usatiuk.objects.transaction.PreCommitTxHook
- onFlush(Runnable) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- onFlush(Runnable) - Method in interface com.usatiuk.objects.transaction.TransactionHandle
- op() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Returns the value of the
op
record component. - op() - Method in record class com.usatiuk.kleppmanntree.LogRecord
-
Returns the value of the
op
record component. - Op - Interface in com.usatiuk.dhfs.invalidation
-
Represents a unit of information to be sent to another peer.
- open(String) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Try to resolve a path to a file or directory.
- open(String, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- OpExtractor<T> - Interface in com.usatiuk.dhfs.invalidation
-
Interface for extracting operations from data objects.
- OpExtractorService - Class in com.usatiuk.dhfs.invalidation
-
Service for extracting operations from JData objects.
- OpExtractorService(Instance<OpExtractor<?>>) - Constructor for class com.usatiuk.dhfs.invalidation.OpExtractorService
- OpHandler<T> - Interface in com.usatiuk.dhfs.invalidation
-
Interface for handling operations.
- OpHandlerService - Class in com.usatiuk.dhfs.invalidation
-
Service for handling operations.
- OpHandlerService(Instance<OpHandler<?>>) - Constructor for class com.usatiuk.dhfs.invalidation.OpHandlerService
- OpMove<TimestampT,
PeerIdT, - Record Class in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Operation that moves a child node to a new parent node.
- OpMove(CombinedTimestamp<TimestampT, PeerIdT>, NodeIdT, MetaT, NodeIdT) - Constructor for record class com.usatiuk.kleppmanntree.OpMove
-
Creates an instance of a
OpMove
record class. - OpP - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpP
- OpP.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpP
- OpPOrBuilder - Interface in com.usatiuk.dhfs.repository
- opPush(PeerId, OpPushRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- opPush(OpPushRequest) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpc
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcBean
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub
- opPush(OpPushRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- opPush(OpPushRequest, StreamObserver<OpPushReply>) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.AsyncService
- opPush(OpPushRequest, StreamObserver<OpPushReply>) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub
- OpPushReply - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpPushReply
- OpPushReply.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpPushReply
- OpPushReplyOrBuilder - Interface in com.usatiuk.dhfs.repository
- OpPushRequest - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpPushRequest
- OpPushRequest.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.OpPushRequest
- OpPushRequestOrBuilder - Interface in com.usatiuk.dhfs.repository
- OpRecorder<TimestampT,
PeerIdT, - Interface in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Interface to provide recording operations to be sent to peers asynchronously.
- OpSerializer - Class in com.usatiuk.dhfs
- OpSerializer() - Constructor for class com.usatiuk.dhfs.OpSerializer
P
- parent() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns the value of the
parent
record component. - parent() - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Get the ID of the parent node.
- parse(String) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerAddrStringHelper
-
Parses a string into an IpPeerAddress object.
- parsedCert() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseDelimitedFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(byte[]) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(ByteString) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(CodedInputStream) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(InputStream) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(ByteBuffer) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpP
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingReply
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.PingRequest
- parseNoPeer(PeerId, String) - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerAddrStringHelper
-
Parses a string into an IpPeerAddress object, with a manually provided peer ID.
- parser() - Static method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- parser() - Static method in class com.usatiuk.dhfs.persistence.JDataP
- parser() - Static method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- parser() - Static method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- parser() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- parser() - Static method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- parser() - Static method in class com.usatiuk.dhfs.persistence.PeerIdP
- parser() - Static method in class com.usatiuk.dhfs.repository.CanDeleteReply
- parser() - Static method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- parser() - Static method in class com.usatiuk.dhfs.repository.GetObjectReply
- parser() - Static method in class com.usatiuk.dhfs.repository.GetObjectRequest
- parser() - Static method in class com.usatiuk.dhfs.repository.OpP
- parser() - Static method in class com.usatiuk.dhfs.repository.OpPushReply
- parser() - Static method in class com.usatiuk.dhfs.repository.OpPushRequest
- parser() - Static method in class com.usatiuk.dhfs.repository.PingReply
- parser() - Static method in class com.usatiuk.dhfs.repository.PingRequest
- peekImpl() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- peekImpl() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- peekImpl() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- peekImpl() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
Fills the next element in the iterator, depending on the current direction.
- peekImpl() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- peekNewest() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Peek the newest log entry.
- peekNextKey() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- peekNextKey() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Returns the upcoming key in the forward direction without advancing the iterator.
- peekNextKey() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- peekNextKey() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- peekNextKey() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- peekOldest() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Peek the oldest log entry.
- peekPrevKey() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- peekPrevKey() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Checks if there is a next element in the forward direction.
- peekPrevKey() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- peekPrevKey() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- peekPrevKey() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- peekTimestamp() - Method in interface com.usatiuk.kleppmanntree.Clock
-
Get the current timestamp without incrementing it.
- peer() - Method in record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Returns the value of the
peer
record component. - peer() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns the value of the
peer
record component. - peer() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerAddress
-
Returns the peer ID associated with this address.
- PeerAddress - Interface in com.usatiuk.dhfs.peerdiscovery
-
Peer address interface, can be used to represent different types of peer addresses, not only IP.
- PeerAddressInfo - Record Class in com.usatiuk.dhfs.webapi
- PeerAddressInfo(String, String) - Constructor for record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Creates an instance of a
PeerAddressInfo
record class. - PeerAddressType - Enum Class in com.usatiuk.dhfs.peerdiscovery
- PeerAddrStringHelper - Class in com.usatiuk.dhfs.peerdiscovery
-
Helper class for parsing peer addresses from strings.
- PeerAddrStringHelper() - Constructor for class com.usatiuk.dhfs.peerdiscovery.PeerAddrStringHelper
- PeerConnectedEventListener - Interface in com.usatiuk.dhfs.peersync
-
Listener for peer connected events.
- PeerDisconnectedEventListener - Interface in com.usatiuk.dhfs.peersync
-
Listener for peer disconnected events.
- PeerDiscoveryDirectory - Class in com.usatiuk.dhfs.peerdiscovery
-
Peer discovery directory collects known peer addresses, and automatically cleans up old entries.
- PeerDiscoveryDirectory() - Constructor for class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryDirectory
- PeerDiscoveryInfo - Class in com.usatiuk.dhfs.peerdiscovery
-
Protobuf type
dhfs.peerdiscovery.PeerDiscoveryInfo
- PeerDiscoveryInfo.Builder - Class in com.usatiuk.dhfs.peerdiscovery
-
Protobuf type
dhfs.peerdiscovery.PeerDiscoveryInfo
- PeerDiscoveryInfoOrBuilder - Interface in com.usatiuk.dhfs.peerdiscovery
- peerId() - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Returns the value of the
peerId
record component. - PeerId - Record Class in com.usatiuk.dhfs.peersync
-
Represents a peer ID Type-safe wrapper for JObjectKey
- PeerId(JObjectKey) - Constructor for record class com.usatiuk.dhfs.peersync.PeerId
-
Creates an instance of a
PeerId
record class. - PeerIdP - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.PeerIdP
- PeerIdP.Builder - Class in com.usatiuk.dhfs.persistence
-
Protobuf type
dhfs.persistence.PeerIdP
- PeerIdPOrBuilder - Interface in com.usatiuk.dhfs.persistence
- peerIdToNodeId(PeerId) - Static method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
- PeerInfo - Record Class in com.usatiuk.dhfs.peersync
-
Represents 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 notification - PeerInfo - Record Class in com.usatiuk.dhfs.webapi
- PeerInfo(PeerId, byte[]) - Constructor for record class com.usatiuk.dhfs.peersync.PeerInfo
- PeerInfo(JObjectKey, PeerId, ByteString, PMap<PeerId, Long>, long) - Constructor for record class com.usatiuk.dhfs.peersync.PeerInfo
-
Creates an instance of a
PeerInfo
record class. - PeerInfo(String, String, String) - Constructor for record class com.usatiuk.dhfs.webapi.PeerInfo
-
Creates an instance of a
PeerInfo
record class. - PeerInfoCertUpdateTxHook - Class in com.usatiuk.dhfs.peertrust
-
Automatically refreshes certificates in the trust manager for peers when their info is updated.
- PeerInfoCertUpdateTxHook() - Constructor for class com.usatiuk.dhfs.peertrust.PeerInfoCertUpdateTxHook
- PeerInfoService - Class in com.usatiuk.dhfs.peersync
-
Service for managing information about peers connected to the cluster.
- PeerInfoService() - Constructor for class com.usatiuk.dhfs.peersync.PeerInfoService
- PeerInfoSyncHandler - Class in com.usatiuk.dhfs.peersync
- PeerInfoSyncHandler() - Constructor for class com.usatiuk.dhfs.peersync.PeerInfoSyncHandler
- PeerInterface<PeerIdT> - Interface in com.usatiuk.kleppmanntree
-
Interface providing access to a list of known peers.
- PeerLastSeenUpdater - Class in com.usatiuk.dhfs.peersync
-
Periodically updates the last seen timestamp of reachable peers and increments the kick counter for unreachable peers.
- PeerLastSeenUpdater() - Constructor for class com.usatiuk.dhfs.peersync.PeerLastSeenUpdater
- PeerManagementApi - Class in com.usatiuk.dhfs.webapi
- PeerManagementApi() - Constructor for class com.usatiuk.dhfs.webapi.PeerManagementApi
- PeerRolesAugmentor - Class in com.usatiuk.dhfs.peertrust
-
Augments the security identity of peers that are members of the cluster.
- PeerRolesAugmentor() - Constructor for class com.usatiuk.dhfs.peertrust.PeerRolesAugmentor
- PeerSyncApi - Class in com.usatiuk.dhfs.peersync.api
-
Provides information about the peer publicly, without any authentication.
- PeerSyncApi() - Constructor for class com.usatiuk.dhfs.peersync.api.PeerSyncApi
- PeerSyncApiClient - Interface in com.usatiuk.dhfs.peersync.api
- PeerSyncApiClientDynamic - Class in com.usatiuk.dhfs.peersync.api
-
Allows to query peers about their information, even if peer isn't part of the cluster.
- PeerSyncApiClientDynamic() - Constructor for class com.usatiuk.dhfs.peersync.api.PeerSyncApiClientDynamic
- peerTimestampLog() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
peerTimestampLog
record component. - PeerTimestampLogInterface<TimestampT,
PeerIdT> - Interface in com.usatiuk.kleppmanntree -
Interface providing a map of newest received timestamps for each peer.
- PeerTrustManager - Class in com.usatiuk.dhfs.peertrust
-
Custom trust manager that trusts the certificates of peers in the cluster.
- PeerTrustManager() - Constructor for class com.usatiuk.dhfs.peertrust.PeerTrustManager
- PeerTrustServerCustomizer - Class in com.usatiuk.dhfs.peertrust
-
Customizes the HTTP server options to use the peer trust manager and the self-signed certificate.
- PeerTrustServerCustomizer() - Constructor for class com.usatiuk.dhfs.peertrust.PeerTrustServerCustomizer
- PendingDelete - Record Class in com.usatiuk.objects.stores
- PendingDelete(JObjectKey, long) - Constructor for record class com.usatiuk.objects.stores.PendingDelete
-
Creates an instance of a
PendingDelete
record class. - PendingWrite - Record Class in com.usatiuk.objects.stores
- PendingWrite(JDataVersionedWrapper, long) - Constructor for record class com.usatiuk.objects.stores.PendingWrite
-
Creates an instance of a
PendingWrite
record class. - PendingWriteEntry - Interface in com.usatiuk.objects.stores
- persistentPeerAddress() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns the value of the
persistentPeerAddress
record component. - PersistentPeerAddressApi - Class in com.usatiuk.dhfs.webapi
-
Simple API for managing connected peers and manually specifying their addresses.
- PersistentPeerAddressApi() - Constructor for class com.usatiuk.dhfs.webapi.PersistentPeerAddressApi
- PersistentPeerDataService - Class in com.usatiuk.dhfs.peersync
-
Handles various locally relevant persistent data related to peers, such as local peer's UUID, certificate, and persistent peer addresses.
- PersistentPeerDataService() - Constructor for class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- PersistentRemoteHostsData - Record Class in com.usatiuk.dhfs.peersync
- PersistentRemoteHostsData(PeerId, ByteString, ByteString, PSet<PeerId>, PMap<PeerId, IpPeerAddress>) - Constructor for record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Creates an instance of a
PersistentRemoteHostsData
record class. - PersistentStaticPeerDiscovery - Class in com.usatiuk.dhfs.peerdiscovery
-
Notified PeerDiscoveryDirectory about manually added peer addresses.
- PersistentStaticPeerDiscovery() - Constructor for class com.usatiuk.dhfs.peerdiscovery.PersistentStaticPeerDiscovery
- ping(PeerId, PingRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- ping(PingRequest) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpc
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcBean
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcClient
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcBlockingStub
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcFutureStub
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
- ping(PingRequest) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.MutinyDhfsObjectSyncGrpcStub
- ping(PingRequest) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- ping(PingRequest, StreamObserver<PingReply>) - Method in interface com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.AsyncService
- ping(PingRequest, StreamObserver<PingReply>) - Method in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcStub
- PingReply - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.PingReply
- PingReply.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.PingReply
- PingReplyOrBuilder - Interface in com.usatiuk.dhfs.repository
- PingRequest - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.PingRequest
- PingRequest.Builder - Class in com.usatiuk.dhfs.repository
-
Protobuf type
dhfs.sync.PingRequest
- PingRequestOrBuilder - Interface in com.usatiuk.dhfs.repository
- port() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns the value of the
port
record component. - port() - Method in interface com.usatiuk.dhfs.peerdiscovery.local.LocalPeerDiscoveryConfig
- PORT_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- PreCommitTxHook - Interface in com.usatiuk.objects.transaction
- prepareForInitialSync(PeerId, JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeInitialSyncProcessor
- prepareForInitialSync(PeerId, JObjectKey) - Method in interface com.usatiuk.dhfs.peersync.InitialSyncProcessor
-
Called when the peer is connected for the first time (or needs to be re-synced).
- prepareForInitialSync(PeerId, JObjectKey) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjectInitialSyncProcessor
- prepend(T, List<T>) - Static method in class com.usatiuk.utils.ListUtils
-
Prepends an item to a list.
- prependAndMap(T_V, List<T>, Function<T, T_V>) - Static method in class com.usatiuk.utils.ListUtils
-
Prepends an item to a list and maps the rest of the list using a provided function.
- prev() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- prev() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Returns the key-value pair in the reverse direction, and advances the iterator.
- prev() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- prev() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- prev() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- ProtoSerializer<M,
O> - Interface in com.usatiuk.dhfs - PROXY - Enum constant in enum class com.usatiuk.dhfs.peerdiscovery.PeerAddressType
- PUSHEDDATA_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.GetObjectReply
- pushInvalidationToAll(JObjectKey) - Method in class com.usatiuk.dhfs.invalidation.InvalidationQueueService
-
Extract operations from an object for all peers and push them.
- pushInvalidationToOne(PeerId, JObjectKey) - Method in class com.usatiuk.dhfs.invalidation.InvalidationQueueService
-
Extract operations from an object for some specific peer and push them.
- pushInvalidationToOneNoDelay(PeerId, JObjectKey) - Method in class com.usatiuk.dhfs.invalidation.InvalidationQueueService
-
Extract operations from an object for some specific peer and push them, without delay.
- pushOps(PeerId, List<Op>) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectServiceClient
-
Push a list of operations to a specific peer.
- put(JMapHolder<K>, K, JObjectKey) - Method in class com.usatiuk.dhfs.jmap.JMapHelper
-
Put a new entry into the map of a given holder.
- put(CombinedTimestamp<TimestampT, PeerIdT>, LogRecord<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Add a log entry to the log.
- put(JData) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- put(JData) - Method in interface com.usatiuk.objects.transaction.Transaction
- putData(T) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Put the data of a remote object into the storage, either creating a new object or updating an existing one.
- putDataNew(T) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Put the data of a remote object into the storage, creating a new object.
- putDataRaw(T) - Method in class com.usatiuk.dhfs.remoteobj.RemoteTransaction
-
Put the data of a remote object into the storage, without incrementing the version vector.
- putDeletionCandidate(RemoteObjectMeta) - Method in class com.usatiuk.dhfs.remoteobj.RemoteObjectDeleter
-
Add a deletion candidate to the queue.
- putForPeer(PeerIdT, TimestampT) - Method in interface com.usatiuk.kleppmanntree.PeerTimestampLogInterface
-
Get the timestamp for the current peer.
- putNew(JData) - Method in class com.usatiuk.objects.transaction.CurrentTransaction
- putNew(JData) - Method in interface com.usatiuk.objects.transaction.Transaction
- putNode(TreeNode<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- putNode(TreeNode<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Put a node into the storage.
- putPeer(PeerId, byte[]) - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Add a new peer to the cluster.
Q
- queues() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
queues
record component.
R
- random() - Static method in interface com.usatiuk.objects.JObjectKey
-
Creates a new JObjectKey with a random UUID.
- ReachablePeerManager - Class in com.usatiuk.dhfs.peersync
-
Handles connections to known peers in the cluster.
- ReachablePeerManager(Instance<PeerConnectedEventListener>, Instance<PeerDisconnectedEventListener>) - Constructor for class com.usatiuk.dhfs.peersync.ReachablePeerManager
- ReachablePeerManager.HostStateSnapshot - Record Class in com.usatiuk.dhfs.peersync
- read(JObjectKey, long, int) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Read the contents of a file.
- read(String, Pointer, long, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- readd(T) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Adds the object to the queue, if it exists re-adds it with a new delay
- readdir(String, Pointer, FuseFillDir, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- readDir(String) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Read the contents of a directory.
- readlink(JObjectKey) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Read the contents of a symlink.
- readlink(String, Pointer, long) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- readlinkBS(JObjectKey) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Read the contents of a symlink as a ByteString.
- readObject(K) - Method in interface com.usatiuk.objects.snapshot.Snapshot
-
Read an object from the snapshot.
- ReceivedObject - Record Class in com.usatiuk.dhfs.remoteobj
- ReceivedObject(PMap<PeerId, Long>, JDataRemoteDto) - Constructor for record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Creates an instance of a
ReceivedObject
record class. - ReceivedObjectSerializer - Class in com.usatiuk.dhfs.rpc
- ReceivedObjectSerializer() - Constructor for class com.usatiuk.dhfs.rpc.ReceivedObjectSerializer
- recordBoostrapFor(PeerIdT) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Record the bootstrap operations for a given peer Will visit all nodes of the tree and add their effective operations to both the queue to be sent to the peer, and to the global operation log.
- recordBootstrap(PeerId) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Record bootstrap operations for the given host.
- recordOp(OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.OpRecorder
-
Records an operation to be sent to peers asynchronously.
- recordOpForPeer(PeerIdT, OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.OpRecorder
-
Records an operation to be sent to a specific peer asynchronously.
- ref() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns the value of the
ref
record component. - RefcounterTxHook - Class in com.usatiuk.dhfs.refcount
- RefcounterTxHook() - Constructor for class com.usatiuk.dhfs.refcount.RefcounterTxHook
- REFERRERS_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.CanDeleteReply
- refsFrom() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Returns the value of the
refsFrom
record component. - refsFrom() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns the value of the
refsFrom
record component. - refsFrom() - Method in interface com.usatiuk.dhfs.refcount.JDataRefcounted
-
Returns list of incoming references to this object.
- refsFrom() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns the value of the
refsFrom
record component. - refsFrom() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
refsFrom
record component. - registerAllExtensions(ExtensionRegistry) - Static method in class com.usatiuk.dhfs.peerdiscovery.DhfsObjectPeerDiscoveryApi
- registerAllExtensions(ExtensionRegistry) - Static method in class com.usatiuk.dhfs.persistence.DhfsObjectPersistence
- registerAllExtensions(ExtensionRegistry) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncApi
- registerAllExtensions(ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.peerdiscovery.DhfsObjectPeerDiscoveryApi
- registerAllExtensions(ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.persistence.DhfsObjectPersistence
- registerAllExtensions(ExtensionRegistryLite) - Static method in class com.usatiuk.dhfs.repository.DhfsObjectSyncApi
- release(String, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- reloadTrustManagerHosts(Collection<PeerInfo>) - Method in class com.usatiuk.dhfs.peertrust.PeerTrustManager
- RemoteObjectDataWrapper<T> - Record Class in com.usatiuk.dhfs.remoteobj
-
Wrapper for remote object data.
- RemoteObjectDataWrapper(JObjectKey, PCollection<JDataRef>, boolean, T) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Creates an instance of a
RemoteObjectDataWrapper
record class. - RemoteObjectDataWrapper(T) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- RemoteObjectDeleter - Class in com.usatiuk.dhfs.remoteobj
-
Handles deletion of remote objects, asynchronously.
- RemoteObjectDeleter(long, long) - Constructor for class com.usatiuk.dhfs.remoteobj.RemoteObjectDeleter
- RemoteObjectInitialSyncProcessor - Class in com.usatiuk.dhfs.remoteobj
- RemoteObjectInitialSyncProcessor() - Constructor for class com.usatiuk.dhfs.remoteobj.RemoteObjectInitialSyncProcessor
- RemoteObjectMeta - Record Class in com.usatiuk.dhfs.remoteobj
-
Metadata for remote objects.
- RemoteObjectMeta(JDataRemote, PeerId) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- RemoteObjectMeta(JObjectKey) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- RemoteObjectMeta(JObjectKey, PCollection<JDataRef>, boolean, PMap<PeerId, Long>, Class<? extends JDataRemote>, PSet<PeerId>, boolean, PMap<PeerId, Long>, boolean) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Creates an instance of a
RemoteObjectMeta
record class. - RemoteObjectMeta(JObjectKey, PMap<PeerId, Long>) - Constructor for record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- RemoteObjectMetaOpExtractor - Class in com.usatiuk.dhfs.invalidation
- RemoteObjectMetaOpExtractor() - Constructor for class com.usatiuk.dhfs.invalidation.RemoteObjectMetaOpExtractor
- RemoteObjectSerializer - Class in com.usatiuk.dhfs.rpc
- RemoteObjectSerializer() - Constructor for class com.usatiuk.dhfs.rpc.RemoteObjectSerializer
- RemoteObjectServiceClient - Class in com.usatiuk.dhfs.rpc
-
Helper class for calling remote peers RPCs.
- RemoteObjectServiceClient() - Constructor for class com.usatiuk.dhfs.rpc.RemoteObjectServiceClient
- RemoteObjectServiceServer - Class in com.usatiuk.dhfs.rpc
- RemoteObjectServiceServer() - Constructor for class com.usatiuk.dhfs.rpc.RemoteObjectServiceServer
- RemoteObjPusherTxHook - Class in com.usatiuk.dhfs.remoteobj
-
Transaction hook to automatically notify
InvalidationQueueService
about changed objects. - RemoteObjPusherTxHook() - Constructor for class com.usatiuk.dhfs.remoteobj.RemoteObjPusherTxHook
- RemoteTransaction - Class in com.usatiuk.dhfs.remoteobj
-
Helper class for working with remote objects.
- RemoteTransaction() - Constructor for class com.usatiuk.dhfs.remoteobj.RemoteTransaction
- remove(T) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Removes the object from the queue.
- removeEntries(int) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- removeMsg(int) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- removeNode(JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree.JKleppmannTreeStorageInterface
- removeNode(NodeIdT) - Method in interface com.usatiuk.kleppmanntree.StorageInterface
-
Remove a node from the storage.
- removePeer(PeerId) - Method in class com.usatiuk.dhfs.peersync.PeerInfoService
-
Remove a peer from the cluster.
- removePersistentPeerAddress(PeerId) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- removeReferrers(int) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- removeRemoteHost(PeerId) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Removes the given host from the cluster
- rename(String, String) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Rename a file or directory.
- rename(String, String) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- replace(CombinedTimestamp<TimestampT, PeerIdT>, LogRecord<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Replace a log entry in the log.
- replaceChunks(File, List<Pair<Long, JObjectKey>>) - Method in class com.usatiuk.dhfsfs.objects.FileHelper
-
Replace the chunks of a file.
- resetInitialSyncDone(PeerId) - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- resyncAfterCrash(StartupEvent) - Method in class com.usatiuk.dhfs.remoteobj.SyncHandler
-
Resync objects after a crash.
- reverse() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- reverse() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- reverse() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- reverse() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
Reverses the current direction of the iterator.
- reverse() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- reversed() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Returns a reversed iterator that iterates in the reverse direction.
- reversed() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- ReversedKvIterator<K,
V> - Class in com.usatiuk.objects.iterators -
A wrapper for a key-value iterator that iterates in reverse order.
- ReversedKvIterator(CloseableKvIterator<K, V>) - Constructor for class com.usatiuk.objects.iterators.ReversedKvIterator
-
Constructs a ReversedKvIterator with the specified backing iterator.
- ReversibleKvIterator<K,
V> - Class in com.usatiuk.objects.iterators -
Base class for a reversible key-value iterator.
- ReversibleKvIterator() - Constructor for class com.usatiuk.objects.iterators.ReversibleKvIterator
- rmdir(String) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- rollback() - Method in interface com.usatiuk.objects.transaction.TransactionManager
- rollback() - Method in class com.usatiuk.objects.transaction.TransactionManagerImpl
- rollback(TransactionImpl) - Method in class com.usatiuk.objects.transaction.TransactionService
- RpcChannelFactory - Class in com.usatiuk.dhfs.rpc
-
Factory for creating gRPC channels
- RpcChannelFactory() - Constructor for class com.usatiuk.dhfs.rpc.RpcChannelFactory
- RpcClientFactory - Class in com.usatiuk.dhfs.rpc
-
Factory for creating gRPC clients for object synchronization and other RPC calls.
- RpcClientFactory() - Constructor for class com.usatiuk.dhfs.rpc.RpcClientFactory
- RpcClientFactory.ObjectSyncClientFunction<R> - Interface in com.usatiuk.dhfs.rpc
- run(Runnable) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- run(Runnable, boolean) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- run(String...) - Method in class com.usatiuk.dhfsfuse.Main.DhfsStorageServerApp
- run(Supplier<T>) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- run(Supplier<T>, boolean) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- runTries(Runnable, int) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- runTries(Runnable, int, boolean) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- runTries(Supplier<T>, int) - Method in interface com.usatiuk.objects.transaction.TransactionManager
- runTries(Supplier<T>, int, boolean) - Method in interface com.usatiuk.objects.transaction.TransactionManager
S
- securePort() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns the value of the
securePort
record component. - SECUREPORT_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- seen() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns the value of the
seen
record component. - selectBestAddress(PeerId) - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
-
Selects the best address for the given host.
- selfCertificate() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns the value of the
selfCertificate
record component. - SelfInfo - Record Class in com.usatiuk.dhfs.webapi
- SelfInfo(String, String) - Constructor for record class com.usatiuk.dhfs.webapi.SelfInfo
-
Creates an instance of a
SelfInfo
record class. - selfKey() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns the value of the
selfKey
record component. - selfKeyPair() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns the value of the
selfKeyPair
record component. - selfUuid() - Method in record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Returns the value of the
selfUuid
record component. - selfUuid() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns the value of the
selfUuid
record component. - SerializationHelper - Class in com.usatiuk.utils
-
Utility class for serialization and deserialization of objects.
- SerializationHelper() - Constructor for class com.usatiuk.utils.SerializationHelper
- serialize(Op) - Method in class com.usatiuk.dhfs.OpSerializer
- serialize(JDataRemoteDto) - Method in class com.usatiuk.dhfs.rpc.RemoteObjectSerializer
- serialize(ReceivedObject) - Method in class com.usatiuk.dhfs.rpc.ReceivedObjectSerializer
- serialize(JData) - Method in class com.usatiuk.objects.JavaDataSerializer
- serialize(JDataVersionedWrapper) - Method in class com.usatiuk.objects.JDataVersionedWrapperSerializer
-
Serializes a JDataVersionedWrapper object to a ByteString.
- serialize(JObjectKey) - Method in class com.usatiuk.dhfs.JObjectKeyProtoSerializer
- serialize(O) - Method in interface com.usatiuk.dhfs.ProtoSerializer
- serialize(T) - Method in interface com.usatiuk.objects.ObjectSerializer
-
Serialize an object to a ByteString.
- serialize(T) - Static method in class com.usatiuk.utils.SerializationHelper
- serializeArray(T) - Static method in class com.usatiuk.utils.SerializationHelper
- SERIALIZEDDATA_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.JDataP
- SERIALIZEDDATA_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- SERIALIZEDDATA_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.repository.OpP
- SerializingObjectPersistentStore - Class in com.usatiuk.objects.stores
-
Serializing wrapper for the ObjectPersistentStore.
- SerializingObjectPersistentStore() - Constructor for class com.usatiuk.objects.stores.SerializingObjectPersistentStore
- SERVICE_NAME - Static variable in class com.usatiuk.dhfs.repository.DhfsObjectSyncGrpcGrpc
- setCacheCallback(Runnable) - Method in class com.usatiuk.objects.JDataVersionedWrapperLazy
-
Set a callback to be called when the data is loaded.
- setChangelog(ObjectChangelog) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- setChangelog(ObjectChangelog.Builder) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.ObjectChangelog changelog = 5;
- setDelay(long) - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Sets the delay for the queue.
- setDeletionCandidate(boolean) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
bool deletionCandidate = 2;
- setEntries(int, ObjectChangelog.entries_Entry) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- setEntries(int, ObjectChangelog.entries_Entry.Builder) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
-
repeated .dhfs.persistence.ObjectChangelog.entries_Entry entries = 1;
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- setId(JObjectKeyP) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- setId(JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
-
.dhfs.persistence.JObjectKeyP id = 1;
- setKey(PeerIdP) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- setKey(PeerIdP.Builder) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
.dhfs.persistence.PeerIdP key = 1;
- setMsg(int, OpP) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- setMsg(int, OpP.Builder) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
-
repeated .dhfs.sync.OpP msg = 2;
- setName(JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- setName(JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- setName(JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- setName(JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
-
.dhfs.persistence.JObjectKeyP name = 2;
- setName(String) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
-
string name = 1;
- setNameBytes(ByteString) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
-
string name = 1;
- setPort(int) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 port = 2;
- setPushedData(JDataRemoteDtoP) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- setPushedData(JDataRemoteDtoP.Builder) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
-
.dhfs.persistence.JDataRemoteDtoP pushedData = 6;
- setReferrers(int, JObjectKeyP) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- setReferrers(int, JObjectKeyP.Builder) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
-
repeated .dhfs.persistence.JObjectKeyP referrers = 3;
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- setSecurePort(int) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
uint32 securePort = 3;
- setSerializedData(ByteString) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
-
bytes serializedData = 1;
- setSerializedData(ByteString) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
-
bytes serializedData = 1;
- setSerializedData(ByteString) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
-
bytes serializedData = 1;
- setTimes(JObjectKey, long) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Set the access and modification times of a file.
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JDataP.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.persistence.PeerIdP.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.GetObjectReply.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpP.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpPushReply.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.OpPushRequest.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.PingReply.Builder
- setUnknownFields(UnknownFieldSet) - Method in class com.usatiuk.dhfs.repository.PingRequest.Builder
- setUuid(String) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
string uuid = 1;
- setUuidBytes(ByteString) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo.Builder
-
string uuid = 1;
- setValue(long) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry.Builder
-
int64 value = 2;
- ShutdownChecker - Class in com.usatiuk.dhfs
-
This class checks if the application was shut down cleanly.
- ShutdownChecker() - Constructor for class com.usatiuk.dhfs.ShutdownChecker
- size() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Get the size of the log.
- size(JObjectKey) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Get the size of a file.
- skip() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- skip() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Skips the next element in the forward direction.
- skip() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- skip() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- skip() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- skipImpl() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- skipImpl() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- skipImpl() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- skipImpl() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
Skips the next element in the iterator, depending on the current direction.
- skipImpl() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- skipPrev() - Method in class com.usatiuk.dhfs.jmap.JMapIterator
- skipPrev() - Method in interface com.usatiuk.objects.iterators.CloseableKvIterator
-
Skips the previous element in the reverse direction.
- skipPrev() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- skipPrev() - Method in class com.usatiuk.objects.iterators.ReversedKvIterator
- skipPrev() - Method in class com.usatiuk.objects.iterators.ReversibleKvIterator
- Snapshot<K,
V> - Interface in com.usatiuk.objects.snapshot -
Interface for a snapshot of a database.
- statfs(String, Statvfs) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- StaticPeerDiscovery - Class in com.usatiuk.dhfs.peerdiscovery
-
Notifies PeerDiscoveryDirectory about statically configured peer addresses.
- StaticPeerDiscovery(Optional<String>) - Constructor for class com.usatiuk.dhfs.peerdiscovery.StaticPeerDiscovery
- StatusRuntimeExceptionNoStacktrace - Exception Class in com.usatiuk.utils
-
A
StatusRuntimeException
that does not fill in the stack trace. - StatusRuntimeExceptionNoStacktrace(Status) - Constructor for exception class com.usatiuk.utils.StatusRuntimeExceptionNoStacktrace
- StatusRuntimeExceptionNoStacktrace(Status, Metadata) - Constructor for exception class com.usatiuk.utils.StatusRuntimeExceptionNoStacktrace
- StorageInterface<TimestampT,
PeerIdT, - Interface in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Storage interface for the Kleppmann tree.
- symlink() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns the value of the
symlink
record component. - symlink(String, String) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Create a symlink.
- symlink(String, String) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- SYMLINK - Enum constant in enum class com.usatiuk.dhfsfs.service.GetattrType
- SyncHandler - Class in com.usatiuk.dhfs.remoteobj
-
Handles synchronization of remote objects.
- SyncHandler(Instance<ObjSyncHandler<?, ?>>, Instance<InitialSyncProcessor<?>>) - Constructor for class com.usatiuk.dhfs.remoteobj.SyncHandler
- SyncHelper - Class in com.usatiuk.dhfs.remoteobj
-
Helper class for synchronizing objects.
- SyncHelper() - Constructor for class com.usatiuk.dhfs.remoteobj.SyncHelper
- SyncHelper.ChangelogCmpResult - Enum Class in com.usatiuk.dhfs.remoteobj
T
- takeOldest() - Method in interface com.usatiuk.kleppmanntree.LogInterface
-
Take the oldest log entry.
- timestamp() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Returns the value of the
timestamp
record component. - timestamp() - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Returns the value of the
timestamp
record component. - timestamp() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns the value of the
timestamp
record component. - toBuilder() - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.JDataP
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- toBuilder() - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- toBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- toBuilder() - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- toBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- toBuilder() - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- toBuilder() - Method in class com.usatiuk.dhfs.repository.OpP
- toBuilder() - Method in class com.usatiuk.dhfs.repository.OpPushReply
- toBuilder() - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- toBuilder() - Method in class com.usatiuk.dhfs.repository.PingReply
- toBuilder() - Method in class com.usatiuk.dhfs.repository.PingRequest
- toByteBuffer() - Method in interface com.usatiuk.objects.JObjectKey
-
Returns the byte buffer representation of the key.
- toByteBuffer() - Method in class com.usatiuk.objects.JObjectKeyImpl
- toByteBuffer() - Method in record class com.usatiuk.objects.JObjectKeyMax
- toByteBuffer() - Method in record class com.usatiuk.objects.JObjectKeyMin
- toDto(File) - Method in class com.usatiuk.dhfsfs.objects.FileDtoMapper
- toDto(F) - Method in interface com.usatiuk.dhfs.syncmap.DtoMapper
-
Converts a remote object to its DTO representation.
- toDto(F, Class<D>) - Method in class com.usatiuk.dhfs.syncmap.DtoMapperService
-
Converts a remote object to its DTO representation.
- toJObjectKey() - Method in record class com.usatiuk.dhfs.peersync.PeerId
- Tombstone<V> - Interface in com.usatiuk.objects.iterators
-
Indicates that the value is a tombstone.
- TombstoneImpl<V> - Record Class in com.usatiuk.objects.iterators
-
Simple implementation of the Tombstone interface.
- TombstoneImpl() - Constructor for record class com.usatiuk.objects.iterators.TombstoneImpl
-
Creates an instance of a
TombstoneImpl
record class. - TombstoneSkippingIterator<K,
V> - Class in com.usatiuk.objects.iterators -
A key-value iterator that skips tombstones.
- TombstoneSkippingIterator(IteratorStart, K, List<CloseableKvIterator<K, MaybeTombstone<V>>>) - Constructor for class com.usatiuk.objects.iterators.TombstoneSkippingIterator
-
Constructs a TombstoneSkippingIterator with the specified start position, start key, and list of iterators.
- toString() - Method in record class com.usatiuk.dhfs.invalidation.IndexUpdateOp
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.invalidation.InvalidationQueueEntry
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jmap.JMapEntry
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jmap.JMapLongKey
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.jmap.JMapRef
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.api.ApiPeerInfo
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.PeerId
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.refcount.JDataNormalRef
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.remoteobj.ReceivedObject
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.webapi.KnownPeerPut
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfs.webapi.SelfInfo
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.objects.ChunkData
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.objects.File
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.objects.FileDto
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.kleppmanntree.CombinedTimestamp
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.kleppmanntree.LogEffect
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.kleppmanntree.LogEffectOld
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.kleppmanntree.LogRecord
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.kleppmanntree.OpMove
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.iterators.DataWrapper
-
Returns a string representation of this record class.
- toString() - Method in class com.usatiuk.objects.iterators.KeyPredicateKvIterator
- toString() - Method in class com.usatiuk.objects.iterators.MappingKvIterator
- toString() - Method in class com.usatiuk.objects.iterators.MergingKvIterator
- toString() - Method in class com.usatiuk.objects.iterators.NavigableMapKvIterator
- toString() - Method in record class com.usatiuk.objects.iterators.TombstoneImpl
-
Returns a string representation of this record class.
- toString() - Method in class com.usatiuk.objects.iterators.TombstoneSkippingIterator
- toString() - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Returns a string representation of this record class.
- toString() - Method in interface com.usatiuk.objects.JObjectKey
- toString() - Method in class com.usatiuk.objects.JObjectKeyImpl
- toString() - Method in record class com.usatiuk.objects.JObjectKeyMax
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.JObjectKeyMin
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.stores.PendingDelete
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.stores.PendingWrite
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.stores.TxManifestObj
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.stores.TxManifestRaw
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordDeleted
-
Returns a string representation of this record class.
- toString() - Method in record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
-
Returns a string representation of this record class.
- Transaction - Interface in com.usatiuk.objects.transaction
- TransactionHandle - Interface in com.usatiuk.objects.transaction
- TransactionManager - Interface in com.usatiuk.objects.transaction
- TransactionManagerImpl - Class in com.usatiuk.objects.transaction
- TransactionManagerImpl() - Constructor for class com.usatiuk.objects.transaction.TransactionManagerImpl
- TransactionService - Class in com.usatiuk.objects.transaction
- trash(JKleppmannTreeNodeMeta, JObjectKey) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Move a node to the trash.
- traverse(List<String>) - Method in class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeManager.JKleppmannTree
-
Traverse the tree from root to find a node with the given name.
- traverse(List<String>) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Traverse the tree from its root node using the given list of names
- TREE_KEY - Static variable in class com.usatiuk.dhfs.peersync.PeerInfoService
- treeName() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreeOpWrapper
-
Returns the value of the
treeName
record component. - treeName() - Method in record class com.usatiuk.dhfs.jkleppmanntree.JKleppmannTreePeriodicPushOp
-
Returns the value of the
treeName
record component. - TreeNode<TimestampT,
PeerIdT, - Interface in com.usatiuk.kleppmanntreeMetaT, NodeIdT> -
Represents a node in the Kleppmann tree.
- truncate(JObjectKey, long) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Truncate a file to the given length.
- truncate(String, long) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- tryConnectAll() - Method in class com.usatiuk.dhfs.peersync.ReachablePeerManager
- tryGet() - Method in class com.usatiuk.utils.HashSetDelayedBlockingQueue
-
Tries to get the object from the queue without waiting.
- tryLock(Object) - Method in class com.usatiuk.utils.DataLocker
-
Tries to lock the data and returns an AutoCloseable that unlocks it when closed.
- TxCommitException - Exception Class in com.usatiuk.objects.transaction
- TxCommitException(String) - Constructor for exception class com.usatiuk.objects.transaction.TxCommitException
- TxCommitException(String, Throwable) - Constructor for exception class com.usatiuk.objects.transaction.TxCommitException
- TxManifestObj<T> - Record Class in com.usatiuk.objects.stores
- TxManifestObj(Collection<Pair<JObjectKey, T>>, Collection<JObjectKey>) - Constructor for record class com.usatiuk.objects.stores.TxManifestObj
-
Creates an instance of a
TxManifestObj
record class. - TxManifestRaw - Record Class in com.usatiuk.objects.stores
- TxManifestRaw(Collection<Pair<JObjectKey, ByteString>>, Collection<JObjectKey>) - Constructor for record class com.usatiuk.objects.stores.TxManifestRaw
-
Creates an instance of a
TxManifestRaw
record class. - TxObjectRecordDeleted(JObjectKey) - Constructor for record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordDeleted
-
Creates an instance of a
TxObjectRecordDeleted
record class. - TxObjectRecordWrite(JData) - Constructor for record class com.usatiuk.objects.transaction.TxRecord.TxObjectRecordWrite
-
Creates an instance of a
TxObjectRecordWrite
record class. - TxRecord - Class in com.usatiuk.objects.transaction
- TxRecord() - Constructor for class com.usatiuk.objects.transaction.TxRecord
- TxRecord.TxObjectRecord<T> - Interface in com.usatiuk.objects.transaction
- TxRecord.TxObjectRecordDeleted - Record Class in com.usatiuk.objects.transaction
- TxRecord.TxObjectRecordWrite<T> - Record Class in com.usatiuk.objects.transaction
- type() - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
-
Returns the value of the
type
record component. - type() - Method in interface com.usatiuk.dhfs.peerdiscovery.PeerAddress
-
Returns the type of this peer address (LAN/WAN/etc)
- type() - Method in record class com.usatiuk.dhfsfs.service.GetattrRes
-
Returns the value of the
type
record component.
U
- unavailable() - Method in record class com.usatiuk.dhfs.peersync.ReachablePeerManager.HostStateSnapshot
-
Returns the value of the
unavailable
record component. - UninitializedByteBuffer - Class in com.usatiuk.utils
-
Utility class for creating uninitialized ByteBuffers, to avoid zeroing memory unnecessarily.
- UninitializedByteBuffer() - Constructor for class com.usatiuk.utils.UninitializedByteBuffer
- unlink(String) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Unlink a file or directory.
- unlink(String) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- UNSAFE - Static variable in class com.usatiuk.utils.UnsafeAccessor
- UnsafeAccessor - Class in com.usatiuk.utils
-
Provides access to the
Unsafe
class andJavaNioAccess
class. - UnsafeAccessor() - Constructor for class com.usatiuk.utils.UnsafeAccessor
- updateCerts() - Method in class com.usatiuk.dhfs.peersync.PersistentPeerDataService
- updateExternalTimestamp(PeerIdT, TimestampT) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Update the causality threshold timestamp for a peer
- updateTimestamp(TimestampT) - Method in interface com.usatiuk.kleppmanntree.Clock
-
Update the timestamp with an externally received timestamp.
- utimens(String, Timespec[]) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- uuid() - Method in record class com.usatiuk.dhfs.webapi.PeerAddressInfo
-
Returns the value of the
uuid
record component. - uuid() - Method in record class com.usatiuk.dhfs.webapi.PeerInfo
-
Returns the value of the
uuid
record component. - uuid() - Method in record class com.usatiuk.dhfs.webapi.SelfInfo
-
Returns the value of the
uuid
record component. - UUID_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
V
- value() - Method in interface com.usatiuk.objects.iterators.Data
-
Get the value.
- value() - Method in record class com.usatiuk.objects.iterators.DataWrapper
-
Returns the value of the
value
record component. - value() - Method in interface com.usatiuk.objects.JDataVersionedWrapper
- value() - Method in interface com.usatiuk.objects.JObjectKey
-
Returns the string value of the key.
- value() - Method in class com.usatiuk.objects.JObjectKeyImpl
- value() - Method in record class com.usatiuk.objects.JObjectKeyMax
- value() - Method in record class com.usatiuk.objects.JObjectKeyMin
- value() - Method in record class com.usatiuk.objects.stores.PendingWrite
-
Returns the value of the
value
record component. - VALUE_FIELD_NUMBER - Static variable in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- valueOf(String) - Static method in enum class com.usatiuk.dhfs.peerdiscovery.PeerAddressType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class com.usatiuk.dhfsfs.service.GetattrType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class com.usatiuk.objects.iterators.IteratorStart
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class com.usatiuk.dhfs.peerdiscovery.PeerAddressType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class com.usatiuk.dhfs.remoteobj.SyncHelper.ChangelogCmpResult
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class com.usatiuk.dhfsfs.service.GetattrType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class com.usatiuk.objects.iterators.IteratorStart
-
Returns an array containing the constants of this enum class, in the order they are declared.
- version() - Method in interface com.usatiuk.objects.JDataVersionedWrapper
-
Returns the version number of the object.
- version() - Method in record class com.usatiuk.objects.JDataVersionedWrapperImpl
-
Returns the value of the
version
record component. - version() - Method in class com.usatiuk.objects.JDataVersionedWrapperLazy
- versionSum() - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
W
- walkTree(Consumer<TreeNode<TimestampT, PeerIdT, MetaT, NodeIdT>>) - Method in class com.usatiuk.kleppmanntree.KleppmannTree
-
Walk the tree and apply the given consumer to each node
- WAN - Enum constant in enum class com.usatiuk.dhfs.peerdiscovery.PeerAddressType
- WebUiRouter - Class in com.usatiuk.dhfs.webui
-
Web UI router for serving static files.
- WebUiRouter(Optional<String>) - Constructor for class com.usatiuk.dhfs.webui.WebUiRouter
- withChangelog(PMap<PeerId, Long>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withChildren(PMap<String, JObjectKey>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- withChildren(PMap<String, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Make a copy of this node with new children.
- withClock(long) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withCompression(String) - Method in class com.usatiuk.dhfs.repository.MutinyDhfsObjectSyncGrpcGrpc.DhfsObjectSyncGrpcImplBase
-
Set whether the server will try to use a compressed response.
- withConfirmedDeletes(PSet<PeerId>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withCTime(long) - Method in record class com.usatiuk.dhfsfs.objects.File
- withCurrentCTime() - Method in record class com.usatiuk.dhfsfs.objects.File
- withCurrentMTime() - Method in record class com.usatiuk.dhfsfs.objects.File
- withData(T) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- withFrozen(boolean) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- withFrozen(boolean) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withFrozen(boolean) - Method in interface com.usatiuk.dhfs.refcount.JDataRefcounted
-
Create a copy of this object with the given frozen state.
- withFrozen(boolean) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- withFrozen(boolean) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withHaveLocal(boolean) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withIncrementedKickCounter(PeerId) - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
- withInitialSyncDone(PSet<PeerId>) - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
- withKickCounter(PMap<PeerId, Long>) - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
- withKnownRemoteVersions(PMap<PeerId, Long>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withKnownType(Class<? extends JDataRemote>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withLastEffectiveOp(OpMove<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- withLastEffectiveOp(OpMove<TimestampT, PeerIdT, MetaT, NodeIdT>) - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Make a copy of this node with a new last effective operation.
- withLastSeenTimestamp(long) - Method in record class com.usatiuk.dhfs.peersync.PeerInfo
- withLog(PSortedMap<CombinedTimestamp<Long, PeerId>, LogRecord<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withMeta(JKleppmannTreeNodeMeta) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- withMeta(MetaT) - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Make a copy of this node with new metadata.
- withMode(long) - Method in record class com.usatiuk.dhfsfs.objects.File
- withMTime(long) - Method in record class com.usatiuk.dhfsfs.objects.File
- withName(String) - Method in interface com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeMeta
- withName(String) - Method in record class com.usatiuk.dhfs.peersync.structs.JKleppmannTreeNodeMetaPeer
- withName(String) - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaDirectory
- withName(String) - Method in record class com.usatiuk.dhfsfs.objects.JKleppmannTreeNodeMetaFile
- withName(String) - Method in interface com.usatiuk.kleppmanntree.NodeMeta
-
Creates a copy of the metadata with a new name.
- withNode(JKleppmannTreeNode) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- withObjSyncClient(PeerId, PeerAddress, long, RpcClientFactory.ObjectSyncClientFunction<R>) - Method in class com.usatiuk.dhfs.rpc.RpcClientFactory
-
Try calling a given function on a given target with a specified timeout.
- withObjSyncClient(PeerId, RpcClientFactory.ObjectSyncClientFunction<R>) - Method in class com.usatiuk.dhfs.rpc.RpcClientFactory
-
Try calling a given function on a given target.
- withObjSyncClient(PeerId, InetAddress, int, long, RpcClientFactory.ObjectSyncClientFunction<R>) - Method in class com.usatiuk.dhfs.rpc.RpcClientFactory
-
Try calling a given function on a given target with a specified timeout.
- withObjSyncClient(Collection<PeerId>, RpcClientFactory.ObjectSyncClientFunction<R>) - Method in class com.usatiuk.dhfs.rpc.RpcClientFactory
-
Try calling a given function on given peers in random order.
- withParent(JObjectKey) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNode
- withParent(NodeIdT) - Method in interface com.usatiuk.kleppmanntree.TreeNode
-
Make a copy of this node with a new parent.
- withPeerTimestampLog(PMap<PeerId, Long>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withPersistentPeerAddress(PMap<PeerId, IpPeerAddress>) - Method in record class com.usatiuk.dhfs.peersync.PersistentRemoteHostsData
- withQueues(PMap<PeerId, PSortedMap<CombinedTimestamp<Long, PeerId>, OpMove<Long, PeerId, JKleppmannTreeNodeMeta, JObjectKey>>>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withRefsFrom(PCollection<JDataRef>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreeNodeHolder
- withRefsFrom(PCollection<JDataRef>) - Method in record class com.usatiuk.dhfs.jkleppmanntree.structs.JKleppmannTreePersistentData
- withRefsFrom(PCollection<JDataRef>) - Method in interface com.usatiuk.dhfs.refcount.JDataRefcounted
-
Create a copy of this object with the given list of incoming references.
- withRefsFrom(PCollection<JDataRef>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectDataWrapper
- withRefsFrom(PCollection<JDataRef>) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withSeen(boolean) - Method in record class com.usatiuk.dhfs.remoteobj.RemoteObjectMeta
- withSymlink(boolean) - Method in record class com.usatiuk.dhfsfs.objects.File
- withType(PeerAddressType) - Method in record class com.usatiuk.dhfs.peerdiscovery.IpPeerAddress
- write(byte) - Method in class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- write(byte[], int, int) - Method in class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- write(JObjectKey, long, byte[]) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Write data to a file.
- write(JObjectKey, long, ByteString) - Method in class com.usatiuk.dhfsfs.service.DhfsFileService
-
Write data to a file.
- write(String, ByteBuffer, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- write(String, Pointer, long, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- write(ByteBuffer) - Method in class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- write_buf(String, FuseBufvec, long, FuseFileInfo) - Method in class com.usatiuk.dhfsfuse.DhfsFuse
- WritebackObjectPersistentStore - Class in com.usatiuk.objects.stores
-
Asynchronous write cache of objects.
- WritebackObjectPersistentStore() - Constructor for class com.usatiuk.objects.stores.WritebackObjectPersistentStore
- writeLazy(byte[], int, int) - Method in class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- writeLazy(ByteBuffer) - Method in class com.usatiuk.dhfsfuse.JnrPtrByteOutput
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.peerdiscovery.PeerDiscoveryInfo
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.JDataP
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.JDataRemoteDtoP
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.JObjectKeyP
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog.entries_Entry
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.ObjectChangelog
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.persistence.PeerIdP
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.CanDeleteReply
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.CanDeleteRequest
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.GetObjectReply
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.GetObjectRequest
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.OpP
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.OpPushReply
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.OpPushRequest
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.PingReply
- writeTo(CodedOutputStream) - Method in class com.usatiuk.dhfs.repository.PingRequest
- written() - Method in record class com.usatiuk.objects.stores.TxManifestObj
-
Returns the value of the
written
record component. - written() - Method in record class com.usatiuk.objects.stores.TxManifestRaw
-
Returns the value of the
written
record component.
_
- _goingForward - Variable in class com.usatiuk.objects.iterators.ReversibleKvIterator
-
The current direction of the iterator.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form