Class PNCounterConfig

    • Field Detail

      • DEFAULT_REPLICA_COUNT

        public static final int DEFAULT_REPLICA_COUNT
        The default number of replicas on which state for this CRDT is kept
        See Also:
        Constant Field Values
      • DEFAULT_STATISTICS_ENABLED

        public static final boolean DEFAULT_STATISTICS_ENABLED
        Default value for statistics enabled.
        See Also:
        Constant Field Values
    • Constructor Detail

      • PNCounterConfig

        public PNCounterConfig()
      • PNCounterConfig

        public PNCounterConfig​(java.lang.String name,
                               int replicaCount,
                               java.lang.String splitBrainProtectionName,
                               boolean statisticsEnabled)
      • PNCounterConfig

        public PNCounterConfig​(java.lang.String name)
    • Method Detail

      • getName

        public java.lang.String getName()
        Gets the name of the PN counter.
        Specified by:
        getName in interface NamedConfig
      • setName

        public PNCounterConfig setName​(java.lang.String name)
        Sets the name of the PN counter.
        Specified by:
        setName in interface NamedConfig
        Parameters:
        name - the name of the PN counter
        Returns:
        the updated PN counter config
      • isStatisticsEnabled

        public boolean isStatisticsEnabled()
        Checks if statistics are enabled for this PN counter
        Returns:
        true if enabled, false otherwise
      • setStatisticsEnabled

        public PNCounterConfig setStatisticsEnabled​(boolean statisticsEnabled)
        Enables or disables statistics for this PN counter
        Parameters:
        statisticsEnabled - true to enable statistics, false to disable
        Returns:
        the updated PN counter config
      • getReplicaCount

        public int getReplicaCount()
        Returns the number of replicas on which state for this PN counter will be kept. This number applies in quiescent state, if there are currently membership changes or clusters are merging, the state may be temporarily kept on more replicas.
        Returns:
        the number of replicas for the CRDT state
      • setReplicaCount

        public PNCounterConfig setReplicaCount​(int replicaCount)
        Sets the number of replicas on which state for this PN counter will be kept. This number applies in quiescent state, if there are currently membership changes or clusters are merging, the state may be temporarily kept on more replicas.

        The provided replicaCount must be between 1 and 2147483647.

        Parameters:
        replicaCount - the number of replicas for the CRDT state
        Returns:
        the updated PN counter config
        Throws:
        InvalidConfigurationException - if the replicaCount is less than 1
      • getSplitBrainProtectionName

        public java.lang.String getSplitBrainProtectionName()
        Returns the split brain protection name for operations.
        Returns:
        the split brain protection name
      • setSplitBrainProtectionName

        public PNCounterConfig setSplitBrainProtectionName​(java.lang.String splitBrainProtectionName)
        Sets the split brain protection name for operations.
        Parameters:
        splitBrainProtectionName - the split brain protection name
        Returns:
        the updated PN counter config
      • writeData

        public void writeData​(ObjectDataOutput out)
                       throws java.io.IOException
        Description copied from interface: DataSerializable
        Writes object fields to output stream
        Specified by:
        writeData in interface DataSerializable
        Parameters:
        out - output
        Throws:
        java.io.IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.
      • readData

        public void readData​(ObjectDataInput in)
                      throws java.io.IOException
        Description copied from interface: DataSerializable
        Reads fields from the input stream
        Specified by:
        readData in interface DataSerializable
        Parameters:
        in - input
        Throws:
        java.io.IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object