Packages

c

nelson.logging

WorkflowLogger

class WorkflowLogger extends ~>[LoggingOp, IO]

Source
WorkflowLogger.scala
Linear Supertypes
FunctionK[LoggingOp, IO], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WorkflowLogger
  2. FunctionK
  3. Serializable
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WorkflowLogger(queue: Queue[IO, (ID, String)], base: Path)

Value Members

  1. def and[H[_]](h: FunctionK[LoggingOp, H]): FunctionK[LoggingOp, [γ$4$]Tuple2K[IO, H, γ$4$]]
    Definition Classes
    FunctionK
  2. def andThen[H[_]](f: FunctionK[IO, H]): FunctionK[LoggingOp, H]
    Definition Classes
    FunctionK
  3. def apply[A](op: LoggingOp[A]): IO[A]
    Definition Classes
    WorkflowLogger → FunctionK
  4. def compose[E[_]](f: FunctionK[E, LoggingOp]): FunctionK[E, IO]
    Definition Classes
    FunctionK
  5. def log(id: ID, line: String): IO[Unit]
  6. def or[H[_]](h: FunctionK[H, IO]): FunctionK[[γ$1$]EitherK[LoggingOp, H, γ$1$], IO]
    Definition Classes
    FunctionK
  7. def process: Stream[IO, Unit]
  8. def read(id: ID, offset: Int): IO[List[String]]
  9. def setup(): IO[Unit]