Packages

package ingest

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class Archive(path: Path, jobId: Option[JobId], timestamp: blueeyes.Instant) extends Event with Product with Serializable
  2. case class ArchiveMessage(path: Path, jobId: Option[JobId], eventId: EventId, timestamp: blueeyes.Instant) extends EventMessage with Product with Serializable
  3. sealed trait ContentEncoding extends AnyRef
  4. sealed trait Event extends AnyRef
  5. case class EventId(producerId: Int, sequenceId: Int) extends Product with Serializable
  6. sealed trait EventMessage extends AnyRef
  7. case class FileContent(data: Array[Byte], mimeType: MimeType, encoding: ContentEncoding) extends Product with Serializable
  8. case class Ingest(path: Path, data: Seq[JValue], jobId: Option[JobId], timestamp: blueeyes.Instant, streamRef: StreamRef) extends Event with Product with Serializable
  9. case class IngestMessage(path: Path, data: Seq[IngestRecord], jobId: Option[JobId], timestamp: blueeyes.Instant, streamRef: StreamRef) extends EventMessage with Product with Serializable

    ownerAccountId must be determined before the message is sent to the central queue; we have to accept records for processing in the local queue.

  10. case class IngestRecord(eventId: EventId, value: JValue) extends Product with Serializable
  11. case class StoreFileMessage(path: Path, jobId: Option[JobId], eventId: EventId, content: FileContent, timestamp: blueeyes.Instant, streamRef: StreamRef) extends EventMessage with Product with Serializable
  12. sealed trait StreamRef extends AnyRef

Value Members

  1. object Archive extends Serializable
  2. object ArchiveMessage extends Serializable
  3. object Base64Encoding extends ContentEncoding
  4. object ContentEncoding
  5. object Event
  6. object EventId extends Serializable
  7. object EventMessage
  8. object FileContent extends Serializable
  9. object Ingest extends Serializable
  10. object IngestMessage extends Serializable
  11. object IngestRecord extends Serializable
  12. object RawUTF8Encoding extends ContentEncoding
  13. object StoreFileMessage extends Serializable
  14. object StreamRef

Ungrouped