Packages

final class Ops[S[_]] extends AnyRef

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Ops
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Ops()(implicit unsafe: Unsafe[S])

Type Members

  1. type F[A] = Free[S, A]
  2. type G[E, A] = EitherT[F, E, A]
  3. type GE[A] = EitherT[F, FileSystemError, A]
  4. type M[A] = EitherT[Unsafe.FreeS, FileSystemError, A]

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 append(dst: AFile, src: Process[F, Data]): Process[M, FileSystemError]

    Appends data to the given file, creating it if it doesn't exist.

    Appends data to the given file, creating it if it doesn't exist. May not write all values from src in the presence of errors, will emit a FileSystemError for each input value that failed to write.

  5. def appendChannel(dst: AFile): Channel[M, slamdata.Predef.Vector[Data], slamdata.Predef.Vector[FileSystemError]]

    Returns a channel that appends chunks of data to the given file, creating it if it doesn't exist.

    Returns a channel that appends chunks of data to the given file, creating it if it doesn't exist. Any errors encountered while writing are emitted, all attempts are made to continue consuming input until the source is exhausted.

  6. def appendChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]]): Process[M, FileSystemError]

    Same as append but accepts chunked Data.

  7. def appendThese(dst: AFile, data: slamdata.Predef.Vector[Data]): M[slamdata.Predef.Vector[FileSystemError]]

    Appends the given data to the specified file, creating it if it doesn't exist.

    Appends the given data to the specified file, creating it if it doesn't exist. May not write every given value in the presence of errors, returns a FileSystemError for each input value that failed to write.

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  10. def create(dst: AFile, src: Process[F, Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Create the given file with the contents of src.

    Create the given file with the contents of src. Fails if already exists.

  11. def createChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Same as create but accepts chunked Data.

  12. def createThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): M[slamdata.Predef.Vector[FileSystemError]]

    Create the given file with the contents of data.

    Create the given file with the contents of data. Fails if already exists. May not write every given value in the presence of errors, returns a FileSystemError for each input value that failed to write.

  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. def replace(dst: AFile, src: Process[F, Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Replace the contents of the given file with src.

    Replace the contents of the given file with src. Fails if the file doesn't exist.

  23. def replaceChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Same as replace but accepts chunked Data.

  24. def replaceWithThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): M[slamdata.Predef.Unit]

    Replace the contents of the given file with data.

    Replace the contents of the given file with data. Fails if the file doesn't exist or if any errors were encountered during writing.

  25. def save(dst: AFile, src: Process[F, Data])(implicit MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Write the data stream to the given path, replacing any existing contents, atomically.

    Write the data stream to the given path, replacing any existing contents, atomically. Any errors during writing will abort the entire operation leaving any existing values unaffected.

  26. def saveChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]

    Same as save but accepts chunked Data.

  27. def saveThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit MF: ManageFile.Ops[S]): M[slamdata.Predef.Unit]

    Write the given data to the specified file, replacing any existing contents, atomically.

    Write the given data to the specified file, replacing any existing contents, atomically. Any errors during writing will abort the entire operation leaving any existing values unaffected.

  28. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. implicit val unsafe: Unsafe[S]
  31. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped