public static class WrappedExcerptAppenders.ByteBufferBytesAppender extends net.openhft.lang.io.ByteBufferBytes implements ExcerptAppender
Constructor and Description |
---|
ByteBufferBytesAppender(ByteBuffer buffer) |
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() |
boolean |
nextSynchronous()
The default value is ChronicleConfig.synchronousMode()
|
void |
nextSynchronous(boolean nextSynchronous) |
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.
|
static WrappedExcerptAppenders.ByteBufferBytesAppender |
withSize(int size) |
address, alignPositionAddr, buffer, byteOrder, bytes, bytes, capacity, checkEndOfBuffer, cleanup, compareAndSwapInt, compareAndSwapLong, limit, limit, load, position, position, read, readByte, readByte, readChar, readChar, readDouble, readDouble, readFloat, readFloat, readFully, readFully, readFully, readInt, readInt, readLong, readLong, readObject, readShort, readShort, readVolatileInt, readVolatileInt, readVolatileLong, readVolatileLong, remaining, slice, slice, subSequence, wrap, wrap, write, writeByte, writeChar, writeChar, writeDouble, writeDouble, writeFloat, writeFloat, writeInt, writeInt, writeLong, writeLong, writeObject, writeOrderedInt, writeOrderedInt, writeOrderedLong, writeOrderedLong, writeShort, writeShort, zeroOut, zeroOut, zeroOut
addAndGetInt, addAtomicDouble, addAtomicFloat, addAtomicInt, addAtomicLong, addByte, addDouble, addFloat, addInt, addLong, addShort, addUnsignedByte, addUnsignedInt, addUnsignedShort, append, append, append, append, append, append, append, append, append, append, append, append, appendDateMillis, appendDateTimeMillis, appendTimeMillis, asString, asString, available, busyLockInt, busyLockLong, charAt, clear, clearThreadAssociation, close, compare, compareAndSwapDouble, compareRest, file, findUTFLength, findUTFLength, findUTFLength, finish, flip, flush, free, getAndAdd, inputStream, isFinished, length, nextSetBit, objectSerializer, outputStream, parseBoolean, parseDecimal, parseDouble, parseEnum, parseLong, parseLong, parseUtf8, parseUtf8, read, read, read, read, read8bitText, readBoolean, readBoolean, readByteOrThrow, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readEnum, readEnum, readFully, readFully, readIncompleteLong, readInstance, readInt24, readInt24, readInt48, readInt48, readLine, readList, readMap, readMarshallable, readObject, readObject, readStopBit, readUnsignedByte, readUnsignedByte, readUnsignedByteOrThrow, readUnsignedInt, readUnsignedInt, readUnsignedShort, readUnsignedShort, readUTF, readUTF0, readUTF2, readUTF2, readUTFΔ, readUTFΔ, readUTFΔ, readVolatileDouble, readVolatileFloat, refCount, release, reserve, resetLockInt, resetLockLong, selfTerminating, selfTerminating, setObjectSerializer, size, skip, skipBytes, skipTo, sliceAsByteBuffer, startsWith, stepBackAndSkipTo, threadIdForLockInt, threadIdForLockLong, toDebugString, toDebugString, toHex, toHexString, toHexString, toString, toString, toString, tryLockInt, tryLockLong, tryLockNanosInt, tryLockNanosLong, tryRWReadLock, tryRWWriteLock, unlockInt, unlockLong, unlockRWReadLock, unlockRWWriteLock, write, write, write, write, write, write, write, write, write, write, write, write8bitText, writeBoolean, writeBoolean, writeByte, writeBytes, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeEnum, writeEnum, writeInstance, writeInt24, writeInt24, writeInt48, writeInt48, writeList, writeMap, writeMarshallable, writeObject, writeOrderedDouble, writeOrderedFloat, writeStopBit, writeUnsignedByte, writeUnsignedByte, writeUnsignedInt, writeUnsignedInt, writeUnsignedShort, writeUnsignedShort, writeUTF, writeUTF0, writeUTF1, writeUTFΔ, writeUTFΔ
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
finish, size
available, close, compare, nextSetBit, read, read, read, read, read, read8bitText, readBoolean, readBoolean, readByte, readByte, readChar, readChar, readCompactDouble, readCompactInt, readCompactLong, readCompactShort, readCompactUnsignedInt, readCompactUnsignedShort, readDouble, readDouble, readEnum, 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, write8bitText, writeBoolean, writeBoolean, writeByte, writeByte, writeBytes, writeChar, writeChar, writeChars, writeChars, writeCompactDouble, writeCompactInt, writeCompactLong, writeCompactShort, writeCompactUnsignedInt, writeCompactUnsignedShort, writeDouble, writeDouble, writeEnum, 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 ByteBufferBytesAppender(@NotNull ByteBuffer buffer)
public void startExcerpt()
ExcerptAppender
startExcerpt
in interface ExcerptAppender
public void startExcerpt(long capacity)
ExcerptAppender
startExcerpt
in interface ExcerptAppender
capacity
- to allow for, but not exceed.public boolean wasPadding()
ExcerptCommon
wasPadding
in interface ExcerptCommon
public long index()
index
in interface ExcerptCommon
public long lastWrittenIndex()
lastWrittenIndex
in interface ExcerptAppender
public Chronicle chronicle()
chronicle
in interface ExcerptCommon
public void addPaddedEntry()
ExcerptAppender
addPaddedEntry
in interface ExcerptAppender
public boolean nextSynchronous()
ExcerptAppender
nextSynchronous
in interface ExcerptAppender
public void nextSynchronous(boolean nextSynchronous)
nextSynchronous
in interface ExcerptAppender
nextSynchronous
- make the next write synchronous or not.public static WrappedExcerptAppenders.ByteBufferBytesAppender withSize(int size)
Copyright © 2017. All rights reserved.