org.corfudb.infrastructure.log

Class StreamLogDataStore

java.lang.Object

org.corfudb.infrastructure.log.StreamLogDataStore

public class StreamLogDataStore
extends Object

Data access layer for StreamLog. Keeps stream log related meta information: startingAddress and tailSegment. Provides access to the stream log related meta information.

Field Summary

Fields

Modifier and Type	Field and Description
static String	STARTING_ADDRESS_KEY
static String	STARTING_ADDRESS_PREFIX
static IDataStore.KvRecord<Long>	STARTING_ADDRESS_RECORD
static String	TAIL_SEGMENT_KEY
static IDataStore.KvRecord<Long>	TAIL_SEGMENT_RECORD

Constructor Summary

Constructors

Constructor and Description
StreamLogDataStore()

Method Summary

Modifier and Type	Method and Description
long	getStartingAddress() Returns the dataStore starting address.
long	getTailSegment() Return current cached tail segment or get the segment from the data store if not initialized
void	resetStartingAddress() Reset starting address
void	resetTailSegment() Reset tail segment
void	updateStartingAddress(long newStartingAddress) Update current starting address in the data store
void	updateTailSegment(long newTailSegment) Update current tail segment in the data store

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TAIL_SEGMENT_KEY

public static final String TAIL_SEGMENT_KEY

See Also:

Constant Field Values

STARTING_ADDRESS_PREFIX

public static final String STARTING_ADDRESS_PREFIX

See Also:

Constant Field Values

STARTING_ADDRESS_KEY

public static final String STARTING_ADDRESS_KEY

See Also:

Constant Field Values

TAIL_SEGMENT_RECORD

public static final IDataStore.KvRecord<Long> TAIL_SEGMENT_RECORD

STARTING_ADDRESS_RECORD

public static final IDataStore.KvRecord<Long> STARTING_ADDRESS_RECORD

Constructor Detail

StreamLogDataStore

public StreamLogDataStore()

Method Detail

getTailSegment

public long getTailSegment()

Return current cached tail segment or get the segment from the data store if not initialized

Returns:

tail segment

updateTailSegment

public void updateTailSegment(long newTailSegment)

Update current tail segment in the data store

Parameters:

newTailSegment - updated tail segment

getStartingAddress

public long getStartingAddress()

Returns the dataStore starting address.

Returns:

the starting address

updateStartingAddress

public void updateStartingAddress(long newStartingAddress)

Update current starting address in the data store

Parameters:

newStartingAddress - updated starting address

resetTailSegment

public void resetTailSegment()

Reset tail segment

resetStartingAddress

public void resetStartingAddress()

Reset starting address