trait Replication[Command] extends AnyRef
Created using Replication.grpcReplication, which starts sharding with the entity and replication stream consumers but not the replication endpoint needed to publish events to other replication places.
- Command
The type of commands the Replicated Event Sourced Entity accepts Not for user extension
- Annotations
- @DoNotInherit()
- Source
- Replication.scala
- Alphabetic
- By Inheritance
- Replication
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def createSingleServiceHandler: () => PartialFunction[HttpRequest, Future[HttpResponse]]
If only replicating one Replicated Event Sourced Entity and not using Akka Projection gRPC this endpoint factory can be used to get a partial function that can be served/bound with an Akka HTTP/2 server
- abstract def entityRefFactory: (String) => EntityRef[Command]
Shortcut for creating EntityRefs for the sharded Replicated Event Sourced entities for sending commands.
- abstract def entityTypeKey: EntityTypeKey[Command]
Entity type key for looking up the entities
- abstract def eventProducerPushDestination: Option[EventProducerPushDestination]
Scala API: Push destinations for accepting/combining multiple Replicated Event Sourced entity types and possibly also regular projections into one producer push destination handler in a set passed to EventProducerPushDestination.grpcServiceHandler to create a single gRPC endpoint.
- abstract def eventProducerSource: EventProducerSource
If combining multiple replicated entity types, or combining with direct usage of Akka Projection gRPC, you will have to use the EventProducerSource of each of them in a set passed to EventProducer.grpcServiceHandler to create a single gRPC endpoint.
- abstract def eventProducerService: EventProducerSource
- Annotations
- @deprecated
- Deprecated
(Since version 1.5.1) Use eventProducerSource instead