Packages

object Replication

Annotations
@ApiMayChange()
Source
Replication.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Replication
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def grpcEdgeReplication[Command, Event, State](settings: ReplicationSettings[Command], replicatedBehaviorFactory: Function[ReplicatedBehaviors[Command, Event, State], Behavior[Command]], 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).

  2. def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command], replicatedBehaviorFactory: Function[ReplicatedBehaviors[Command, Event, State], Behavior[Command]], 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

  1. def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command], topicExpression: String, replicatedBehaviorFactory: Function[ReplicatedBehaviors[Command, Event, State], Behavior[Command]], 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
    Deprecated

    (Since version 1.5.1) Define topicExpression via settings.withProducerFilterTopicExpression

  2. def grpcReplication[Command, Event, State](settings: ReplicationSettings[Command], producerFilter: Predicate[EventEnvelope[Event]], replicatedBehaviorFactory: Function[ReplicatedBehaviors[Command, Event, State], Behavior[Command]], 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
    Deprecated

    (Since version 1.5.1) Define producerFilter via settings.withProducerFilter