Package me.hsgamer.topper.agent.snapshot

Class SnapshotAgent<K,V>

java.lang.Object

me.hsgamer.topper.agent.snapshot.SnapshotAgent<K,V>

All Implemented Interfaces:

Runnable, Agent

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

Constructor Summary

Constructors

Constructor	Description
SnapshotAgent()

Method Summary

Modifier and Type	Method	Description
void	addFilter(Predicate<Map.Entry<K,V>> filter)
static <K, V> SnapshotAgent<K,V>	create(DataHolder<K,V> holder)
protected abstract Stream<Map.Entry<K,V>>	getDataStream()
List<Map.Entry<K,V>>	getSnapshot()
Optional<Map.Entry<K,V>>	getSnapshotByIndex(int index)
int	getSnapshotIndex(K key)
List<Map.Entry<K,V>>	getUrgentSnapshot()
void	run()
void	setComparator(Comparator<V> comparator)
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface me.hsgamer.topper.agent.core.Agent

beforeStop, start

Constructor Details

SnapshotAgent

public SnapshotAgent()

Method Details

create

public static <K,
V> SnapshotAgent<K,V> create(DataHolder<K,V> holder)

getDataStream

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

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)

addFilter

public void addFilter(Predicate<Map.Entry<K,V>> filter)