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/30 08:14:22 UTC
[rocketmq-schema-registry] 04/27: Merge pull request #1 from ferrirW/main
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 fcced73ffba5b52319e3732adc757167ab883441
Merge: 03002ee 691d780
Author: Heng Du <du...@apache.org>
AuthorDate: Tue Jul 12 11:17:28 2022 +0800
Merge pull request #1 from ferrirW/main
[RIP-42] Support schema registry basic feature
.gitignore | 36 +++
README.md | 11 +-
bump-version.sh | 9 +
common/pom.xml | 92 ++++++
.../schema/registry/common/QualifiedName.java | 84 +++++
.../registry/common/auth/AccessControlService.java | 33 ++
.../auth/DefaultAccessControlServiceImpl.java | 62 ++++
.../registry/common/context/RequestContext.java | 80 +++++
.../common/context/RequestContextManager.java | 43 +++
.../common/context/StoragePluginContext.java | 37 +++
.../common/context/StorageServiceContext.java | 31 ++
.../schema/registry/common/dto/AuditDto.java | 51 +++
.../schema/registry/common/dto/BaseDto.java | 69 ++++
.../schema/registry/common/dto/FieldDto.java | 67 ++++
.../registry/common/dto/SchemaDetailDto.java | 41 +++
.../schema/registry/common/dto/SchemaDto.java | 61 ++++
.../schema/registry/common/dto/SchemaMetaDto.java | 58 ++++
.../registry/common/dto/SchemaRecordDto.java | 53 +++
.../registry/common/dto/SchemaStorageDto.java | 49 +++
.../schema/registry/common/dto/SubjectDto.java | 40 +++
.../common/exception/RequestExceptionHandler.java | 57 ++++
.../exception/SchemaAuthorizedException.java | 34 ++
.../exception/SchemaCompatibilityException.java | 36 +++
.../registry/common/exception/SchemaException.java | 45 +++
.../common/exception/SchemaExistException.java | 36 +++
.../common/exception/SchemaNotFoundException.java | 36 +++
.../registry/common/filter/RequestFilter.java | 91 ++++++
.../schema/registry/common/json/JsonConverter.java | 97 ++++++
.../registry/common/json/JsonConverterImpl.java | 99 ++++++
.../schema/registry/common/model/AuditInfo.java | 42 +++
.../schema/registry/common/model/BaseInfo.java | 43 +++
.../registry/common/model/Compatibility.java | 34 ++
.../schema/registry/common/model/Dependency.java | 49 +++
.../schema/registry/common/model/FieldInfo.java | 42 +++
.../registry/common/model/PluginLoadState.java | 26 ++
.../registry/common/model/SchemaDefination.java | 21 ++
.../registry/common/model/SchemaDetailInfo.java | 45 +++
.../schema/registry/common/model/SchemaEntity.java | 39 +++
.../schema/registry/common/model/SchemaInfo.java | 84 +++++
.../registry/common/model/SchemaMetaInfo.java | 43 +++
.../registry/common/model/SchemaOperation.java | 38 +++
.../registry/common/model/SchemaRecordInfo.java | 59 ++++
.../registry/common/model/SchemaStorageInfo.java | 42 +++
.../schema/registry/common/model/SchemaType.java | 53 +++
.../schema/registry/common/model/StorageType.java | 37 +++
.../schema/registry/common/model/SubjectInfo.java | 52 +++
.../registry/common/properties/AclProperties.java | 63 ++++
.../common/properties/CacheProperties.java | 26 ++
.../common/properties/DependencyProperties.java | 32 ++
.../registry/common/properties/GlobalConfig.java | 131 ++++++++
.../common/properties/GlobalConfigImpl.java | 110 +++++++
.../common/properties/SchemaProperties.java | 40 +++
.../common/properties/ServiceProperties.java | 27 ++
.../common/properties/StorageProperties.java | 36 +++
.../common/storage/DefaultStorageServiceImpl.java | 24 ++
.../common/storage/SpringStorageFactory.java | 70 ++++
.../registry/common/storage/StorageFactory.java | 51 +++
.../registry/common/storage/StorageManager.java | 126 ++++++++
.../registry/common/storage/StoragePlugin.java | 39 +++
.../common/storage/StoragePluginManager.java | 43 +++
.../registry/common/storage/StorageService.java | 81 +++++
.../common/storage/StorageServiceProxy.java | 121 +++++++
.../schema/registry/common/utils/CommonUtil.java | 247 ++++++++++++++
.../schema/registry/common/utils/IdGenerator.java | 27 ++
.../common/utils/MemoryJavaFileManager.java | 126 ++++++++
.../common/utils/SnowFlakeIdGenerator.java | 104 ++++++
.../schema/registry/common/utils/StorageUtil.java | 104 ++++++
core/.gitignore | 33 ++
core/.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 58727 bytes
core/.mvn/wrapper/maven-wrapper.properties | 2 +
core/mvnw | 316 ++++++++++++++++++
core/mvnw.cmd | 188 +++++++++++
core/pom.xml | 61 ++++
.../schema/registry/core/CoreApplication.java | 25 ++
.../schema/registry/core/api/RequestProcessor.java | 81 +++++
.../registry/core/api/v1/SchemaController.java | 355 +++++++++++++++++++++
.../registry/core/config/SchemaManagerConfig.java | 51 +++
.../core/config/SchemaPropertiesConfig.java | 52 +++
.../registry/core/config/SchemaServiceConfig.java | 110 +++++++
.../registry/core/config/SchemaUtilsConfig.java | 36 +++
.../schema/registry/core/config/SwaggerConfig.java | 112 +++++++
.../ArtifactoryDependencyServiceImpl.java | 79 +++++
.../registry/core/dependency/DependencyHelper.java | 111 +++++++
.../core/dependency/DependencyService.java | 36 +++
.../core/dependency/DynamicCompileProvider.java | 139 ++++++++
.../core/dependency/DynamicJarsProvider.java | 48 +++
.../schema/registry/core/package-info.java | 26 ++
.../core/service/SchemaInitializationService.java | 90 ++++++
.../registry/core/service/SchemaService.java | 70 ++++
.../registry/core/service/SchemaServiceImpl.java | 257 +++++++++++++++
.../schema/registry/core/service/Service.java | 25 ++
core/src/main/resources/application.properties | 29 ++
core/src/main/resources/template.pom | 11 +
.../schema/registry/core/CoreApplicationTests.java | 11 +
.../core/controller/HelloControllerTest.java | 34 ++
pom.xml | 171 ++++++++++
schema-storage-rocketmq/pom.xml | 50 +++
.../registry/storage/rocketmq/RocketmqClient.java | 344 ++++++++++++++++++++
.../storage/rocketmq/RocketmqStorageClient.java | 75 +++++
.../rocketmq/RocketmqStorageClientImpl.java | 95 ++++++
.../storage/rocketmq/RocketmqStorageFactory.java | 42 +++
.../storage/rocketmq/RocketmqStoragePlugin.java | 43 +++
.../storage/rocketmq/RocketmqStorageService.java | 80 +++++
.../storage/rocketmq/RocketmqStorageUtils.java | 38 +++
.../storage/rocketmq/configs/ClientConfig.java | 39 +++
.../rocketmq/configs/RocketmqConfigConstants.java | 50 +++
.../storage/rocketmq/configs/ServiceConfig.java | 39 +++
.../registry/storage/rocketmq/package-info.java | 26 ++
...mq.schema.registry.common.storage.StoragePlugin | 19 ++
.../src/main/resources/rocketmq.properties | 19 ++
storage-war/pom.xml | 57 ++++
.../rocketmq/schema/registry/StorageWar.java | 38 +++
112 files changed, 7527 insertions(+), 1 deletion(-)