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

Interface IDirectPersistencyIoHandler

All Known Implementing Classes:

DirectPersistencyBlobStoreIO

public interface IDirectPersistencyIoHandler

The actual i/o of DirectPersistencyOpInfo objects

Since:

10.2

Author:

yechielf

Field Summary

Fields

Modifier and Type	Field and Description
static int	BULK_SIZE

Method Summary

Modifier and Type	Method and Description
IDirectPersistencyOpInfo	get(long generationId, long seq)
List<EmbeddedSyncTransferredInfo>	getAllTransferredInfo(EmbeddedSyncHandler h, Collection<Long> generations)
EmbeddedRelevantGenerationIdsInfo	getEmbeddedRelevantGenerationIdsInfo()
DirectPersistencyOverflowListSegment	getOverflowSegment(long generationId, long seq)
DirectPersistencySyncAdminInfo	getSyncAdminIfExists()
void	insert(DirectPersistencyOverflowListSegment segment)
void	insert(DirectPersistencySyncAdminInfo ai)
void	insert(EmbeddedRelevantGenerationIdsInfo ai)
void	insert(EmbeddedSyncTransferredInfo ai)
void	insert(IDirectPersistencyOpInfo entry)
Iterator<IDirectPersistencyOpInfo>	iterateOps(boolean currentGeneration)
Iterator<DirectPersistencyOverflowListSegment>	iterateOverflow(boolean currentGeneration)
void	remove(DirectPersistencyOverflowListSegment segment)
void	remove(EmbeddedSyncTransferredInfo ai)
void	remove(IDirectPersistencyOpInfo entry)
void	removeOpsBulk(List<IDirectPersistencyOpInfo> ops)
void	removeOvfBulk(List<DirectPersistencyOverflowListSegment> ovfs)
void	removePhantom(String uid, boolean checkExistance, long generationId, long seq)
void	update(DirectPersistencyOverflowListSegment segment)
void	update(DirectPersistencySyncAdminInfo ai)
void	update(EmbeddedRelevantGenerationIdsInfo ai)
void	update(EmbeddedSyncTransferredInfo ai)
void	update(IDirectPersistencyOpInfo entry)

Field Detail

BULK_SIZE

static final int BULK_SIZE

See Also:

Constant Field Values

Method Detail

insert

void insert(IDirectPersistencyOpInfo entry)

remove

void remove(IDirectPersistencyOpInfo entry)

update

void update(IDirectPersistencyOpInfo entry)

get

IDirectPersistencyOpInfo get(long generationId,
                             long seq)

iterateOps

Iterator<IDirectPersistencyOpInfo> iterateOps(boolean currentGeneration)

insert

void insert(DirectPersistencyOverflowListSegment segment)

remove

void remove(DirectPersistencyOverflowListSegment segment)

update

void update(DirectPersistencyOverflowListSegment segment)

getOverflowSegment

DirectPersistencyOverflowListSegment getOverflowSegment(long generationId,
                                                        long seq)

iterateOverflow

Iterator<DirectPersistencyOverflowListSegment> iterateOverflow(boolean currentGeneration)

removeOvfBulk

void removeOvfBulk(List<DirectPersistencyOverflowListSegment> ovfs)

removeOpsBulk

void removeOpsBulk(List<IDirectPersistencyOpInfo> ops)

insert

void insert(DirectPersistencySyncAdminInfo ai)

update

void update(DirectPersistencySyncAdminInfo ai)

getSyncAdminIfExists

DirectPersistencySyncAdminInfo getSyncAdminIfExists()

removePhantom

void removePhantom(String uid,
                   boolean checkExistance,
                   long generationId,
                   long seq)

insert

void insert(EmbeddedSyncTransferredInfo ai)

update

void update(EmbeddedSyncTransferredInfo ai)

remove

void remove(EmbeddedSyncTransferredInfo ai)

getAllTransferredInfo

List<EmbeddedSyncTransferredInfo> getAllTransferredInfo(EmbeddedSyncHandler h,
                                                        Collection<Long> generations)

getEmbeddedRelevantGenerationIdsInfo

EmbeddedRelevantGenerationIdsInfo getEmbeddedRelevantGenerationIdsInfo()

update

void update(EmbeddedRelevantGenerationIdsInfo ai)

insert

void insert(EmbeddedRelevantGenerationIdsInfo ai)