Class SnapshotAgent<K,V>

java.lang.Object
me.hsgamer.topper.agent.snapshot.SnapshotAgent<K,V>
All Implemented Interfaces:
Runnable, Agent
Direct Known Subclasses:
SnapshotHolderAgent

public abstract class SnapshotAgent<K,V> extends Object implements Agent, Runnable
  • Constructor Details

    • SnapshotAgent

      public SnapshotAgent()
  • Method Details

    • getDataStream

      protected abstract Stream<Map.Entry<K,V>> getDataStream()
    • needUpdate

      protected abstract boolean needUpdate()
    • run

      public void run()
      Specified by:
      run in interface Runnable
    • stop

      public void stop()
      Specified by:
      stop in interface Agent
    • getUrgentSnapshot

      public List<Map.Entry<K,V>> getUrgentSnapshot()
    • getSnapshot

      public List<Map.Entry<K,V>> getSnapshot()
    • getSnapshotIndex

      public int getSnapshotIndex(K key)
    • getSnapshotByIndex

      public Optional<Map.Entry<K,V>> getSnapshotByIndex(int index)
    • setComparator

      public void setComparator(Comparator<V> comparator)