final class ReplicationSettings[Command] extends AnyRef
Not for user extension. Constructed through companion object factories.
- Annotations
- @ApiMayChange()
- Source
- ReplicationSettings.scala
- Alphabetic
- By Inheritance
- ReplicationSettings
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val acceptEdgeReplication: Boolean
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def configureEntity(configure: (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.
- val configureEntity: (Entity[Command, ShardingEnvelope[Command]]) => Entity[Command, ShardingEnvelope[Command]]
- val edgeReplicationDeliveryMaxBackoff: FiniteDuration
- val edgeReplicationDeliveryMinBackoff: FiniteDuration
- val edgeReplicationDeliveryRetries: Int
- val entityEventReplicationTimeout: FiniteDuration
- val entityTypeKey: EntityTypeKey[Command]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val eventProducerInterceptor: Option[EventProducerInterceptor]
- val eventProducerSettings: EventProducerSettings
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- val initialConsumerFilter: Seq[FilterCriteria]
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- val otherReplicas: Set[Replica]
- val parallelUpdates: Int
- val producerFilter: (EventEnvelope[Any]) => Boolean
- val projectionProvider: ReplicationProjectionProvider
- val selfReplicaId: ReplicaId
- val streamId: String
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ReplicationSettings → AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withEdgeReplication(edgeReplicationAllowed: Boolean): ReplicationSettings[Command]
Allow edge replicas to connect and replicate updates, default is to not allow.
- def withEdgeReplicationDeliveryMaxBackoff(maxBackoff: FiniteDuration): ReplicationSettings[Command]
- def withEdgeReplicationDeliveryMinBackoff(minBackoff: FiniteDuration): ReplicationSettings[Command]
- 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
- def withEntityEventReplicationTimeout(duration: FiniteDuration): ReplicationSettings[Command]
Set the timeout for events being completely processed after arriving to a node in the replication stream
- def withEventProducerInterceptor(interceptor: EventProducerInterceptor): ReplicationSettings[Command]
Add an interceptor to the gRPC event producer for example for authentication of incoming requests
- def withEventProducerSettings(eventProducerSettings: EventProducerSettings): ReplicationSettings[Command]
- def withInitialConsumerFilter(initialConsumerFilter: Seq[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.
- def withOtherReplicas(replicas: Set[Replica]): ReplicationSettings[Command]
- 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.
- def withProducerFilter[Event](producerFilter: (EventEnvelope[Event]) => Boolean): ReplicationSettings[Command]
Filter events matching the
producerFilterpredicate, for example based on tags. - 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-prefixconfiguration. - def withProjectionProvider(projectionProvider: ReplicationProjectionProvider): ReplicationSettings[Command]
Change projection provider
- def withSelfReplicaId(selfReplicaId: ReplicaId): ReplicationSettings[Command]
- def withStreamId(streamId: String): ReplicationSettings[Command]