Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
ILiveStream.subscribe(io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
ILiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
ILiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler,
IRecordStarvationStrategy onStarve) |
Modifier and Type | Method and Description |
---|---|
ITopicStore.IResumeToken |
LiveStream.subscribe(io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
LiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
LiveStream.subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler,
IRecordStarvationStrategy onStarve) |
Modifier and Type | Method and Description |
---|---|
void |
DomainRestorationHandler.handle(DataElement event) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,RestoreTopology.PromotingServer> |
RestoreTopology.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> servers) |
void |
RestoreJobPlans.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> jobs) |
java.util.Map<java.lang.String,ItemValue<Domain>> |
RestoreDomains.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> domains) |
SystemConf |
RestoreSysconf.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> sysconfs) |
java.lang.String |
RestoreToken.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> maybeTok) |
void |
RestoreContainerItemIdSeq.restore(IServerTaskMonitor monitor,
java.util.List<DataElement> dataElements) |
Copyright © 2023. All Rights Reserved.