Class DefaultDocumentStore

java.lang.Object

io.fluxzero.sdk.common.AbstractNamespaced<DocumentStore>

io.fluxzero.sdk.persisting.search.DefaultDocumentStore

All Implemented Interfaces:

Namespaced<DocumentStore>, DocumentStore, HasLocalHandlers

public class DefaultDocumentStore
extends AbstractNamespaced<DocumentStore>
implements DocumentStore, HasLocalHandlers

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	DefaultDocumentStore.DefaultSearch

Constructor Summary

Constructors

Constructor	Description
DefaultDocumentStore()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	bulkUpdate(Collection<? extends BulkUpdate> updates, Guarantee guarantee)	Applies a batch of document updates, using given Guarantee.
CompletableFuture<Void>	createAuditTrail(Object collection, Duration retentionTime)	Configures Fluxzero to use a search collection as a searchable audit trail with the given retention time.
protected DocumentStore	createForNamespace(String namespace)
CompletableFuture<Void>	deleteCollection(Object collection)	Deletes an entire collection of documents.
CompletableFuture<Void>	deleteDocument(Object id, Object collection, Guarantee guarantee)	Deletes a document from the collection, using given Guarantee.
<T> Optional<T>	fetchDocument(Object id, Object collection)	Fetches a document by ID and deserializes it into the stored type.
<T> Optional<T>	fetchDocument(Object id, Object collection, Class<T> type)	Fetches a document by ID and deserializes it into the provided type.
<T> Collection<T>	fetchDocuments(Collection<?> ids, Object collection)	Fetches a collection of documents by their IDs and deserializes them into the stored type.
<T> Collection<T>	fetchDocuments(Collection<?> ids, Object collection, Class<T> type)	Fetches a collection of documents by their IDs and deserializes them into the provided type.
boolean	hasDocument(Object id, Object collection)	Checks if a document exists in the specified collection.
CompletableFuture<Void>	index(@NonNull Object object, @NonNull Object id, @NonNull Object collection, Instant begin, Instant end, Metadata metadata, Guarantee guarantee, boolean ifNotExists)	Indexes a document with the specified guarantees, metadata, and if-not-exists condition, using Guarantee.STORED.
CompletableFuture<Void>	index(Collection<?> objects, Object collection, String idPath, String beginPath, String endPath, Guarantee guarantee, boolean ifNotExists)	Indexes a collection of objects using functional accessors for ID and time intervals, using Guarantee.STORED.
<T> CompletableFuture<Void>	index(Collection<? extends T> objects, Object collection, Function<? super T, ?> idFunction, Function<? super T, Instant> beginFunction, Function<? super T, Instant> endFunction, Guarantee guarantee, boolean ifNotExists)	Indexes a collection of objects using functional accessors for ID and time intervals, using Guarantee.STORED.
CompletableFuture<Void>	moveDocument(Object id, Object collection, Object targetCollection, Guarantee guarantee)	Deletes a document from the collection, using given Guarantee.
Search	search(SearchQuery.Builder searchBuilder)	Prepares a search query based on the specified SearchQuery.Builder.
DocumentUpdate	serializeAction(BulkUpdate update)

Methods inherited from class AbstractNamespaced

close, forNamespace

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface DocumentStore

bulkUpdate, deleteDocument, determineCollection, fetchDocument, getSerializer, hasDocument, index, index, index, index, index, index, index, index, index, index, index, index, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, indexIfNotExists, moveDocument, prepareIndex, search

Methods inherited from interface HasLocalHandlers

hasLocalHandlers, registerHandler, registerHandler, setSelfHandlerFilter

Methods inherited from interface Namespaced

forDefaultNamespace, forNamespace

Constructor Details

DefaultDocumentStore

public DefaultDocumentStore()

Method Details

index

public CompletableFuture<Void> index(@NonNull
 @NonNull Object object,
 @NonNull
 @NonNull Object id,
 @NonNull
 @NonNull Object collection,
 Instant begin,
 Instant end,
 Metadata metadata,
 Guarantee guarantee,
 boolean ifNotExists)

