public class WrappedExcerptAppender<T extends ExcerptAppender> extends net.openhft.lang.io.WrappedBytes<T> implements ExcerptAppender
Constructor and Description |
---|
WrappedExcerptAppender(T appender) |
Modifier and Type | Method and Description |
---|---|
void |
addPaddedEntry()
Add a padded entry to keep the index in sync with a master source.
|
Chronicle |
chronicle() |
long |
index() |
long |
lastWrittenIndex() |
long |
nextSetBit(long l) |
boolean |
nextSynchronous()
The default value is ChronicleConfig.synchronousMode()
|
void |
nextSynchronous(boolean nextSynchronous) |
boolean |
read8bitText(StringBuilder stringBuilder) |
<E> E |
readEnum(long l,
int i,
Class<E> aClass) |
void |
startExcerpt()
Start an excerpt with the default message capacity of 128K (can be configured)
This can waste up to 0.1% of disk space, unless you have sparse file support like Linux,
when you will waste far less.
|
void |
startExcerpt(long capacity)
Ensure there is enough capacity for a new entry of up to the size given.
|
boolean |
wasPadding()
Not for public use.
|
void |
write8bitText(CharSequence charSequence) |
void |
writeEnum(long l,
int i,
Object o) |
addAndGetInt, addAtomicDouble, addAtomicFloat, addAtomicInt, addAtomicLong, addByte, addDouble, addFloat, addInt, addLong, address, addShort, addUnsignedByte, addUnsignedInt, addUnsignedShort, alignPositionAddr, append, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillis, asString, asString, available, busyLockInt, busyLockLong, byteOrder, bytes, bytes, capacity, charAt, checkEndOfBuffer, clear, clearThreadAssociation, close, compare, compareAndSwapDouble, compareAndSwapInt, compareAndSwapLong, file, finish, flip, flush, free, getAndAdd, inputStream, isFinished, length, limit, limit, load, objectSerializer, outputStream, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, position, position, read, read, read, read, read, readBoolean, readBoolean, readByte, readByte, readChar, readChar, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readDouble, readDouble, readEnum, readFloat, readFloat, readFully, readFully, readFully, readFully, readFully, readIncompleteLong, readInstance, readInt, readInt, readInt24, readInt24, readInt48, readInt48, readLine, readList, readLong, readLong, readMap, readMarshallable, readObject, readObject, readObject, readShort, readShort, readStopBit, readUnsignedByte, readUnsignedByte, readUnsignedByteOrThrow, readUnsignedInt, readUnsignedInt, readUnsignedShort, readUnsignedShort, readUTF, readUTFΔ, readUTFΔ, readUTFΔ, readVolatileDouble, readVolatileFloat, readVolatileInt, readVolatileInt, readVolatileLong, readVolatileLong, refCount, release, remaining, reserve, resetLockInt, resetLockLong, selfTerminating, selfTerminating, size, skip, skipBytes, skipTo, slice, slice, sliceAsByteBuffer, startsWith, stepBackAndSkipTo, subSequence, threadIdForLockInt, threadIdForLockLong, toDebugString, toDebugString, toHexString, toString, tryLockInt, tryLockLong, tryLockNanosInt, tryLockNanosLong, tryRWReadLock, tryRWWriteLock, unlockInt, unlockLong, unlockRWReadLock, unlockRWWriteLock, write, write, write, write, write, write, write, write, write, write, write, write, writeBoolean, writeBoolean, writeByte, writeByte, writeBytes, writeChar, writeChar, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeDouble, writeDouble, writeEnum, writeFloat, writeFloat, writeInstance, writeInt, writeInt, writeInt24, writeInt24, writeInt48, writeInt48, writeList, writeLong, writeLong, writeMap, writeMarshallable, writeObject, writeObject, writeOrderedDouble, writeOrderedFloat, writeOrderedInt, writeOrderedInt, writeOrderedLong, writeOrderedLong, writeShort, writeShort, writeStopBit, writeUnsignedByte, writeUnsignedByte, writeUnsignedInt, writeUnsignedInt, writeUnsignedShort, writeUnsignedShort, writeUTF, writeUTFΔ, writeUTFΔ, zeroOut, zeroOut, zeroOut
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
finish, size
available, close, compare, read, read, read, read, read, readBoolean, readBoolean, readByte, readByte, readChar, readChar, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readDouble, readDouble, readEnum, readFloat, readFloat, readFully, readFully, readFully, readFully, readFully, readIncompleteLong, readInstance, readInt, readInt, readInt24, readInt24, readInt48, readInt48, readLine, readList, readLong, readLong, readMap, readObject, readObject, readObject, readShort, readShort, readStopBit, readUnsignedByte, readUnsignedByte, readUnsignedInt, readUnsignedInt, readUnsignedShort, readUnsignedShort, readUTF, readUTFΔ, readUTFΔ, readUTFΔ, readVolatileDouble, readVolatileFloat, readVolatileInt, readVolatileInt, readVolatileLong, readVolatileLong, skip, skipBytes, startsWith
addAndGetInt, close, compareAndSwapDouble, compareAndSwapInt, compareAndSwapLong, flush, getAndAdd, write, write, write, write, write, write, write, write, write, write, write, write, writeBoolean, writeBoolean, writeByte, writeByte, writeBytes, writeChar, writeChar, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeDouble, writeDouble, writeEnum, writeFloat, writeFloat, writeInstance, writeInt, writeInt, writeInt24, writeInt24, writeInt48, writeInt48, writeList, writeLong, writeLong, writeMap, writeObject, writeObject, writeOrderedDouble, writeOrderedFloat, writeOrderedInt, writeOrderedInt, writeOrderedLong, writeOrderedLong, writeShort, writeShort, writeStopBit, writeUnsignedByte, writeUnsignedByte, writeUnsignedInt, writeUnsignedInt, writeUnsignedShort, writeUnsignedShort, writeUTF, writeUTFΔ, writeUTFΔ, zeroOut, zeroOut, zeroOut
addAtomicDouble, addAtomicFloat, addAtomicInt, addAtomicLong, addByte, addDouble, addFloat, addInt, addLong, addShort, addUnsignedByte, addUnsignedInt, addUnsignedShort, busyLockInt, busyLockLong, resetLockInt, resetLockLong, threadIdForLockInt, threadIdForLockLong, tryLockInt, tryLockLong, tryLockNanosInt, tryLockNanosLong, tryRWReadLock, tryRWWriteLock, unlockInt, unlockLong, unlockRWReadLock, unlockRWWriteLock
address, bytes, bytes, file, free, objectSerializer
append, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillis
asString, asString, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, readUnsignedByteOrThrow, selfTerminating, selfTerminating, skipTo, stepBackAndSkipTo
alignPositionAddr, byteOrder, capacity, checkEndOfBuffer, clear, flip, inputStream, isFinished, limit, limit, load, objectSerializer, outputStream, position, position, remaining, slice, slice, sliceAsByteBuffer, toDebugString, toDebugString, toHexString, toString
charAt, chars, codePoints, length, subSequence, toString
public WrappedExcerptAppender(@NotNull T appender)
public void startExcerpt()
ExcerptAppender
startExcerpt
in interface ExcerptAppender
public void addPaddedEntry()
ExcerptAppender
addPaddedEntry
in interface ExcerptAppender
public Chronicle chronicle()
chronicle
in interface ExcerptCommon
public boolean wasPadding()
ExcerptCommon
wasPadding
in interface ExcerptCommon
public long index()
index
in interface ExcerptCommon
public long lastWrittenIndex()
lastWrittenIndex
in interface ExcerptAppender
public void startExcerpt(long capacity)
ExcerptAppender
startExcerpt
in interface ExcerptAppender
capacity
- to allow for, but not exceed.public void nextSynchronous(boolean nextSynchronous)
nextSynchronous
in interface ExcerptAppender
nextSynchronous
- make the next write synchronous or not.public boolean nextSynchronous()
ExcerptAppender
nextSynchronous
in interface ExcerptAppender
public boolean read8bitText(@NotNull StringBuilder stringBuilder) throws StreamCorruptedException
read8bitText
in interface net.openhft.lang.io.RandomDataInput
read8bitText
in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>
StreamCorruptedException
public void write8bitText(CharSequence charSequence)
write8bitText
in interface net.openhft.lang.io.RandomDataOutput
write8bitText
in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>
public <E> E readEnum(long l, int i, Class<E> aClass)
readEnum
in interface net.openhft.lang.io.RandomDataInput
readEnum
in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>
public long nextSetBit(long l)
nextSetBit
in interface net.openhft.lang.io.RandomDataInput
public void writeEnum(long l, int i, Object o)
writeEnum
in interface net.openhft.lang.io.RandomDataOutput
writeEnum
in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>
Copyright © 2017. All rights reserved.