This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 23633cd KAFKA-12584; Remove deprecated `Sum` and `Total` classes
(#10511)
add 3278090 KAFKA-12368: Added inmemory implementations for
RemoteStorageManager and RemoteLogMetadataManager. (#10218)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 5 +
.../test/java/org/apache/kafka/test/TestUtils.java | 41 +++
.../remote/storage/RemoteLogMetadataManager.java | 14 +-
.../log/remote/storage/RemoteLogSegmentState.java | 31 +-
.../remote/storage/RemotePartitionDeleteState.java | 35 +-
.../log/remote/storage/RemoteStorageException.java | 9 +-
.../storage/RemoteLogLeaderEpochState.java | 172 +++++++++
.../metadata/storage/RemoteLogMetadataCache.java | 316 +++++++++++++++++
.../storage/RemoteLogMetadataCacheTest.java | 387 +++++++++++++++++++++
.../storage/InmemoryRemoteLogMetadataManager.java | 161 +++++++++
.../InmemoryRemoteLogMetadataManagerTest.java | 130 +++++++
.../storage/InmemoryRemoteStorageManager.java | 177 ++++++++++
.../storage/InmemoryRemoteStorageManagerTest.java | 246 +++++++++++++
.../src/test/resources/log4j.properties | 2 +-
14 files changed, 1705 insertions(+), 21 deletions(-)
create mode 100644
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochState.java
create mode 100644
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManager.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManagerTest.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteStorageManager.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteStorageManagerTest.java
copy {clients => storage}/src/test/resources/log4j.properties (94%)
