Packages

final class EventProducerPush[Event] extends AnyRef

Source
EventProducerPush.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventProducerPush
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. 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

  1. val connectionMetadata: Option[Metadata]
  2. val eventProducerSource: EventProducerSource
  3. val grpcClientSettings: GrpcClientSettings
  4. def handler()(implicit system: ActorSystem[_]): FlowWithContext[EventEnvelope[Event], ProjectionContext, Done, ProjectionContext, NotUsed]
  5. val originId: String