final class Transformation extends AnyRef
Transformation of events to the external (public) representation.
Events can be excluded by mapping them to None.
- Source
- EventProducer.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]) @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def registerAsyncEnvelopeMapper[A, B](f: (EventEnvelope[A]) => Future[Option[B]])(implicit arg0: ClassTag[A]): Transformation
- f
A function that is fed each event envelope where the payload is of type
Aand returns an async payload to emit, orNoneto filter the event from being produced.
- def registerAsyncEnvelopeOrElseMapper(m: (EventEnvelope[Any]) => Future[Option[Any]]): Transformation
- m
A function that is fed each event envelope, that did not match any other registered mappers, returns a payload to emit, or
Noneto filter the event from being produced. Replaces any previous "orElse" mapper defined.
- def registerAsyncMapper[A, B](f: (A) => Future[Option[B]])(implicit arg0: ClassTag[A]): Transformation
- f
A function that is fed each event payload of type
Aand returns an async payload to emit, orNoneto filter the event from being produced.
- def registerAsyncOrElseMapper(f: (Any) => Future[Option[Any]]): Transformation
- f
A function that is fed each event payload, that did not match any other registered mappers, returns an async payload to emit, or
Noneto filter the event from being produced. Replaces any previous "orElse" mapper defined.
- def registerEnvelopeMapper[A, B](f: (EventEnvelope[A]) => Option[B])(implicit arg0: ClassTag[A]): Transformation
- f
A function that is fed each event envelope where the payload is of type
Aand returns a payload to emit, orNoneto filter the event from being produced.
- def registerMapper[A, B](f: (A) => Option[B])(implicit arg0: ClassTag[A]): Transformation
- f
A function that is fed each event payload of type
Aand returns a payload to emit, orNoneto filter the event from being produced.
- def registerOrElseMapper(f: (Any) => Option[Any]): Transformation
- f
A function that is fed each event payload, that did not match any other registered mappers, returns a payload to emit, or
Noneto filter the event from being produced. Replaces any previous "orElse" mapper defined.
- 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])