Class ConfigurationPoller

  • All Implemented Interfaces:
    java.lang.Runnable

    public class ConfigurationPoller
    extends java.lang.Object
    implements java.lang.Runnable
    AWS ElastiCache configuration poller
    • Field Detail

      • serverOrderCounter

        private final java.util.concurrent.atomic.AtomicInteger serverOrderCounter
      • ordersMap

        private java.util.Map<java.lang.String,​java.lang.Integer> ordersMap
      • log

        private static final org.slf4j.Logger log
      • pollIntervalMills

        private final long pollIntervalMills
      • scheduledExecutorService

        private java.util.concurrent.ScheduledExecutorService scheduledExecutorService
    • Constructor Detail

      • ConfigurationPoller

        public ConfigurationPoller​(AWSElasticCacheClient client,
                                   long pollIntervalMills)
    • Method Detail

      • getClusterConfiguration

        public ClusterConfiguration getClusterConfiguration()
        Return current ClusterConfigration.
        Returns:
      • getCacheNodeOrder

        public int getCacheNodeOrder​(CacheNode node)
      • removeCacheNodeOrder

        public void removeCacheNodeOrder​(CacheNode node)
      • start

        public void start()
      • stop

        public void stop()
      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable