Uses of Interface
net.bluemind.core.backup.continuous.IRecordStarvationStrategy

Packages that use IRecordStarvationStrategy

Package	Description
net.bluemind.core.backup.continuous
net.bluemind.core.backup.continuous.impl
net.bluemind.core.backup.continuous.restore
net.bluemind.core.backup.continuous.store
net.bluemind.core.backup.store.kafka

Uses of IRecordStarvationStrategy in net.bluemind.core.backup.continuous

Fields in net.bluemind.core.backup.continuous declared as IRecordStarvationStrategy

Modifier and Type	Field and Description
static IRecordStarvationStrategy	RecordStarvationStrategies.ALWAYS_RETRY Keeps consuming records
static IRecordStarvationStrategy	RecordStarvationStrategies.EARLY_ABORT Aborts at first record starvation

Methods in net.bluemind.core.backup.continuous with parameters of type IRecordStarvationStrategy

Modifier and Type	Method and Description
ITopicStore.IResumeToken	ILiveStream.subscribe(ITopicStore.IResumeToken startOffset, io.vertx.core.Handler<DataElement> handler, IRecordStarvationStrategy onStarve)

Uses of IRecordStarvationStrategy in net.bluemind.core.backup.continuous.impl

Methods in net.bluemind.core.backup.continuous.impl with parameters of type IRecordStarvationStrategy

Modifier and Type	Method and Description
ITopicStore.IResumeToken	LiveStream.subscribe(ITopicStore.IResumeToken startOffset, io.vertx.core.Handler<DataElement> handler, IRecordStarvationStrategy onStarve)

Uses of IRecordStarvationStrategy in net.bluemind.core.backup.continuous.restore

Classes in net.bluemind.core.backup.continuous.restore that implement IRecordStarvationStrategy

Modifier and Type	Class and Description
class	RecordStarvationHandler

Uses of IRecordStarvationStrategy in net.bluemind.core.backup.continuous.store

Methods in net.bluemind.core.backup.continuous.store with parameters of type IRecordStarvationStrategy

Modifier and Type	Method and Description
ITopicStore.IResumeToken	TopicSubscriber.subscribe(ITopicStore.IResumeToken index, RecordHandler handler, IRecordStarvationStrategy strat)

Uses of IRecordStarvationStrategy in net.bluemind.core.backup.store.kafka

Classes in net.bluemind.core.backup.store.kafka that implement IRecordStarvationStrategy

Modifier and Type	Class and Description
class	ParallelStarvationHandler Create IRecordStarvationStrategy "workers" for dealing with starvation in multiple consumers.

Methods in net.bluemind.core.backup.store.kafka with parameters of type IRecordStarvationStrategy

Modifier and Type	Method and Description
ITopicStore.IResumeToken	KafkaTopicSubscriber.subscribe(ITopicStore.IResumeToken index, RecordHandler handler, IRecordStarvationStrategy strat)

Constructors in net.bluemind.core.backup.store.kafka with parameters of type IRecordStarvationStrategy

Constructor and Description
ParallelStarvationHandler(IRecordStarvationStrategy starved, int worker)