c
akka.projection.grpc.consumer.scaladsl
EventProducerPushDestination
Companion object EventProducerPushDestination
final class EventProducerPushDestination extends AnyRef
- Annotations
- @ApiMayChange()
- Source
- EventProducerPushDestination.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EventProducerPushDestination
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- val acceptedStreamId: String
- val filters: Seq[FilterCriteria]
- val interceptor: Option[EventDestinationInterceptor]
- val journalPluginId: Option[String]
- val protobufDescriptors: Seq[FileDescriptor]
- val settings: EventProducerPushDestinationSettings
- val transformationForOrigin: (String, Metadata) => Transformation
- def withConsumerFilters(filters: Seq[FilterCriteria]): EventProducerPushDestination
Filter incoming streams, at producer side, with these filters
- def withInterceptor(interceptor: EventDestinationInterceptor): EventProducerPushDestination
- def withJournalPluginId(journalPluginId: String): EventProducerPushDestination
- def withSettings(settings: EventProducerPushDestinationSettings): EventProducerPushDestination
- def withTransformation(transformation: Transformation): EventProducerPushDestination
- transformation
A transformation to use for all events.
- def withTransformationForOrigin(transformationForOrigin: (String, Metadata) => Transformation): EventProducerPushDestination