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
- val delegate: scaladsl.EventProducerPushDestination.Transformation
- 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