final class Transformation extends AnyRef
Transformation of incoming pushed events from the producer to the internal representation stored in the journal and seen by local projections. Start from Transformation.empty when defining transformations.
- Source
- Transformation.scala
- Alphabetic
- By Inheritance
- Transformation
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val delegate: scaladsl.EventProducerPushDestination.Transformation
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def registerEnvelopeMapper[A, B](inputEventClass: Class[A], f: Function[EventEnvelope[A], Optional[B]]): Transformation
Transform incoming event payloads, with access to the entire envelope for additional metadata.
Transform incoming event payloads, with access to the entire envelope for additional metadata.
Events can be excluded by mapping the payload
Optional.empty. - def registerMapper[A, B](inputEventClass: Class[A], f: Function[A, Optional[B]]): Transformation
Transform incoming event payloads.
Transform incoming event payloads.
Events can be excluded by mapping the payload to
Optional.empty. - def registerOrElsePayloadMapper(f: Function[EventEnvelope[Any], Optional[Any]]): Transformation
Events can be excluded by mapping them to
Optional.empty. - def registerPersistenceIdMapper(system: ActorSystem[_], f: Function[EventEnvelope[Any], String]): Transformation
Transform incoming persistence ids, care must be taken to produce a valid persistence id and to always map the same incoming persistence id to the same stored persistence id to not introduce gaps in the sequence numbers and break consuming projections.
- def registerTagMapper[A](inputEventClass: Class[A], f: Function[EventEnvelope[A], Set[String]]): Transformation
Add or replace tags for incoming events
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])