jayeson.lib.sports.client

Interface DeltaEventHandler<M extends IBetMatch,E extends IBetEvent,R extends IBetRecord>

public interface DeltaEventHandler<M extends IBetMatch,E extends IBetEvent,R extends IBetRecord>

DeltaEventHandler handles delta snapshots.The function that will be triggered first is onFullSnapshotStart().The onFullSnapshotStart() indicates that this is the begining of the full snapshot.The following message will be the onInsertMatch and the very first onInsertMatch will contain the events and odds in the INSERT_MATCH message.Subsequently will receive onInsertEvent message followed by onInsertOdd.The onFullSnapshotEnd() indicates that the full snapshot is received completely.
For Match Insertion in sequence will be:

1.onInsertMatch
2.onInsertEvent (insert event always appear before a child insert odd msg)
3.onInsertOdd

For Match Deletion in sequence will be:
1.onDeleteOdd (an odd always be deleted before the parent event is removed)
2.onDeleteEvent
3.onDeleteMatch
Implement this interface to call methods whenever there is change is snapshot data

Method Summary

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.

Method Detail

onInsertMatch

default void onInsertMatch(InsertMatch<M> insertMatch)

This method is invoked when new matches are added to snapshot. DeltaMsg.after() is the snapshot after matches in DeltaMsg.get() are added to snapshot.

Parameters:

insertMatch -

onUpdateMatch

default void onUpdateMatch(UpdateMatch<M> updateMatch)

This method is invoked when existing matches are updated. DeltaMsg.after() is the snapshot after matches in DeltaMsg.get() are updated to snapshot.

Update Match refers to updating match's meta information etc

Parameters:

updateMatch -

onDeleteMatch

default void onDeleteMatch(DeleteMatch<M> deleteMatch)

This method is invoked when matches are deleted from snapshot. DeltaMsg.after() is the snapshot after matches in DeltaMsg.get() are deleted from snapshot.

Parameters:

deleteMatch -

onInsertEvent

default void onInsertEvent(InsertEvent<E> insertEvent)

This method is invoked when new events are inserted into snapshot. DeltaMsg.after() is the snapshot after events in DeltaMsg.get() are inserted into snapshot.

Parameters:

insertEvent -

onUpdateEvent

default void onUpdateEvent(UpdateEvent<E> updateEvent)

This method is invoked when events are updated in snapshot. DeltaMsg.after() is the snapshot after events in DeltaMsg.get() are updated to snapshot.

Event update means: A new live state is inserted/deleted into snapshot or Existing live state is updated or any meta information of the event is updated

Parameters:

updateEvent -

onDeleteEvent

default void onDeleteEvent(DeleteEvent<E> deleteEvent)

This method is invoked when events are deleted from snapshot. DeltaMsg.after() is the snapshot after events in DeltaMsg.get() are removed from snapshot

Parameters:

deleteEvent -

onInsertOdd

default void onInsertOdd(InsertOdd<R> insertOdd)

This method is invoked when records are inserted into snapshot. DeltaMsg.after() is the snapshot after records in DeltaMsg.get() are added to snapshot

Parameters:

insertOdd -

onUpdateOdd

default void onUpdateOdd(UpdateOdd<R> updateOdd)

This method is invoked when existing records are updated in snapshot. DeltaMsg.after() is the snapshot after records in DeltaMsg.get() are updated to snapshot

Parameters:

updateOdd -

onDeleteOdd

default void onDeleteOdd(DeleteOdd<R> deleteOdd)

This method is invoked when records are deleted from snapshot. DeltaMsg.after() is the snapshot after records in DeltaMsg.get() are deleted from snapshot

Parameters:

deleteOdd -

onReset

default void onReset(Reset resetKeys)

This method is invoked when all the data belonging to a certain parition is cleared is cleared

Parameters:

resetKeys -

onSwitchFilterStart

default void onSwitchFilterStart()

Indicates that the start of filter switching has begun.

onSwitchFilterEnd

default void onSwitchFilterEnd()

Indicates that the end of filter switch is reached.

onFullSnapshotStart

default void onFullSnapshotStart()

Indicates that the start of full snapshot has begun.

onFullSnapshotEnd

default void onFullSnapshotEnd()

Indicates that the end of full snapshot is reached.

onSwitchFilterFail

default void onSwitchFilterFail()

Indicates that the switching of filter switching has failed.

onRefresh

default void onRefresh(java.util.List<PartitionKey> keys)

Method is invoked when client receives refresh from upstream.

Parameters:

keys -