ingest

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