public abstract class DocumentStoreBase extends Object implements IDocumentStore
Modifier and Type | Field and Description |
---|---|
protected DocumentConvention |
conventions |
protected FailoverServers |
failoverServers |
protected boolean |
initialized |
protected ProfilingContext |
profilingContext |
protected IReliableSubscriptions |
subscriptions |
protected String |
url |
protected boolean |
useFips |
Modifier | Constructor and Description |
---|---|
protected |
DocumentStoreBase() |
Modifier and Type | Method and Description |
---|---|
void |
addSessionCreatedInternal(Action1<InMemoryDocumentSessionOperations> action) |
protected void |
afterSessionCreated(InMemoryDocumentSessionOperations session) |
CleanCloseable |
aggressivelyCache()
Setup the context for aggressive caching.
|
protected void |
assertInitialized() |
protected void |
ensureNotClosed() |
void |
executeIndex(AbstractIndexCreationTask indexCreationTask)
Executes index creation.
|
void |
executeIndexes(List<AbstractIndexCreationTask> indexCreationTasks) |
void |
executeTransformer(AbstractTransformerCreationTask transformerCreationTask)
executes the transformer creation
|
DocumentConvention |
getConventions()
Gets the conventions.
|
FailoverServers |
getFailoverServers() |
ILastEtagHolder |
getLastEtagHolder() |
Etag |
getLastWrittenEtag()
Gets the etag of the last document written by any session belonging to this
document store
|
DocumentSessionListeners |
getListeners() |
ProfilingInformation |
getProfilingInformationFor(UUID id)
Get the profiling information for the given id
|
com.google.common.collect.ImmutableList<IDocumentConflictListener> |
getRegisteredConflictListeners()
Gets a read-only collection of the registered conflict listeners.
|
com.google.common.collect.ImmutableList<IDocumentConversionListener> |
getRegisteredConversionListeners()
Gets a read-only collection of the registered conversion listeners.
|
com.google.common.collect.ImmutableList<IDocumentDeleteListener> |
getRegisteredDeleteListeners()
Gets a read-only collection of the registered delete listeners.
|
com.google.common.collect.ImmutableList<IDocumentQueryListener> |
getRegisteredQueryListeners()
Gets a read-only collection of the registered query listeners.
|
com.google.common.collect.ImmutableList<IDocumentStoreListener> |
getRegisteredStoreListeners()
Gets a read-only collection of the registered store listeners.
|
Map<String,String> |
getSharedOperationsHeaders()
Gets the shared operations headers.
|
ITransactionRecoveryStorage |
getTransactionRecoveryStorage() |
String |
getUrl()
Gets the URL.
|
boolean |
getWasDisposed()
Whatever the instance has been disposed
|
abstract boolean |
hasJsonRequestFactory()
Whatever this instance has json request factory available
|
void |
initializeEncryptor() |
DocumentStoreBase |
registerListener(IDocumentConflictListener conflictListener)
Registers the conflict listener.
|
DocumentStoreBase |
registerListener(IDocumentConversionListener conversionListener)
Registers the conversion listener.
|
DocumentStoreBase |
registerListener(IDocumentDeleteListener deleteListener)
Registers the delete listener.
|
DocumentStoreBase |
registerListener(IDocumentQueryListener queryListener)
Registers the query listener.
|
IDocumentStore |
registerListener(IDocumentStoreListener documentStoreListener)
Registers the store listener.
|
void |
removeSessionCreatedInternal(Action1<InMemoryDocumentSessionOperations> action) |
void |
setConventions(DocumentConvention conventions) |
void |
setFailoverServers(FailoverServers failoverServers) |
void |
setLastEtagHolder(ILastEtagHolder lastEtagHolder) |
void |
setListeners(DocumentSessionListeners listeneres) |
protected void |
setSharedOperationsHeaders(Map<String,String> sharedOperationsHeaders) |
void |
setTransactionRecoveryStorage(ITransactionRecoveryStorage transactionRecoveryStorage) |
void |
setUrl(String url) |
protected void |
setWasDisposed(boolean wasDisposed) |
void |
sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask)
Executes the index creation in side-by-side mode.
|
void |
sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc)
Executes the index creation in side-by-side mode.
|
void |
sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks) |
void |
sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
IReliableSubscriptions |
subscriptions() |
DocumentStore |
withConventions(DocumentConvention conventions) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggressivelyCacheFor, bulkInsert, bulkInsert, bulkInsert, changes, changes, disableAggressiveCaching, getDatabaseCommands, getIdentifier, getJsonRequestFactory, initialize, initializeProfiling, openSession, openSession, openSession, setIdentifier, setRequestsTimeoutFor
addAfterDisposeEventHandler, removeAfterDisposeEventHandler
close
protected boolean useFips
protected DocumentConvention conventions
protected String url
protected boolean initialized
protected IReliableSubscriptions subscriptions
protected ProfilingContext profilingContext
protected FailoverServers failoverServers
public DocumentSessionListeners getListeners()
getListeners
in interface IDocumentStore
public void setListeners(DocumentSessionListeners listeneres)
setListeners
in interface IDocumentStore
public FailoverServers getFailoverServers()
public void setFailoverServers(FailoverServers failoverServers)
public void addSessionCreatedInternal(Action1<InMemoryDocumentSessionOperations> action)
public void removeSessionCreatedInternal(Action1<InMemoryDocumentSessionOperations> action)
public boolean getWasDisposed()
IDisposalNotification
getWasDisposed
in interface IDisposalNotification
protected void setWasDisposed(boolean wasDisposed)
public abstract boolean hasJsonRequestFactory()
IDocumentStore
hasJsonRequestFactory
in interface IDocumentStore
public Map<String,String> getSharedOperationsHeaders()
IDocumentStore
getSharedOperationsHeaders
in interface IDocumentStore
protected void setSharedOperationsHeaders(Map<String,String> sharedOperationsHeaders)
public void executeIndex(AbstractIndexCreationTask indexCreationTask)
executeIndex
in interface IDocumentStore
public void executeIndexes(List<AbstractIndexCreationTask> indexCreationTasks)
executeIndexes
in interface IDocumentStore
public void sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks)
sideBySideExecuteIndexes
in interface IDocumentStore
public void sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks, Etag minimumEtagBeforeReplace, Date replaceTimeUtc)
sideBySideExecuteIndexes
in interface IDocumentStore
public void sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask)
IDocumentStore
sideBySideExecuteIndex
in interface IDocumentStore
public void sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask, Etag minimumEtagBeforeReplace, Date replaceTimeUtc)
IDocumentStore
sideBySideExecuteIndex
in interface IDocumentStore
public void executeTransformer(AbstractTransformerCreationTask transformerCreationTask)
IDocumentStore
executeTransformer
in interface IDocumentStore
public DocumentConvention getConventions()
IDocumentStore
getConventions
in interface IDocumentStore
public void setConventions(DocumentConvention conventions)
public DocumentStore withConventions(DocumentConvention conventions)
public String getUrl()
IDocumentStore
getUrl
in interface IDocumentStore
public void setUrl(String url)
public Etag getLastWrittenEtag()
getLastWrittenEtag
in interface IDocumentStore
protected void ensureNotClosed()
protected void assertInitialized()
public DocumentStoreBase registerListener(IDocumentConversionListener conversionListener)
conversionListener
- public DocumentStoreBase registerListener(IDocumentQueryListener queryListener)
queryListener
- public IDocumentStore registerListener(IDocumentStoreListener documentStoreListener)
documentStoreListener
- public DocumentStoreBase registerListener(IDocumentDeleteListener deleteListener)
deleteListener
- public DocumentStoreBase registerListener(IDocumentConflictListener conflictListener)
conflictListener
- public com.google.common.collect.ImmutableList<IDocumentConversionListener> getRegisteredConversionListeners()
public com.google.common.collect.ImmutableList<IDocumentQueryListener> getRegisteredQueryListeners()
public com.google.common.collect.ImmutableList<IDocumentStoreListener> getRegisteredStoreListeners()
public com.google.common.collect.ImmutableList<IDocumentDeleteListener> getRegisteredDeleteListeners()
public com.google.common.collect.ImmutableList<IDocumentConflictListener> getRegisteredConflictListeners()
protected void afterSessionCreated(InMemoryDocumentSessionOperations session)
public ILastEtagHolder getLastEtagHolder()
public void setLastEtagHolder(ILastEtagHolder lastEtagHolder)
public ITransactionRecoveryStorage getTransactionRecoveryStorage()
public void setTransactionRecoveryStorage(ITransactionRecoveryStorage transactionRecoveryStorage)
public ProfilingInformation getProfilingInformationFor(UUID id)
id
- public CleanCloseable aggressivelyCache()
aggressivelyCache
in interface IDocumentStore
public void initializeEncryptor()
public IReliableSubscriptions subscriptions()
subscriptions
in interface IDocumentStore
Copyright © 2016. All Rights Reserved.