Class DurableExecutorConfig

    • Field Detail

      • DEFAULT_POOL_SIZE

        public static final int DEFAULT_POOL_SIZE
        The number of executor threads per Member for the Executor based on this configuration.
        See Also:
        Constant Field Values
      • DEFAULT_RING_BUFFER_CAPACITY

        public static final int DEFAULT_RING_BUFFER_CAPACITY
        Capacity of RingBuffer (per partition).
        See Also:
        Constant Field Values
      • DEFAULT_DURABILITY

        public static final int DEFAULT_DURABILITY
        Durability of Executor.
        See Also:
        Constant Field Values
    • Constructor Detail

      • DurableExecutorConfig

        public DurableExecutorConfig()
      • DurableExecutorConfig

        public DurableExecutorConfig​(java.lang.String name)
      • DurableExecutorConfig

        public DurableExecutorConfig​(java.lang.String name,
                                     int poolSize,
                                     int durability,
                                     int capacity,
                                     boolean statisticsEnabled)
      • DurableExecutorConfig

        public DurableExecutorConfig​(java.lang.String name,
                                     int poolSize,
                                     int durability,
                                     int capacity,
                                     java.lang.String splitBrainProtectionName,
                                     boolean statisticsEnabled)
    • Method Detail

      • getName

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

        public DurableExecutorConfig setName​(java.lang.String name)
        Sets the name of the executor task.
        Specified by:
        setName in interface NamedConfig
        Parameters:
        name - the name of the executor task
        Returns:
        this executor config instance
      • getPoolSize

        public int getPoolSize()
        Gets the number of executor threads per member for the executor.
        Returns:
        the number of executor threads per member for the executor
      • setPoolSize

        public DurableExecutorConfig setPoolSize​(int poolSize)
        Sets the number of executor threads per member for the executor.
        Parameters:
        poolSize - the number of executor threads per member for the executor
        Returns:
        this executor config instance
      • getDurability

        public int getDurability()
        Gets the durability of the executor
        Returns:
        the durability of the executor
      • setDurability

        public DurableExecutorConfig setDurability​(int durability)
        Sets the durability of the executor
        Parameters:
        durability - the durability of the executor
        Returns:
        this executor config instance
      • getCapacity

        public int getCapacity()
        Gets the ring buffer capacity of the executor task. This is a per partition parameter, so total capacity of the ringbuffers will be partitionCount * capacity
        Returns:
        Ring buffer capacity of the executor task
      • setCapacity

        public DurableExecutorConfig setCapacity​(int capacity)
        Sets the ring buffer capacity of the executor task.
        Parameters:
        capacity - Ring Buffer capacity of the executor task
        Returns:
        this executor config instance
      • getSplitBrainProtectionName

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

        public DurableExecutorConfig setSplitBrainProtectionName​(java.lang.String splitBrainProtectionName)
        Sets the split brain protection name for operations.
        Parameters:
        splitBrainProtectionName - the split brain protection name
        Returns:
        the updated configuration
      • isStatisticsEnabled

        public boolean isStatisticsEnabled()
        Returns:
        true if statistics gathering is enabled on the executor task (default), false otherwise
      • setStatisticsEnabled

        public DurableExecutorConfig setStatisticsEnabled​(boolean statisticsEnabled)
        Enables or disables statistics gathering on the executor task.
        Parameters:
        statisticsEnabled - true if statistics gathering is enabled on the executor task, false otherwise @return this executor config instance
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • 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 final boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

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