Packages

object ReplicationSettings

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

Value Members

  1. def apply[Command](entityTypeName: String, replicationProjectionProvider: ReplicationProjectionProvider)(implicit system: ActorSystem[_], classTag: ClassTag[Command]): ReplicationSettings[Command]

    Create settings from config, the system config is expected to contain a block with the entity type key name.

    Create settings from config, the system config is expected to contain a block with the entity type key name. Each replica is further expected to have a top level config entry 'akka.grpc.client.[replica-id]' with Akka gRPC client config for reaching the replica from the other replicas.

  2. def apply[Command](entityTypeName: String, selfReplicaId: ReplicaId, eventProducerSettings: EventProducerSettings, replicas: Set[Replica], entityEventReplicationTimeout: FiniteDuration, parallelUpdates: Int, replicationProjectionProvider: ReplicationProjectionProvider)(implicit arg0: ClassTag[Command]): ReplicationSettings[Command]

    Settings for replicating an entity over gRPC

    Settings for replicating an entity over gRPC

    Note: The replica ids and the entity type name is used as id in offset tracking, changing those will replay events from the start.

    entityTypeName

    A name for the type of replicated entity

    selfReplicaId

    The replica id of this node, must not be present among 'otherReplicas'

    eventProducerSettings

    Event producer settings for the event stream published by this replica

    replicas

    One entry for each remote replica to replicate into this replica

    entityEventReplicationTimeout

    A timeout for the replication event, needs to be large enough for the time of sending a message across sharding and persisting it in the local replica of an entity. Hitting this timeout means the entire replication stream will back off and restart.

    parallelUpdates

    Maximum number of parallel updates sent over sharding to the destination entities

    replicationProjectionProvider

    A factory for the projection used to keep track of offsets when consuming replicated events