Description copied from interface: DocumentStore

Indexes a document with the specified guarantees, metadata, and if-not-exists condition, using Guarantee.STORED.

Specified by:

index in interface DocumentStore

index

public CompletableFuture<Void> index(Collection<?> objects,
 Object collection,
 String idPath,
 String beginPath,
 String endPath,
 Guarantee guarantee,
 boolean ifNotExists)

Description copied from interface: DocumentStore

Indexes a collection of objects using functional accessors for ID and time intervals, using Guarantee.STORED.

Specified by:

index in interface DocumentStore

index

public <T> CompletableFuture<Void> index(Collection<? extends T> objects,
 Object collection,
 Function<? super T, ?> idFunction,
 Function<? super T, Instant> beginFunction,
 Function<? super T, Instant> endFunction,
 Guarantee guarantee,
 boolean ifNotExists)

Description copied from interface: DocumentStore

Indexes a collection of objects using functional accessors for ID and time intervals, using Guarantee.STORED.

Specified by:

index in interface DocumentStore

bulkUpdate

public CompletableFuture<Void> bulkUpdate(Collection<? extends BulkUpdate> updates,
 Guarantee guarantee)

Description copied from interface: DocumentStore

Applies a batch of document updates, using given Guarantee.

Specified by:

bulkUpdate in interface DocumentStore

serializeAction

public DocumentUpdate serializeAction(BulkUpdate update)

search

public Search search(SearchQuery.Builder searchBuilder)

Description copied from interface: DocumentStore

Prepares a search query based on the specified SearchQuery.Builder.

Specified by:

search in interface DocumentStore

hasDocument

public boolean hasDocument(Object id,
 Object collection)

Description copied from interface: DocumentStore

Checks if a document exists in the specified collection.

Specified by:

hasDocument in interface DocumentStore

fetchDocument

public <T> Optional<T> fetchDocument(Object id,
 Object collection)

Description copied from interface: DocumentStore

Fetches a document by ID and deserializes it into the stored type.

Specified by:

fetchDocument in interface DocumentStore

fetchDocument

public <T> Optional<T> fetchDocument(Object id,
 Object collection,
 Class<T> type)

Description copied from interface: DocumentStore

Fetches a document by ID and deserializes it into the provided type.

Specified by:

fetchDocument in interface DocumentStore

fetchDocuments

public <T> Collection<T> fetchDocuments(Collection<?> ids,
 Object collection)

Description copied from interface: DocumentStore

Fetches a collection of documents by their IDs and deserializes them into the stored type.

Specified by:

fetchDocuments in interface DocumentStore

fetchDocuments

public <T> Collection<T> fetchDocuments(Collection<?> ids,
 Object collection,
 Class<T> type)

Description copied from interface: DocumentStore

Fetches a collection of documents by their IDs and deserializes them into the provided type.

Specified by:

fetchDocuments in interface DocumentStore

deleteDocument

public CompletableFuture<Void> deleteDocument(Object id,
 Object collection,
 Guarantee guarantee)

Description copied from interface: DocumentStore

Deletes a document from the collection, using given Guarantee.

Specified by:

deleteDocument in interface DocumentStore

moveDocument

public CompletableFuture<Void> moveDocument(Object id,
 Object collection,
 Object targetCollection,
 Guarantee guarantee)

Description copied from interface: DocumentStore

Deletes a document from the collection, using given Guarantee.

Specified by:

moveDocument in interface DocumentStore

deleteCollection

public CompletableFuture<Void> deleteCollection(Object collection)

Description copied from interface: DocumentStore

Deletes an entire collection of documents.

Specified by:

deleteCollection in interface DocumentStore

createAuditTrail

public CompletableFuture<Void> createAuditTrail(Object collection,
 Duration retentionTime)

Description copied from interface: DocumentStore

Configures Fluxzero to use a search collection as a searchable audit trail with the given retention time.

Specified by:

createAuditTrail in interface DocumentStore

createForNamespace

protected DocumentStore createForNamespace(String namespace)

Specified by:

createForNamespace in class AbstractNamespaced<DocumentStore>