Modifier and Type | Method and Description |
---|---|
Etag |
ScriptedPatchCommandData.getEtag()
Current document etag, used for concurrency checks (null to skip check).
|
Etag |
DeleteCommandData.getEtag()
Current document etag, used for concurrency checks (null to skip check)
|
Etag |
PatchCommandData.getEtag()
Current document etag, used for concurrency checks (null to skip check)
|
Etag |
ICommandData.getEtag()
Current document etag, used for concurrency checks (null to skip check).
|
Etag |
PutCommandData.getEtag()
Current document etag, used for concurrency checks (null to skip check).
|
Modifier and Type | Method and Description |
---|---|
void |
ScriptedPatchCommandData.setEtag(Etag etag)
Current document etag, used for concurrency checks (null to skip check).
|
void |
DeleteCommandData.setEtag(Etag etag)
Current document etag, used for concurrency checks (null to skip check)
|
void |
PatchCommandData.setEtag(Etag etag)
Current document etag, used for concurrency checks (null to skip check)
|
void |
PutCommandData.setEtag(Etag etag)
Current document etag, used for concurrency checks (null to skip check).
|
Constructor and Description |
---|
DeleteCommandData(String key,
Etag etag) |
PutCommandData(String key,
Etag etag,
RavenJObject document,
RavenJObject metadata) |
Modifier and Type | Method and Description |
---|---|
Etag |
ErrorResponseException.getEtag() |
Modifier and Type | Method and Description |
---|---|
Etag |
Etag.clone() |
static Etag |
Etag.empty() |
Etag |
SubscriptionConfig.getAckEtag() |
Etag |
IndexQuery.getCutoffEtag()
Gets or sets the cutoff etag.
|
Etag |
IndexChangeNotification.getEtag()
Gets etag
|
Etag |
AttachmentInformation.getEtag()
Deprecated.
Current attachment etag.
|
Etag |
JsonDocument.getEtag()
Current document etag.
|
Etag |
PutResult.getEtag()
Etag of the document after PUT operation.
|
Etag |
StreamResult.getEtag()
Document etag.
|
Etag |
JsonDocumentMetadata.getEtag()
Current document etag.
|
Etag |
ReplicationConflictNotification.getEtag()
Current conflict document Etag.
|
Etag |
DocumentChangeNotification.getEtag()
Document etag.
|
Etag |
BatchResult.getEtag()
Etag generated by the operation (null if not applicable).
|
Etag |
IJsonDocumentMetadata.getEtag()
Current document etag, used for concurrency checks (null to skip check)
|
Etag |
Attachment.getEtag()
Deprecated.
Current attachment etag, used for concurrency checks (null to skip check).
|
Etag |
QueryResult.getIndexEtag()
The last etag indexed by the index.
|
Etag |
QueryHeaderInformation.getIndexEtag() |
Etag |
FacetResults.getIndexStateEtag() |
Etag |
DatabaseStatistics.getLastAttachmentEtag()
Deprecated.
Use RavenFS instead.
|
Etag |
DatabaseStatistics.getLastDocEtag()
Last document etag in database.
|
Etag |
IndexStats.getLastIndexedEtag()
This value represents etag of last document indexed (using map) by this index.
|
Etag |
IndexStats.getLastReducedEtag()
This value represents etag of last document indexed (using reduce) by this index.
|
Etag |
SideBySideIndexes.getMinimumEtagBeforeReplace() |
Etag |
QueryResult.getResultEtag()
The ETag value for this index current state, which include what docs were indexed,
what document were deleted, etc.
|
Etag |
QueryHeaderInformation.getResultEtag() |
Etag |
SubscriptionCriteria.getStartEtag() |
Etag |
Etag.incrementBy(int amount) |
static Etag |
Etag.invalidEtag() |
static Etag |
Etag.parse(byte[] bytes) |
static Etag |
Etag.parse(String str) |
static Etag |
Etag.random() |
Etag |
Etag.setup(UuidType type,
long restartsNum) |
Modifier and Type | Method and Description |
---|---|
int |
Etag.compareTo(Etag other) |
void |
SubscriptionConfig.setAckEtag(Etag ackEtag) |
void |
IndexQuery.setCutoffEtag(Etag cutoffEtag)
Gets or sets the cutoff etag.
|
void |
IndexChangeNotification.setEtag(Etag etag)
Sets etag
|
void |
AttachmentInformation.setEtag(Etag etag)
Deprecated.
Current attachment etag.
|
void |
JsonDocument.setEtag(Etag etag)
Current document etag.
|
void |
PutResult.setEtag(Etag etag)
Etag of the document after PUT operation.
|
void |
StreamResult.setEtag(Etag etag)
Document etag.
|
void |
JsonDocumentMetadata.setEtag(Etag etag)
Current document etag.
|
void |
ReplicationConflictNotification.setEtag(Etag etag)
Current conflict document Etag.
|
void |
DocumentChangeNotification.setEtag(Etag etag)
Document etag.
|
void |
BatchResult.setEtag(Etag etag)
Etag generated by the operation (null if not applicable).
|
void |
IJsonDocumentMetadata.setEtag(Etag etag)
Current document etag, used for concurrency checks (null to skip check)
|
void |
Attachment.setEtag(Etag etag)
Deprecated.
Current attachment etag, used for concurrency checks (null to skip check).
|
void |
QueryResult.setIndexEtag(Etag indexEtag)
The last etag indexed by the index.
|
void |
QueryHeaderInformation.setIndexEtag(Etag indexEtag) |
void |
FacetResults.setIndexStateEtag(Etag indexStateEtag) |
void |
DatabaseStatistics.setLastAttachmentEtag(Etag lastAttachmentEtag)
Deprecated.
Use RavenFS instead.
|
void |
DatabaseStatistics.setLastDocEtag(Etag lastDocEtag)
Last document etag in database.
|
void |
IndexStats.setLastIndexedEtag(Etag lastIndexedEtag)
This value represents etag of last document indexed (using map) by this index.
|
void |
IndexStats.setLastReducedEtag(Etag lastReducedEtag)
This value represents etag of last document indexed (using reduce) by this index.
|
void |
SideBySideIndexes.setMinimumEtagBeforeReplace(Etag minimumEtagBeforeReplace) |
void |
QueryResult.setResultEtag(Etag resultEtag)
The ETag value for this index current state, which include what docs were indexed,
what document were deleted, etc.
|
void |
QueryHeaderInformation.setResultEtag(Etag resultEtag) |
void |
SubscriptionCriteria.setStartEtag(Etag startEtag) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Etag.tryParse(String str,
Reference<Etag> etag) |
Constructor and Description |
---|
Attachment(boolean canGetData,
byte[] data,
int size,
RavenJObject metadata,
Etag etag,
String key)
Deprecated.
|
JsonDocument(RavenJObject dataAsJson,
RavenJObject metadata,
String key,
Boolean nonAuthoritativeInformation,
Etag etag,
Date lastModified) |
PutResult(String key,
Etag etag) |
Modifier and Type | Method and Description |
---|---|
Etag |
ConcurrencyException.getActualEtag()
Actual Etag.
|
Etag |
ConcurrencyException.getExpectedEtag()
Expected Etag.
|
Constructor and Description |
---|
ConcurrencyException(Etag expectedEtag,
Etag actualEtag,
String error,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
protected Etag |
JsonExtensions.EtagDeserializer._deserialize(String value,
org.codehaus.jackson.map.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
Etag |
IndexReplaceDocument.getMinimumEtagBeforeReplace() |
Modifier and Type | Method and Description |
---|---|
void |
IndexReplaceDocument.setMinimumEtagBeforeReplace(Etag minimumEtagBeforeReplace) |
Modifier and Type | Method and Description |
---|---|
Etag |
ReplicatedEtagInfo.getDocumentEtag() |
Etag |
ReplicationStatistics.DestinationStats.getLastEtagCheckedForReplication() |
Etag |
ReplicationStatistics.DestinationStats.getLastReplicatedAttachmentEtag() |
Etag |
ReplicationStatistics.DestinationStats.getLastReplicatedEtag() |
Etag |
ReplicationStatistics.getMostRecentAttachmentEtag()
Deprecated.
|
Etag |
ReplicationStatistics.getMostRecentDocumentEtag() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedEtagInfo.setDocumentEtag(Etag documentEtag) |
void |
ReplicationStatistics.DestinationStats.setLastEtagCheckedForReplication(Etag lastEtagCheckedForReplication) |
void |
ReplicationStatistics.DestinationStats.setLastReplicatedAttachmentEtag(Etag lastReplicatedAttachmentEtag) |
void |
ReplicationStatistics.DestinationStats.setLastReplicatedEtag(Etag lastReplicatedEtag) |
void |
ReplicationStatistics.setMostRecentAttachmentEtag(Etag mostRecentAttachmentEtag)
Deprecated.
|
void |
ReplicationStatistics.setMostRecentDocumentEtag(Etag mostRecentDocumentEtag) |
Modifier and Type | Method and Description |
---|---|
Etag |
LastEtagsInfo.getLastAttachmentDeleteEtag() |
Etag |
LastEtagsInfo.getLastAttachmentEtag() |
Etag |
LastEtagsInfo.getLastDocDeleteEtag() |
Etag |
LastEtagsInfo.getLastDocsEtag() |
Modifier and Type | Method and Description |
---|---|
void |
LastEtagsInfo.setLastAttachmentDeleteEtag(Etag lastAttachmentDeleteEtag) |
void |
LastEtagsInfo.setLastAttachmentEtag(Etag lastAttachmentEtag) |
void |
LastEtagsInfo.setLastDocDeleteEtag(Etag lastDocDeleteEtag) |
void |
LastEtagsInfo.setLastDocsEtag(Etag lastDocsEtag) |
Modifier and Type | Method and Description |
---|---|
<T> Etag |
IAdvancedDocumentSessionOperations.getEtagFor(T instance)
Gets the ETag for the specified entity.
|
Etag |
RavenQueryStatistics.getIndexEtag() |
Etag |
IDocumentStore.getLastWrittenEtag()
Gets the etag of the last document written by any session belonging to this
document store
|
Etag |
DocumentStoreBase.getLastWrittenEtag()
Gets the etag of the last document written by any session belonging to this
document store
|
Etag |
RavenQueryStatistics.getResultEtag() |
Modifier and Type | Method and Description |
---|---|
void |
RavenQueryStatistics.setIndexEtag(Etag indexEtag)
The etag of the queried index
|
void |
RavenQueryStatistics.setResultEtag(Etag resultEtag) |
void |
IDocumentStore.sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc)
Executes the index creation in side-by-side mode.
|
void |
DocumentStoreBase.sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
void |
IDocumentStore.sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
void |
DocumentStoreBase.sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
void |
IDocumentSession.store(Object entity,
Etag etag)
Stores entity in session, extracts Id from entity using Conventions or generates new one if it is not available and
forces concurrency check with given Etag
|
void |
IDocumentSession.store(Object entity,
Etag etag,
String id)
Stores the specified entity with the specified etag, under the specified id
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation)
Stream the results on the query to the client, converting them to
Java types along the way.
|
<T> CloseableIterator<StreamResult<T>> |
ISyncAdvancedSessionOperation.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation,
String skipAfter)
Stream the results on the query to the client, converting them to
Java types along the way.
|
IDocumentQueryCustomization |
IDocumentQueryCustomization.waitForNonStaleResultsAsOf(Etag cutOffEtag)
Instructs the query to wait for non stale results as of the cutoff etag.
|
TSelf |
IDocumentQueryBase.waitForNonStaleResultsAsOf(Etag cutOffEtag)
Instructs the query to wait for non stale results as of the cutoff etag.
|
IDocumentQueryCustomization |
IDocumentQueryCustomization.waitForNonStaleResultsAsOf(Etag cutOffEtag,
long waitTimeout)
Instructs the query to wait for non stale results as of the cutoff etag for the specified timeout.
|
TSelf |
IDocumentQueryBase.waitForNonStaleResultsAsOf(Etag cutOffEtag,
long waitTimeout)
Instructs the query to wait for non stale results as of the cutoff etag for the specified timeout.
|
Constructor and Description |
---|
RemoteDatabaseChanges(String url,
String apiKey,
HttpJsonRequestFactory jsonRequestFactory,
DocumentConvention conventions,
IDocumentStoreReplicationInformer replicationInformer,
Action0 onDispose,
Function4<String,Etag,String[],OperationMetadata,Boolean> tryResolveConflictByUsingRegisteredConflictListeners) |
Modifier and Type | Method and Description |
---|---|
static Etag |
HttpExtensions.etagHeaderToEtag(String responseHeader) |
static Etag |
HttpExtensions.getEtagHeader(GetResponse response) |
static Etag |
HttpExtensions.getEtagHeader(HttpJsonRequest request) |
static Etag |
HttpExtensions.getEtagHeader(org.apache.http.HttpResponse httpResponse) |
Modifier and Type | Method and Description |
---|---|
void |
IDatabaseCommands.delete(String key,
Etag etag)
Deletes the document with the specified key
|
void |
ServerClient.delete(String key,
Etag etag) |
void |
IDatabaseCommands.deleteAttachment(String key,
Etag etag)
Deprecated.
Use RavenFS instead.
|
void |
ServerClient.deleteAttachment(String key,
Etag etag)
Deprecated.
|
protected void |
ServerClient.directDelete(OperationMetadata operationMetadata,
String key,
Etag etag) |
protected void |
ServerClient.directDeleteAttachment(String key,
Etag etag,
OperationMetadata operationMetadata)
Deprecated.
|
protected AttachmentInformation[] |
ServerClient.directGetAttachments(int start,
Etag startEtag,
int pageSize,
OperationMetadata operationMetadata)
Deprecated.
|
protected PutResult |
ServerClient.directPut(RavenJObject metadata,
String key,
Etag etag,
RavenJObject document,
OperationMetadata operationMetadata) |
protected void |
ServerClient.directPutAttachment(String key,
RavenJObject metadata,
Etag etag,
InputStream data,
OperationMetadata operationMetadata)
Deprecated.
|
RavenJObjectIterator |
ServerClient.directStreamDocs(OperationMetadata operationMetadata,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude,
RavenPagingInformation pagingInformation,
String skipAfter) |
protected void |
ServerClient.directUpdateAttachmentMetadata(String key,
RavenJObject metadata,
Etag etag,
OperationMetadata operationMetadata)
Deprecated.
|
AttachmentInformation[] |
IDatabaseCommands.getAttachments(int start,
Etag startEtag,
int pageSize)
Deprecated.
Use RavenFS instead.
|
AttachmentInformation[] |
ServerClient.getAttachments(int start,
Etag startEtag,
int pageSize)
Deprecated.
|
List<JsonDocument> |
IDatabaseCommands.getDocuments(Etag fromEtag,
int pageSize)
Retrieves multiple documents.
|
List<JsonDocument> |
ServerClient.getDocuments(Etag fromEtag,
int pageSize) |
List<JsonDocument> |
IDatabaseCommands.getDocuments(Etag fromEtag,
int pageSize,
boolean metadataOnly)
Retrieves multiple documents.
|
List<JsonDocument> |
ServerClient.getDocuments(Etag fromEtag,
int pageSize,
boolean metadataOnly) |
RavenJObject |
IDatabaseCommands.patch(String key,
PatchRequest[] patches,
Etag etag)
Sends a patch request for a specific document
|
RavenJObject |
ServerClient.patch(String key,
PatchRequest[] patches,
Etag etag) |
RavenJObject |
IDatabaseCommands.patch(String key,
ScriptedPatchRequest patch,
Etag etag)
Sends a patch request for a specific document
|
RavenJObject |
ServerClient.patch(String key,
ScriptedPatchRequest patch,
Etag etag) |
PutResult |
IDatabaseCommands.put(String key,
Etag guid,
RavenJObject document,
RavenJObject metadata)
Puts the document in the database with the specified key.
|
PutResult |
ServerClient.put(String key,
Etag etag,
RavenJObject document,
RavenJObject metadata) |
void |
IDatabaseCommands.putAttachment(String key,
Etag etag,
InputStream data,
RavenJObject metadata)
Deprecated.
Use RavenFS instead.
|
void |
ServerClient.putAttachment(String key,
Etag etag,
InputStream data,
RavenJObject metadata)
Deprecated.
|
String[] |
IDatabaseCommands.putSideBySideIndexes(IndexToAdd[] indexesToAdd,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc)
Creates multiple side by side indexes with the specified name, using given index definitions and priorities
|
String[] |
ServerClient.putSideBySideIndexes(IndexToAdd[] indexesToAdd,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude,
RavenPagingInformation pagingInformation)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude,
RavenPagingInformation pagingInformation) |
CloseableIterator<RavenJObject> |
IDatabaseCommands.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude,
RavenPagingInformation pagingInformation,
String skipAfter)
Streams the documents by etag OR starts with the prefix and match the matches
Will return *all* results, regardless of the number of items that might be returned.
|
RavenJObjectIterator |
ServerClient.streamDocs(Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
String exclude,
RavenPagingInformation pagingInformation,
String skipAfter) |
static QueryResult |
SerializationHelper.toQueryResult(RavenJObject json,
Etag etagHeader,
String tempRequestTime,
long numberOfCharactersRead) |
Boolean |
IDatabaseCommands.tryResolveConflictByUsingRegisteredListeners(OperationMetadata operationMetadata,
String key,
Etag etag,
List<String> conflictedIds,
OperationMetadata opUrl)
Tries to resolve conflict using registered listeners
|
Boolean |
ServerClient.tryResolveConflictByUsingRegisteredListeners(OperationMetadata operationMetadata,
String key,
Etag etag,
List<String> conflictedIds,
OperationMetadata opUrl) |
void |
IDatabaseCommands.updateAttachmentMetadata(String key,
Etag etag,
RavenJObject metadata)
Deprecated.
Use RavenFS instead.
|
void |
ServerClient.updateAttachmentMetadata(String key,
Etag etag,
RavenJObject metadata)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiGetOperation.tryResolveConflictOrCreateConcurrencyException(GetResponse[] responses,
Function3<String,RavenJObject,Etag,ConflictException> tryResolveConflictOrCreateConcurrencyException) |
Modifier and Type | Field and Description |
---|---|
protected Etag |
AbstractDocumentQuery.cutoffEtag |
Modifier and Type | Method and Description |
---|---|
Etag |
DocumentMetadata.getEtag() |
<T> Etag |
InMemoryDocumentSessionOperations.getEtagFor(T instance)
Gets the ETag for the specified entity.
|
Etag |
Subscription.LastProcessedEtagEventArgs.getLastProcessedEtag() |
Modifier and Type | Method and Description |
---|---|
void |
DocumentMetadata.setEtag(Etag etag) |
void |
InMemoryDocumentSessionOperations.store(Object entity,
Etag etag)
Stores the specified entity in the session.
|
void |
InMemoryDocumentSessionOperations.store(Object entity,
Etag etag,
String id)
Stores the specified entity in the session, explicitly specifying its Id.
|
protected void |
InMemoryDocumentSessionOperations.storeEntityInUnitOfWork(String id,
Object entity,
Etag etag,
RavenJObject metadata,
boolean forceConcurrencyCheck) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation) |
<T> CloseableIterator<StreamResult<T>> |
DocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation,
String skipAfter) |
DocumentQueryCustomizationFactory |
DocumentQueryCustomizationFactory.waitForNonStaleResultsAsOf(Etag cutOffEtag)
Instructs the query to wait for non stale results as of the cutoff etag.
|
IDocumentQueryCustomization |
DocumentQueryCustomization.waitForNonStaleResultsAsOf(Etag cutOffEtag) |
IDocumentQuery<T> |
AbstractDocumentQuery.waitForNonStaleResultsAsOf(Etag cutOffEtag)
Instructs the query to wait for non stale results as of the cutoff etag.
|
DocumentQueryCustomizationFactory |
DocumentQueryCustomizationFactory.waitForNonStaleResultsAsOf(Etag cutOffEtag,
long waitTimeout)
Instructs the query to wait for non stale results as of the cutoff etag for the specified timeout.
|
IDocumentQueryCustomization |
DocumentQueryCustomization.waitForNonStaleResultsAsOf(Etag cutOffEtag,
long waitTimeout) |
IDocumentQuery<T> |
AbstractDocumentQuery.waitForNonStaleResultsAsOf(Etag cutOffEtag,
long waitTimeout)
Instructs the query to wait for non stale results as of the cutoff etag.
|
protected void |
ReplicationBehavior.waitForReplicationFromServer(String url,
String sourceUrl,
String sourceDbId,
Etag etag,
ReplicatedEtagInfo[] latestEtags,
int index,
CancellationTokenSource.CancellationToken cancellationToken) |
int |
ReplicationBehavior.waitSync(Etag etag,
Long timeout,
String database,
int replicas) |
Constructor and Description |
---|
Subscription.LastProcessedEtagEventArgs(Etag lastProcessedEtag) |
Modifier and Type | Method and Description |
---|---|
Etag |
ConflictException.getEtag() |
Modifier and Type | Method and Description |
---|---|
void |
ConflictException.setEtag(Etag etag) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractIndexCreationTask.sideBySideExecute(IDatabaseCommands databaseCommands,
DocumentConvention documentConvention,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc)
Executes the index creation using in side-by-side mode.
|
void |
AbstractIndexCreationTask.sideBySideExecute(IDocumentStore store,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
Modifier and Type | Method and Description |
---|---|
Etag |
ShardedDocumentStore.getLastWrittenEtag()
Gets the etag of the last document written by any session belonging to this
|
Modifier and Type | Method and Description |
---|---|
void |
ShardedDocumentStore.sideBySideExecuteIndex(AbstractIndexCreationTask indexCreationTask,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
void |
ShardedDocumentStore.sideBySideExecuteIndexes(List<AbstractIndexCreationTask> indexCreationTasks,
Etag minimumEtagBeforeReplace,
Date replaceTimeUtc) |
protected void |
BaseShardedDocumentSession.storeEntityInUnitOfWork(String id,
Object entity,
Etag etag,
RavenJObject metadata,
boolean forceConcurrencyCheck) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation) |
<T> CloseableIterator<StreamResult<T>> |
ShardedDocumentSession.stream(Class<T> entityClass,
Etag fromEtag,
String startsWith,
String matches,
int start,
int pageSize,
RavenPagingInformation pagingInformation,
String skipAfter) |
Modifier and Type | Method and Description |
---|---|
Etag |
ILastEtagHolder.getLastWrittenEtag() |
Etag |
GlobalLastEtagHolder.getLastWrittenEtag() |
Modifier and Type | Method and Description |
---|---|
void |
ILastEtagHolder.updateLastWrittenEtag(Etag etag) |
void |
GlobalLastEtagHolder.updateLastWrittenEtag(Etag etag) |
Copyright © 2016. All Rights Reserved.