Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jnr/jffi/1.2.15
- com.github.jnr/jffi/1.2.15/native
- com.github.jnr/jnr-constants/0.9.8
- com.github.jnr/jnr-enxio/0.16
- com.github.jnr/jnr-ffi/2.1.4
- com.github.jnr/jnr-posix/3.0.35
- com.github.jnr/jnr-unixsocket/0.18
- com.github.jnr/jnr-x86asm/1.0.2
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mongodb/bson/3.10.1
- org.mongodb/mongodb-driver-async/3.10.1
- org.mongodb/mongodb-driver-core/3.10.1
- org.mvel/mvel2/2.3.1.Final
- org.ow2.asm/asm/5.0.3
- org.ow2.asm/asm-analysis/5.0.3
- org.ow2.asm/asm-commons/5.0.3
- org.ow2.asm/asm-tree/5.0.3
- org.ow2.asm/asm-util/5.0.3
- org.slf4j/slf4j-api/1.7.6
- org.xerial.snappy/snappy-java/1.1.4
Declarations
-
examples
-
MongoClientExamples
-
exampleCreateDefault(Vertx, JsonObject): void
-
exampleCreatePoolName(Vertx, JsonObject): void
-
exampleCreateNonShared(Vertx, JsonObject): void
-
example1(MongoClient): void
-
example2(MongoClient): void
-
example3(MongoClient): void
-
example4(MongoClient): void
-
example5(MongoClient): void
-
example6(MongoClient): void
-
example7(MongoClient): void
-
example8(MongoClient): void
-
example9(MongoClient): void
-
findBatch(MongoClient): void
-
findBatchWithOptions(MongoClient): void
-
example10(MongoClient): void
-
example11(MongoClient): void
-
example11_1(MongoClient): void
-
example11_2(MongoClient): void
-
example11_3(MongoClient): void
-
example12(MongoClient): void
-
example13_0(MongoClient): void
-
example14_01_dl(MongoClient): void
-
example14_02_dl(MongoClient): void
-
example15_dl(MongoClient): void
-
example16(MongoClient): void
-
example16_d1(MongoClient): void
-
example17(MongoClient): void
-
example17_d1(MongoClient): void
-
-
-
io
-
vertx
-
ext
-
mongo
-
AggregateOptions
-
DEFAULT_BATCH_SIZE: int
-
DEFAULT_MAX_TIME: long
-
DEFAULT_MAX_AWAIT_TIME: long
-
batchSize: int
-
maxTime: long
-
maxAwaitTime: long
-
allowDiskUse: Boolean
-
AggregateOptions(): void
-
AggregateOptions(AggregateOptions): void
-
AggregateOptions(JsonObject): void
-
toJson(): JsonObject
-
getMaxTime(): long
-
setMaxTime(long): AggregateOptions
-
getBatchSize(): int
-
getAllowDiskUse(): Boolean
-
setAllowDiskUse(Boolean): AggregateOptions
-
setBatchSize(int): AggregateOptions
-
getMaxAwaitTime(): long
-
setMaxAwaitTime(long): AggregateOptions
-
equals(Object): boolean
-
hashCode(): int
-
-
AggregateOptionsConverter
-
BulkOperation
-
DEFAULT_MULTI: boolean
-
DEFAULT_UPSERT: boolean
-
BulkOperationType
-
type: BulkOperationType
-
filter: JsonObject
-
document: JsonObject
-
upsert: boolean
-
multi: boolean
-
BulkOperation(BulkOperationType): void
-
BulkOperation(JsonObject): void
-
toJson(): JsonObject
-
createDelete(JsonObject): BulkOperation
-
createInsert(JsonObject): BulkOperation
-
createReplace(JsonObject, JsonObject): BulkOperation
-
createReplace(JsonObject, JsonObject, boolean): BulkOperation
-
createUpdate(JsonObject, JsonObject): BulkOperation
-
createUpdate(JsonObject, JsonObject, boolean, boolean): BulkOperation
-
getType(): BulkOperationType
-
setType(BulkOperationType): BulkOperation
-
getFilter(): JsonObject
-
setFilter(JsonObject): BulkOperation
-
getDocument(): JsonObject
-
setDocument(JsonObject): BulkOperation
-
isUpsert(): boolean
-
setUpsert(boolean): BulkOperation
-
isMulti(): boolean
-
setMulti(boolean): BulkOperation
-
equals(Object): boolean
-
hashCode(): int
-
-
BulkWriteOptions
-
ORDERED: String
-
WRITE_OPTION: String
-
DEFAULT_ORDERED: boolean
-
writeOption: WriteOption
-
ordered: boolean
-
BulkWriteOptions(): void
-
BulkWriteOptions(boolean): void
-
BulkWriteOptions(BulkWriteOptions): void
-
BulkWriteOptions(JsonObject): void
-
toJson(): JsonObject
-
getWriteOption(): WriteOption
-
setWriteOption(WriteOption): BulkWriteOptions
-
isOrdered(): boolean
-
setOrdered(boolean): BulkWriteOptions
-
-
FindOptions
-
DEFAULT_SKIP: int
-
DEFAULT_BATCH_SIZE: int
-
fields: JsonObject
-
DEFAULT_LIMIT: int
-
sort: JsonObject
-
limit: int
-
skip: int
-
batchSize: int
-
FindOptions(): void
-
FindOptions(FindOptions): void
-
FindOptions(JsonObject): void
-
toJson(): JsonObject
-
getFields(): JsonObject
-
setFields(JsonObject): FindOptions
-
getSort(): JsonObject
-
setSort(JsonObject): FindOptions
-
getLimit(): int
-
setLimit(int): FindOptions
-
getSkip(): int
-
setSkip(int): FindOptions
-
getBatchSize(): int
-
setBatchSize(int): FindOptions
-
equals(Object): boolean
-
hashCode(): int
-
-
FindOptionsConverter
-
IndexOptions
-
DEFAULT_BACKGROUD: boolean
-
DEFAULT_UNIQUE: boolean
-
DEFAULT_SPARSE: boolean
-
background: boolean
-
unique: boolean
-
name: String
-
sparse: boolean
-
expireAfterSeconds: Long
-
version: Integer
-
weights: JsonObject
-
defaultLanguage: String
-
languageOverride: String
-
textVersion: Integer
-
sphereVersion: Integer
-
bits: Integer
-
min: Double
-
max: Double
-
bucketSize: Double
-
storageEngine: JsonObject
-
partialFilterExpression: JsonObject
-
IndexOptions(): void
-
IndexOptions(IndexOptions): void
-
IndexOptions(JsonObject): void
-
toJson(): JsonObject
-
isBackground(): boolean
-
background(boolean): IndexOptions
-
isUnique(): boolean
-
unique(boolean): IndexOptions
-
getName(): String
-
name(String): IndexOptions
-
isSparse(): boolean
-
sparse(boolean): IndexOptions
-
getExpireAfter(TimeUnit): Long
-
expireAfter(Long, TimeUnit): IndexOptions
-
getVersion(): Integer
-
version(Integer): IndexOptions
-
getWeights(): JsonObject
-
weights(JsonObject): IndexOptions
-
getDefaultLanguage(): String
-
defaultLanguage(String): IndexOptions
-
getLanguageOverride(): String
-
languageOverride(String): IndexOptions
-
getTextVersion(): Integer
-
textVersion(Integer): IndexOptions
-
getSphereVersion(): Integer
-
sphereVersion(Integer): IndexOptions
-
getBits(): Integer
-
bits(Integer): IndexOptions
-
getMin(): Double
-
min(Double): IndexOptions
-
getMax(): Double
-
max(Double): IndexOptions
-
getBucketSize(): Double
-
bucketSize(Double): IndexOptions
-
getStorageEngine(): JsonObject
-
storageEngine(JsonObject): IndexOptions
-
getPartialFilterExpression(): JsonObject
-
partialFilterExpression(JsonObject): IndexOptions
-
-
MongoClient
-
close(): void
-
createNonShared(Vertx, JsonObject): MongoClient
-
DEFAULT_POOL_NAME: String
-
DEFAULT_DB_NAME: String
-
createShared(Vertx, JsonObject, String): MongoClient
-
createShared(Vertx, JsonObject): MongoClient
-
save(String, JsonObject, Handler<AsyncResult<String>>): MongoClient
-
saveWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<String>>): MongoClient
-
insert(String, JsonObject, Handler<AsyncResult<String>>): MongoClient
-
insertWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<String>>): MongoClient
-
update(String, JsonObject, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
updateCollection(String, JsonObject, JsonObject, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
updateWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<Void>>): MongoClient
-
updateCollectionWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
replace(String, JsonObject, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
replaceDocuments(String, JsonObject, JsonObject, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
replaceWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<Void>>): MongoClient
-
replaceDocumentsWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
bulkWrite(String, List<BulkOperation>, Handler<AsyncResult<MongoClientBulkWriteResult>>): MongoClient
-
bulkWriteWithOptions(String, List<BulkOperation>, BulkWriteOptions, Handler<AsyncResult<MongoClientBulkWriteResult>>): MongoClient
-
find(String, JsonObject, Handler<AsyncResult<List<JsonObject>>>): MongoClient
-
findBatch(String, JsonObject): ReadStream<JsonObject>
-
findWithOptions(String, JsonObject, FindOptions, Handler<AsyncResult<List<JsonObject>>>): MongoClient
-
findBatchWithOptions(String, JsonObject, FindOptions): ReadStream<JsonObject>
-
findOne(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndUpdate(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndUpdateWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndReplace(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndReplaceWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndDelete(String, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndDeleteWithOptions(String, JsonObject, FindOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
count(String, JsonObject, Handler<AsyncResult<Long>>): MongoClient
-
remove(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
removeDocuments(String, JsonObject, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<Void>>): MongoClient
-
removeDocumentsWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeOne(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
removeDocument(String, JsonObject, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeOneWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<Void>>): MongoClient
-
removeDocumentWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
createCollection(String, Handler<AsyncResult<Void>>): MongoClient
-
getCollections(Handler<AsyncResult<List<String>>>): MongoClient
-
dropCollection(String, Handler<AsyncResult<Void>>): MongoClient
-
createIndex(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
createIndexWithOptions(String, JsonObject, IndexOptions, Handler<AsyncResult<Void>>): MongoClient
-
listIndexes(String, Handler<AsyncResult<JsonArray>>): MongoClient
-
dropIndex(String, String, Handler<AsyncResult<Void>>): MongoClient
-
runCommand(String, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
distinct(String, String, String, Handler<AsyncResult<JsonArray>>): MongoClient
-
distinctWithQuery(String, String, String, JsonObject, Handler<AsyncResult<JsonArray>>): MongoClient
-
distinctBatch(String, String, String): ReadStream<JsonObject>
-
distinctBatchWithQuery(String, String, String, JsonObject): ReadStream<JsonObject>
-
distinctBatchWithQuery(String, String, String, JsonObject, int): ReadStream<JsonObject>
-
aggregate(String, JsonArray): ReadStream<JsonObject>
-
aggregateWithOptions(String, JsonArray, AggregateOptions): ReadStream<JsonObject>
-
-
MongoClientBulkWriteResult
-
INSERTED_COUNT: String
-
MATCHED_COUNT: String
-
MODIFIED_COUNT: String
-
DELETED_COUNT: String
-
UPSERTS: String
-
ID: String
-
INDEX: String
-
DEFAULT_INSERTED_COUNT: long
-
DEFAULT_MATCHED_COUNT: long
-
DEFAULT_DELETED_COUNT: long
-
DEFAULT_MODIFIED_COUNT: long
-
insertedCount: long
-
matchedCount: long
-
deletedCount: long
-
modifiedCount: long
-
upserts: List<JsonObject>
-
MongoClientBulkWriteResult(): void
-
MongoClientBulkWriteResult(long, long, long, long, List<JsonObject>): void
-
MongoClientBulkWriteResult(MongoClientBulkWriteResult): void
-
MongoClientBulkWriteResult(JsonObject): void
-
toJson(): JsonObject
-
getInsertedCount(): long
-
getMatchedCount(): long
-
getDeletedCount(): long
-
getModifiedCount(): long
-
getUpserts(): List<JsonObject>
-
hashCode(): int
-
equals(Object): boolean
-
-
MongoClientDeleteResult
-
DEFAULT_REMOVEDCOUNT: long
-
REMOVED_COUNT: String
-
docRemovedCount: long
-
MongoClientDeleteResult(): void
-
MongoClientDeleteResult(long): void
-
MongoClientDeleteResult(MongoClientDeleteResult): void
-
MongoClientDeleteResult(JsonObject): void
-
toJson(): JsonObject
-
getRemovedCount(): long
-
equals(Object): boolean
-
hashCode(): int
-
-
MongoClientUpdateResult
-
DEFAULT_DOCMATCHED: long
-
DEFAULT_DOCMODIFIED: long
-
DOC_MATCHED: String
-
UPSERTED_ID: String
-
DOC_MODIFIED: String
-
ID_FIELD: String
-
docMatched: long
-
docUpsertedId: JsonObject
-
docModified: long
-
MongoClientUpdateResult(): void
-
MongoClientUpdateResult(long, JsonObject, long): void
-
MongoClientUpdateResult(MongoClientUpdateResult): void
-
MongoClientUpdateResult(JsonObject): void
-
toJson(): JsonObject
-
getDocMatched(): long
-
getDocUpsertedId(): JsonObject
-
getDocModified(): long
-
equals(Object): boolean
-
hashCode(): int
-
-
UpdateOptions
-
DEFAULT_UPSERT: boolean
-
DEFAULT_MULTI: boolean
-
DEFAULT_RETURN_NEW_DOCUMENT: boolean
-
writeOption: WriteOption
-
upsert: boolean
-
multi: boolean
-
returnNewDocument: boolean
-
UpdateOptions(): void
-
UpdateOptions(boolean): void
-
UpdateOptions(boolean, boolean): void
-
UpdateOptions(UpdateOptions): void
-
UpdateOptions(JsonObject): void
-
getWriteOption(): WriteOption
-
setWriteOption(WriteOption): UpdateOptions
-
isUpsert(): boolean
-
isReturningNewDocument(): boolean
-
setUpsert(boolean): UpdateOptions
-
setReturningNewDocument(boolean): UpdateOptions
-
isMulti(): boolean
-
setMulti(boolean): UpdateOptions
-
toJson(): JsonObject
-
equals(Object): boolean
-
hashCode(): int
-
-
WriteOption
-
impl
-
JsonObjectBsonAdapter
-
MongoClientImpl
-
log: Logger
-
DEFAULT_UPDATE_OPTIONS: UpdateOptions
-
DEFAULT_FIND_OPTIONS: FindOptions
-
DEFAULT_AGGREGATE_OPTIONS: AggregateOptions
-
DEFAULT_BULK_WRITE_OPTIONS: BulkWriteOptions
-
ID_FIELD: String
-
DS_LOCAL_MAP_NAME: String
-
vertx: Vertx
-
mongo: MongoClient
-
holder: MongoHolder
-
useObjectId: boolean
-
MongoClientImpl(Vertx, JsonObject, String): void
-
close(): void
-
save(String, JsonObject, Handler<AsyncResult<String>>): MongoClient
-
saveWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<String>>): MongoClient
-
insert(String, JsonObject, Handler<AsyncResult<String>>): MongoClient
-
insertWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<String>>): MongoClient
-
update(String, JsonObject, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
updateCollection(String, JsonObject, JsonObject, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
updateWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<Void>>): MongoClient
-
updateCollectionWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
generateIdIfNeeded(JsonObject, JsonObject, UpdateOptions): JsonObject
-
replace(String, JsonObject, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
replaceDocuments(String, JsonObject, JsonObject, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
replaceWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<Void>>): MongoClient
-
replaceDocumentsWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler<AsyncResult<MongoClientUpdateResult>>): MongoClient
-
find(String, JsonObject, Handler<AsyncResult<List<JsonObject>>>): MongoClient
-
findBatch(String, JsonObject): ReadStream<JsonObject>
-
findWithOptions(String, JsonObject, FindOptions, Handler<AsyncResult<List<JsonObject>>>): MongoClient
-
findBatchWithOptions(String, JsonObject, FindOptions): ReadStream<JsonObject>
-
findOne(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndUpdate(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndUpdateWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndReplace(String, JsonObject, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndReplaceWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndDelete(String, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
findOneAndDeleteWithOptions(String, JsonObject, FindOptions, Handler<AsyncResult<JsonObject>>): MongoClient
-
count(String, JsonObject, Handler<AsyncResult<Long>>): MongoClient
-
remove(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
removeDocuments(String, JsonObject, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<Void>>): MongoClient
-
removeDocumentsWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeOne(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
removeDocument(String, JsonObject, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
removeOneWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<Void>>): MongoClient
-
removeDocumentWithOptions(String, JsonObject, WriteOption, Handler<AsyncResult<MongoClientDeleteResult>>): MongoClient
-
bulkWrite(String, List<BulkOperation>, Handler<AsyncResult<MongoClientBulkWriteResult>>): MongoClient
-
bulkWriteWithOptions(String, List<BulkOperation>, BulkWriteOptions, Handler<AsyncResult<MongoClientBulkWriteResult>>): MongoClient
-
mongoBulkWriteOptions(BulkWriteOptions): BulkWriteOptions
-
convertBulkOperations(List<BulkOperation>): List<WriteModel<JsonObject>>
-
createCollection(String, Handler<AsyncResult<Void>>): MongoClient
-
getCollections(Handler<AsyncResult<List<String>>>): MongoClient
-
dropCollection(String, Handler<AsyncResult<Void>>): MongoClient
-
createIndex(String, JsonObject, Handler<AsyncResult<Void>>): MongoClient
-
createIndexWithOptions(String, JsonObject, IndexOptions, Handler<AsyncResult<Void>>): MongoClient
-
toBson(JsonObject): Bson
-
listIndexes(String, Handler<AsyncResult<JsonArray>>): MongoClient
-
dropIndex(String, String, Handler<AsyncResult<Void>>): MongoClient
-
runCommand(String, JsonObject, Handler<AsyncResult<JsonObject>>): MongoClient
-
distinct(String, String, String, Handler<AsyncResult<JsonArray>>): MongoClient
-
distinctWithQuery(String, String, String, JsonObject, Handler<AsyncResult<JsonArray>>): MongoClient
-
distinctBatch(String, String, String): ReadStream<JsonObject>
-
distinctBatchWithQuery(String, String, String, JsonObject): ReadStream<JsonObject>
-
distinctBatchWithQuery(String, String, String, JsonObject, int): ReadStream<JsonObject>
-
aggregate(String, JsonArray): ReadStream<JsonObject>
-
aggregateWithOptions(String, JsonArray, AggregateOptions): ReadStream<JsonObject>
-
convertMongoIterable(MongoIterable, Handler<AsyncResult<JsonArray>>): void
-
findDistinctValuesWithQuery(String, String, String, JsonObject): DistinctIterable<Object>
-
doAggregate(String, JsonArray, AggregateOptions): AggregateIterable<JsonObject>
-
encodeKeyWhenUseObjectId(JsonObject): JsonObject
-
decodeKeyWhenUseObjectId(JsonObject): JsonObject
-
convertCallback(Handler<AsyncResult<Object>>, Function<Object, Object>): SingleResultCallback<Object>
-
toVoidAsyncResult(Handler<AsyncResult<Void>>): Handler<AsyncResult<Object>>
-
toMongoClientUpdateResult(Handler<AsyncResult<MongoClientUpdateResult>>): SingleResultCallback<UpdateResult>
-
toMongoClientDeleteResult(Handler<AsyncResult<MongoClientDeleteResult>>): SingleResultCallback<DeleteResult>
-
toMongoClientBulkWriteResult(Handler<AsyncResult<MongoClientBulkWriteResult>>): SingleResultCallback<BulkWriteResult>
-
convertToMongoClientBulkWriteResult(int, int, int, int, List<BulkWriteUpsert>): MongoClientBulkWriteResult
-
wrapCallback(Handler<AsyncResult<Object>>): SingleResultCallback<Object>
-
doFind(String, JsonObject, FindOptions): FindIterable<JsonObject>
-
getCollection(String): MongoCollection<JsonObject>
-
getCollection(String, WriteOption): MongoCollection<JsonObject>
-
mongoUpdateOptions(UpdateOptions): UpdateOptions
-
wrap(JsonObject): JsonObjectBsonAdapter
-
removeFromMap(LocalMap<String, MongoHolder>, String): void
-
lookupHolder(String, JsonObject): MongoHolder
-
convertToMongoClientUpdateResult(long, BsonValue, long): MongoClientUpdateResult
-
convertUpsertId(BsonValue): JsonObject
-
MongoHolder
-
FailedStream
-
e: ClassNotFoundException
-
FailedStream(ClassNotFoundException): void
-
exceptionHandler(Handler<Throwable>): ReadStream<JsonObject>
-
handler(Handler<JsonObject>): ReadStream<JsonObject>
-
pause(): ReadStream<JsonObject>
-
fetch(long): ReadStream<JsonObject>
-
resume(): ReadStream<JsonObject>
-
endHandler(Handler<Void>): ReadStream<JsonObject>
-
-
-
MongoIterableStream
-
context: Context
-
mongoIterable: MongoIterable<JsonObject>
-
batchSize: int
-
batchCursor: AsyncBatchCursor<JsonObject>
-
queue: InboundBuffer<JsonObject>
-
exceptionHandler: Handler<Throwable>
-
endHandler: Handler<Void>
-
closed: boolean
-
MongoIterableStream(Context, MongoIterable<JsonObject>, int): void
-
exceptionHandler(Handler<Throwable>): MongoIterableStream
-
handler(Handler<JsonObject>): MongoIterableStream
-
pause(): MongoIterableStream
-
resume(): MongoIterableStream
-
fetch(long): ReadStream<JsonObject>
-
doRead(): void
-
handleException(Throwable): void
-
endHandler(Handler<Void>): MongoIterableStream
-
close(): void
-
-
codec
-
VertxCodecRegistry
-
json
-
AbstractJsonCodec
-
writeInt32(BsonWriter, String, Object, EncoderContext): void
-
readInt64(BsonReader, DecoderContext): Object
-
decode(BsonReader, DecoderContext): Object
-
encode(BsonWriter, Object, EncoderContext): void
-
readValue(BsonReader, DecoderContext): Object
-
writeValue(BsonWriter, String, Object, EncoderContext): void
-
getBsonType(Object): BsonType
-
readNull(BsonReader, DecoderContext): Object
-
writeNull(BsonWriter, String, Object, EncoderContext): void
-
readBoolean(BsonReader, DecoderContext): Object
-
writeBoolean(BsonWriter, String, Object, EncoderContext): void
-
readDouble(BsonReader, DecoderContext): Object
-
writeDouble(BsonWriter, String, Object, EncoderContext): void
-
readInt32(BsonReader, DecoderContext): Object
-
writeInt64(BsonWriter, String, Object, EncoderContext): void
-
readString(BsonReader, DecoderContext): Object
-
writeString(BsonWriter, String, Object, EncoderContext): void
-
isObjectIdInstance(Object): boolean
-
readDocument(BsonReader, DecoderContext): Object
-
writeDocument(BsonWriter, String, Object, EncoderContext): void
-
newObject(): Object
-
add(Object, String, Object): void
-
isObjectInstance(Object): boolean
-
beforeFields(Object, BiConsumer<String, Object>): void
-
forEach(Object, BiConsumer<String, Object>): void
-
readArray(BsonReader, DecoderContext): Object
-
writeArray(BsonWriter, String, Object, EncoderContext): void
-
newArray(): Object
-
add(Object, Object): void
-
isArrayInstance(Object): boolean
-
forEach(Object, Consumer<Object>): void
-
readBinary(BsonReader, DecoderContext): Object
-
writeBinary(BsonWriter, String, Object, EncoderContext): void
-
readDateTime(BsonReader, DecoderContext): Object
-
writeDateTime(BsonWriter, String, Object, EncoderContext): void
-
readDbPointer(BsonReader, DecoderContext): Object
-
writeDbPointer(BsonWriter, String, Object, EncoderContext): void
-
readMaxKey(BsonReader, DecoderContext): Object
-
writeMaxKey(BsonWriter, String, Object, EncoderContext): void
-
readMinKey(BsonReader, DecoderContext): Object
-
writeMinKey(BsonWriter, String, Object, EncoderContext): void
-
readJavaScript(BsonReader, DecoderContext): Object
-
writeJavaScript(BsonWriter, String, Object, EncoderContext): void
-
readJavaScriptWithScope(BsonReader, DecoderContext): Object
-
writeJavaScriptWithScope(BsonWriter, String, Object, EncoderContext): void
-
readObjectId(BsonReader, DecoderContext): Object
-
writeObjectId(BsonWriter, String, Object, EncoderContext): void
-
readRegularExpression(BsonReader, DecoderContext): Object
-
writeRegularExpression(BsonWriter, String, Object, EncoderContext): void
-
readSymbol(BsonReader, DecoderContext): Object
-
writeSymbol(BsonWriter, String, Object, EncoderContext): void
-
readTimeStamp(BsonReader, DecoderContext): Object
-
writeTimeStamp(BsonWriter, String, Object, EncoderContext): void
-
readUndefined(BsonReader, DecoderContext): Object
-
writeUndefined(BsonWriter, String, Object, EncoderContext): void
-
-
JsonObjectCodec
-
ID_FIELD: String
-
DATE_FIELD: String
-
BINARY_FIELD: String
-
TYPE_FIELD: String
-
OID_FIELD: String
-
TIMESTAMP_FIELD: String
-
TIMESTAMP_TIME_FIELD: String
-
TIMESTAMP_INCREMENT_FIELD: String
-
useObjectId: boolean
-
JsonObjectCodec(JsonObject): void
-
generateIdIfAbsentFromDocument(JsonObject): JsonObject
-
generateHexObjectId(): String
-
documentHasId(JsonObject): boolean
-
getDocumentId(JsonObject): BsonValue
-
getEncoderClass(): Class<JsonObject>
-
isObjectIdInstance(Object): boolean
-
beforeFields(JsonObject, BiConsumer<String, Object>): void
-
newObject(): JsonObject
-
add(JsonObject, String, Object): void
-
isObjectInstance(Object): boolean
-
forEach(JsonObject, BiConsumer<String, Object>): void
-
newArray(): JsonArray
-
add(JsonArray, Object): void
-
isArrayInstance(Object): boolean
-
forEach(JsonArray, Consumer<Object>): void
-
getBsonType(Object): BsonType
-
readObjectId(BsonReader, DecoderContext): Object
-
writeObjectId(BsonWriter, String, Object, EncoderContext): void
-
readDateTime(BsonReader, DecoderContext): Object
-
writeDateTime(BsonWriter, String, Object, EncoderContext): void
-
readBinary(BsonReader, DecoderContext): Object
-
writeBinary(BsonWriter, String, Object, EncoderContext): void
-
readTimeStamp(BsonReader, DecoderContext): Object
-
writeTimeStamp(BsonWriter, String, Object, EncoderContext): void
-
-
-
-
config
-
ClusterSettingsParser
-
ConnectionPoolSettingsParser
-
CredentialListParser
-
MongoClientOptionsParser
-
ReadConcernLevelParser
-
ReadPreferenceParser
-
SSLSettingsParser
-
ServerSettingsParser
-
SocketSettingsParser
-
StreamTypeParser
-
connectionString: ConnectionString
-
config: JsonObject
-
StreamTypeParser(ConnectionString, JsonObject): void
-
streamFactory(): Optional<StreamFactoryFactory>
-
fromConnectionString(): Optional<StreamFactoryFactory>
-
lift(StreamFactoryFactory): Optional<StreamFactoryFactory>
-
fromConfiguration(): Optional<StreamFactoryFactory>
-
StreamType
-
-
WriteConcernParser
-
-
-
-
mongo
-
ext
-
vertx