scalaz.stream.mongodb

collectionSyntax

object collectionSyntax extends Collection with QuerySyntax with QueryEnums with CollectionIndexSyntax with ChannelResultSyntax with UpdateSyntax with FindAndModifySyntax with FileSystemSyntax with AggregationSyntax with BSONValues with BSONValuesImplicits

Generic implicit that has to be injected to get or collection related functionality in scope

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. collectionSyntax
  2. BSONValuesImplicits
  3. BSONValues
  4. AggregationSyntax
  5. FileSystemSyntax
  6. FileUtil
  7. FindAndModifySyntax
  8. UpdateSyntax
  9. ChannelResultSyntax
  10. CollectionIndexSyntax
  11. QueryEnums
  12. QuerySyntax
  13. Collection
  14. AnyRef
  15. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. implicit class AggregationKeySyntax extends AggregationStringOps

    Definition Classes
    AggregationSyntax
  2. type BSONAny = AnyRef { type Tag = scalaz.stream.mongodb.bson.BSONValueTag }

    Small trick to define any value of bson

    Small trick to define any value of bson

    Definition Classes
    BSONValues
  3. implicit class BSONCollection[C[A] <: Iterable[A], A] extends CollectionBSONOps[C]

    Definition Classes
    BSONValuesImplicits
  4. implicit class BSONDBOConverter[A <: BSONObject] extends DBObjectOps[A]

    Definition Classes
    BSONValuesImplicits
  5. type BSONList[A] = List[BSONAny]

    List has own type *

    List has own type *

    Definition Classes
    BSONValues
  6. implicit class BSONMap[C[String, A] <: Map[String, A], A] extends MapBSONOps[C]

    Definition Classes
    BSONValuesImplicits
  7. type BSONObject = Map[String, BSONAny]

    BSONObject is actually a Map *

    BSONObject is actually a Map *

    Definition Classes
    BSONValues
  8. type BSONSeq = Seq[BSONAny]

    Just helper for Seq *

    Just helper for Seq *

    Definition Classes
    BSONValues
  9. type BSONSet = Set[BSONAny]

    Set has own type *

    Set has own type *

    Definition Classes
    BSONValues
  10. type BSONValue[+A] = A with Tagged[BSONValueTag]

    Essentially and convertible scala type must have implicit of BSONValue to be used in queries *

    Essentially and convertible scala type must have implicit of BSONValue to be used in queries *

    Definition Classes
    BSONValues
  11. implicit class BasicQuerySyntax extends BasicQueryOps

    Definition Classes
    QuerySyntax
  12. implicit class DBCollectionSyntax extends AnyRef

    Definition Classes
    Collection
  13. implicit class ListChannelResultSyntax extends AnyRef

    syntax sugar on listCommand channelResult *

  14. implicit class QueryKeyPairBuilderSyntax extends QueryPairBuilderOps with OrderingOps with ProjectionOps

    Definition Classes
    QuerySyntax
  15. implicit class QueryPairSyntax[A] extends QueryPairOps[A]

    Definition Classes
    QuerySyntax
  16. implicit class QueryPairSyntax2[A] extends QueryPairOps[A]

    Definition Classes
    QuerySyntax
  17. implicit class UpdatePairBuilderSyntax extends UpdatePairOps

    implicit for findAndModify

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object BSONList

    Constructor to create lists

  7. val BSONNull: BSONValue[Null]

    BSON currently contains type of null this prepresents that type *

    BSON currently contains type of null this prepresents that type *

    Definition Classes
    BSONValues
  8. object BSONObject

    Constructor to create objects

  9. val BSONSeq: BSONList.type

    Definition Classes
    BSONValues
  10. object BSONSet

    Constructor to create sets

  11. object ExplainVerbosity extends Enumeration

    Enumeration to define explain verbosity *

  12. object Order extends Enumeration

    Enumeration to define ordering *

  13. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  14. implicit def boolean2BSONValue(b: Boolean): BSONValue[Boolean]

    Definition Classes
    BSONValuesImplicits
  15. implicit def bson2dbo(m: BSONObject): DBObject

    Definition Classes
    BSONValuesImplicits
  16. implicit def byte2BSONValue(b: Byte): BSONValue[Byte]

    Definition Classes
    BSONValuesImplicits
  17. implicit def channelResult2Channel[R, A](r: ChannelResult[R, A]): Process.Channel[Task, R, Process[Task, A]]

    Definition Classes
    ChannelResultSyntax
  18. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. implicit def container2BSONValue(c: Iterable[BSONAny]): BSONValue[Iterable[BSONAny]]

    Definition Classes
    BSONValuesImplicits
  20. implicit def date2BSONValue(d: Date): BSONValue[Date]

    Definition Classes
    BSONValuesImplicits
  21. implicit def dbCollection2Process(c: DBCollection): Process[Task, DBCollection]

    Definition Classes
    Collection
  22. implicit def double2BSONValue(d: Double): BSONValue[Double]

    Definition Classes
    BSONValuesImplicits
  23. def drop(idx: CollectionIndex): DropIndexByKeys

    drops specified index from collection

    drops specified index from collection

    Definition Classes
    CollectionIndexSyntax
  24. def drop(s: String): DropIndexByName

    drops index with specified name

    drops index with specified name

    Definition Classes
    CollectionIndexSyntax
  25. def ensure(idx: CollectionIndex): EnsureIndex

    Ensures index on collection, see: http://docs.mongodb.org/manual/reference/method/db.collection.ensureIndex/#db.collection.ensureIndex

  26. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  27. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  28. def file(name: String, id: ObjectId = new ObjectId, meta: Option[DBObject] = None, contentType: Option[String] = None, chunkSize: Long = GridFS.DEFAULT_CHUNKSIZE): MongoFileWrite

    Creates information that uniquely identifies single file in filesystem

    Creates information that uniquely identifies single file in filesystem

    name

    name of the file (required, must be unique)

    id

    unique file identifier

    meta

    optional metadata to store with file

    Definition Classes
    FileSystemSyntax
  29. def filesystem(db: DB, filesystemName: String = GridFS.DEFAULT_BUCKET): GridFs

    filesystem syntax, wrapper around gridFs *

    filesystem syntax, wrapper around gridFs *

    Definition Classes
    FileSystemSyntax
  30. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  31. implicit def float2BSONValue(f: Float): BSONValue[Float]

    Definition Classes
    BSONValuesImplicits
  32. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  33. def group(o: DBObject): GroupId

    Creates the group pipeline operation

    Creates the group pipeline operation

    Definition Classes
    AggregationSyntax
  34. def group[A](p1: (String, A), p2: (String, A)*)(implicit arg0: BSONSerializable[A]): GroupId

    Creates the group pipeline operation

    Creates the group pipeline operation

    Definition Classes
    AggregationSyntax
  35. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  36. def index(h: OrderPair, t: OrderPair*): CollectionIndex

    Definition Classes
    CollectionIndexSyntax
  37. def insert(o: DBObject): InsertAction

    syntax for inserting supplied object

    syntax for inserting supplied object

    Definition Classes
    UpdateSyntax
  38. implicit def int2BSONValue(i: Int): BSONValue[Int]

    Definition Classes
    BSONValuesImplicits
  39. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  40. def limit(count: Int): LimitPipeline

    syntax fro limit pipeline *

    syntax fro limit pipeline *

    Definition Classes
    AggregationSyntax
  41. val list: ListCommandSyntax

    Definition Classes
    FileSystemSyntax
  42. implicit def long2BSONValue(i: Long): BSONValue[Long]

    Definition Classes
    BSONValuesImplicits
  43. implicit def map2BSONValue(c: Map[String, BSONAny]): BSONValue[Map[String, BSONAny]]

    Definition Classes
    BSONValuesImplicits
  44. implicit def mongoCommand2Channel[A](cmd: MongoCollectionCommand[A]): Process.Channel[Task, DBCollection, Process[Task, A]]

    Definition Classes
    ChannelResultSyntax
  45. implicit def mongoCommand2ChannelResult[A](cmd: MongoCollectionCommand[A]): ChannelResult[DBCollection, A]

    Definition Classes
    ChannelResultSyntax
  46. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  47. def not[A](p: QueryPair[A]): QueryPair[A]

    Definition Classes
    QuerySyntax
  48. final def notify(): Unit

    Definition Classes
    AnyRef
  49. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  50. implicit def object2BSONValue(o: DBObject): BSONValue[DBObject]

    Definition Classes
    BSONValuesImplicits
  51. implicit def objectId2BSONValue(id: ObjectId): BSONValue[ObjectId]

    Definition Classes
    BSONValuesImplicits
  52. def only(o: DBObject): MatchPipeline

    pipeline to filter documents *

    pipeline to filter documents *

    Definition Classes
    AggregationSyntax
  53. def only(bq: BasicQuery): MatchPipeline

    pipeline to filter documents *

    pipeline to filter documents *

    Definition Classes
    AggregationSyntax
  54. def only[A](q: QueryPair[A]*): MatchPipeline

    pipeline to filter documents *

    pipeline to filter documents *

    Definition Classes
    AggregationSyntax
  55. implicit def option2BSONValue[A](opt: Option[A])(implicit arg0: BSONSerializable[A]): BSONValue[Option[BSONAny]]

    Definition Classes
    BSONValuesImplicits
  56. implicit def pair2OrderPair(p: (String, query.QueryEnums.Order.Value)): OrderPair

    Definition Classes
    QuerySyntax
  57. implicit def pair2QueryPair[A](p: (String, A))(implicit arg0: QueryPredicateWitness[A]): BasicQueryPair[A]

    Definition Classes
    QuerySyntax
  58. def project(actions: ProjectPipelineAction*): ProjectPipeline

    syntax for project pipeline *

    syntax for project pipeline *

    Definition Classes
    AggregationSyntax
  59. def pull[A](qp: QueryPair[A]*): DBObjectUpdatePair

    specific syntax for array update operations *

    specific syntax for array update operations *

    Definition Classes
    UpdateSyntax
  60. def query(o: DBObject): Query

    Definition Classes
    QuerySyntax
  61. def query(bq: BasicQuery): Query

    Definition Classes
    QuerySyntax
  62. def query[A](q: QueryPair[A]*): Query

    Definition Classes
    QuerySyntax
  63. implicit def query2ChannelResult(q: Query): ChannelResult[DBCollection, DBObject]

    Definition Classes
    QuerySyntax
  64. implicit def readCmd2ChannelResult[A](cmd: ReadCommand[A]): ChannelResult[GridFS, A]

    conversion of listCommand to process

    conversion of listCommand to process

    Definition Classes
    FileSystemSyntax
  65. def readFile(buffSize: Int = GridFS.DEFAULT_CHUNKSIZE): ChannelResult[GridFS, (MongoFileRead) ⇒ Process[Task, Bytes]]

    Produces ChannelResult, that will read single file *

    Produces ChannelResult, that will read single file *

    Definition Classes
    FileUtil
  66. def remove: RemoveAction

    syntax for removing documents

    syntax for removing documents

    Definition Classes
    UpdateSyntax
  67. val removeFile: ChannelResult[GridFS, (MongoFileRead) ⇒ Process[Task, Unit]]

    Produces ChannelResult, that will remove single file.

    Produces ChannelResult, that will remove single file. true is returned when file was removed *

    Definition Classes
    FileUtil
  68. def removeOne: FindAndRemoveAction

    Definition Classes
    FindAndModifySyntax
  69. implicit def rpv2ReadPreference(rp: query.ReadPreference.Value): ReadPreference

    Definition Classes
    QuerySyntax
  70. def save(o: DBObject): SaveAction

    syntax for saving supplied uobject

    syntax for saving supplied uobject

    Definition Classes
    UpdateSyntax
  71. implicit def short2BSONValue(s: Short): BSONValue[Short]

    Definition Classes
    BSONValuesImplicits
  72. def skip(count: Int): SkipPipeline

    syntax fro limit pipeline *

    syntax fro limit pipeline *

    Definition Classes
    AggregationSyntax
  73. def sort(h: OrderPair, t: OrderPair*): SortPipeline

    syntax for creating sort pipeline operation *

    syntax for creating sort pipeline operation *

    Definition Classes
    AggregationSyntax
  74. implicit def string2BSONValue(s: String): BSONValue[String]

    Definition Classes
    BSONValuesImplicits
  75. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  76. def toString(): String

    Definition Classes
    AnyRef → Any
  77. def unsafeAny2BSONValue(a: Any): BSONAny

    Definition Classes
    BSONValuesImplicits
  78. def unwind(field: String): UnWindPipeline

    unwinds the element in projection to turn BSON array into separate documents *

    unwinds the element in projection to turn BSON array into separate documents *

    Definition Classes
    AggregationSyntax
  79. def update(o: DBObject): UpdateAction

    syntax creating update action that replaces the whole document

    syntax creating update action that replaces the whole document

    Definition Classes
    UpdateSyntax
  80. def update(ps: UpdatePair*): UpdateAction

    santax creating update action from pairs

    santax creating update action from pairs

    Definition Classes
    UpdateSyntax
  81. def updateOne(o: DBObject): FindAndModifyAction

    Definition Classes
    FindAndModifySyntax
  82. def updateOne(ps: UpdatePair*): FindAndModifyAction

    Definition Classes
    FindAndModifySyntax
  83. def use(c: DBCollection): Process[Task, DBCollection]

    Definition Classes
    Collection
  84. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  85. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  86. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  87. val write: WriteCommandSyntax

    Definition Classes
    FileSystemSyntax
  88. implicit def writeCmd2ChannelResult[A](cmd: WriteCommand): ChannelResult[GridFS, (Bytes) ⇒ Task[Unit]]

    conversion of WriteCommand to sink

    conversion of WriteCommand to sink

    Definition Classes
    FileSystemSyntax

Inherited from BSONValuesImplicits

Inherited from BSONValues

Inherited from AggregationSyntax

Inherited from FileSystemSyntax

Inherited from FileUtil

Inherited from FindAndModifySyntax

Inherited from UpdateSyntax

Inherited from ChannelResultSyntax

Inherited from CollectionIndexSyntax

Inherited from QueryEnums

Inherited from QuerySyntax

Inherited from Collection

Inherited from AnyRef

Inherited from Any

Ungrouped