object Replication
- Annotations
- @ApiMayChange()
- Source
- Replication.scala
- Alphabetic
- By Inheritance
- Replication
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait EdgeReplication[Command] extends AnyRef
Value Members
- def grpcEdgeReplication[Command, Event, State](settings: ReplicationSettings[Command])(replicatedBehaviorFactory: (ReplicatedBehaviors[Command, Event, State]) => Behavior[Command])(implicit system: ActorSystem[_]): EdgeReplication[Command]
Called to bootstrap the entity on each edge node.
Called to bootstrap the entity on each edge node. In edge mode all connections for replication comes from edge node to cloud. Cloud service needs to be configured for regular grpc replication with edge replication enabled through
ReplicationSettings#withEdgeReplication(true)
.Each edge replica must use a unique replica id.
The cloud replicas does not know about the edge replica ids up front (it should not be in their "other replicas" set).
An edge replica can connect to more than one cloud replica for redundancy (but only one is required).
- def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command])(replicatedBehaviorFactory: (ReplicatedBehaviors[Command, Event, State]) => Behavior[Command])(implicit system: ActorSystem[_]): Replication[Command]
Called to bootstrap the entity on each cluster node in each of the replicas.
Called to bootstrap the entity on each cluster node in each of the replicas.
Important: Note that this does not publish the endpoint, additional steps are needed!
Deprecated Value Members
- def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command], topicExpression: String)(replicatedBehaviorFactory: (ReplicatedBehaviors[Command, Event, State]) => Behavior[Command])(implicit system: ActorSystem[_]): Replication[Command]
Called to bootstrap the entity on each cluster node in each of the replicas.
Called to bootstrap the entity on each cluster node in each of the replicas.
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.Important: Note that this does not publish the endpoint, additional steps are needed!
- Annotations
- @deprecated
- Deprecated
(Since version 1.5.1) Define topicExpression via settings.withProducerFilterTopicExpression
- def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command], producerFilter: (EventEnvelope[Event]) => Boolean)(replicatedBehaviorFactory: (ReplicatedBehaviors[Command, Event, State]) => Behavior[Command])(implicit system: ActorSystem[_]): Replication[Command]
Called to bootstrap the entity on each cluster node in each of the replicas.
Called to bootstrap the entity on each cluster node in each of the replicas.
Filter events matching the
producerFilter
predicate, for example based on tags.Important: Note that this does not publish the endpoint, additional steps are needed!
- Annotations
- @deprecated
- Deprecated
(Since version 1.5.1) Define producerFilter via settings.withProducerFilter