public interface IDatabaseChanges extends IConnectableChanges
Modifier and Type | Method and Description |
---|---|
IObservable<DataSubscriptionChangeNotification> |
forAllDataSubscriptions()
Subscribe to changes for all data subscriptions.
|
IObservable<DocumentChangeNotification> |
forAllDocuments()
Subscribe to changes for all documents.
|
IObservable<IndexChangeNotification> |
forAllIndexes()
Subscribe to changes for all indexes.
|
IObservable<ReplicationConflictNotification> |
forAllReplicationConflicts()
Subscribe to all replication conflicts.
|
IObservable<TransformerChangeNotification> |
forAllTransformers()
Subscribe to changes for all transformers.
|
IObservable<BulkInsertChangeNotification> |
forBulkInsert()
Subscribe to all bulk insert operation changes
|
IObservable<BulkInsertChangeNotification> |
forBulkInsert(UUID operationId)
Subscribe to all bulk insert operation changes that belong to a operation with given Id.
|
IObservable<DataSubscriptionChangeNotification> |
forDataSubscription(long id)
Subscribe to changes for a specified data subscription.
|
IObservable<DocumentChangeNotification> |
forDocument(String docId)
Subscribe to changes for specified document only.
|
IObservable<DocumentChangeNotification> |
forDocumentsInCollection(Class<?> clazz)
Subscribe to changes for all documents that belong to specified collection (Raven-Entity-Name).
|
IObservable<DocumentChangeNotification> |
forDocumentsInCollection(String collectionName)
Subscribe to changes for all documents that belong to specified collection (Raven-Entity-Name).
|
IObservable<DocumentChangeNotification> |
forDocumentsOfType(Class<?> clazz)
Subscribe to changes for all documents that belong to specified type (Raven-Clr-Type).
|
IObservable<DocumentChangeNotification> |
forDocumentsOfType(String typeName)
Subscribe to changes for all documents that belong to specified type (Raven-Clr-Type).
|
IObservable<DocumentChangeNotification> |
forDocumentsStartingWith(String docIdPrefix)
Subscribe to changes for all documents that Id starts with given prefix.
|
IObservable<IndexChangeNotification> |
forIndex(String indexName)
Subscribe to changes for specified index only.
|
addConnectionStatusChanged, isConnected, removeConnectionStatusChanges, waitForAllPendingSubscriptions
IObservable<IndexChangeNotification> forIndex(String indexName)
indexName
- IObservable<DocumentChangeNotification> forDocument(String docId)
docId
- IObservable<DocumentChangeNotification> forAllDocuments()
IObservable<IndexChangeNotification> forAllIndexes()
IObservable<TransformerChangeNotification> forAllTransformers()
IObservable<DocumentChangeNotification> forDocumentsStartingWith(String docIdPrefix)
docIdPrefix
- IObservable<DocumentChangeNotification> forDocumentsInCollection(String collectionName)
collectionName
- IObservable<DocumentChangeNotification> forDocumentsInCollection(Class<?> clazz)
clazz
- IObservable<DocumentChangeNotification> forDocumentsOfType(String typeName)
typeName
- IObservable<DocumentChangeNotification> forDocumentsOfType(Class<?> clazz)
clazz
- IObservable<ReplicationConflictNotification> forAllReplicationConflicts()
IObservable<BulkInsertChangeNotification> forBulkInsert(UUID operationId)
operationId
- IObservable<BulkInsertChangeNotification> forBulkInsert()
IObservable<DataSubscriptionChangeNotification> forAllDataSubscriptions()
IObservable<DataSubscriptionChangeNotification> forDataSubscription(long id)
Copyright © 2016. All Rights Reserved.