Uses of Interface
com.tangosol.io.ReadBuffer

Packages that use 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

    Methods in com.oracle.coherence.grpc that return ReadBuffer
    Modifier and Type
    Method
    Description
    static ReadBuffer
    BinaryHelper.toReadBuffer(com.google.protobuf.ByteString bytes)
    Convert a ByteString to a ReadBuffer.
  • 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
    A ParameterizedBuilder that creates a PersistenceEnvironment.
    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 a PersistenceEnvironment 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 a builder to be used instantiate the appropriate PersistenceEnvironment.
    protected com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer>
    PersistenceEnvironmentParamBuilder.wrap(com.oracle.coherence.persistence.PersistenceEnvironment<ReadBuffer> env)
    Wrap a PersistenceEnvironment with a SafePersistenceEnvironment.
  • Uses of ReadBuffer in com.tangosol.io

    Classes in com.tangosol.io that implement ReadBuffer
    Modifier and Type
    Class
    Description
    class 
    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 NIO
    class 
    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.
    Methods in com.tangosol.io that return ReadBuffer
    Modifier and Type
    Method
    Description
    BinaryDeltaCompressor.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.
    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)
    Read cb bytes and return them as a ReadBuffer object.
    MultiBufferReadBuffer.MultiBufferInput.readBuffer(int cb)
    Read cb bytes and return them as a ReadBuffer object.
    ReadBuffer.BufferInput.readBuffer(int cb)
    Read cb bytes and return them as a ReadBuffer object.
    WrapperBufferInput.readBuffer(int cb)
    Read cb 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
    BinaryDeltaCompressor.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)
    Write cb bytes from the passed ReadBuffer object starting at offset of 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)
    Write cb bytes from the passed ReadBuffer object starting at offset of 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)
    Write cb bytes from the passed ReadBuffer object starting at offset of 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)
    Write cb bytes from the passed ReadBuffer object starting at offset of 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)
    Write cb bytes from the passed ReadBuffer object starting at offset of within the passed ReadBuffer.
    Constructors in com.tangosol.io with parameters of type ReadBuffer
    Modifier
    Constructor
    Description
     
    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 
    A ReadBuffer implementation on top of a Java NIO ByteBuffer.
    Methods in com.tangosol.io.nio that return ReadBuffer
    Modifier and Type
    Method
    Description
    ByteBufferWriteBuffer.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.
    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
    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
    PofDeltaCompressor.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 Type
    Method
    Description
    AbstractPofValue.getChanges()
    Return a buffer containing changes made to this PofValue in the format defined by the BinaryDeltaCompressor.
    PofValue.getChanges()
    Return a buffer containing changes made to this PofValue in the format defined by the BinaryDeltaCompressor.
    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.
    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 a PofValue 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 a PofValue 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 a PofValue 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
    Modifier
    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 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.
    Fields in com.tangosol.persistence with type parameters of type ReadBuffer
    Modifier and Type
    Field
    Description
    protected final com.oracle.coherence.persistence.PersistentStore<ReadBuffer>
    AbstractPersistenceManager.AbstractPersistentStore.OpenTask.f_storeFrom
    The PersistentStore 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.
    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.
    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 a PersistentStore.Visitor that can read a PersistentStore and populate the provided mapEvents with events that are larger than the provided version (inclusive) and match the given Filter.
    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 a PersistentStore.Visitor that can read a PersistentStore and populate the provided mapEvents 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>
    Instantiate a visitor for the PersistentStore backed by the
    com.oracle.coherence.persistence.PersistentStore<ReadBuffer>
    AbstractPersistenceManager.open(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom)
    Open or create a PersistentStore associated with the specified identifier and based on the provided store.
    com.oracle.coherence.persistence.PersistentStore<ReadBuffer>
    AbstractPersistenceManager.open(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector)
    Open or create a PersistentStore associated with the specified identifier and based on the provided store.
    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.
    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.
    CachePersistenceHelper.getCacheNames(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> store)
    Return the cache names that have been stored 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)
    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 a PersistentStore.Visitor that can read a PersistentStore and populate the provided mapEvents with events that are larger than the provided version (inclusive) and match the given Filter.
    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 a PersistentStore.Visitor that can read a PersistentStore and populate the provided mapEvents 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 a PersistentStore associated with the specified identifier and based on the provided store.
    com.oracle.coherence.persistence.PersistentStore<ReadBuffer>
    AbstractPersistenceManager.open(String sId, com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector)
    Open or create a PersistentStore associated with the specified identifier and based on the provided store.
    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
    Modifier
    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
    Modifier
    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
    final class 
    A thread-safe immutable binary object.
    static class 
    DecoratedMultiBufferReadBuffer is a MultiBufferWriteBuffer that represents a binary "decorated" value, and allows a more optimized ExternalizableHelper.getUndecorated(ReadBuffer) operation.
    Fields in com.tangosol.util declared as ReadBuffer
    Modifier and Type
    Field
    Description
    protected final ReadBuffer
    ExternalizableHelper.DecoratedMultiBufferReadBuffer.m_bufValue
    The undecorated value.
    Methods in com.tangosol.util that return ReadBuffer
    Modifier and Type
    Method
    Description
    ExternalizableHelper.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).
    Methods in com.tangosol.util with parameters of type ReadBuffer
    Modifier and Type
    Method
    Description
    ExternalizableHelper.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)
    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
    Write the contents of the specified ReadBuffer to the specified DataOutput stream in a format that can be restored as a Binary via Binary.readExternal(java.io.ObjectInput)
    Constructors in com.tangosol.util with parameters of type ReadBuffer
    Modifier
    Constructor
    Description
     
    Construct a DecoratedMultiBufferReadBuffer for the specified value.