nl.renarj.jasdb.storage.transactional

Class FSWriter

java.lang.Object

nl.renarj.jasdb.storage.transactional.FSWriter

All Implemented Interfaces:

Writer

public class FSWriter
extends Object
implements Writer

Author:

Renze de Vries

Constructor Summary

Constructors

Constructor and Description
FSWriter(File recordLocation)

Method Summary

Modifier and Type	Method and Description
void	closeWriter()
long	getDiskSize()
long	getSize()
boolean	isOpen()
void	openWriter()
RecordIteratorImpl	readAllRecords()
RecordIteratorImpl	readAllRecords(int limit)
RecordResultImpl	readRecord(java.util.function.Supplier<Optional<Long>> recordPointerSupplier)
void	removeRecord(java.util.function.Supplier<Optional<Long>> recordPointerSupplier, java.util.function.Consumer<Long> postRemoveAction)
Long	updateRecord(String recordContents, java.util.function.Supplier<Optional<Long>> recordPointerSupplier, java.util.function.BiConsumer<Long,Long> postUpdateAction)
Long	writeRecord(String recordContents, java.util.function.Consumer<Long> postAction)

Methods inherited from class java.lang.Object

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

Constructor Detail

FSWriter

public FSWriter(File recordLocation)

Method Detail

openWriter

public void openWriter()
                throws DatastoreException

Specified by:

openWriter in interface Writer

Throws:

DatastoreException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Writer

closeWriter

public void closeWriter()
                 throws JasDBStorageException

Specified by:

closeWriter in interface Writer

Throws:

JasDBStorageException

getDiskSize

public long getDiskSize()
                 throws JasDBStorageException

Specified by:

getDiskSize in interface Writer

Throws:

JasDBStorageException

getSize

public long getSize()

Specified by:

getSize in interface Writer

readAllRecords

public RecordIteratorImpl readAllRecords()
                                  throws DatastoreException

Specified by:

readAllRecords in interface Writer

Throws:

DatastoreException

readAllRecords

public RecordIteratorImpl readAllRecords(int limit)
                                  throws DatastoreException

Specified by:

readAllRecords in interface Writer

Throws:

DatastoreException

readRecord

public RecordResultImpl readRecord(java.util.function.Supplier<Optional<Long>> recordPointerSupplier)
                            throws DatastoreException

Specified by:

readRecord in interface Writer

Throws:

DatastoreException

writeRecord

public Long writeRecord(String recordContents,
                        java.util.function.Consumer<Long> postAction)
                 throws DatastoreException

Specified by:

writeRecord in interface Writer

Throws:

DatastoreException

removeRecord

public void removeRecord(java.util.function.Supplier<Optional<Long>> recordPointerSupplier,
                         java.util.function.Consumer<Long> postRemoveAction)
                  throws DatastoreException

Specified by:

removeRecord in interface Writer

Throws:

DatastoreException

updateRecord

public Long updateRecord(String recordContents,
                         java.util.function.Supplier<Optional<Long>> recordPointerSupplier,
                         java.util.function.BiConsumer<Long,Long> postUpdateAction)
                  throws DatastoreException

Specified by:

updateRecord in interface Writer

Throws:

DatastoreException