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 <[email protected]> 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(-)
