Packages

final class EventProducerPushDestination extends AnyRef

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventProducerPushDestination
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val acceptedStreamId: String
  2. val filters: List[FilterCriteria]
  3. val interceptor: Optional[EventDestinationInterceptor]
  4. val journalPluginId: Optional[String]
  5. val protobufDescriptors: List[FileDescriptor]
  6. val settings: EventProducerPushDestinationSettings
  7. val transformationForOrigin: BiFunction[String, Metadata, Transformation]
  8. def withConsumerFilters(filters: List[FilterCriteria]): EventProducerPushDestination

    Filter incoming streams, at producer side, with these filters

  9. def withInterceptor(interceptor: EventDestinationInterceptor): EventProducerPushDestination
  10. def withJournalPluginId(journalPluginId: String): EventProducerPushDestination
  11. def withSettings(settings: EventProducerPushDestinationSettings): EventProducerPushDestination
  12. def withTransformation(transformation: Transformation): EventProducerPushDestination

    transformation

    A transformation to use for all events.

  13. def withTransformationForOrigin(transformationForOrigin: BiFunction[String, Metadata, Transformation]): EventProducerPushDestination