Uses of Interface
com.tangosol.io.ReadBuffer
Package
Description
Low-level utilities for Coherence gRPC server and client implementation.
Defines the typical runtime configuration builders for the Coherence
configuration object model.
Contains classes providing cache persistence of serialized objects.
Contains classes related to J2SE 1.4 NIO functionality.
Contains classes related to POF serialization and deserialization.
Contains classes related to POF stream navigation and manipulation.
Contains classes and helpers for implementing various types of persistence.
Contains various generic utilities.
-
Uses of ReadBuffer in com.oracle.coherence.grpc
Modifier and TypeMethodDescriptionstatic ReadBuffer
BinaryHelper.toReadBuffer
(com.google.protobuf.ByteString bytes) Convert aByteString
to aReadBuffer
. -
Uses of ReadBuffer in com.tangosol.coherence.config.builder
Modifier and TypeFieldDescriptionprotected ParameterizedBuilder
<com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>> PersistenceEnvironmentParamBuilder.m_bldr
AParameterizedBuilder
that creates aPersistenceEnvironment
.Modifier and TypeMethodDescriptioncom.oracle.coherence.persistence.PersistenceEnvironment
<ReadBuffer> PersistenceEnvironmentParamBuilder.realize
(ParameterResolver resolver, ClassLoader loader, ParameterList listParameters) protected com.oracle.coherence.persistence.PersistenceEnvironment
<ReadBuffer> PersistenceEnvironmentParamBuilder.wrap
(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) Wrap aPersistenceEnvironment
with a SafePersistenceEnvironment.Modifier and TypeMethodDescriptionvoid
PersistenceEnvironmentParamBuilder.setCustomEnvironment
(ParameterizedBuilder<com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>> bldrPersistence) Set abuilder
to be used instantiate the appropriatePersistenceEnvironment
.protected com.oracle.coherence.persistence.PersistenceEnvironment
<ReadBuffer> PersistenceEnvironmentParamBuilder.wrap
(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) Wrap aPersistenceEnvironment
with a SafePersistenceEnvironment. -
Uses of ReadBuffer in com.tangosol.io
Modifier and TypeClassDescriptionclass
The AbstractByteArrayReadBuffer abstract class is intended to serve as a base class for the following: the pre-existing Binary class a new byte[] based class that does not attempt to add the immutability aspect provided by the Binary class a new ByteBuffer based class that will work with Java NIOclass
Abstract base implementation of the ReadBuffer interface.class
A ReadBuffer on top of a byte array.class
The MultiBufferReadBuffer is a ReadBuffer implementation that presents a view across any number of underlying ReadBuffer objects, as if they were appended end-to-end into a single ReadBuffer.Modifier and TypeMethodDescriptionBinaryDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DecoratedBinaryDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DecorationOnlyDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.protected ReadBuffer
BinaryDeltaCompressor.createDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Actually create a delta in the binary delta format.BinaryDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DecoratedBinaryDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DecorationOnlyDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.AbstractReadBuffer.AbstractBufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.protected ReadBuffer
MultiBufferReadBuffer.getBuffer
(int iBuffer) Obtain the specified buffer.ReadBuffer.BufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.WrapperBufferInput.getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.AbstractReadBuffer.getReadBuffer
(int of, int cb) Obtain a ReadBuffer for a portion of this ReadBuffer.AbstractWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.DelegatingWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.MultiBufferWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ReadBuffer.getReadBuffer
(int of, int cb) Obtain a ReadBuffer for a portion of this ReadBuffer.WriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.abstract ReadBuffer
AbstractWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.final ReadBuffer
ByteArrayWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.DelegatingWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.MultiBufferWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.WriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.protected abstract ReadBuffer
AbstractReadBuffer.instantiateReadBuffer
(int of, int cb) Factory method: Instantiate a ReadBuffer for a portion of this ReadBuffer.protected final ReadBuffer
ByteArrayReadBuffer.instantiateReadBuffer
(int of, int cb) Factory method: Instantiate a ReadBuffer for a portion of this ReadBuffer.protected ReadBuffer
MultiBufferReadBuffer.instantiateReadBuffer
(int of, int cb) Factory method: Instantiate a ReadBuffer for a portion of this ReadBuffer.AbstractReadBuffer.AbstractBufferInput.readBuffer
(int cb) Readcb
bytes and return them as a ReadBuffer object.MultiBufferReadBuffer.MultiBufferInput.readBuffer
(int cb) Readcb
bytes and return them as a ReadBuffer object.ReadBuffer.BufferInput.readBuffer
(int cb) Readcb
bytes and return them as a ReadBuffer object.WrapperBufferInput.readBuffer
(int cb) Readcb
bytes and return them as a ReadBuffer object.protected ReadBuffer
MultiBufferReadBuffer.releaseBuffer
(int iBuffer) Release the specified buffer.Modifier and TypeMethodDescriptionBinaryDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DecoratedBinaryDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DecorationOnlyDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.DeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.protected ReadBuffer
BinaryDeltaCompressor.createDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Actually create a delta in the binary delta format.BinaryDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DecoratedBinaryDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DecorationOnlyDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.DeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.void
AbstractWriteBuffer.write
(int ofDest, ReadBuffer bufSrc) Store the contents of the specified ReadBuffer at the specified offset within this buffer.void
AbstractWriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer.final void
ByteArrayWriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer.void
DelegatingWriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer.void
MultiBufferWriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer.void
WriteBuffer.write
(int ofDest, ReadBuffer bufSrc) Store the contents of the specified ReadBuffer at the specified offset within this buffer.void
WriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer.void
AbstractWriteBuffer.AbstractBufferOutput.writeBuffer
(ReadBuffer buf) Write all the bytes from the passed ReadBuffer object.void
AbstractWriteBuffer.AbstractBufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) Writecb
bytes from the passed ReadBuffer object starting at offsetof
within the passed ReadBuffer.void
DelegatingWriteBuffer.DelegatingBufferOutput.writeBuffer
(ReadBuffer buf) Write all the bytes from the passed ReadBuffer object.void
DelegatingWriteBuffer.DelegatingBufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) Writecb
bytes from the passed ReadBuffer object starting at offsetof
within the passed ReadBuffer.void
MultiBufferWriteBuffer.MultiBufferOutput.writeBuffer
(ReadBuffer buf) Write all the bytes from the passed ReadBuffer object.void
MultiBufferWriteBuffer.MultiBufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) Writecb
bytes from the passed ReadBuffer object starting at offsetof
within the passed ReadBuffer.void
SizeEstimatingBufferOutput.writeBuffer
(ReadBuffer buf) void
SizeEstimatingBufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) void
WrapperBufferOutput.writeBuffer
(ReadBuffer buf) Write all the bytes from the passed ReadBuffer object.void
WrapperBufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) Writecb
bytes from the passed ReadBuffer object starting at offsetof
within the passed ReadBuffer.void
WriteBuffer.BufferOutput.writeBuffer
(ReadBuffer buf) Write all the bytes from the passed ReadBuffer object.void
WriteBuffer.BufferOutput.writeBuffer
(ReadBuffer buf, int of, int cb) Writecb
bytes from the passed ReadBuffer object starting at offsetof
within the passed ReadBuffer.ModifierConstructorDescriptionMultiBufferReadBuffer
(ReadBuffer[] abuf) Construct a MultiBufferReadBuffer from an array of underlying ReadBuffer objects. -
Uses of ReadBuffer in com.tangosol.io.nio
Modifier and TypeClassDescriptionclass
A ReadBuffer implementation on top of a Java NIO ByteBuffer.Modifier and TypeMethodDescriptionByteBufferWriteBuffer.getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ByteBufferWriteBuffer.getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.protected ReadBuffer
ByteBufferReadBuffer.instantiateReadBuffer
(int of, int cb) Factory method: Instantiate a ReadBuffer for a portion of this ReadBuffer.Modifier and TypeMethodDescriptionvoid
ByteBufferWriteBuffer.write
(int ofDest, ReadBuffer bufSrc, int ofSrc, int cbSrc) Store the specified portion of the contents of the specified ReadBuffer at the specified offset within this buffer. -
Uses of ReadBuffer in com.tangosol.io.pof
Modifier and TypeMethodDescriptionPofDeltaCompressor.createDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Actually create a delta in the binary delta format.Modifier and TypeMethodDescriptionPofDeltaCompressor.createDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Actually create a delta in the binary delta format. -
Uses of ReadBuffer in com.tangosol.io.pof.reflect
Modifier and TypeMethodDescriptionAbstractPofValue.getChanges()
Return a buffer containing changes made to this PofValue in the format defined by theBinaryDeltaCompressor
.PofValue.getChanges()
Return a buffer containing changes made to this PofValue in the format defined by theBinaryDeltaCompressor
.protected ReadBuffer
AbstractPofValue.getOriginalBuffer()
Get the original buffer the changes should be applied to.AbstractPofValue.getSerializedValue()
Return this value's serialized form.PofSparseArray.NilPofValue.getSerializedValue()
Return this value's serialized form.protected ReadBuffer
AbstractPofValue.getValueBuffer()
Get the raw value buffer.Modifier and TypeMethodDescriptionprotected PofValue
ComplexPofValue.extractChild
(ReadBuffer buf, int of, int cb) Extract child PofValue from a buffer.protected static PofValue
PofValueParser.instantiatePofValue
(PofValue valueParent, int nType, ReadBuffer bufValue, PofContext ctx, int of, ReadBuffer.BufferInput in) Creates a PofValue instance.static PofValue
PofValueParser.parse
(ReadBuffer buf, PofContext ctx) Parses POF-encoded binary and returns an instance of aPofValue
wrapper for it.protected static PofValue
PofValueParser.parseUniformValue
(PofValue valueParent, int nType, ReadBuffer bufValue, PofContext ctx, int of) Parses a uniform POF-encoded binary and returns an instance of aPofValue
wrapping the binary.protected static PofValue
PofValueParser.parseValue
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of) Parse a POF-encoded binary and return an instance of aPofValue
wrapping the binary.protected void
AbstractPofValue.setDecorations
(long nDecoMask, ReadBuffer bufDeco) Set the decoration mask and decorations for the PofValue.protected void
AbstractPofValue.setOriginalBuffer
(ReadBuffer bufValue) Set the original buffer the changes should be applied to.ModifierConstructorDescriptionAbstractPofValue
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType) Construct a PofValue instance wrapping the supplied buffer.ComplexPofValue
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren) Construct a PofValue instance wrapping the supplied buffer.PofArray
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int cElements) Construct a PofArray instance wrapping the supplied buffer.PofCollection
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int cElements) Construct a PofCollection instance wrapping the supplied buffer.PofSparseArray
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren) Construct a PofSparseArray instance wrapping the supplied buffer.PofUniformArray
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int cElements, int nElementType) Construct a PofUniformArray instance wrapping the supplied buffer.PofUniformCollection
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int cElements, int nElementType) Construct a PofUniformCollection instance wrapping the supplied buffer.PofUniformSparseArray
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int nElementType) Construct a PofUniformSparseArray instance wrapping the supplied buffer.PofUserType
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType, int ofChildren, int nVersion) Construct a PofUserType instance wrapping the supplied buffer.SimplePofValue
(PofValue valueParent, ReadBuffer bufValue, PofContext ctx, int of, int nType) Construct a SimplePofValue instance wrapping the supplied buffer. -
Uses of ReadBuffer in com.tangosol.persistence
Modifier and TypeFieldDescriptionprotected final ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.Operation.f_bufKey
The target key of the operation.protected final ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.StoreOperation.f_bufValue
The value to store.static final ReadBuffer
CachePersistenceHelper.LAST_ENTRY
A constant that suggests to a PersistentStore implementation to load the last entry.Modifier and TypeFieldDescriptionprotected final com.oracle.coherence.persistence.PersistentStore
<ReadBuffer> AbstractPersistenceManager.AbstractPersistentStore.OpenTask.f_storeFrom
ThePersistentStore
to open with.static final Converter
<Long, ReadBuffer> CachePersistenceHelper.LONG_CONVERTER_DOWN
A converter that converts from a Long to a ReadBuffer.static final Converter
<ReadBuffer, Long> CachePersistenceHelper.LONG_CONVERTER_UP
A converter that converts from a ReadBuffer to a Long.Modifier and TypeMethodDescriptionprotected static ReadBuffer
CachePersistenceHelper.createIndexRegistrationKey
(long lCacheId, Binary binExtractor) Create a key representing an index registration.protected static ReadBuffer
CachePersistenceHelper.createListenerRegistrationKey
(long lMemberId, long lCacheId, Binary binKey) Create a key representing a cache listener registration.protected static ReadBuffer
CachePersistenceHelper.createLockRegistrationKey
(long lHolderId, long lHolderThreadId, long lCacheId, Binary binKey) Create a key representing a cache entry lock.protected static ReadBuffer
CachePersistenceHelper.createTriggerRegistrationKey
(long lCacheId, Binary binTrigger) Create a key representing an trigger registration.AbstractPersistenceManager.AbstractPersistentStore.load
(long lExtentId, ReadBuffer bufKey) Return the value associated with the specified key, or null if the key does not have an associated value in the underlying store.protected abstract ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.loadInternal
(long lExtentId, ReadBuffer bufKey) Load and return the value associated with the specified key from the underlying persistent storage.Modifier and TypeMethodDescriptioncom.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.createSnapshot
(String sSnapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager) Create a PersistenceManager used to manage the snapshot with the specified identifier.protected com.oracle.coherence.persistence.PersistenceEnvironment
<ReadBuffer> AbstractSnapshotArchiver.createTempEnvironment
(File fileBaseDir, String sStorageFormat) Create a temporary PersistenceEnvironment to write archived snapshots to in the given format.static com.oracle.coherence.persistence.PersistentStore.Visitor
<ReadBuffer> CachePersistenceHelper.instantiateEventsVisitor
(long lExtentId, Filter filter, long lVersion, Map<Long, MapEvent> mapEvents, Converter<Long, ReadBuffer> convKeyDown, Converter<ReadBuffer, Long> convKeyUp, Converter<Object, ReadBuffer> convDown, Converter<ReadBuffer, Object> convUp) Create aPersistentStore.Visitor
that can read a PersistentStore and populate the providedmapEvents
with events that are larger than the provided version (inclusive) and match the givenFilter
.static com.oracle.coherence.persistence.PersistentStore.Visitor
<ReadBuffer> CachePersistenceHelper.instantiateEventsVisitor
(long lExtentId, Set setKeys, long lVersion, Map<Long, MapEvent> mapEvents, Converter<Long, ReadBuffer> convKeyDown, Converter<ReadBuffer, Long> convKeyUp, Converter<Object, ReadBuffer> convDown, Converter<ReadBuffer, Object> convUp) Create aPersistentStore.Visitor
that can read a PersistentStore and populate the providedmapEvents
with events that are larger than the provided version (inclusive) and within the given set of keys.static com.oracle.coherence.persistence.PersistentStore.Visitor
<ReadBuffer> CachePersistenceHelper.instantiatePersistenceVisitor
(CachePersistenceHelper.Visitor visitorCache) Instantiate avisitor
for the PersistentStore backed by thecom.oracle.coherence.persistence.PersistentStore
<ReadBuffer> AbstractPersistenceManager.open
(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom) Open or create aPersistentStore
associated with the specified identifier and based on the providedstore
.com.oracle.coherence.persistence.PersistentStore
<ReadBuffer> AbstractPersistenceManager.open
(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector) Open or create aPersistentStore
associated with the specified identifier and based on the providedstore
.com.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.openActive()
Open and return the singleton active PersistenceManager.com.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.openBackup()
Open and return a singleton PersistenceManager to store backup data.com.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.openEvents()
Open and return a singleton PersistenceManager to store MapEvents.com.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.openSnapshot
(String sSnapshot) Open a PersistenceManager used to access the snapshot with the specified identifier.Modifier and TypeMethodDescriptionvoid
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.erase
(long lExtentId, ReadBuffer bufKey) Queue an erase operation.void
AbstractPersistenceManager.AbstractPersistentStore.erase
(long lExtentId, ReadBuffer bufKey, Object oToken) Remove the specified key from the underlying store if present.protected abstract void
AbstractPersistenceManager.AbstractPersistentStore.eraseInternal
(long lExtentId, ReadBuffer bufKey, Object oToken) Remove the specified key from the underlying persistent storage if present.AbstractPersistenceManager.AbstractPersistentStore.load
(long lExtentId, ReadBuffer bufKey) Return the value associated with the specified key, or null if the key does not have an associated value in the underlying store.protected abstract ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.loadInternal
(long lExtentId, ReadBuffer bufKey) Load and return the value associated with the specified key from the underlying persistent storage.void
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.store
(long lExtentId, ReadBuffer bufKey, ReadBuffer bufValue) Queue a store operation.void
AbstractPersistenceManager.AbstractPersistentStore.store
(long lExtentId, ReadBuffer bufKey, ReadBuffer bufValue, Object oToken) Store the specified value under the specific key in the underlying store.protected abstract void
AbstractPersistenceManager.AbstractPersistentStore.storeInternal
(long lExtentId, ReadBuffer bufKey, ReadBuffer bufValue, Object oToken) Store the specified value under the specific key in the underlying persistent storage.Modifier and TypeMethodDescriptionvoid
AbstractSnapshotArchiver.archive
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) void
SnapshotArchiver.archive
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) Archive the specified snapshot.protected abstract void
AbstractSnapshotArchiver.archiveInternal
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) Internal implementation to Archive the specified snapshot.protected void
DirectorySnapshotArchiver.archiveInternal
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) protected void
AbstractPersistenceManager.AbstractPersistentStore.copyAndOpenInternal
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom) Copy the provided store to ensure both the contents are available in the new store and it is open thus ready to receive requests.com.oracle.coherence.persistence.PersistenceManager
<ReadBuffer> AbstractPersistenceEnvironment.createSnapshot
(String sSnapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager) Create a PersistenceManager used to manage the snapshot with the specified identifier.protected abstract AbstractPersistenceManager
AbstractPersistenceEnvironment.createSnapshotInternal
(File fileSnapshot, String sSnapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> manager) Create a snapshot with the specified identifier.CachePersistenceHelper.getCacheNames
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Return the cache names that have beenstored
in the specified store.static int
CachePersistenceHelper.getPartitionCount
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Return the partition count that has been stored in the specified store.static int
CachePersistenceHelper.getPersistenceVersion
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Return the persistence version the provided store was written with.static String
CachePersistenceHelper.getServiceVersion
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Deprecated.protected boolean
AbstractSnapshotArchiver.hasLocalSnapshot
(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env, String sSnapshot) Return true if the specified snapshot exists for the PersistenceEnvironment.static com.oracle.coherence.persistence.PersistentStore.Visitor
<ReadBuffer> CachePersistenceHelper.instantiateEventsVisitor
(long lExtentId, Filter filter, long lVersion, Map<Long, MapEvent> mapEvents, Converter<Long, ReadBuffer> convKeyDown, Converter<ReadBuffer, Long> convKeyUp, Converter<Object, ReadBuffer> convDown, Converter<ReadBuffer, Object> convUp) Create aPersistentStore.Visitor
that can read a PersistentStore and populate the providedmapEvents
with events that are larger than the provided version (inclusive) and match the givenFilter
.static com.oracle.coherence.persistence.PersistentStore.Visitor
<ReadBuffer> CachePersistenceHelper.instantiateEventsVisitor
(long lExtentId, Set setKeys, long lVersion, Map<Long, MapEvent> mapEvents, Converter<Long, ReadBuffer> convKeyDown, Converter<ReadBuffer, Long> convKeyUp, Converter<Object, ReadBuffer> convDown, Converter<ReadBuffer, Object> convUp) Create aPersistentStore.Visitor
that can read a PersistentStore and populate the providedmapEvents
with events that are larger than the provided version (inclusive) and within the given set of keys.static boolean
CachePersistenceHelper.isSealed
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Return true if the specified store has been sealed.void
AbstractPersistenceManager.AbstractPersistentStore.iterate
(com.oracle.coherence.persistence.PersistentStore.Visitor<ReadBuffer> visitor) Iterate the key-value pairs in the persistent store, applying the specified visitor to each key-value pair.protected abstract void
AbstractPersistenceManager.AbstractPersistentStore.iterateInternal
(com.oracle.coherence.persistence.PersistentStore.Visitor<ReadBuffer> visitor) Iterate the key-value pairs in the underlying persistent storage, applying the specified visitor to each key-value pair.protected boolean
AbstractPersistenceManager.AbstractPersistentStore.open
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom) Open this persistent store.com.oracle.coherence.persistence.PersistentStore
<ReadBuffer> AbstractPersistenceManager.open
(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom) Open or create aPersistentStore
associated with the specified identifier and based on the providedstore
.com.oracle.coherence.persistence.PersistentStore
<ReadBuffer> AbstractPersistenceManager.open
(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector) Open or create aPersistentStore
associated with the specified identifier and based on the providedstore
.static com.tangosol.net.internal.QuorumInfo
CachePersistenceHelper.readQuorum
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Read the membership information from the "META" extent.static Binary
CachePersistenceHelper.readQuorumRaw
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Read the membership information in Binary format from the "META" extent.static void
CachePersistenceHelper.registerIndex
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binExtractor, Binary binComparator, Object oToken) Store the index registration in the specified persistent store.static void
CachePersistenceHelper.registerListener
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binKey, long lListenerId, boolean fLite, Object oToken) Store the listener registration in the specified persistent store.static void
CachePersistenceHelper.registerLock
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binKey, long lHolderId, long lHolderThreadId, Object oToken) Store the cache entry lock in the specified persistent store.static void
CachePersistenceHelper.registerTrigger
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binTrigger, Object oToken) Store the trigger registration in the specified persistent store.void
AbstractSnapshotArchiver.retrieve
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) void
SnapshotArchiver.retrieve
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env) Retrieve the specified archived snapshot.protected abstract void
AbstractSnapshotArchiver.retrieveInternal
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) Internal implementation to retrieve the specified snapshot.protected void
DirectorySnapshotArchiver.retrieveInternal
(Snapshot snapshot, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr) static void
CachePersistenceHelper.seal
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, PartitionedService service, Object oToken) Seal the specified PersistentStore on behalf of the specified service, indicating that it is fully initialized and eligible to be recovered from this point forward.protected void
AbstractPersistenceManager.AbstractPersistentStore.submitOpen
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector) Open this store either asynchronously, iff both a store to open from and a collector have been provided, or synchronously.static void
CachePersistenceHelper.unregisterIndex
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binExtractor, Object oToken) Clear the index registration from the specified persistent store.static void
CachePersistenceHelper.unregisterIndices
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId) Clear all index registrations for the specified cache from the specified persistent store.static void
CachePersistenceHelper.unregisterListener
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binKey, long lListenerId, Object oToken) Clear the listener registration from the specified persistent store.static void
CachePersistenceHelper.unregisterListeners
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId) Clear all listener registrations for the specified cache from the specified persistent store.static void
CachePersistenceHelper.unregisterLock
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binKey, long lHolderId, long lHolderThreadId, Object oToken) Clear the cache entry lock from the specified persistent store.static void
CachePersistenceHelper.unregisterLocks
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId) Clear all cache entry locks for the specified cache from the specified persistent store.static void
CachePersistenceHelper.unregisterTrigger
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId, Binary binTrigger, Object oToken) Clear the trigger registration from the specified persistent store.static void
CachePersistenceHelper.unregisterTriggers
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, long lCacheId) Clear all trigger registrations for the specified cache from the specified persistent store.static void
CachePersistenceHelper.unseal
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Remove a seal from a PersistentStore.protected void
AbstractPersistenceManager.AbstractPersistenceSnapshotTools.validateStoreSealed
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store) Validate the given store is sealed.protected void
AbstractSnapshotArchiver.writeMetadata
(File fileDir, com.oracle.coherence.persistence.PersistenceManager<ReadBuffer> mgr, String sStore) Write the metadata using given manager for a particular store to a destination directory.static Binary
CachePersistenceHelper.writeQuorum
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, PartitionedService service) Write the current membership information to the "META" extent.static void
CachePersistenceHelper.writeQuorumRaw
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store, Binary binInfo) Write the current membership information in raw format to the "META" extent.ModifierConstructorDescriptionEraseOperation
(long lExtentId, ReadBuffer bufKey) Create a new EraseOperation.Operation
(long lExtentId, ReadBuffer bufKey) Create a new Operation.StoreOperation
(long lExtentId, ReadBuffer bufKey, ReadBuffer bufValue) Create a new StoreOperation.ModifierConstructorDescriptionOpenTask
(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector) Construct an OpenTask. -
Uses of ReadBuffer in com.tangosol.util
Modifier and TypeClassDescriptionfinal class
A thread-safe immutable binary object.static class
DecoratedMultiBufferReadBuffer is a MultiBufferWriteBuffer that represents a binary "decorated" value, and allows a more optimizedExternalizableHelper.getUndecorated(ReadBuffer)
operation.Modifier and TypeFieldDescriptionprotected final ReadBuffer
ExternalizableHelper.DecoratedMultiBufferReadBuffer.m_bufValue
The undecorated value.Modifier and TypeMethodDescriptionExternalizableHelper.FormatAwareCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.NullImplementation.NullDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.static ReadBuffer
ExternalizableHelper.decorate
(ReadBuffer bufOrig, int nId, ReadBuffer bufDeco) Decorate the passed value with the specified decoration and return the resulting ReadBuffer.static ReadBuffer
ExternalizableHelper.decorate
(ReadBuffer buf, ReadBuffer[] abufDeco) Decorate the passed Binary with the passed decorations.static ReadBuffer
ExternalizableHelper.decorateBinary
(ReadBuffer bufValue, int nDecoration) Decorate the specified ReadBuffer with the specified integer decoration.static ReadBuffer
ExternalizableHelper.encodeExpiry
(ReadBuffer buf, long ldtExpiry) Return a ReadBuffer whose contents represent the specified buffer with the specified expiry encoded as a DECO_EXPIRY decoration.ExternalizableHelper.FormatAwareCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.NullImplementation.NullDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.static ReadBuffer
ExternalizableHelper.getDecoration
(ReadBuffer buf, int nId) Extract and return the specified decoration from the passed ReadBuffer.static ReadBuffer[]
ExternalizableHelper.getDecorations
(ReadBuffer buf) Return an array containing all of the decorations from the passed ReadBuffer.ExternalizableHelper.DecoratedMultiBufferReadBuffer.getUndecorated()
Return the undecorated value.static ReadBuffer
ExternalizableHelper.getUndecorated
(ReadBuffer buf) If the passed ReadBuffer is decorated, extract the original contents that the decorations were added to, otherwise return the passed Binary value.protected ReadBuffer
Binary.instantiateReadBuffer
(int of, int cb) Factory method: Instantiate a ReadBuffer for a portion of this ReadBuffer.static ReadBuffer
ExternalizableHelper.removeIntDecoration
(ReadBuffer buf) Remove a decoration value from the specified ReadBuffer that contains a representation of an IntDecoratedObject.static ReadBuffer
ExternalizableHelper.undecorate
(ReadBuffer buf, int nId) Remove the specified decoration from the passed ReadBuffer and return the resulting contents (which may be undecorated, or contain the remaining decorations).Modifier and TypeMethodDescriptionExternalizableHelper.FormatAwareCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.NullImplementation.NullDeltaCompressor.applyDelta
(ReadBuffer bufOld, ReadBuffer bufDelta) Apply a delta to an old value in order to create a new value.static Binary
ExternalizableHelper.asBinary
(ReadBuffer buf) Return a Binary representing the contents of the specified ReadBuffer, or null if the buffer is null.static long
ExternalizableHelper.decodeExpiry
(ReadBuffer buf) Decode the expiry time from the specified ReadBuffer.static ReadBuffer
ExternalizableHelper.decorate
(ReadBuffer bufOrig, int nId, ReadBuffer bufDeco) Decorate the passed value with the specified decoration and return the resulting ReadBuffer.static ReadBuffer
ExternalizableHelper.decorate
(ReadBuffer buf, ReadBuffer[] abufDeco) Decorate the passed Binary with the passed decorations.static ReadBuffer
ExternalizableHelper.decorateBinary
(ReadBuffer bufValue, int nDecoration) Decorate the specified ReadBuffer with the specified integer decoration.static ReadBuffer
ExternalizableHelper.encodeExpiry
(ReadBuffer buf, long ldtExpiry) Return a ReadBuffer whose contents represent the specified buffer with the specified expiry encoded as a DECO_EXPIRY decoration.ExternalizableHelper.FormatAwareCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.NullImplementation.NullDeltaCompressor.extractDelta
(ReadBuffer bufOld, ReadBuffer bufNew) Compare an old value to a new value and generate a delta that represents the changes that must be made to the old value in order to transform it into the new value.static int
ExternalizableHelper.extractIntDecoration
(ReadBuffer buf) Extract a decoration value from the specified ReadBuffer that contains a representation of an IntDecoratedObject.static ReadBuffer
ExternalizableHelper.getDecoration
(ReadBuffer buf, int nId) Extract and return the specified decoration from the passed ReadBuffer.static ReadBuffer[]
ExternalizableHelper.getDecorations
(ReadBuffer buf) Return an array containing all of the decorations from the passed ReadBuffer.static ReadBuffer
ExternalizableHelper.getUndecorated
(ReadBuffer buf) If the passed ReadBuffer is decorated, extract the original contents that the decorations were added to, otherwise return the passed Binary value.static boolean
ExternalizableHelper.isDecorated
(ReadBuffer buf) If the ReadBuffer is the result of serialization by ExternalizableHelper, determine if the buffer contains decorations.static boolean
ExternalizableHelper.isDecorated
(ReadBuffer buf, int nId) If the ReadBuffer is the result of serialization by ExternalizableHelper, determine if the buffer contains the specified decoration.static boolean
ExternalizableHelper.isIntDecorated
(ReadBuffer buf) Deprecated.static ReadBuffer
ExternalizableHelper.removeIntDecoration
(ReadBuffer buf) Remove a decoration value from the specified ReadBuffer that contains a representation of an IntDecoratedObject.static ReadBuffer
ExternalizableHelper.undecorate
(ReadBuffer buf, int nId) Remove the specified decoration from the passed ReadBuffer and return the resulting contents (which may be undecorated, or contain the remaining decorations).static void
Binary.writeExternal
(DataOutput out, ReadBuffer buf) Write the contents of the specified ReadBuffer to the specified DataOutput stream in a format that can be restored as a Binary viaBinary.readExternal(java.io.ObjectInput)
ModifierConstructorDescriptionDecoratedMultiBufferReadBuffer
(ReadBuffer bufValue, ReadBuffer[] abuf) Construct a DecoratedMultiBufferReadBuffer for the specified value.
CachePersistenceHelper.getPersistenceVersion(PersistentStore)
instead