Package com.alpha.mongodb.sharding.core.client

Class DatabaseShardedReactiveMongoClient

java.lang.Object

com.alpha.mongodb.sharding.core.client.DatabaseShardedReactiveMongoClient

All Implemented Interfaces:

ShardedReactiveMongoClient, com.mongodb.reactivestreams.client.MongoClient, Closeable, AutoCloseable

Direct Known Subclasses:

CompositeShardedReactiveMongoClient

public class DatabaseShardedReactiveMongoClient
extends Object
implements ShardedReactiveMongoClient

Database Sharded Reactive Mongo Client to get the databases which are sharded by database.

Author:

Shashank Sharma

Constructor Summary

Constructors

Constructor	Description
DatabaseShardedReactiveMongoClient(com.mongodb.reactivestreams.client.MongoClient delegatedMongoClient, DatabaseShardingOptions shardingOptions)
DatabaseShardedReactiveMongoClient(Map<String,com.mongodb.reactivestreams.client.MongoClient> delegatedMongoClientMap, DatabaseShardingOptions shardingOptions)

Method Summary

Modifier and Type	Method	Description
void	close()
com.mongodb.connection.ClusterDescription	getClusterDescription()
com.mongodb.reactivestreams.client.MongoDatabase	getDatabase(String s)
org.reactivestreams.Publisher<String>	listDatabaseNames()
org.reactivestreams.Publisher<String>	listDatabaseNames(com.mongodb.reactivestreams.client.ClientSession clientSession)
com.mongodb.reactivestreams.client.ListDatabasesPublisher<org.bson.Document>	listDatabases()
com.mongodb.reactivestreams.client.ListDatabasesPublisher<org.bson.Document>	listDatabases(com.mongodb.reactivestreams.client.ClientSession clientSession)
<T> com.mongodb.reactivestreams.client.ListDatabasesPublisher<T>	listDatabases(com.mongodb.reactivestreams.client.ClientSession clientSession, Class<T> aClass)
<T> com.mongodb.reactivestreams.client.ListDatabasesPublisher<T>	listDatabases(Class<T> aClass)
org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession>	startSession()
org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession>	startSession(com.mongodb.ClientSessionOptions clientSessionOptions)
com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document>	watch()
com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document>	watch(com.mongodb.reactivestreams.client.ClientSession clientSession)
<T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T>	watch(com.mongodb.reactivestreams.client.ClientSession clientSession, Class<T> aClass)
com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document>	watch(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list)
<T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T>	watch(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list, Class<T> aClass)
<T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T>	watch(Class<T> aClass)
com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document>	watch(List<? extends org.bson.conversions.Bson> list)
<T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T>	watch(List<? extends org.bson.conversions.Bson> list, Class<T> aClass)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseShardedReactiveMongoClient

public DatabaseShardedReactiveMongoClient(Map<String,com.mongodb.reactivestreams.client.MongoClient> delegatedMongoClientMap,
                                          DatabaseShardingOptions shardingOptions)

DatabaseShardedReactiveMongoClient

public DatabaseShardedReactiveMongoClient(com.mongodb.reactivestreams.client.MongoClient delegatedMongoClient,
                                          DatabaseShardingOptions shardingOptions)

Method Detail

getDatabase

public com.mongodb.reactivestreams.client.MongoDatabase getDatabase(String s)

Specified by:

getDatabase in interface com.mongodb.reactivestreams.client.MongoClient

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface com.mongodb.reactivestreams.client.MongoClient

listDatabaseNames

public org.reactivestreams.Publisher<String> listDatabaseNames()

Specified by:

listDatabaseNames in interface com.mongodb.reactivestreams.client.MongoClient

listDatabaseNames

public org.reactivestreams.Publisher<String> listDatabaseNames(com.mongodb.reactivestreams.client.ClientSession clientSession)

Specified by:

listDatabaseNames in interface com.mongodb.reactivestreams.client.MongoClient

listDatabases

public com.mongodb.reactivestreams.client.ListDatabasesPublisher<org.bson.Document> listDatabases()

Specified by:

listDatabases in interface com.mongodb.reactivestreams.client.MongoClient

listDatabases

public <T> com.mongodb.reactivestreams.client.ListDatabasesPublisher<T> listDatabases(Class<T> aClass)

Specified by:

listDatabases in interface com.mongodb.reactivestreams.client.MongoClient

listDatabases

public com.mongodb.reactivestreams.client.ListDatabasesPublisher<org.bson.Document> listDatabases(com.mongodb.reactivestreams.client.ClientSession clientSession)

Specified by:

listDatabases in interface com.mongodb.reactivestreams.client.MongoClient

listDatabases

public <T> com.mongodb.reactivestreams.client.ListDatabasesPublisher<T> listDatabases(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                                      Class<T> aClass)

Specified by:

listDatabases in interface com.mongodb.reactivestreams.client.MongoClient

watch

public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch()

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch(Class<T> aClass)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch(List<? extends org.bson.conversions.Bson> list)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch(List<? extends org.bson.conversions.Bson> list,
                                                                             Class<T> aClass)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch(com.mongodb.reactivestreams.client.ClientSession clientSession)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                             Class<T> aClass)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                                         List<? extends org.bson.conversions.Bson> list)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

watch

public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                             List<? extends org.bson.conversions.Bson> list,
                                                                             Class<T> aClass)

Specified by:

watch in interface com.mongodb.reactivestreams.client.MongoClient

startSession

public org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession> startSession()

Specified by:

startSession in interface com.mongodb.reactivestreams.client.MongoClient

startSession

public org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession> startSession(com.mongodb.ClientSessionOptions clientSessionOptions)

Specified by:

startSession in interface com.mongodb.reactivestreams.client.MongoClient

getClusterDescription

public com.mongodb.connection.ClusterDescription getClusterDescription()

Specified by:

getClusterDescription in interface com.mongodb.reactivestreams.client.MongoClient