public class ShardedDatabaseChanges extends Object implements IDatabaseChanges
Constructor and Description |
---|
ShardedDatabaseChanges(IDatabaseChanges[] shardedDatabaseChanges) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionStatusChanged(EventHandler<VoidArgs> handler) |
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.
|
boolean |
isConnected() |
void |
removeConnectionStatusChanges(EventHandler<VoidArgs> handler) |
void |
waitForAllPendingSubscriptions() |
public ShardedDatabaseChanges(IDatabaseChanges[] shardedDatabaseChanges)
public boolean isConnected()
isConnected
in interface IConnectableChanges
public void addConnectionStatusChanged(EventHandler<VoidArgs> handler)
addConnectionStatusChanged
in interface IConnectableChanges
public void removeConnectionStatusChanges(EventHandler<VoidArgs> handler)
removeConnectionStatusChanges
in interface IConnectableChanges
public IObservable<IndexChangeNotification> forIndex(String indexName)
IDatabaseChanges
forIndex
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocument(String docId)
IDatabaseChanges
forDocument
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forAllDocuments()
IDatabaseChanges
forAllDocuments
in interface IDatabaseChanges
public IObservable<IndexChangeNotification> forAllIndexes()
IDatabaseChanges
forAllIndexes
in interface IDatabaseChanges
public IObservable<TransformerChangeNotification> forAllTransformers()
IDatabaseChanges
forAllTransformers
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsStartingWith(String docIdPrefix)
IDatabaseChanges
forDocumentsStartingWith
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsInCollection(String collectionName)
IDatabaseChanges
forDocumentsInCollection
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsInCollection(Class<?> clazz)
IDatabaseChanges
forDocumentsInCollection
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsOfType(String typeName)
IDatabaseChanges
forDocumentsOfType
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsOfType(Class<?> clazz)
IDatabaseChanges
forDocumentsOfType
in interface IDatabaseChanges
public IObservable<ReplicationConflictNotification> forAllReplicationConflicts()
IDatabaseChanges
forAllReplicationConflicts
in interface IDatabaseChanges
public IObservable<BulkInsertChangeNotification> forBulkInsert()
IDatabaseChanges
forBulkInsert
in interface IDatabaseChanges
public IObservable<BulkInsertChangeNotification> forBulkInsert(UUID operationId)
IDatabaseChanges
forBulkInsert
in interface IDatabaseChanges
public IObservable<DataSubscriptionChangeNotification> forAllDataSubscriptions()
IDatabaseChanges
forAllDataSubscriptions
in interface IDatabaseChanges
public IObservable<DataSubscriptionChangeNotification> forDataSubscription(long id)
IDatabaseChanges
forDataSubscription
in interface IDatabaseChanges
public void waitForAllPendingSubscriptions()
waitForAllPendingSubscriptions
in interface IConnectableChanges
Copyright © 2016. All Rights Reserved.