Package at.twinformatics.eureka.adapter.consul.service

Class ServiceChangeDetector

  • @Component
public class ServiceChangeDetector
extends java.lang.Object

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      rx.Observable<java.lang.Long> getIndexOfApp​(java.lang.String appName, long millis)  
      java.lang.Long getLastEmitted()  
      java.lang.Long getLastEmittedOfApp​(java.lang.String appName)  
      rx.Observable<java.lang.Long> getTotalIndex​(long millis)  
      void publish​(java.lang.String appName, long timestamp)  
      void reset()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ServiceChangeDetector

        public ServiceChangeDetector()

    • Method Detail

      • publish

        public void publish​(java.lang.String appName,
                    long timestamp)

      • getIndexOfApp

        public rx.Observable<java.lang.Long> getIndexOfApp​(java.lang.String appName,
                                                   long millis)

      • getTotalIndex

        public rx.Observable<java.lang.Long> getTotalIndex​(long millis)

      • getLastEmitted

        public java.lang.Long getLastEmitted()

      • getLastEmittedOfApp

        public java.lang.Long getLastEmittedOfApp​(java.lang.String appName)

      • reset

        public void reset()