com.gigaspaces.internal.cluster.node.impl.directPersistency

Interface IDirectPersistencySyncHandler

All Known Implementing Classes:

DirectPersistencySyncHandler

public interface IDirectPersistencySyncHandler

The synchronizing direct-persistency handler

Since:

10.2

Author:

yechielf

Method Summary

Modifier and Type	Method and Description
void	afterInitializedBlobStoreIO(IDirectPersistencyIoHandler ioHandler)
void	afterInsertingToRedolog(IReplicationOutContext context, long redoKey)
void	afterOperationPersisted(IDirectPersistencyOpInfo e)
void	afterRecovery()
void	beforeDirectPersistencyOp(IReplicationOutContext context, IEntryHolder entryHolder, boolean phantom)
void	beforeDirectPersistencyOp(IReplicationOutContext context, List<String> uids, Set<String> phantoms, Map<String,IEntryHolder> entryHolderMap)
void	close()
IReplicationGroupBacklog	getBackLog()
long	getCurrentGenerationId()
EmbeddedSyncHandler	getEmbeddedSyncHandler()
Iterator<String>	getEntriesForRecovery()
long	getLastConfirmed()
DirectPersistencyListHandler	getListHandler()
SpaceEngine	getSpaceEngine()
void	initialize()
boolean	isEmbeddedListUsed()
boolean	isOverflow()
void	onEmbeddedListRecordTransferEnd(IDirectPersistencyOpInfo o)
void	onEmbeddedListRecordTransferStart(IDirectPersistencyOpInfo o, boolean onlyIfNotExists)
void	onEmbeddedOpFromInitialLoad(List<String> uids, long gen, long seq, Set<String> phantoms)
void	onEmbeddedOpFromInitialLoad(String uid, long gen, long seq, boolean phantom)
void	setBackLog(IReplicationGroupBacklog backlog)
void	setLastConfirmed(long confirmed)

Method Detail

initialize

void initialize()

getCurrentGenerationId

long getCurrentGenerationId()

isOverflow

boolean isOverflow()

beforeDirectPersistencyOp

void beforeDirectPersistencyOp(IReplicationOutContext context,
                               IEntryHolder entryHolder,
                               boolean phantom)

beforeDirectPersistencyOp

void beforeDirectPersistencyOp(IReplicationOutContext context,
                               List<String> uids,
                               Set<String> phantoms,
                               Map<String,IEntryHolder> entryHolderMap)

getEntriesForRecovery

Iterator<String> getEntriesForRecovery()

afterInsertingToRedolog

void afterInsertingToRedolog(IReplicationOutContext context,
                             long redoKey)

afterOperationPersisted

void afterOperationPersisted(IDirectPersistencyOpInfo e)

afterRecovery

void afterRecovery()

setBackLog

void setBackLog(IReplicationGroupBacklog backlog)

getBackLog

IReplicationGroupBacklog getBackLog()

getListHandler

DirectPersistencyListHandler getListHandler()

getLastConfirmed

long getLastConfirmed()

setLastConfirmed

void setLastConfirmed(long confirmed)

close

void close()

getSpaceEngine

SpaceEngine getSpaceEngine()

isEmbeddedListUsed

boolean isEmbeddedListUsed()

afterInitializedBlobStoreIO

void afterInitializedBlobStoreIO(IDirectPersistencyIoHandler ioHandler)

onEmbeddedListRecordTransferStart

void onEmbeddedListRecordTransferStart(IDirectPersistencyOpInfo o,
                                       boolean onlyIfNotExists)

onEmbeddedListRecordTransferEnd

void onEmbeddedListRecordTransferEnd(IDirectPersistencyOpInfo o)

onEmbeddedOpFromInitialLoad

void onEmbeddedOpFromInitialLoad(String uid,
                                 long gen,
                                 long seq,
                                 boolean phantom)

onEmbeddedOpFromInitialLoad

void onEmbeddedOpFromInitialLoad(List<String> uids,
                                 long gen,
                                 long seq,
                                 Set<String> phantoms)

getEmbeddedSyncHandler

EmbeddedSyncHandler getEmbeddedSyncHandler()