You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/07/31 06:47:01 UTC
[rocketmq-schema-registry] 14/34: Merge pull request #4 from MatrixHB/controller_optimize
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-schema-registry.git
commit 3e08609993fd1c20966764d62b5b3d8fda8c612e
Merge: fcced73 05bcf9d
Author: Heng Du <du...@apache.org>
AuthorDate: Mon Jul 25 11:44:56 2022 +0800
Merge pull request #4 from MatrixHB/controller_optimize
optimize Schema Rest API and the cache refresh mechanism
.../schema/registry/common/QualifiedName.java | 21 +-
.../registry/common/dto/SchemaRecordDto.java | 4 +
.../schema/registry/common/dto/SubjectDto.java | 3 +
.../exception/SchemaAuthorizedException.java | 5 +
.../exception/SchemaCompatibilityException.java | 4 +
.../registry/common/exception/SchemaException.java | 5 +
.../common/exception/SchemaExistException.java | 6 +-
.../common/exception/SchemaNotFoundException.java | 4 +
.../schema/registry/common/model/SchemaInfo.java | 3 +
.../registry/common/model/SchemaRecordInfo.java | 1 +
.../schema/registry/common/model/SubjectInfo.java | 5 +-
.../registry/common/storage/StorageService.java | 6 +
.../common/storage/StorageServiceProxy.java | 17 +-
.../schema/registry/common/utils/CommonUtil.java | 7 +-
core/pom.xml | 8 -
.../registry/core/api/v1/SchemaController.java | 178 ++++++++----
.../core/expection}/RequestExceptionHandler.java | 15 +-
.../registry/core/service/SchemaService.java | 9 +
.../registry/core/service/SchemaServiceImpl.java | 49 ++--
schema-storage-rocketmq/pom.xml | 8 +-
.../registry/storage/rocketmq/RocketmqClient.java | 312 +++++++++++++++------
.../storage/rocketmq/RocketmqStorageClient.java | 11 +
.../rocketmq/RocketmqStorageClientImpl.java | 38 ++-
.../storage/rocketmq/RocketmqStorageService.java | 7 +
.../rocketmq/configs/RocketmqConfigConstants.java | 2 +-
25 files changed, 534 insertions(+), 194 deletions(-)