Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def aggregate(src: Collection, pipeline: slamdata.Predef.List[Doc], allowDiskUse: slamdata.Predef.Boolean): MongoDbIO[slamdata.Predef.Unit]

   Aggregates documents according to the given aggregation pipeline, which must end with an $out stage specifying the collection where results may be found.

5.  def aggregated(src: Collection, pipeline: slamdata.Predef.List[Doc], allowDiskUse: slamdata.Predef.Boolean): Process[MongoDbIO, BsonDocument]

   Returns the stream of results of aggregating documents according to the given aggregation pipeline.

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

8.  def collectionExists(c: Collection): MongoDbIO[slamdata.Predef.Boolean]
9.  def collectionStatistics(coll: Collection): MongoDbIO[CollectionStatistics]
10.  def collections: Process[MongoDbIO, Collection]

    All discoverable collections on the server.

11.  def collectionsIn(dbName: DatabaseName): Process[MongoDbIO, Collection]

    The collections in the named database.

12.  def createCollection(c: Collection): MongoDbIO[slamdata.Predef.Unit]

    Creates the given collection.

13.  def databaseNames: Process[MongoDbIO, DatabaseName]

    Names of all discoverable databases on the server.

14.  def dropAllDatabases: MongoDbIO[slamdata.Predef.Unit]
15.  def dropCollection(c: Collection): MongoDbIO[slamdata.Predef.Unit]
16.  def dropDatabase(named: DatabaseName): MongoDbIO[slamdata.Predef.Unit]
17.  def ensureCollection(c: Collection): MongoDbIO[slamdata.Predef.Unit]

    Ensure the given collection exists, creating it if not.

18.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

19.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

20.  def fail[A](t: slamdata.Predef.Throwable): MongoDbIO[A]
21.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22.  def first(coll: Collection): OptionT[MongoDbIO, BsonDocument]

    Returns the first document in the collection.

23.  def firstWritableDb(collName: CollectionName): OptionT[MongoDbIO, DatabaseName]

    Returns the name of the first database where an insert to the collection having the given name succeeds.

24.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

25.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

26.  def indexes(coll: Collection): MongoDbIO[slamdata.Predef.Set[Index]]

    Set of indexes on a collection, including only simple index types and ignoring the rest.

27.  def insert[F[_]](coll: Collection, docs: F[BsonDocument])(implicit arg0: Foldable[F]): MongoDbIO[slamdata.Predef.Unit]

    Inserts the given documents into the collection.

28.  def insertAny[F[_]](coll: Collection, docs: F[BsonDocument])(implicit arg0: Foldable[F]): OptionT[MongoDbIO, slamdata.Predef.Int]

    Attempts to insert as many of the given documents into the collection as possible.

    Attempts to insert as many of the given documents into the collection as possible. The number of documents inserted is returned, if possible, and may be smaller than the original amount if any documents failed to insert.

29.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

30.  val liftTask: ~>[Task, MongoDbIO]
31.  def mapReduce(src: Collection, dst: OutputCollection, cfg: MapReduce): MongoDbIO[slamdata.Predef.Unit]

    Executes the map-reduce job described by cfg, sourcing documents from src and writing the output to dst.

32.  implicit val mongoDbInstance: Monad[MongoDbIO] with Catchable[MongoDbIO]
33.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

34.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

35.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

36.  def rename(src: Collection, dst: Collection, semantics: RenameSemantics): MongoDbIO[slamdata.Predef.Unit]

    Rename src to dst using the given semantics.

37.  def runNT(client: MongoClient): ~>[MongoDbIO, Task]
38.  def serverVersion: MongoDbIO[ServerVersion]

    Returns the version of the MongoDB server the client is connected to.

39.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

40.  def toString(): String

    Definition Classes

    AnyRef → Any

41.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

42.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

43.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )