package fs
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- fs
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
- final case class DefaultDb(run: DatabaseName) extends Product with Serializable
- type Eff[A] = Coproduct[MonotonicSeq, [A]Coproduct[MongoDbIO, [A]Coproduct[[β$2$]Kleisli[MongoDbIO, (Option[DefaultDb], TaskRef[(Long, Map[ResultHandle, \/[List[Bson], WorkflowCursor[AsyncBatchCursor[BsonValue]]]])]), β$2$], [A]Coproduct[[A]Kleisli[MongoDbIO, (TmpPrefix, TaskRef[Long]), A], [A]Coproduct[[A]KeyValueStore[ReadHandle, AsyncBatchCursor[BsonValue], A], [A]KeyValueStore[WriteHandle, Collection, A], A], A], A], A], A]
- final case class MongoConfig(client: MongoClient, serverVersion: ServerVersion, defaultDb: slamdata.Predef.Option[DefaultDb], wfExec: WorkflowExecutor[MongoDbIO, BsonCursor]) extends Product with Serializable
- type MongoM[A] = Free[Eff, A]
- type MongoQScript[T[_[_]], A] = Coproduct[[β$5$]QScriptCore[T, β$5$], [A]Coproduct[[β$3$]EquiJoin[T, β$3$], [β$4$]Const[ShiftedRead[Path[Abs, File, Sandboxed]], β$4$], A], A]
- type MongoQScriptCP[T[_[_]]] = :\:[[β$5$]QScriptCore[T, β$5$], :/:[[β$3$]EquiJoin[T, β$3$], [β$4$]Const[ShiftedRead[Path[Abs, File, Sandboxed]], β$4$]]]
- type MongoReadHandles[A] = KeyValueStore[ReadHandle, BsonCursor, A]
- type MongoWriteHandles[A] = KeyValueStore[WriteHandle, Collection, A]
- type PhysFsEff[A] = Coproduct[Task, PhysErr, A]
- type PlanT[F[_], A] = Kleisli[[β$1$]EitherT[[β$0$]WriterT[F, Vector[PhaseResult], β$0$], FileSystemError, β$1$], Instant, A]
- final case class QueryContext(statistics: (Collection) ⇒ slamdata.Predef.Option[CollectionStatistics], indexes: (Collection) ⇒ slamdata.Predef.Option[slamdata.Predef.Set[Index]]) extends Product with Serializable
- final class QueryFileInterpreter extends AnyRef
- final case class TmpPrefix(run: slamdata.Predef.String) extends AnyVal with Product with Serializable
Value Members
- def compile(cfg: MongoConfig): DefErrT[Task, (~>[MongoM, Task], Task[slamdata.Predef.Unit])]
- val listContents: (ADir) ⇒ EitherT[MongoDbIO, FileSystemError, slamdata.Predef.Set[PathSegment]]
- def parseConfig(uri: ConnectionUri): DefErrT[Task, MongoConfig]
- def wfExec(client: MongoClient): DefErrT[[β$7$]Free[Task, β$7$], WorkflowExecutor[MongoDbIO, BsonCursor]]
- object DefaultDb extends Serializable
- object QueryContext extends Serializable
- object bsoncursor
- object fsops
- object managefile
- object queryfile
- object queryfileTypes