public interface DeltaEventHandler<M extends IBetMatch,E extends IBetEvent,R extends IBetRecord>
Modifier and Type | Method and Description |
---|---|
default void |
onDeleteEvent(DeleteEvent<E> deleteEvent)
This method is invoked when events are deleted from snapshot.
|
default void |
onDeleteMatch(DeleteMatch<M> deleteMatch)
This method is invoked when matches are deleted from snapshot.
|
default void |
onDeleteOdd(DeleteOdd<R> deleteOdd)
This method is invoked when records are deleted from snapshot.
|
default void |
onFullSnapshotEnd()
Indicates that the end of full snapshot is reached.
|
default void |
onFullSnapshotStart()
Indicates that the start of full snapshot has begun.
|
default void |
onInsertEvent(InsertEvent<E> insertEvent)
This method is invoked when new events are inserted into snapshot.
|
default void |
onInsertMatch(InsertMatch<M> insertMatch)
This method is invoked when new matches are added to snapshot.
|
default void |
onInsertOdd(InsertOdd<R> insertOdd)
This method is invoked when records are inserted into snapshot.
|
default void |
onRefresh(java.util.List<PartitionKey> keys)
Method is invoked when client receives refresh from upstream.
|
default void |
onReset(Reset resetKeys)
This method is invoked when all the data belonging to a certain parition is cleared is
cleared
|
default void |
onSwitchFilterEnd()
Indicates that the end of filter switch is reached.
|
default void |
onSwitchFilterFail()
Indicates that the switching of filter switching has failed.
|
default void |
onSwitchFilterStart()
Indicates that the start of filter switching has begun.
|
default void |
onUpdateEvent(UpdateEvent<E> updateEvent)
This method is invoked when events are updated in snapshot.
|
default void |
onUpdateMatch(UpdateMatch<M> updateMatch)
This method is invoked when existing matches are updated.
|
default void |
onUpdateOdd(UpdateOdd<R> updateOdd)
This method is invoked when existing records are updated in snapshot.
|
default void onInsertMatch(InsertMatch<M> insertMatch)
DeltaMsg.after()
is the snapshot after matches in DeltaMsg.get()
are
added to snapshot.insertMatch
- default void onUpdateMatch(UpdateMatch<M> updateMatch)
DeltaMsg.after()
is the snapshot after matches in DeltaMsg.get()
are
updated to snapshot. updateMatch
- default void onDeleteMatch(DeleteMatch<M> deleteMatch)
DeltaMsg.after()
is the snapshot after matches in DeltaMsg.get()
are
deleted from snapshot.deleteMatch
- default void onInsertEvent(InsertEvent<E> insertEvent)
DeltaMsg.after()
is the snapshot after events in DeltaMsg.get()
are
inserted into snapshot.insertEvent
- default void onUpdateEvent(UpdateEvent<E> updateEvent)
DeltaMsg.after()
is the snapshot after events in DeltaMsg.get()
are
updated to snapshot. updateEvent
- default void onDeleteEvent(DeleteEvent<E> deleteEvent)
DeltaMsg.after()
is the snapshot after events in DeltaMsg.get()
are
removed from snapshotdeleteEvent
- default void onInsertOdd(InsertOdd<R> insertOdd)
DeltaMsg.after()
is the snapshot after records in DeltaMsg.get()
are
added to snapshotinsertOdd
- default void onUpdateOdd(UpdateOdd<R> updateOdd)
DeltaMsg.after()
is the snapshot after records in DeltaMsg.get()
are
updated to snapshotupdateOdd
- default void onDeleteOdd(DeleteOdd<R> deleteOdd)
DeltaMsg.after()
is the snapshot after records in DeltaMsg.get()
are
deleted from snapshotdeleteOdd
- default void onReset(Reset resetKeys)
resetKeys
- default void onSwitchFilterStart()
default void onSwitchFilterEnd()
default void onFullSnapshotStart()
default void onFullSnapshotEnd()
default void onSwitchFilterFail()
default void onRefresh(java.util.List<PartitionKey> keys)
keys
-