public class MockInMemoryTierObjectStore extends java.lang.Object implements TierObjectStore, java.lang.AutoCloseable
TierObjectStore.Backend, TierObjectStore.DataTypePathPrefix, TierObjectStore.FileType, TierObjectStore.ObjectMetadata, TierObjectStore.ObjectStoreMetadata, TierObjectStore.TierStateRestoreSnapshotMetadata
Modifier and Type | Field and Description |
---|---|
boolean |
throwExceptionOnSegmentFetch |
boolean |
throwExceptionOnTransactionFetch |
Constructor and Description |
---|
MockInMemoryTierObjectStore(TierObjectStoreConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) |
TierObjectStore.Backend |
getBackend() |
TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType objectFileType,
java.lang.Integer byteOffset,
java.lang.Integer byteOffsetEnd) |
java.util.concurrent.ConcurrentHashMap<TierObjectStore.FileType,java.lang.Integer> |
getObjectCounts() |
java.util.concurrent.ConcurrentHashMap<java.lang.String,byte[]> |
getStored() |
java.lang.String |
keyPath(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType) |
void |
putObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
java.io.File file,
TierObjectStore.FileType fileType) |
void |
putSegment(TierObjectStore.ObjectMetadata objectMetadata,
java.io.File segmentData,
java.io.File offsetIndexData,
java.io.File timestampIndexData,
java.util.Optional<java.io.File> producerStateSnapshotData,
java.util.Optional<java.nio.ByteBuffer> transactionIndexData,
java.util.Optional<java.nio.ByteBuffer> epochState) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getObject, getObject
public volatile boolean throwExceptionOnSegmentFetch
public volatile boolean throwExceptionOnTransactionFetch
public MockInMemoryTierObjectStore(TierObjectStoreConfig config)
public java.util.concurrent.ConcurrentHashMap<java.lang.String,byte[]> getStored()
public java.util.concurrent.ConcurrentHashMap<TierObjectStore.FileType,java.lang.Integer> getObjectCounts()
public TierObjectStore.Backend getBackend()
getBackend
in interface TierObjectStore
public TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType objectFileType, java.lang.Integer byteOffset, java.lang.Integer byteOffsetEnd) throws java.io.IOException
getObject
in interface TierObjectStore
java.io.IOException
public void close()
close
in interface java.lang.AutoCloseable
close
in interface TierObjectStore
public void putSegment(TierObjectStore.ObjectMetadata objectMetadata, java.io.File segmentData, java.io.File offsetIndexData, java.io.File timestampIndexData, java.util.Optional<java.io.File> producerStateSnapshotData, java.util.Optional<java.nio.ByteBuffer> transactionIndexData, java.util.Optional<java.nio.ByteBuffer> epochState)
putSegment
in interface TierObjectStore
public void putObject(TierObjectStore.ObjectStoreMetadata objectMetadata, java.io.File file, TierObjectStore.FileType fileType)
putObject
in interface TierObjectStore
public void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata)
deleteSegment
in interface TierObjectStore
public java.lang.String keyPath(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType fileType)