public interface OWriteAheadLog
Modifier and Type | Field and Description |
---|---|
static String |
MASTER_RECORD_EXTENSION |
static String |
WAL_SEGMENT_EXTENSION |
static final String MASTER_RECORD_EXTENSION
static final String WAL_SEGMENT_EXTENSION
OLogSequenceNumber logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) throws IOException
IOException
OLogSequenceNumber logFuzzyCheckPointEnd() throws IOException
IOException
OLogSequenceNumber logFullCheckpointStart() throws IOException
IOException
OLogSequenceNumber logFullCheckpointEnd() throws IOException
IOException
OLogSequenceNumber getLastCheckpoint()
OLogSequenceNumber begin()
OLogSequenceNumber begin(long segmentId) throws IOException
IOException
OLogSequenceNumber end()
void flush()
OLogSequenceNumber logAtomicOperationStartRecord(boolean isRollbackSupported, long unitId, byte[] metadata)
OLogSequenceNumber logAtomicOperationStartRecord(boolean isRollbackSupported, long unitId) throws IOException
IOException
OLogSequenceNumber logAtomicOperationEndRecord(long operationUnitId, boolean rollback, OLogSequenceNumber startLsn, Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) throws IOException
IOException
OLogSequenceNumber log(WriteableWALRecord record) throws IOException
IOException
void close() throws IOException
IOException
void close(boolean flush) throws IOException
IOException
void delete() throws IOException
IOException
List<WriteableWALRecord> read(OLogSequenceNumber lsn, int limit) throws IOException
IOException
List<WriteableWALRecord> next(OLogSequenceNumber lsn, int limit) throws IOException
IOException
OLogSequenceNumber getFlushedLsn()
boolean cutTill(OLogSequenceNumber lsn) throws IOException
addCutTillLimit(OLogSequenceNumber)
then "protected" part of WAL will be preserved for sure.lsn
- Maximum value of LSN till WAL will be cut.true
if some portion of WAL will be cut and false
if WAL left
untouched.IOException
boolean cutAllSegmentsSmallerThan(long segmentId) throws IOException
IOException
void addFullCheckpointListener(OCheckpointRequestListener listener)
void removeFullCheckpointListener(OCheckpointRequestListener listener)
void addLowDiskSpaceListener(OLowDiskSpaceListener listener)
void removeLowDiskSpaceListener(OLowDiskSpaceListener listener)
void moveLsnAfter(OLogSequenceNumber lsn) throws IOException
IOException
void addCutTillLimit(OLogSequenceNumber lsn)
lsn
- LSN after which cut of the WAL is not allowed.removeCutTillLimit(OLogSequenceNumber)
,
cutTill(OLogSequenceNumber)
void removeCutTillLimit(OLogSequenceNumber lsn)
lsn
- LSN after which cut of the WAL is not allowed.removeCutTillLimit(OLogSequenceNumber)
,
cutTill(OLogSequenceNumber)
File[] nonActiveSegments(long fromSegment)
long[] nonActiveSegments()
long activeSegment()
void addEventAt(OLogSequenceNumber lsn, Runnable event)
lsn
- the LSN to fire at.event
- the event to fire.boolean appendNewSegment()
true
if new segment is added, and false
otherwise.Copyright © 2009–2020 OrientDB. All rights reserved.