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, zeroOutclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfinish, sizeavailable, 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, startsWithaddAndGetInt, 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, zeroOutaddAtomicDouble, 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, unlockRWWriteLockaddress, bytes, bytes, file, free, objectSerializerappend, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillisasString, asString, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, readUnsignedByteOrThrow, selfTerminating, selfTerminating, skipTo, stepBackAndSkipToalignPositionAddr, byteOrder, capacity, checkEndOfBuffer, clear, flip, inputStream, isFinished, limit, limit, load, objectSerializer, outputStream, position, position, remaining, slice, slice, sliceAsByteBuffer, toDebugString, toDebugString, toHexString, toStringcharAt, chars, codePoints, length, subSequence, toStringpublic WrappedExcerptAppender(@NotNull
T appender)
public void startExcerpt()
ExcerptAppenderstartExcerpt in interface ExcerptAppenderpublic void addPaddedEntry()
ExcerptAppenderaddPaddedEntry in interface ExcerptAppenderpublic Chronicle chronicle()
chronicle in interface ExcerptCommonpublic boolean wasPadding()
ExcerptCommonwasPadding in interface ExcerptCommonpublic long index()
index in interface ExcerptCommonpublic long lastWrittenIndex()
lastWrittenIndex in interface ExcerptAppenderpublic void startExcerpt(long capacity)
ExcerptAppenderstartExcerpt in interface ExcerptAppendercapacity - to allow for, but not exceed.public void nextSynchronous(boolean nextSynchronous)
nextSynchronous in interface ExcerptAppendernextSynchronous - make the next write synchronous or not.public boolean nextSynchronous()
ExcerptAppendernextSynchronous in interface ExcerptAppenderpublic boolean read8bitText(@NotNull
StringBuilder stringBuilder)
throws StreamCorruptedException
read8bitText in interface net.openhft.lang.io.RandomDataInputread8bitText in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>StreamCorruptedExceptionpublic void write8bitText(CharSequence charSequence)
write8bitText in interface net.openhft.lang.io.RandomDataOutputwrite8bitText 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.RandomDataInputreadEnum in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>public long nextSetBit(long l)
nextSetBit in interface net.openhft.lang.io.RandomDataInputpublic void writeEnum(long l,
int i,
Object o)
writeEnum in interface net.openhft.lang.io.RandomDataOutputwriteEnum in class net.openhft.lang.io.WrappedBytes<T extends ExcerptAppender>Copyright © 2021. All rights reserved.