Type Members

1.  type ChannelId = String
2.  case class FileData[M[_]](mimeType: Option[MimeType], data: StreamT[M, Array[Byte]]) extends Product with Serializable
3.  trait FileStorage[M[_]] extends AnyRef

   An abstraction for storing/manipulating/retrieving files.

4.  trait IdExtractor extends AnyRef
5.  final class InMemoryFileStorage[M[+_]] extends FileStorage[M]
6.  case class Job(id: JobId, name: String, jobType: String, data: Option[JValue], state: JobState) extends Product with Serializable
7.  type JobId = String
8.  trait JobManager[M[+_]] extends AnyRef
9.  trait JobResultManager[M[+_]] extends AnyRef
10.  sealed abstract class JobState extends AnyRef

    The Job state is used to keep track of the overall state of a Job.

    The Job state is used to keep track of the overall state of a Job. A Job is put in a special initial state (NotStarted) when it is first created, and is moved to the Started state once it gets its first status update. From here it can either be Cancelled or put into one of several terminal states. Once a job is in a terminal state, it can no longer be moved to a new state.

11.  trait JobStateManager[M[+_]] extends AnyRef

    Given a method that can transition a Job between states, this provides default implementations of the explicit state transition methods.

12.  trait JobStateSerialization extends AnyRef
13.  case class Message(job: JobId, id: MessageId, channel: String, value: JValue) extends Product with Serializable
14.  type MessageId = Long
15.  case class Status(job: JobId, id: StatusId, message: String, progress: BigDecimal, unit: String, info: Option[JValue]) extends Product with Serializable
16.  type StatusId = Long