co.paralleluniverse.fibers.mongodb

Class FiberMongoDatabaseImpl

java.lang.Object

com.allanbank.mongodb.client.MongoDatabaseImpl

co.paralleluniverse.fibers.mongodb.FiberMongoDatabaseImpl

All Implemented Interfaces:

MongoDatabase

public class FiberMongoDatabaseImpl
extends MongoDatabaseImpl

Field Summary

Fields inherited from class com.allanbank.mongodb.client.MongoDatabaseImpl

EMPTY_QUERY, myClient

Fields inherited from interface com.allanbank.mongodb.MongoDatabase

ADMIN_NAME, CONFIG_NAME, LOCAL_NAME, TEST_NAME

Constructor Summary

Constructors

Constructor and Description
FiberMongoDatabaseImpl(MongoClient mongoClient, Client client, String string)

Method Summary

Methods

Modifier and Type	Method and Description
MongoCollection	getCollection(String name)
Document	runCommand(DocumentAssignable command)
Document	runCommand(String command)
Document	runCommand(String command, DocumentAssignable options)
Document	runCommand(String commandName, int commandValue, DocumentAssignable options)
Document	runCommand(String commandName, String commandValue, DocumentAssignable options)
ListenableFuture<Document>	runCommandAsync(DocumentAssignable command)
ListenableFuture<Document>	runCommandAsync(String command)
ListenableFuture<Document>	runCommandAsync(String command, DocumentAssignable options)
ListenableFuture<Document>	runCommandAsync(String commandName, int commandValue, DocumentAssignable options)
ListenableFuture<Document>	runCommandAsync(String commandName, String commandValue, DocumentAssignable options)

Methods inherited from class com.allanbank.mongodb.client.MongoDatabaseImpl

addOptions, createCappedCollection, createCollection, drop, exists, getDurability, getLockType, getName, getProfilingStatus, getReadPreference, listCollectionNames, listCollections, runAdminCommand, runAdminCommand, runAdminCommand, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, runCommandAsync, setDurability, setProfilingStatus, setReadPreference, stats

Methods inherited from class java.lang.Object

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

Constructor Detail

FiberMongoDatabaseImpl

public FiberMongoDatabaseImpl(MongoClient mongoClient,
                      Client client,
                      String string)

Method Detail

getCollection

public MongoCollection getCollection(String name)

Specified by:

getCollection in interface MongoDatabase

Overrides:

getCollection in class MongoDatabaseImpl

runCommand

@Suspendable
public Document runCommand(DocumentAssignable command)
                    throws MongoDbException

Specified by:

runCommand in interface MongoDatabase

Overrides:

runCommand in class MongoDatabaseImpl

Throws:

MongoDbException

runCommand

@Suspendable
public Document runCommand(String command)
                    throws MongoDbException

Specified by:

runCommand in interface MongoDatabase

Overrides:

runCommand in class MongoDatabaseImpl

Throws:

MongoDbException

runCommand

@Suspendable
public Document runCommand(String command,
                              DocumentAssignable options)
                    throws MongoDbException

Specified by:

runCommand in interface MongoDatabase

Overrides:

runCommand in class MongoDatabaseImpl

Throws:

MongoDbException

runCommand

@Suspendable
public Document runCommand(String commandName,
                              int commandValue,
                              DocumentAssignable options)
                    throws MongoDbException

Specified by:

runCommand in interface MongoDatabase

Overrides:

runCommand in class MongoDatabaseImpl

Throws:

MongoDbException

runCommand

@Suspendable
public Document runCommand(String commandName,
                              String commandValue,
                              DocumentAssignable options)
                    throws MongoDbException

Specified by:

runCommand in interface MongoDatabase

Overrides:

runCommand in class MongoDatabaseImpl

Throws:

MongoDbException

runCommandAsync

public ListenableFuture<Document> runCommandAsync(DocumentAssignable command)

Specified by:

runCommandAsync in interface MongoDatabase

Overrides:

runCommandAsync in class MongoDatabaseImpl

runCommandAsync

public ListenableFuture<Document> runCommandAsync(String command)

Specified by:

runCommandAsync in interface MongoDatabase

Overrides:

runCommandAsync in class MongoDatabaseImpl

runCommandAsync

public ListenableFuture<Document> runCommandAsync(String command,
                                         DocumentAssignable options)

Specified by:

runCommandAsync in interface MongoDatabase

Overrides:

runCommandAsync in class MongoDatabaseImpl

runCommandAsync

public ListenableFuture<Document> runCommandAsync(String commandName,
                                         int commandValue,
                                         DocumentAssignable options)

Specified by:

runCommandAsync in interface MongoDatabase

Overrides:

runCommandAsync in class MongoDatabaseImpl

runCommandAsync

public ListenableFuture<Document> runCommandAsync(String commandName,
                                         String commandValue,
                                         DocumentAssignable options)

Specified by:

runCommandAsync in interface MongoDatabase

Overrides:

runCommandAsync in class MongoDatabaseImpl