Package org.eclipse.ditto.internal.utils.ddata

Interface PekkoReplicatorConfig

@Immutable public interface PekkoReplicatorConfig
Provides configuration settings for the Pekko Replicator.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static enum 
    PekkoReplicatorConfig.PekkoReplicatorConfigValue
    An enumeration of the known config path expressions and their associated default values for PekkoReplicatorConfig.

  • Method Summary

    Modifier and Type
    Method
    Description
    com.typesafe.config.Config
    getCompleteConfig()
    Gets the complete Pekko distributed-data config to use for the Replicator.
    Duration
    getGossipInterval()
    Returns the interval with which cluster members initiate gossip.
    String
    getName()
    Returns the name of the replicator.
    Duration
    getNotifySubscribersInterval()
    Returns the interval subscribers are notified.
    String
    getRole()
    Returns the cluster role of members with replicas of the distributed collection.

  • Method Details

    • getName

      String getName()
      Returns the name of the replicator.
      Returns:
      the name.

    • getRole

      String getRole()
      Returns the cluster role of members with replicas of the distributed collection.
      Returns:
      cluster role.

    • getGossipInterval

      Duration getGossipInterval()
      Returns the interval with which cluster members initiate gossip.
      Returns:
      the gossip interval.

    • getNotifySubscribersInterval

      Duration getNotifySubscribersInterval()
      Returns the interval subscribers are notified.
      Returns:
      the duration.

    • getCompleteConfig

      com.typesafe.config.Config getCompleteConfig()
      Gets the complete Pekko distributed-data config to use for the Replicator.
      Returns:
      the complete config.