mongodb-driver-kotlin-coroutine/com.mongodb.kotlin.client.coroutine

Package-level declarations

Types

AggregateFlow

class AggregateFlow<T : Any>(wrapped: AggregatePublisher<T>) : Flow<T>

Flow implementation for aggregate operations.

ChangeStreamFlow

class ChangeStreamFlow<T : Any>(wrapped: ChangeStreamPublisher<T>) : Flow<ChangeStreamDocument<T>>

Flow implementation for change streams.

ClientSession

class ClientSession(val wrapped: ClientSession) : ClientSession

A client session that supports transactions.

DistinctFlow

class DistinctFlow<T : Any>(wrapped: DistinctPublisher<T>) : Flow<T>

Flow implementation for distinct operations.

FindFlow

class FindFlow<T : Any>(wrapped: FindPublisher<T>) : Flow<T>

Flow implementation for find operations.

ListCollectionNamesFlow

class ListCollectionNamesFlow(wrapped: ListCollectionNamesPublisher) : Flow<String>

Flow for listing collection names.

ListCollectionsFlow

class ListCollectionsFlow<T : Any>(wrapped: ListCollectionsPublisher<T>) : Flow<T>

Flow implementation for list collection operations.

ListDatabasesFlow

class ListDatabasesFlow<T : Any>(wrapped: ListDatabasesPublisher<T>) : Flow<T>

Flow implementation for list database operations.

ListIndexesFlow

class ListIndexesFlow<T : Any>(wrapped: ListIndexesPublisher<T>) : Flow<T>

Flow implementation for list index operations.

ListSearchIndexesFlow

class ListSearchIndexesFlow<T : Any>(wrapped: ListSearchIndexesPublisher<T>) : Flow<T>

Flow implementation for list Atlas Search index operations.

MapReduceFlow

class ~~MapReduceFlow~~<T : Any>(wrapped: MapReducePublisher<T>) : Flow<T>

Flow implementation for map reduce operations.

MongoClient

class MongoClient(wrapped: MongoClient) : MongoCluster, Closeable

A client-side representation of a MongoDB cluster.

MongoCluster

open class MongoCluster

The client-side representation of a MongoDB cluster operations.

MongoCollection

class MongoCollection<T : Any>(wrapped: MongoCollection<T>)

The MongoCollection representation.

MongoDatabase

class MongoDatabase(wrapped: MongoDatabase)

The MongoDatabase representation.

Functions

defaultTimeout

fun ClientSessionOptions.Builder.defaultTimeout(defaultTimeout: Long): ClientSessionOptions.Builder

ClientSessionOptions.Builder.defaultTimeout extension function

expireAfter

fun CreateCollectionOptions.expireAfter(maxTime: Long): CreateCollectionOptions

fun IndexOptions.expireAfter(expireAfter: Long): IndexOptions

expireAfter extension function

maxCommitTime

fun TransactionOptions.Builder.maxCommitTime(maxCommitTime: Long): TransactionOptions.Builder

maxCommitTime extension function

maxTime

fun CountOptions.maxTime(maxTime: Long): CountOptions

fun CreateIndexOptions.maxTime(maxTime: Long): CreateIndexOptions

fun DropIndexOptions.maxTime(maxTime: Long): DropIndexOptions

fun EstimatedDocumentCountOptions.maxTime(maxTime: Long): EstimatedDocumentCountOptions

fun FindOneAndDeleteOptions.maxTime(maxTime: Long): FindOneAndDeleteOptions

fun FindOneAndReplaceOptions.maxTime(maxTime: Long): FindOneAndReplaceOptions

fun FindOneAndUpdateOptions.maxTime(maxTime: Long): FindOneAndUpdateOptions

maxTime extension function