public class MockInMemoryTierObjectStore extends Object implements TierObjectStore, AutoCloseable
TierObjectStore.Backend, TierObjectStore.DataTypePathPrefix, TierObjectStore.FileType, TierObjectStore.ObjectMetadata, TierObjectStore.ObjectStoreMetadata, TierObjectStore.OpaqueData, TierObjectStore.TierStateRestoreSnapshotMetadata
Modifier and Type | Field and Description |
---|---|
boolean |
throwExceptionOnSegmentFetch |
boolean |
throwExceptionOnTransactionFetch |
Constructor and Description |
---|
MockInMemoryTierObjectStore(org.apache.kafka.common.utils.Time time,
org.apache.kafka.common.metrics.Metrics metrics,
TierObjectStoreConfig config) |
MockInMemoryTierObjectStore(org.apache.kafka.common.utils.Time time,
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,
Integer byteOffset,
Integer byteOffsetEnd) |
ConcurrentHashMap<TierObjectStore.FileType,Integer> |
getObjectCounts() |
List<String> |
getStoredKeys()
Returns the set of keys which are currently stored.
|
TierObjectStore.OpaqueData |
prepPutSegment() |
void |
putObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
File file,
TierObjectStore.FileType fileType) |
void |
putSegment(TierObjectStore.ObjectMetadata objectMetadata,
File segmentData,
File offsetIndexData,
File timestampIndexData,
Optional<File> producerStateSnapshotData,
Optional<ByteBuffer> transactionIndexData,
Optional<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(org.apache.kafka.common.utils.Time time, TierObjectStoreConfig config)
public MockInMemoryTierObjectStore(org.apache.kafka.common.utils.Time time, org.apache.kafka.common.metrics.Metrics metrics, TierObjectStoreConfig config)
public List<String> getStoredKeys()
public ConcurrentHashMap<TierObjectStore.FileType,Integer> getObjectCounts()
public TierObjectStore.Backend getBackend()
getBackend
in interface TierObjectStore
public TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType objectFileType, Integer byteOffset, Integer byteOffsetEnd) throws IOException
getObject
in interface TierObjectStore
IOException
public TierObjectStore.OpaqueData prepPutSegment() throws TierObjectStoreRetriableException
prepPutSegment
in interface TierObjectStore
TierObjectStoreRetriableException
public void close()
close
in interface AutoCloseable
close
in interface TierObjectStore
public void putSegment(TierObjectStore.ObjectMetadata objectMetadata, File segmentData, File offsetIndexData, File timestampIndexData, Optional<File> producerStateSnapshotData, Optional<ByteBuffer> transactionIndexData, Optional<ByteBuffer> epochState)
putSegment
in interface TierObjectStore
public void putObject(TierObjectStore.ObjectStoreMetadata objectMetadata, File file, TierObjectStore.FileType fileType)
putObject
in interface TierObjectStore
public void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata)
deleteSegment
in interface TierObjectStore