Packages

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
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Transformation
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. 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 A and returns an async payload to emit, or None to filter the event from being produced.

  2. 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 None to filter the event from being produced. Replaces any previous "orElse" mapper defined.

  3. 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 A and returns an async payload to emit, or None to filter the event from being produced.

  4. 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 None to filter the event from being produced. Replaces any previous "orElse" mapper defined.

  5. 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 A and returns a payload to emit, or None to filter the event from being produced.

  6. def registerMapper[A, B](f: (A) => Option[B])(implicit arg0: ClassTag[A]): Transformation

    f

    A function that is fed each event payload of type A and returns a payload to emit, or None to filter the event from being produced.

  7. 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 None to filter the event from being produced. Replaces any previous "orElse" mapper defined.