Uses of Interface
com.tangosol.io.ReadBuffer
-
Packages that use ReadBuffer Package Description com.oracle.coherence.grpc Low-level utilities for Coherence gRPC server and client implementation.com.tangosol.coherence.config.builder Defines the typical runtime configuration builders for the Coherence configuration object model.com.tangosol.io Contains classes providing cache persistence of serialized objects.com.tangosol.io.nio Contains classes related to J2SE 1.4 NIO functionality.com.tangosol.io.pof Contains classes related to POF serialization and deserialization.com.tangosol.io.pof.reflect Contains classes related to POF stream navigation and manipulation.com.tangosol.persistence Contains classes and helpers for implementing various types of persistence.com.tangosol.util Contains various generic utilities. -
-
Uses of ReadBuffer in com.oracle.coherence.grpc
Methods in com.oracle.coherence.grpc that return ReadBuffer Modifier and Type Method Description static ReadBuffer
BinaryHelper. toReadBuffer(com.google.protobuf.ByteString bytes)
Convert aByteString
to aReadBuffer
. -
Uses of ReadBuffer in com.tangosol.coherence.config.builder
Fields in com.tangosol.coherence.config.builder with type parameters of type ReadBuffer Modifier and Type Field Description protected ParameterizedBuilder<com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>>
PersistenceEnvironmentParamBuilder. m_bldr
AParameterizedBuilder
that creates aPersistenceEnvironment
.Methods in com.tangosol.coherence.config.builder that return types with arguments of type ReadBuffer Modifier and Type Method Description com.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.Method parameters in com.tangosol.coherence.config.builder with type arguments of type ReadBuffer Modifier and Type Method Description void
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
Classes in com.tangosol.io that implement ReadBuffer Modifier and Type Class Description class
AbstractByteArrayReadBuffer
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
AbstractReadBuffer
Abstract base implementation of the ReadBuffer interface.class
ByteArrayReadBuffer
A ReadBuffer on top of a byte array.class
MultiBufferReadBuffer
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.Methods in com.tangosol.io that return ReadBuffer Modifier and Type Method Description ReadBuffer
BinaryDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
DecoratedBinaryDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
DecorationOnlyDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.ReadBuffer
AbstractReadBuffer.AbstractBufferInput. getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.protected ReadBuffer
MultiBufferReadBuffer. getBuffer(int iBuffer)
Obtain the specified buffer.ReadBuffer
ReadBuffer.BufferInput. getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.ReadBuffer
WrapperBufferInput. getBuffer()
Get the ReadBuffer object that this BufferInput is reading from.ReadBuffer
AbstractReadBuffer. getReadBuffer(int of, int cb)
Obtain a ReadBuffer for a portion of this ReadBuffer.ReadBuffer
AbstractWriteBuffer. getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ReadBuffer
DelegatingWriteBuffer. getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ReadBuffer
MultiBufferWriteBuffer. getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ReadBuffer
ReadBuffer. getReadBuffer(int of, int cb)
Obtain a ReadBuffer for a portion of this ReadBuffer.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.ReadBuffer
ByteArrayWriteBuffer. getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.ReadBuffer
DelegatingWriteBuffer. getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.ReadBuffer
MultiBufferWriteBuffer. getUnsafeReadBuffer()
Get a ReadBuffer object to read data from this buffer.ReadBuffer
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 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.ReadBuffer
AbstractReadBuffer.AbstractBufferInput. readBuffer(int cb)
Readcb
bytes and return them as a ReadBuffer object.ReadBuffer
MultiBufferReadBuffer.MultiBufferInput. readBuffer(int cb)
Readcb
bytes and return them as a ReadBuffer object.ReadBuffer
ReadBuffer.BufferInput. readBuffer(int cb)
Readcb
bytes and return them as a ReadBuffer object.ReadBuffer
WrapperBufferInput. readBuffer(int cb)
Readcb
bytes and return them as a ReadBuffer object.protected ReadBuffer
MultiBufferReadBuffer. releaseBuffer(int iBuffer)
Release the specified buffer.Methods in com.tangosol.io with parameters of type ReadBuffer Modifier and Type Method Description ReadBuffer
BinaryDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
DecoratedBinaryDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
DecorationOnlyDeltaCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.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.Constructors in com.tangosol.io with parameters of type ReadBuffer Constructor Description MultiBufferReadBuffer(ReadBuffer[] abuf)
Construct a MultiBufferReadBuffer from an array of underlying ReadBuffer objects. -
Uses of ReadBuffer in com.tangosol.io.nio
Classes in com.tangosol.io.nio that implement ReadBuffer Modifier and Type Class Description class
ByteBufferReadBuffer
A ReadBuffer implementation on top of a Java NIO ByteBuffer.Methods in com.tangosol.io.nio that return ReadBuffer Modifier and Type Method Description ReadBuffer
ByteBufferWriteBuffer. getReadBuffer()
Get a ReadBuffer object that is a snapshot of this WriteBuffer's data.ReadBuffer
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.Methods in com.tangosol.io.nio with parameters of type ReadBuffer Modifier and Type Method Description void
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
Methods in com.tangosol.io.pof that return ReadBuffer Modifier and Type Method Description ReadBuffer
PofDeltaCompressor. createDelta(ReadBuffer bufOld, ReadBuffer bufNew)
Actually create a delta in the binary delta format.Methods in com.tangosol.io.pof with parameters of type ReadBuffer Modifier and Type Method Description ReadBuffer
PofDeltaCompressor. createDelta(ReadBuffer bufOld, ReadBuffer bufNew)
Actually create a delta in the binary delta format. -
Uses of ReadBuffer in com.tangosol.io.pof.reflect
Methods in com.tangosol.io.pof.reflect that return ReadBuffer Modifier and Type Method Description ReadBuffer
AbstractPofValue. getChanges()
Return a buffer containing changes made to this PofValue in the format defined by theBinaryDeltaCompressor
.ReadBuffer
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.ReadBuffer
AbstractPofValue. getSerializedValue()
Return this value's serialized form.ReadBuffer
PofSparseArray.NilPofValue. getSerializedValue()
Return this value's serialized form.protected ReadBuffer
AbstractPofValue. getValueBuffer()
Get the raw value buffer.Methods in com.tangosol.io.pof.reflect with parameters of type ReadBuffer Modifier and Type Method Description protected 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.Constructors in com.tangosol.io.pof.reflect with parameters of type ReadBuffer Constructor Description AbstractPofValue(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
Fields in com.tangosol.persistence declared as ReadBuffer Modifier and Type Field Description protected ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.Operation. f_bufKey
The target key of the operation.protected ReadBuffer
AbstractPersistenceManager.AbstractPersistentStore.BatchTask.StoreOperation. f_bufValue
The value to store.static ReadBuffer
CachePersistenceHelper. LAST_ENTRY
A constant that suggests to a PersistentStore implementation to load the last entry.Fields in com.tangosol.persistence with type parameters of type ReadBuffer Modifier and Type Field Description protected com.oracle.coherence.persistence.PersistentStore<ReadBuffer>
AbstractPersistenceManager.AbstractPersistentStore.OpenTask. f_storeFrom
ThePersistentStore
to open with.static Converter<Long,ReadBuffer>
CachePersistenceHelper. LONG_CONVERTER_DOWN
A converter that converts from a Long to a ReadBuffer.static Converter<ReadBuffer,Long>
CachePersistenceHelper. LONG_CONVERTER_UP
A converter that converts from a ReadBuffer to a Long.Methods in com.tangosol.persistence that return ReadBuffer Modifier and Type Method Description protected 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.ReadBuffer
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.Methods in com.tangosol.persistence that return types with arguments of type ReadBuffer Modifier and Type Method Description 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 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.Methods in com.tangosol.persistence with parameters of type ReadBuffer Modifier and Type Method Description void
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.ReadBuffer
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.Method parameters in com.tangosol.persistence with type arguments of type ReadBuffer Modifier and Type Method Description void
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.static LongArray<String>
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.Constructors in com.tangosol.persistence with parameters of type ReadBuffer Constructor Description EraseOperation(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.Constructor parameters in com.tangosol.persistence with type arguments of type ReadBuffer Constructor Description OpenTask(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector)
Construct an OpenTask. -
Uses of ReadBuffer in com.tangosol.util
Classes in com.tangosol.util that implement ReadBuffer Modifier and Type Class Description class
Binary
A thread-safe immutable binary object.static class
ExternalizableHelper.DecoratedMultiBufferReadBuffer
DecoratedMultiBufferReadBuffer is a MultiBufferWriteBuffer that represents a binary "decorated" value, and allows a more optimizedExternalizableHelper.getUndecorated(ReadBuffer)
operation.Fields in com.tangosol.util declared as ReadBuffer Modifier and Type Field Description protected ReadBuffer
ExternalizableHelper.DecoratedMultiBufferReadBuffer. m_bufValue
The undecorated value.Methods in com.tangosol.util that return ReadBuffer Modifier and Type Method Description ReadBuffer
ExternalizableHelper.FormatAwareCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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.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).Methods in com.tangosol.util with parameters of type ReadBuffer Modifier and Type Method Description ReadBuffer
ExternalizableHelper.FormatAwareCompressor. applyDelta(ReadBuffer bufOld, ReadBuffer bufDelta)
Apply a delta to an old value in order to create a new value.ReadBuffer
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.ReadBuffer
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.ReadBuffer
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)
Constructors in com.tangosol.util with parameters of type ReadBuffer Constructor Description DecoratedMultiBufferReadBuffer(ReadBuffer bufValue, ReadBuffer[] abuf)
Construct a DecoratedMultiBufferReadBuffer for the specified value.
-