object InMemory
In-Memory FileSystem interpreters, useful for testing/stubbing when a "real" interpreter isn't needed or desired.
NB: Since this is in-memory, careful with writing large amounts of data to the file system.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- InMemory
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
- type FileMap = Map[AFile, slamdata.Predef.Vector[Data]]
-
final
case class
InMemState(seq: slamdata.Predef.Long, contents: FileMap, rm: RM, wm: WM, queryResps: QueryResponses, resultMap: ResultMap) extends Product with Serializable
Represents the current state of the InMemoryFilesystem
Represents the current state of the InMemoryFilesystem
- seq
Represents the next available uid for a ReadHandle or WriteHandle
- contents
The mapping of Data associated with each file in the Filesystem
- rm
Currently open quasar.fs.ReadFile.ReadHandles
- wm
Currently open quasar.fs.WriteFile.WriteHandles
- type InMemoryFs[A] = IndexedStateT[scalaz.Id.Id, InMemState, InMemState, A]
- type QueryResponses = Map[Fix[LogicalPlan], slamdata.Predef.Vector[Data]]
- type RM = Map[ReadHandle, Reading]
- final case class Reading(f: AFile, start: Natural, lim: slamdata.Predef.Option[Positive], pos: slamdata.Predef.Int) extends Product with Serializable
- type ResultMap = Map[ResultHandle, slamdata.Predef.Vector[Data]]
- type WM = Map[WriteHandle, AFile]
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val fileSystem: ~>[FileSystem, InMemoryFs]
- val fileSystem0: ~>[BackendEffect, InMemoryFs]
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val manageFile: ~>[ManageFile, InMemoryFs]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val queryFile: ~>[QueryFile, InMemoryFs]
- val readFile: ~>[ReadFile, InMemoryFs]
- def runBackend(initial: InMemState): Task[~>[BackendEffect, Task]]
- def runBackendInspect(initial: InMemState): Task[(~>[BackendEffect, Task], Task[InMemState])]
- def runFs(initial: InMemState): Task[~>[FileSystem, Task]]
- def runInspect(initial: InMemState): Task[(~>[InMemoryFs, Task], Task[InMemState])]
- def runStatefully(initial: InMemState): Task[~>[InMemoryFs, Task]]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
- val writeFile: ~>[WriteFile, InMemoryFs]
- object InMemState extends Serializable