Packages

final class ReplicationSettings[Command] extends AnyRef

Not for user extension, construct using ReplicationSettings#create

Annotations
@ApiMayChange() @DoNotInherit()
Source
ReplicationSettings.scala
Linear Supertypes
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 configureEntity(configure: Function[Entity[Command, ShardingEnvelope[Command]], Entity[Command, ShardingEnvelope[Command]]]): ReplicationSettings[Command]

    Allows for changing the settings of the replicated entity, such as stop message, passivation strategy etc.

  2. val configureEntity: Function[Entity[Command, ShardingEnvelope[Command]], Entity[Command, ShardingEnvelope[Command]]]
  3. val edgeReplication: Boolean
  4. val edgeReplicationDeliveryMaxBackoff: Duration
  5. val edgeReplicationDeliveryMinBackoff: Duration
  6. val edgeReplicationDeliveryRetries: Int
  7. val entityEventReplicationTimeout: Duration
  8. val entityTypeKey: EntityTypeKey[Command]
  9. val eventProducerInterceptor: Optional[EventProducerInterceptor]
  10. val eventProducerSettings: EventProducerSettings
  11. val initialConsumerFilter: List[FilterCriteria]
  12. val otherReplicas: Set[Replica]
  13. val parallelUpdates: Int
  14. val producerFilter: Predicate[EventEnvelope[Any]]
  15. val replicationProjectionProvider: ReplicationProjectionProvider
  16. val selfReplicaId: ReplicaId
  17. val streamId: String
  18. def toString(): String
    Definition Classes
    ReplicationSettings → AnyRef → Any
  19. def withEdgeReplication(edgeReplication: Boolean): ReplicationSettings[Command]
  20. def withEdgeReplicationDeliveryMaxBackoff(maxBackoff: Duration): ReplicationSettings[Command]
  21. def withEdgeReplicationDeliveryMinBackoff(minBackoff: Duration): ReplicationSettings[Command]
  22. def withEdgeReplicationDeliveryRetries(retries: Int): ReplicationSettings[Command]

    Replicated event sourcing from edge sends each event over sharding, in case that delivery fails or times out, retry this number of times

  23. def withEntityEventReplicationTimeout(duration: Duration): ReplicationSettings[Command]

    Set the timeout for events being completely processed after arriving to a node in the replication stream

  24. def withEventProducerInterceptor(interceptor: EventProducerInterceptor): ReplicationSettings[Command]

    Add an interceptor to the gRPC event producer for example for authentication of incoming requests

  25. def withEventProducerSettings(eventProducerSettings: EventProducerSettings): ReplicationSettings[Command]
  26. def withInitialConsumerFilter(initialConsumerFilter: List[FilterCriteria]): ReplicationSettings[Command]

    Set the initial consumer filter to use for events.

    Set the initial consumer filter to use for events. Should only be used for static, up front consumer filters. Combining this with updating consumer filters directly means that the filters may be reset to these filters.

  27. def withOtherReplicas(otherReplicas: Set[Replica]): ReplicationSettings[Command]
  28. def withParallelUpdates(parallelUpdates: Int): ReplicationSettings[Command]

    Run up to this many parallel updates over sharding.

    Run up to this many parallel updates over sharding. Note however that updates for the same persistence id is always sequential.

  29. def withProducerFilter[Event](producerFilter: Predicate[EventEnvelope[Event]]): ReplicationSettings[Command]

    Filter events matching the producerFilter predicate, for example based on tags.

  30. def withProducerFilterTopicExpression(topicExpression: String): ReplicationSettings[Command]

    Filter events matching the topic expression according to MQTT specification, including wildcards.

    Filter events matching the topic expression according to MQTT specification, including wildcards. The topic of an event is defined by a tag with certain prefix, see topic-tag-prefix configuration.

  31. def withProjectionProvider(projectionProvider: ReplicationProjectionProvider): ReplicationSettings[Command]

    Change projection provider

  32. def withSelfReplicaId(selfReplicaId: ReplicaId): ReplicationSettings[Command]
  33. def withStreamId(streamId: String): ReplicationSettings[Command]