public class MockInMemoryTierObjectStore extends java.lang.Object implements TierObjectStore, java.lang.AutoCloseable
TierObjectStore.FileType, TierObjectStore.ObjectMetadata
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) |
TierObjectStoreResponse |
getObject(TierObjectStore.ObjectMetadata 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.ObjectMetadata objectMetadata,
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.io.File> 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 TierObjectStoreResponse getObject(TierObjectStore.ObjectMetadata 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.io.File> epochState)
putSegment
in interface TierObjectStore
public void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata)
deleteSegment
in interface TierObjectStore
public java.lang.String keyPath(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType fileType)