sealed trait GridFS[P <: SerializationPack with Singleton] extends GridFSSerialization[P]
- Alphabetic
- By Inheritance
- GridFS
- GridFSSerialization
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Type Members
- type ReadFile[Id <: P.Value] = gridfs.ReadFile[P, Id]
Abstract Value Members
- abstract def db: DB with DBMetaCommands
- Attributes
- protected
- abstract def prefix: String
- Attributes
- protected
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (GridFS[P], B)
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def chunks(file: ReadFile[P.Value], readPreference: ReadPreference = defaultReadPreference)(implicit cp: CursorProducer[Array[Byte]]): ProducedCursor
Returns a cursor for the chunks of the specified file.
Returns a cursor for the chunks of the specified file. The cursor walks the chunks orderly.
- file
the file to be read
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def ensureIndex()(implicit ec: ExecutionContext): Future[Boolean]
Creates the needed indexes on the GridFS collections (
chunksandfiles).Creates the needed indexes on the GridFS collections (
chunksandfiles).Please note that you should really consider reading http://www.mongodb.org/display/DOCS/Indexes before doing this, especially in production.
- returns
A future containing true if the index was created, false if it already exists.
- def ensuring(cond: (GridFS[P]) => Boolean, msg: => Any): GridFS[P]
- def ensuring(cond: (GridFS[P]) => Boolean): GridFS[P]
- def ensuring(cond: Boolean, msg: => Any): GridFS[P]
- def ensuring(cond: Boolean): GridFS[P]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exists(implicit ec: ExecutionContext): Future[Boolean]
Returns whether the data related to this GridFS instance exists on the database.
- def fileToSave[Id <: P.Value](_filename: Option[String], _contentType: Option[String], _uploadDate: Option[Long], _metadata: P.Document, _id: Id): FileToSave[pack.type, Id]
Prepare the information to save a file.
- def fileToSave(_filename: Option[String] = None, _contentType: Option[String] = None, _uploadDate: Option[Long] = None, _metadata: P.Document = document(Seq.empty)): FileToSave[pack.type, P.Value]
Prepare the information to save a file.
Prepare the information to save a file. The unique ID is automatically generated.
- def find(selector: P.Document)(implicit ec: ExecutionContext, r: FileReader[P.Value], cp: CursorProducer[ReadFile[P.Value]]): ProducedCursor
Finds the files matching the given selector.
Finds the files matching the given selector.
- selector
the query to find the files
- r
fileReader a file reader automatically resolved if
Idis a valid valueimport scala.concurrent.ExecutionContext import reactivemongo.api.gridfs.GridFS import reactivemongo.api.bson.{ BSONDocument, BSONValue } import reactivemongo.api.bson.collection.{ BSONSerializationPack => Pack } def foo(gfs: GridFS[Pack.type], n: String)(implicit ec: ExecutionContext) = gfs.find(BSONDocument("filename" -> n)).headOption
- def find[S, Id <: P.Value](selector: S)(implicit w: P.Writer[S], r: FileReader[Id], cp: CursorProducer[ReadFile[Id]]): ProducedCursor
Finds the files matching the given selector.
Finds the files matching the given selector.
- S
The type of the selector document. An implicit
Writer[S]must be in the scope.- Id
the type of the file ID to be read
import scala.concurrent.ExecutionContext import reactivemongo.api.gridfs.GridFS import reactivemongo.api.bson.{ BSONDocument, BSONValue } import reactivemongo.api.bson.collection.{ BSONSerializationPack => Pack } def foo(gfs: GridFS[Pack.type], n: String)(implicit ec: ExecutionContext) = gfs.find[BSONDocument, BSONValue]( BSONDocument("filename" -> n)).headOption
- selector
the query to find the files
- r
fileReader a file reader automatically resolved if
Idis a valid value
- def formatted(fmtstr: String): String
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def readToOutputStream[Id <: P.Value](file: ReadFile[Id], out: OutputStream, readPreference: ReadPreference = defaultReadPreference)(implicit ec: ExecutionContext): Future[Unit]
Reads the given file and writes its contents to the given OutputStream.
Reads the given file and writes its contents to the given OutputStream.
- file
the file to be read
- def remove[Id <: P.Value](id: Id)(implicit ec: ExecutionContext): Future[WriteResult]
Removes a file from this store.
Removes a file from this store. Note that if the file does not actually exist, the returned future will not be hold an error.
- id
the file id to remove from this store
- def remove[Id <: P.Value](file: BasicMetadata[Id])(implicit ec: ExecutionContext): Future[WriteResult]
Removes a file from this store.
Removes a file from this store. Note that if the file does not actually exist, the returned future will not be hold an error.
- file
the file entry to remove from this store
- Annotations
- @inline()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- GridFS → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def writeFromInputStream[Id <: P.Value](file: FileToSave[pack.type, Id], input: InputStream, chunkSize: Int = 262144)(implicit ec: ExecutionContext): Future[ReadFile[Id]]
Writes the data provided by the given InputStream to the given file.
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
- def →[B](y: B): (GridFS[P], B)
- Implicit
- This member is added by an implicit conversion from GridFS[P] toArrowAssoc[GridFS[P]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.