com.neeve.rog.log
Interface RogLogCompactionReader.ReadHandler

Enclosing class:

RogLogCompactionReader

public static interface RogLogCompactionReader.ReadHandler

Interface through which compacted reads and dispatched to caller

Nested Class Summary

static class

RogLogCompactionReader.ReadHandler.ChangeType Enumerates the various types of change for an object that can be reported by the compaction reader.

Method Summary

void	handleChange(RogLogCompactionReader.ReadHandler.ChangeType changeType, List<RogLog.Entry> entries) Called to notify about a change.
void	onCheckpointComplete(long checkpointVersion) Dispatched when the processing of a checkpoint has completed
void	onCheckpointStart(long checkpointVersion) Dispatched when the processing of a new checkpoint is started
void	onWait() Dispatched when waiting for more entries to enter the log This event is dispatched once each time the reader reaches the end of a log and it waits for a new entry to be added to the log.

Method Detail

onCheckpointStart

void onCheckpointStart(long checkpointVersion)

Dispatched when the processing of a new checkpoint is started

Parameters:

checkpointVersion - The checkpoint number

handleChange

void handleChange(RogLogCompactionReader.ReadHandler.ChangeType changeType,
                  List<RogLog.Entry> entries)

Called to notify about a change.

Parameters:

changeType - The change being reported

entries - The set of entries that list the operations performed on the object within the checkpoint being processed.

onCheckpointComplete

void onCheckpointComplete(long checkpointVersion)

Dispatched when the processing of a checkpoint has completed

Parameters:

checkpointVersion - The checkpoint number

onWait

void onWait()

Dispatched when waiting for more entries to enter the log

This event is dispatched once each time the reader reaches the end of a log and it waits for a new entry to be added to the log. This event is dispatched maximum of once per checkpoint in the log.