final class EventProducerPush[Event] extends AnyRef
- Source
- EventProducerPush.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EventProducerPush
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new EventProducerPush(originId: String, eventProducerSource: EventProducerSource, connectionMetadata: Option[Metadata], grpcClientSettings: GrpcClientSettings)
- originId
unique producer identifier showing where the events came from/was produced
- connectionMetadata
Additional metadata to pass to the consumer when connecting
- grpcClientSettings
Where to connect and publish the events, must have a EventProducerPush service listening
Value Members
- val connectionMetadata: Option[Metadata]
- val eventProducerSource: EventProducerSource
- val grpcClientSettings: GrpcClientSettings
- def handler()(implicit system: ActorSystem[_]): FlowWithContext[EventEnvelope[Event], ProjectionContext, Done, ProjectionContext, NotUsed]
- val originId: String