Package me.hsgamer.topper.agent.snapshot

Class SnapshotHolderAgent<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

Runnable, Agent, DataEntryAgent<K,V>

public class SnapshotHolderAgent<K,V>
extends SnapshotAgent<K,V>
implements DataEntryAgent<K,V>

Constructor Summary

Constructors

Constructor	Description
SnapshotHolderAgent(DataHolder<K,V> holder)

Method Summary

Modifier and Type	Method	Description
protected Stream<Map.Entry<K,V>>	getDataStream()
protected boolean	needUpdate()
void	onCreate(DataEntry<K,V> entry)
void	onRemove(DataEntry<K,V> entry)
void	onUpdate(DataEntry<K,V> entry, V oldValue, V newValue)
void	setDataFilter(Predicate<DataEntry<K,V>> dataFilter)

Methods inherited from class me.hsgamer.topper.agent.snapshot.SnapshotAgent

getSnapshot, getSnapshotByIndex, getSnapshotIndex, getUrgentSnapshot, run, setComparator, 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

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

onUnregister

Constructor Details

SnapshotHolderAgent

public SnapshotHolderAgent(DataHolder<K,V> holder)

Method Details

setDataFilter

public void setDataFilter(Predicate<DataEntry<K,V>> dataFilter)

getDataStream

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

Specified by:

getDataStream in class SnapshotAgent<K,V>

needUpdate

protected boolean needUpdate()

Specified by:

needUpdate in class SnapshotAgent<K,V>

onCreate

public void onCreate(DataEntry<K,V> entry)

Specified by:

onCreate in interface DataEntryAgent<K,V>

onUpdate

public void onUpdate(DataEntry<K,V> entry,
 V oldValue,
 V newValue)

Specified by:

onUpdate in interface DataEntryAgent<K,V>

onRemove

public void onRemove(DataEntry<K,V> entry)

Specified by:

onRemove in interface DataEntryAgent<K,V>