Packages

object Replication

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

Type Members

  1. trait EdgeReplication[Command] extends AnyRef

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  9. 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).

  10. 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!

  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  16. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. 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

  3. 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

Inherited from AnyRef

Inherited from Any

Ungrouped