Package com.alpha.mongodb.sharding.core.template

Class CompositeShardedReactiveMongoTemplate

java.lang.Object

org.springframework.data.mongodb.core.ReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.ShardedReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.DatabaseShardedReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.CompositeShardedReactiveMongoTemplate

All Implemented Interfaces:

DatabaseShardingAssistant<org.springframework.data.mongodb.core.ReactiveMongoTemplate>, ShardingAssistant, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.data.mongodb.core.ReactiveAggregationOperation, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation, org.springframework.data.mongodb.core.ReactiveFindOperation, org.springframework.data.mongodb.core.ReactiveFluentMongoOperations, org.springframework.data.mongodb.core.ReactiveInsertOperation, org.springframework.data.mongodb.core.ReactiveMapReduceOperation, org.springframework.data.mongodb.core.ReactiveMongoOperations, org.springframework.data.mongodb.core.ReactiveRemoveOperation, org.springframework.data.mongodb.core.ReactiveUpdateOperation

public class CompositeShardedReactiveMongoTemplate
extends DatabaseShardedReactiveMongoTemplate

Composite Sharded Reactive Mongo Template to be used with collections that are sharded both by Database and Collection

Author:

Shashank Sharma

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveAggregationOperation

org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.ReactiveAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.TerminatingAggregationOperation<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveChangeStreamOperation

org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ReactiveChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ResumingChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.TerminatingChangeStream<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveFindOperation

org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithProjection, org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindDistinct, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.ReactiveFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingDistinct<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFindNear<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveInsertOperation

org.springframework.data.mongodb.core.ReactiveInsertOperation.InsertWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.ReactiveInsert<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.TerminatingInsert<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveMapReduceOperation

org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithMapFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithReduceFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.ReactiveMapReduce<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.TerminatingMapReduce<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveRemoveOperation

org.springframework.data.mongodb.core.ReactiveRemoveOperation.ReactiveRemove<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.TerminatingRemove<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveUpdateOperation

org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndModifyWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.ReactiveUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndModify<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndReplace<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithUpdate<T extends Object>

Field Summary

Fields inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

NO_OP_REF_RESOLVER

Constructor Summary

Constructors

Constructor	Description
CompositeShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient, String databaseName, CompositeShardingOptions shardingOptions)
CompositeShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory, CompositeShardingOptions shardingOptions)
CompositeShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory, org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter, CompositeShardingOptions shardingOptions)

Method Summary

Methods inherited from class com.alpha.mongodb.sharding.core.template.DatabaseShardedReactiveMongoTemplate

find, find, findAll, findAll, findAllAndRemove, findAllAndRemove, findAllAndRemove, findAndModify, findAndModify, findAndModify, findAndModify, findAndRemove, findAndRemove, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findById, findById, findDistinct, findDistinct, findDistinct, findDistinct, findOne, findOne, insert, insert, insert, insert, insert, insertAll, query, remove, remove, remove, remove, remove, remove, save, save, update, updateFirst, updateFirst, updateFirst, updateMulti, updateMulti, updateMulti, upsert, upsert, upsert

Methods inherited from class com.alpha.mongodb.sharding.core.template.ShardedReactiveMongoTemplate

setApplicationContext

Methods inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

aggregate, aggregate, aggregate, aggregate, aggregateAndReturn, changeStream, changeStream, collectionExists, collectionExists, convertToCreateCollectionOptions, convertToCreateCollectionOptions, count, count, count, countCanBeEstimated, createCollection, createCollection, createCollection, createCollection, createFlux, createFlux, createMono, createMono, doAggregate, doCount, doCreateCollection, doEstimatedCount, doExactCount, doFind, doFind, doFind, doFindAndDelete, doFindAndModify, doFindAndRemove, doFindAndReplace, doFindOne, doFindOne, doGetDatabase, doInsert, doInsertAll, doInsertBatch, doRemove, doSave, doUpdate, dropCollection, dropCollection, ensureNotCollectionLike, ensureNotIterable, estimatedCount, exactCount, execute, execute, execute, executeCommand, executeCommand, executeCommand, exists, exists, exists, geoNear, geoNear, geoNear, getCollection, getCollectionName, getCollectionNames, getConverter, getMongoDatabase, getMongoDatabaseFactory, indexOps, indexOps, insert, insertAll, insertAll, insertAll, insertDocument, insertDocumentList, inTransaction, inTransaction, mapReduce, mapReduce, mapReduce, maybeCallAfterConvert, maybeCallAfterSave, maybeCallBeforeConvert, maybeCallBeforeSave, maybeEmitEvent, prepareCollection, prepareDatabase, prepareWriteConcern, remove, remove, save, save, saveDocument, setEntityCallbacks, setReadPreference, setSessionSynchronization, setWriteConcern, setWriteConcernResolver, setWriteResultChecking, tail, tail, useEstimatedCount, withSession, withSession, withSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alpha.mongodb.sharding.core.assitant.DatabaseShardingAssistant

getDelegatedShardedMongoTemplateMap, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForFindContext, getDelegatedTemplateForFindContext, getDelegatedTemplateForSaveContext, getDelegatedTemplateForUpdateContext, getDelegatedTemplateForUpdateContext, getDelegatedTemplateWithEntityContext, getDelegatedTemplateWithoutEntityContext, resolveDatabaseHintWithEntityContext

Methods inherited from interface org.springframework.data.mongodb.core.ReactiveMongoOperations

changeStream, changeStream, estimatedCount, exactCount, exactCount, withSession

Methods inherited from interface com.alpha.mongodb.sharding.core.assitant.ShardingAssistant

getHintResolutionCallbacks, getShardingOptions, resolveCollectionHintWithoutEntityContext, resolveCollectionNameWithoutEntityContext, resolveDatabaseHintWithoutEntityContext, resolveDatabaseNameWithoutEntityContext

Constructor Detail

CompositeShardedReactiveMongoTemplate

public CompositeShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient,
                                             String databaseName,
                                             CompositeShardingOptions shardingOptions)

CompositeShardedReactiveMongoTemplate

public CompositeShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory,
                                             CompositeShardingOptions shardingOptions)

CompositeShardedReactiveMongoTemplate

public CompositeShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory,
                                             org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter,
                                             CompositeShardingOptions shardingOptions)