Class InMemoryBlobStore
- java.lang.Object
-
- org.nuxeo.ecm.core.blob.AbstractBlobStore
-
- org.nuxeo.ecm.core.blob.InMemoryBlobStore
-
- All Implemented Interfaces:
BlobStore
public class InMemoryBlobStore extends AbstractBlobStore
Blob storage in memory, mostly for unit tests.- Since:
- 11.1
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
InMemoryBlobStore.InMemoryBlobGarbageCollector
-
Nested classes/interfaces inherited from interface org.nuxeo.ecm.core.blob.BlobStore
BlobStore.OptionalOrUnknown<T>
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
allowByteRange
protected boolean
emulateLocalFile
protected boolean
emulateNoStream
protected boolean
emulateVersioning
protected InMemoryBlobStore.InMemoryBlobGarbageCollector
gc
protected Map<String,Boolean>
legalHold
protected Map<String,byte[]>
map
protected String
path
protected static Random
RANDOM
-
Fields inherited from class org.nuxeo.ecm.core.blob.AbstractBlobStore
blobProviderId, BYTE_RANGE_SEP, keyStrategy, name
-
-
Constructor Summary
Constructors Modifier Constructor Description InMemoryBlobStore(String name, KeyStrategy keyStrategy)
protected
InMemoryBlobStore(String name, KeyStrategy keyStrategy, boolean emulateNoStream, boolean emulateLocalFile)
InMemoryBlobStore(String name, PropertyBasedConfiguration config, KeyStrategy keyStrategy)
protected
InMemoryBlobStore(String name, PropertyBasedConfiguration config, KeyStrategy keyStrategy, boolean emulateNoStream, boolean emulateLocalFile)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clear()
INTERNAL (TESTS).protected String
copyBlob(String key, BlobStore sourceStore, String sourceKey)
boolean
copyBlobIsOptimized(BlobStore sourceStore)
Checks if blob copy/move from another blob store to this one can be done efficiently.String
copyOrMoveBlob(String key, BlobStore sourceStore, String sourceKey, boolean atomicMove)
Writes a file based on a key, as an optimized copy/move from a source in another compatible blob store.void
deleteBlob(String key)
Deletes a blob based on a key.boolean
exists(String key)
Does a blob with the given key exist in the blob store.BinaryGarbageCollector
getBinaryGarbageCollector()
Returns the binary garbage collector (GC).BlobStore.OptionalOrUnknown<Path>
getFile(String key)
Gets an already-existing file containing the blob for the given key, if present.Iterator<String>
getKeyIterator()
Gets an iterator over the blob keys.long
getLength(String key)
Gets the blob length.BlobStore.OptionalOrUnknown<InputStream>
getStream(String key)
Gets the stream of the blob for the given key, if present.protected ByteArrayInputStream
getStreamInternal(String key)
boolean
hasVersioning()
Whether this blob store has versioning.protected String
putBytes(String key, byte[] bytes)
boolean
readBlob(String key, Path dest)
Reads a blob based on its key into the given file.protected String
writeBlobGeneric(BlobWriteContext blobWriteContext)
Writes the blob without using any store-to-store optimization.void
writeBlobProperties(BlobUpdateContext blobUpdateContext)
Sets properties on a blob.-
Methods inherited from class org.nuxeo.ecm.core.blob.AbstractBlobStore
deleteBlob, getBlobKeyReplacement, getByteRangeFromKey, getKeyStrategy, getName, logTrace, logTrace, logTrace, notifyAsyncDigest, randomLong, randomString, setByteRangeInKey, stripBlobKeyPrefix, stripBlobKeyVersionSuffix, transfer, transfer, transfer, unwrap, useAsyncDigest, writeBlob, writeBlob, writeBlobUsingOptimizedCopy
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.nuxeo.ecm.core.blob.BlobStore
copyBlob, hasDefaultStorageClass
-
-
-
-
Field Detail
-
RANDOM
protected static final Random RANDOM
-
gc
protected final InMemoryBlobStore.InMemoryBlobGarbageCollector gc
-
emulateNoStream
protected final boolean emulateNoStream
-
emulateLocalFile
protected final boolean emulateLocalFile
-
emulateVersioning
protected final boolean emulateVersioning
-
allowByteRange
protected final boolean allowByteRange
-
path
protected final String path
-
-
Constructor Detail
-
InMemoryBlobStore
public InMemoryBlobStore(String name, KeyStrategy keyStrategy)
-
InMemoryBlobStore
public InMemoryBlobStore(String name, PropertyBasedConfiguration config, KeyStrategy keyStrategy)
-
InMemoryBlobStore
protected InMemoryBlobStore(String name, KeyStrategy keyStrategy, boolean emulateNoStream, boolean emulateLocalFile)
-
InMemoryBlobStore
protected InMemoryBlobStore(String name, PropertyBasedConfiguration config, KeyStrategy keyStrategy, boolean emulateNoStream, boolean emulateLocalFile)
-
-
Method Detail
-
hasVersioning
public boolean hasVersioning()
Description copied from interface:BlobStore
Whether this blob store has versioning.With versioning, two writes may use the same key. The returned keys will include a different version number to distinguish the writes.
- Specified by:
hasVersioning
in interfaceBlobStore
- Overrides:
hasVersioning
in classAbstractBlobStore
-
writeBlobGeneric
protected String writeBlobGeneric(BlobWriteContext blobWriteContext) throws IOException
Description copied from class:AbstractBlobStore
Writes the blob without using any store-to-store optimization.- Overrides:
writeBlobGeneric
in classAbstractBlobStore
- Throws:
IOException
-
writeBlobProperties
public void writeBlobProperties(BlobUpdateContext blobUpdateContext) throws IOException
Description copied from interface:BlobStore
Sets properties on a blob.- Specified by:
writeBlobProperties
in interfaceBlobStore
- Overrides:
writeBlobProperties
in classAbstractBlobStore
- Parameters:
blobUpdateContext
- the blob update context- Throws:
IOException
-
copyBlobIsOptimized
public boolean copyBlobIsOptimized(BlobStore sourceStore)
Description copied from interface:BlobStore
Checks if blob copy/move from another blob store to this one can be done efficiently.- Specified by:
copyBlobIsOptimized
in interfaceBlobStore
- Overrides:
copyBlobIsOptimized
in classAbstractBlobStore
- Parameters:
sourceStore
- the source store- Returns:
true
if the copy/move can be done efficiently
-
copyOrMoveBlob
public String copyOrMoveBlob(String key, BlobStore sourceStore, String sourceKey, boolean atomicMove) throws IOException
Description copied from interface:BlobStore
Writes a file based on a key, as an optimized copy/move from a source in another compatible blob store.The target
key
may benull
, which is a signal from the caller that it has determined that deduplication is enabled and async digest computation is enabled, but the needed digest hasn't been computed, so this method should either find the digest in an efficient way if it can, or otherwise trigger an async digest computation.If the copy/move is requested to be atomic, then the destination file is created atomically. In case of atomic move, in some stores the destination will be created atomically but the source will only be deleted afterwards.
The returned key may be different than the passed one when versioning is used.
- Parameters:
key
- the key; ornull
if the store should choose it or trigger async digest computationsourceStore
- the source storesourceKey
- the source keyatomicMove
-true
for an atomic move,false
for a regular copy- Returns:
- the key of the copied/moved file, or
null
if copy/move failed - Throws:
IOException
-
copyBlob
protected String copyBlob(String key, BlobStore sourceStore, String sourceKey) throws IOException
- Throws:
IOException
-
getStreamInternal
protected ByteArrayInputStream getStreamInternal(String key)
-
getFile
public BlobStore.OptionalOrUnknown<Path> getFile(String key)
Description copied from interface:BlobStore
Gets an already-existing file containing the blob for the given key, if present.Note that this method is best-effort, it may return unknown even though the blob exists in the store, it's just that it's not handily available locally in a file.
- Parameters:
key
- the blob key- Returns:
- the file containing the blob, or empty if the blob cannot be found, or unknown if no file is available locally
-
getStream
public BlobStore.OptionalOrUnknown<InputStream> getStream(String key) throws IOException
Description copied from interface:BlobStore
Gets the stream of the blob for the given key, if present.Note that this method is best-effort, it may return unknown even though the blob exists in the store, it's just that it's not efficient to return it as a stream.
- Parameters:
key
- the blob key- Returns:
- the blob stream, or empty if the blob cannot be found, or unknown if no stream is efficiently available
- Throws:
IOException
-
readBlob
public boolean readBlob(String key, Path dest) throws IOException
Description copied from interface:BlobStore
Reads a blob based on its key into the given file.- Parameters:
key
- the blob keydest
- the file to use to store the fetched data- Returns:
true
if the file was fetched,false
if the file was not found- Throws:
IOException
-
deleteBlob
public void deleteBlob(String key)
Description copied from interface:BlobStore
Deletes a blob based on a key. No error occurs if the blob does not exist.This method does not throw
IOException
, but may log an error message.- Parameters:
key
- the blob key
-
exists
public boolean exists(String key)
Description copied from interface:BlobStore
Does a blob with the given key exist in the blob store.The existence of the blob is checked in the store where the blob is effectively stored. Intermediate cache is ignored.
- Parameters:
key
- the blob key- Returns:
- true if it exists in the blob store
-
clear
public void clear()
Description copied from interface:BlobStore
INTERNAL (TESTS). Clears the blob store of all its data.
-
getKeyIterator
public Iterator<String> getKeyIterator()
Gets an iterator over the blob keys.- Since:
- 2023
-
getLength
public long getLength(String key)
Gets the blob length.- Since:
- 2023
-
getBinaryGarbageCollector
public BinaryGarbageCollector getBinaryGarbageCollector()
Description copied from interface:BlobStore
Returns the binary garbage collector (GC).Several calls to this method will return the same GC, so that its status can be monitored using
BinaryGarbageCollector.isInProgress()
.- Returns:
- the binary GC
-
-