net.bluemind.core.backup.continuous

Interface IRecordStarvationStrategy

All Known Implementing Classes:

ParallelStarvationHandler, RecordStarvationHandler

public interface IRecordStarvationStrategy

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IRecordStarvationStrategy.ExpectedBehaviour

Method Summary

Modifier and Type	Method and Description
default void	checkpoint(java.lang.String topicName, ITopicStore.IResumeToken state) Override this to save intermediate states while cloning
default void	onRecordsReceived(io.vertx.core.json.JsonObject metas)
IRecordStarvationStrategy.ExpectedBehaviour	onStarvation(io.vertx.core.json.JsonObject infos)

Method Detail

onStarvation

IRecordStarvationStrategy.ExpectedBehaviour onStarvation(io.vertx.core.json.JsonObject infos)

onRecordsReceived

default void onRecordsReceived(io.vertx.core.json.JsonObject metas)

checkpoint

default void checkpoint(java.lang.String topicName,
                        ITopicStore.IResumeToken state)

Override this to save intermediate states while cloning

Parameters:

state -