services

ExtractorMessage

case class ExtractorMessage(fileId: UUID, intermediateId: UUID, host: String, queue: String, metadata: Map[String, Any], fileSize: String, datasetId: UUID = null, flags: String = "", secretKey: String, routing_key: String, source: Entity, activity: String, target: Option[Entity]) extends Product with Serializable

Despite the fileId be named as such, it is currently serialized as id and used as the id of any resource in question. So this will be the preview id in the case of messages operating on a preview, it will be the dataset id in the case of dataset messages (yes there is also datasetId, pyclowder2 checks that the two are the same. FIXME make optional fields Option[UUID] FIXME rename fileId to id and add a resourceType field (dataset, file, preview, etc.) TODO drop intermediateId or figure out how it works and use accordingly

fileId

this should only be used as

intermediateId
host
queue
metadata
fileSize
datasetId
flags
secretKey

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ExtractorMessage
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ExtractorMessage(fileId: UUID, intermediateId: UUID, host: String, queue: String, metadata: Map[String, Any], fileSize: String, datasetId: UUID = null, flags: String = "", secretKey: String, routing_key: String, source: Entity, activity: String, target: Option[Entity])

    fileId

    this should only be used as

    intermediateId
    host
    queue
    metadata
    fileSize
    datasetId
    flags
    secretKey

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. val activity: String

  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. val datasetId: UUID

  10. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  11. val fileId: UUID

    this should only be used as

  12. val fileSize: String

  13. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. val flags: String

  15. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  16. val host: String

  17. val intermediateId: UUID

  18. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  19. val metadata: Map[String, Any]

  20. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  21. final def notify(): Unit

    Definition Classes
    AnyRef
  22. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  23. val queue: String

  24. val routing_key: String

  25. val secretKey: String

  26. val source: Entity

  27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  28. val target: Option[Entity]

  29. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped