This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.apache.kafka-kafka-clients-3.7.1
in repository https://gitbox.apache.org/repos/asf/ozhera.git
omit e53f3ea7 build(deps): bump org.apache.kafka:kafka-clients from 2.6.3
to 3.7.1
add 5cdcd64f refactor: add apache header (#511)
add 617fbd2c fix: update hera-log and hera-operator file header (#508)
add 05a504e3 build(deps): bump org.apache.kafka:kafka-clients from 2.6.3
to 3.7.1
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e53f3ea7)
\
N -- N -- N
refs/heads/dependabot/maven/org.apache.kafka-kafka-clients-3.7.1 (05a504e3)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
ozhera-log/.dockerignore | 7 -
ozhera-log/Ozhera_log_optimization.md | 20 ++
...227\245\345\277\227\344\274\230\345\214\226.md" | 20 ++
ozhera-log/README.md | 20 ++
ozhera-log/README_cn.md | 20 ++
ozhera-log/log-agent-server/Dockerfile | 14 ++
ozhera-log/log-agent-server/README.md | 20 ++
ozhera-log/log-agent-server/pom.xml | 20 ++
.../ozhera/log/server/LogAgentServerBootstrap.java | 25 ++-
.../ozhera/log/server/common/ServerConstant.java | 25 ++-
.../apache/ozhera/log/server/common/Version.java | 25 ++-
.../porcessor/AgentCollectProgressProcessor.java | 25 ++-
.../log/server/porcessor/AgentConfigProcessor.java | 26 +--
.../ozhera/log/server/porcessor/PingProcessor.java | 25 ++-
.../server/service/ApplicationShutdownHook.java | 25 ++-
.../server/service/DefaultAgentConfigAcquirer.java | 26 +--
.../server/service/DefaultLogProcessCollector.java | 25 ++-
.../service/DefaultPublishConfigService.java | 25 ++-
.../src/main/resources/config.properties | 14 ++
.../src/main/resources/config/open.properties | 14 ++
.../src/main/resources/logback.xml | 20 ++
.../log/server/DefaultAgentConfigAcquirerTest.java | 109 +++++-----
.../log/server/DefaultLogProcessCollectorTest.java | 148 ++++++-------
.../org/apache/ozhera/log/server/DubboTest.java | 80 +++----
ozhera-log/log-agent/Dockerfile | 14 ++
ozhera-log/log-agent/pom.xml | 20 ++
.../log/agent/bootstrap/MiLogAgentBootstrap.java | 25 ++-
.../log/agent/channel/AbstractChannelService.java | 25 ++-
.../ozhera/log/agent/channel/ChannelDefine.java | 25 ++-
.../ozhera/log/agent/channel/ChannelEngine.java | 25 ++-
.../ozhera/log/agent/channel/ChannelService.java | 25 ++-
.../log/agent/channel/ChannelServiceImpl.java | 25 ++-
.../ozhera/log/agent/channel/ChannelState.java | 25 ++-
.../apache/ozhera/log/agent/channel/Closeable.java | 25 ++-
.../agent/channel/WildcardChannelServiceImpl.java | 25 ++-
.../channel/comparator/AppSimilarComparator.java | 25 ++-
.../comparator/FilterSimilarComparator.java | 25 ++-
.../channel/comparator/InputSimilarComparator.java | 25 ++-
.../comparator/OutputSimilarComparator.java | 25 ++-
.../channel/comparator/SimilarComparator.java | 25 ++-
.../log/agent/channel/conf/AgentTailConf.java | 25 ++-
.../log/agent/channel/file/FileListener.java | 25 ++-
.../ozhera/log/agent/channel/file/FileMonitor.java | 25 ++-
.../ozhera/log/agent/channel/file/FileWatcher.java | 25 ++-
.../agent/channel/file/InodeFileComparator.java | 25 ++-
.../channel/file/LogFileAlterationObserver.java | 25 ++-
.../ozhera/log/agent/channel/file/MonitorFile.java | 25 ++-
.../listener/DefaultFileMonitorListener.java | 25 ++-
.../channel/listener/FileMonitorListener.java | 25 ++-
.../channel/locator/ChannelDefineJsonLocator.java | 25 ++-
.../channel/locator/ChannelDefineLocator.java | 25 ++-
.../channel/locator/ChannelDefineRpcLocator.java | 25 ++-
.../agent/channel/memory/AgentMemoryService.java | 25 ++-
.../channel/memory/AgentMemoryServiceImpl.java | 25 ++-
.../log/agent/channel/memory/ChannelMemory.java | 25 ++-
.../log/agent/common/AbstractElementAdapter.java | 25 ++-
.../ozhera/log/agent/common/ChannelUtil.java | 25 ++-
.../ozhera/log/agent/common/ExecutorUtil.java | 25 ++-
.../apache/ozhera/log/agent/common/HashUtil.java | 25 ++-
.../apache/ozhera/log/agent/common/Version.java | 25 ++-
.../ozhera/log/agent/common/trace/MessageUtil.java | 25 ++-
.../ozhera/log/agent/common/trace/TraceUtil.java | 25 ++-
.../ozhera/log/agent/exception/AgentException.java | 25 ++-
.../ozhera/log/agent/export/MsgExporter.java | 25 ++-
.../ozhera/log/agent/extension/KafkaExporter.java | 25 ++-
.../ozhera/log/agent/extension/KafkaOutput.java | 25 ++-
.../ozhera/log/agent/extension/KafkaService.java | 25 ++-
.../ozhera/log/agent/extension/RmqExporter.java | 25 ++-
.../ozhera/log/agent/extension/RmqOutput.java | 25 ++-
.../log/agent/extension/RocketMQService.java | 25 ++-
.../log/agent/factory/OutPutServiceFactory.java | 25 ++-
.../ozhera/log/agent/filter/FilterChain.java | 25 ++-
.../ozhera/log/agent/filter/FilterTrans.java | 25 ++-
.../apache/ozhera/log/agent/filter/Invoker.java | 25 ++-
.../ozhera/log/agent/filter/MilogFilter.java | 25 ++-
.../agent/filter/ratelimit/RatelimitFilter.java | 25 ++-
.../apache/ozhera/log/agent/input/AppLogInput.java | 25 ++-
.../ozhera/log/agent/input/FreeLogInput.java | 25 ++-
.../org/apache/ozhera/log/agent/input/Input.java | 25 ++-
.../ozhera/log/agent/input/MisAppLogInput.java | 25 ++-
.../apache/ozhera/log/agent/input/NginxInput.java | 25 ++-
.../ozhera/log/agent/input/OpentelemetryInput.java | 25 ++-
.../ozhera/log/agent/input/OriginLogInput.java | 25 ++-
.../org/apache/ozhera/log/agent/output/Output.java | 25 ++-
.../ozhera/log/agent/rpc/processor/IService.java | 25 ++-
.../log/agent/rpc/processor/LogProcessor.java | 25 ++-
.../log/agent/rpc/processor/ProcessorInit.java | 25 ++-
.../apache/ozhera/log/agent/rpc/task/PingTask.java | 25 ++-
.../service/ChannelDefineLocatorExtension.java | 25 ++-
.../ozhera/log/agent/service/OutPutService.java | 25 ++-
.../log/agent/service/ServiceRegistryService.java | 26 +--
.../OuterChannelDefineLocatorExtensionImpl.java | 25 ++-
.../service/impl/ServiceRegistryServiceImpl.java | 26 +--
.../log-agent/src/main/resources/config.properties | 14 ++
.../src/main/resources/config/dev.properties | 14 ++
.../src/main/resources/config/open.properties | 14 ++
.../log-agent/src/main/resources/logback.xml | 20 ++
.../org/apache/ozhera/log/agent/Comparator.java | 25 ++-
.../log/agent/DefaultFileMonitorListenerTest.java | 25 ++-
.../org/apache/ozhera/log/agent/FileInodeTest.java | 25 ++-
.../apache/ozhera/log/agent/FilterMonitorTest.java | 25 ++-
.../apache/ozhera/log/agent/LogProcessorTest.java | 25 ++-
.../log/agent/channel/ChannelServiceTest.java | 25 ++-
.../ozhera/log/agent/common/ExecutorUtilTest.java | 25 ++-
.../log/agent/common/trace/TraceUtilTest.java | 25 ++-
.../log/agent/extension/RocketMQServiceTest.java | 25 ++-
.../ozhera/log/agent/filter/ComparatorTest.java | 25 ++-
.../ozhera/log/agent/filter/FilterTransTest.java | 25 ++-
.../org/apache/ozhera/log/agent/lock/LockTest.java | 25 ++-
.../service/ChannelDefineRpcLocatorTest.java | 25 ++-
.../log/agent/rpc/processor/service/LimitTest.java | 25 ++-
.../log/agent/rpc/processor/service/RpcTest.java | 25 ++-
ozhera-log/log-api/pom.xml | 20 ++
.../apache/ozhera/log/api/enums/AppTypeEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/DeployWayEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/ESClusterEnum.java | 25 ++-
.../ozhera/log/api/enums/EsOperatorEnum.java | 25 ++-
.../ozhera/log/api/enums/EsOperatorMatchEnum.java | 25 ++-
.../ozhera/log/api/enums/FavouriteSearchEnum.java | 25 ++-
.../ozhera/log/api/enums/K8sPodTypeEnum.java | 25 ++-
.../ozhera/log/api/enums/LogStorageTypeEnum.java | 26 +--
.../ozhera/log/api/enums/LogStructureEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/LogTypeEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/MQSourceEnum.java | 25 ++-
.../ozhera/log/api/enums/MachineRegionEnum.java | 25 ++-
.../ozhera/log/api/enums/MachineTypeEnum.java | 25 ++-
.../ozhera/log/api/enums/MiddlewareEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/OperateEnum.java | 25 ++-
.../ozhera/log/api/enums/ProjectSourceEnum.java | 25 ++-
.../ozhera/log/api/enums/ProjectTypeEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/RateLimitEnum.java | 25 ++-
.../apache/ozhera/log/api/enums/ResourceEnum.java | 25 ++-
.../org/apache/ozhera/log/api/filter/Common.java | 25 ++-
.../ozhera/log/api/filter/RateLimitStrategy.java | 25 ++-
.../apache/ozhera/log/api/model/bo/AlertInfo.java | 25 ++-
.../ozhera/log/api/model/bo/MiLogMoneTransfer.java | 25 ++-
.../ozhera/log/api/model/bo/MiLogResource.java | 25 ++-
.../ozhera/log/api/model/bo/ResourcePage.java | 25 ++-
.../ozhera/log/api/model/dto/MontorAppDTO.java | 25 ++-
.../ozhera/log/api/model/dto/TraceLogDTO.java | 25 ++-
.../ozhera/log/api/model/meta/AgentDefine.java | 25 ++-
.../ozhera/log/api/model/meta/AppLogMeta.java | 25 ++-
.../ozhera/log/api/model/meta/FilterConf.java | 25 ++-
.../ozhera/log/api/model/meta/FilterDefine.java | 25 ++-
.../ozhera/log/api/model/meta/FilterName.java | 25 ++-
.../ozhera/log/api/model/meta/FilterType.java | 25 ++-
.../ozhera/log/api/model/meta/LogCollectMeta.java | 25 ++-
.../ozhera/log/api/model/meta/LogPattern.java | 25 ++-
.../apache/ozhera/log/api/model/meta/MQConfig.java | 25 ++-
.../ozhera/log/api/model/meta/package-info.java | 25 ++-
.../ozhera/log/api/model/msg/LineMessage.java | 25 ++-
.../log/api/model/vo/AgentLogProcessDTO.java | 25 ++-
.../ozhera/log/api/model/vo/AlarmPattern.java | 25 ++-
.../apache/ozhera/log/api/model/vo/CommonVo.java | 25 ++-
.../apache/ozhera/log/api/model/vo/EsIndexVo.java | 25 ++-
.../org/apache/ozhera/log/api/model/vo/LogCmd.java | 25 ++-
.../ozhera/log/api/model/vo/LogRecordConfig.java | 25 ++-
.../ozhera/log/api/model/vo/MiLogMoneEnv.java | 25 ++-
.../apache/ozhera/log/api/model/vo/PingReq.java | 25 ++-
.../ozhera/log/api/model/vo/ResourceInfo.java | 25 ++-
.../log/api/model/vo/ResourceUserSimple.java | 25 ++-
.../ozhera/log/api/model/vo/TailLogProcessDTO.java | 25 ++-
.../ozhera/log/api/model/vo/TraceLogQuery.java | 25 ++-
.../log/api/model/vo/UpdateLogProcessCmd.java | 25 ++-
.../ozhera/log/api/model/vo/ValueKeyObj.java | 25 ++-
.../ozhera/log/api/service/AgentConfigService.java | 25 ++-
.../ozhera/log/api/service/LogCountService.java | 25 ++-
.../ozhera/log/api/service/LogDataService.java | 25 ++-
.../log/api/service/LogProcessCollector.java | 25 ++-
.../ozhera/log/api/service/LogProcessService.java | 25 ++-
.../ozhera/log/api/service/MilogOpenService.java | 25 ++-
.../log/api/service/PublishConfigService.java | 25 ++-
.../ozhera/log/api/LogStorageTypeEnumTest.java | 25 ++-
ozhera-log/log-common/pom.xml | 20 ++
.../ozhera/log/annotation/UnifiedResponse.java | 25 ++-
.../java/org/apache/ozhera/log/common/Config.java | 25 ++-
.../org/apache/ozhera/log/common/Constant.java | 25 ++-
.../main/java/org/apache/ozhera/log/common/Es.java | 25 ++-
.../apache/ozhera/log/common/HeraLocalCache.java | 25 ++-
.../org/apache/ozhera/log/common/MiLogCmd.java | 25 ++-
.../org/apache/ozhera/log/common/NetUtils.java | 25 ++-
.../org/apache/ozhera/log/common/PathUtils.java | 25 ++-
.../java/org/apache/ozhera/log/common/Result.java | 25 ++-
.../apache/ozhera/log/exception/CommonError.java | 26 +--
.../ozhera/log/exception/CommonException.java | 25 ++-
.../org/apache/ozhera/log/model/LogtailConfig.java | 25 ++-
.../apache/ozhera/log/model/MiLogStreamConfig.java | 25 ++-
.../apache/ozhera/log/model/MilogSpaceData.java | 25 ++-
.../apache/ozhera/log/model/MilogStreamData.java | 25 ++-
.../org/apache/ozhera/log/model/SinkConfig.java | 25 ++-
.../org/apache/ozhera/log/model/StorageInfo.java | 25 ++-
.../apache/ozhera/log/parse/AbstractLogParser.java | 25 ++-
.../apache/ozhera/log/parse/CustomLogParser.java | 25 ++-
.../apache/ozhera/log/parse/FieldInterceptor.java | 25 ++-
.../org/apache/ozhera/log/parse/JsonLogParser.java | 25 ++-
.../org/apache/ozhera/log/parse/LogParser.java | 25 ++-
.../org/apache/ozhera/log/parse/LogParserData.java | 25 ++-
.../apache/ozhera/log/parse/LogParserFactory.java | 25 ++-
.../apache/ozhera/log/parse/NginxLogParser.java | 25 ++-
.../org/apache/ozhera/log/parse/RawLogParser.java | 25 ++-
.../apache/ozhera/log/parse/RegexLogParser.java | 25 ++-
.../ozhera/log/parse/SeparatorLogParser.java | 25 ++-
.../org/apache/ozhera/log/utils/ConfigUtils.java | 25 ++-
.../org/apache/ozhera/log/utils/DateUtils.java | 25 ++-
.../org/apache/ozhera/log/utils/IndexUtils.java | 25 ++-
.../org/apache/ozhera/log/utils/KafkaUtils.java | 25 ++-
.../java/org/apache/ozhera/log/utils/NetUtil.java | 25 ++-
.../org/apache/ozhera/log/utils/PinYin4jUtils.java | 25 ++-
.../org/apache/ozhera/log/utils/SimilarUtils.java | 25 ++-
.../apache/ozhera/log/common/DateUtilsTest.java | 25 ++-
.../apache/ozhera/log/common/IndexUtilsTest.java | 25 ++-
.../org/apache/ozhera/log/common/LineMessage.java | 25 ++-
.../ozhera/log/common/LogParserFactoryTest.java | 25 ++-
.../apache/ozhera/log/common/LogParserTest.java | 25 ++-
.../org/apache/ozhera/log/common/NetUtilsTest.java | 26 +--
.../apache/ozhera/log/common/PathUtilsTest.java | 25 ++-
.../ozhera/log/common/PinYin4jUtilsTest.java | 25 ++-
.../apache/ozhera/log/common/SimilarityTest.java | 25 ++-
ozhera-log/log-manager/Dockerfile | 14 ++
ozhera-log/log-manager/pom.xml | 21 ++
.../apache/ozhera/log/manager/bootstrap/Cache.java | 25 ++-
.../log/manager/bootstrap/LogStoragePlugin.java | 25 ++-
.../manager/bootstrap/MiLogManagerBootstrap.java | 25 ++-
.../ozhera/log/manager/common/ErrorCode.java | 25 ++-
.../ozhera/log/manager/common/ExceptionCode.java | 25 ++-
.../ozhera/log/manager/common/ManagerConstant.java | 25 ++-
.../ozhera/log/manager/common/MilogConfig.java | 25 ++-
.../apache/ozhera/log/manager/common/Result.java | 25 ++-
.../apache/ozhera/log/manager/common/Utils.java | 25 ++-
.../apache/ozhera/log/manager/common/Version.java | 25 ++-
.../log/manager/common/context/MilogUserUtil.java | 25 ++-
.../manager/common/context/MoneUserContext.java | 25 ++-
.../common/exception/MilogManageException.java | 25 ++-
.../manager/common/helper/MilogAccessHelper.java | 25 ++-
.../log/manager/common/utils/ExportUtils.java | 25 ++-
.../log/manager/common/utils/ManagerUtil.java | 25 ++-
.../manager/common/validation/HeraConfigValid.java | 25 ++-
.../manager/common/validation/OpenSourceValid.java | 25 ++-
.../common/validation/ResourceValidation.java | 25 ++-
.../common/validation/StoreSpaceAuthValid.java | 25 ++-
.../manager/common/validation/StoreValidation.java | 25 ++-
.../log/manager/controller/EsDataController.java | 25 ++-
.../manager/controller/LogAnalyseController.java | 25 ++-
.../manager/controller/LogTemplateController.java | 25 ++-
.../controller/MIlogAgentManageController.java | 25 ++-
.../controller/MiLogMetaManageController.java | 25 ++-
.../controller/MiLogResourceController.java | 25 ++-
.../manager/controller/MilogConfigController.java | 25 ++-
.../controller/MilogDictionaryController.java | 25 ++-
.../manager/controller/MilogLoginController.java | 25 ++-
.../MilogMiddlewareConfigController.java | 25 ++-
.../controller/MilogStatisticController.java | 26 +--
.../controller/MilogStoreSpaceAuthController.java | 25 ++-
.../manager/controller/MilogStreamController.java | 25 ++-
.../controller/StreamPartitionController.java | 25 ++-
.../interceptor/HttpRequestInterceptor.java | 25 ++-
.../log/manager/dao/LogStreamBalanceConfigDao.java | 25 ++-
.../log/manager/dao/MilogAppMiddlewareRelDao.java | 25 ++-
.../log/manager/dao/MilogAppTopicRelDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogLockDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogLogProcessDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogLogTailDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogLogstoreDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogMachineDao.java | 25 ++-
.../log/manager/dao/MilogMiddlewareConfigDao.java | 25 ++-
.../manager/dao/MilogRegionAvailableZoneDao.java | 25 ++-
.../ozhera/log/manager/dao/MilogSpaceDao.java | 25 ++-
.../log/manager/dao/MilogStoreSpaceAuthDao.java | 25 ++-
.../ozhera/log/manager/domain/AnalyseLog.java | 25 ++-
.../ozhera/log/manager/domain/ClusterIndexVO.java | 25 ++-
.../org/apache/ozhera/log/manager/domain/Down.java | 25 ++-
.../ozhera/log/manager/domain/EsCluster.java | 25 ++-
.../ozhera/log/manager/domain/EsIndexTemplate.java | 35 ++--
.../ozhera/log/manager/domain/LogProcess.java | 25 ++-
.../apache/ozhera/log/manager/domain/LogStore.java | 25 ++-
.../apache/ozhera/log/manager/domain/LogTail.java | 25 ++-
.../ozhera/log/manager/domain/LogTemplate.java | 25 ++-
.../ozhera/log/manager/domain/SearchLog.java | 25 ++-
.../apache/ozhera/log/manager/domain/Store.java | 25 ++-
.../org/apache/ozhera/log/manager/domain/Tpc.java | 25 ++-
.../apache/ozhera/log/manager/domain/TraceLog.java | 25 ++-
.../log/manager/domain/analyse/AggrCalcu.java | 25 ++-
.../manager/domain/analyse/AggrCalcuStrategy.java | 25 ++-
.../manager/domain/analyse/DateGroupStrategy.java | 25 ++-
.../log/manager/domain/analyse/FieldStrategy.java | 25 ++-
.../apache/ozhera/log/manager/job/EsIndexJob.java | 25 ++-
.../ozhera/log/manager/job/TailLogCountJob.java | 25 ++-
.../MilogAnalyseDashboardGraphRefMapper.java | 25 ++-
.../mapper/MilogAnalyseDashboardMapper.java | 25 ++-
.../manager/mapper/MilogAnalyseGraphMapper.java | 25 ++-
.../mapper/MilogAnalyseGraphTypeMapper.java | 25 ++-
.../log/manager/mapper/MilogEsClusterMapper.java | 25 ++-
.../log/manager/mapper/MilogEsIndexMapper.java | 25 ++-
.../log/manager/mapper/MilogLogCountMapper.java | 25 ++-
.../log/manager/mapper/MilogLogNumAlertMapper.java | 25 ++-
.../log/manager/mapper/MilogLogProcessMapper.java | 25 ++-
.../manager/mapper/MilogLogSearchSaveMapper.java | 25 ++-
.../mapper/MilogLogTemplateDetailMapper.java | 25 ++-
.../log/manager/mapper/MilogLogTemplateMapper.java | 25 ++-
.../log/manager/mapper/MilogLogstailMapper.java | 25 ++-
.../log/manager/model/bo/AccessMilogParam.java | 25 ++-
.../ozhera/log/manager/model/bo/AppTopicParam.java | 25 ++-
.../log/manager/model/bo/AutoAccessLogParam.java | 25 ++-
.../log/manager/model/bo/BatchQueryParam.java | 25 ++-
.../log/manager/model/bo/CalcuAggrParam.java | 25 ++-
.../log/manager/model/bo/EsStatisticParam.java | 25 ++-
.../log/manager/model/bo/IpPartitionBalance.java | 25 ++-
.../ozhera/log/manager/model/bo/LogTailParam.java | 25 ++-
.../log/manager/model/bo/MachineParamParam.java | 25 ++-
.../manager/model/bo/MachinePartitionBalance.java | 25 ++-
.../log/manager/model/bo/MachineQueryParam.java | 25 ++-
.../log/manager/model/bo/MiddlewareAddParam.java | 25 ++-
.../log/manager/model/bo/MiddlewareQueryParam.java | 25 ++-
.../manager/model/bo/MiddlewareUpdateParam.java | 25 ++-
.../log/manager/model/bo/MilogAgentIpParam.java | 25 ++-
.../log/manager/model/bo/MilogDictionaryParam.java | 25 ++-
.../log/manager/model/bo/MilogLogstoreBo.java | 25 ++-
.../log/manager/model/bo/MilogPageParam.java | 25 ++-
.../log/manager/model/bo/MlogParseParam.java | 25 ++-
.../ozhera/log/manager/model/bo/RegionZoneBo.java | 25 ++-
.../manager/model/bo/RocketMqStatisticParam.java | 25 ++-
.../manager/model/bo/SpacePartitionBalance.java | 25 ++-
.../log/manager/model/bo/StoreSpaceAuth.java | 25 ++-
.../ozhera/log/manager/model/vo/LogQuery.java | 1 +
.../ozhera/log/manager/service/BaseService.java | 25 ++-
.../log/manager/service/CommonRocketMqService.java | 25 ++-
.../log/manager/service/EsDataBaseService.java | 25 ++-
.../ozhera/log/manager/service/EsDataService.java | 25 ++-
.../log/manager/service/EsIndexOperateService.java | 25 ++-
.../manager/service/EsIndexTemplateService.java | 25 ++-
.../log/manager/service/HeraAppEnvService.java | 25 ++-
.../ozhera/log/manager/service/HeraAppService.java | 25 ++-
.../manager/service/HeralogHomePageService.java | 26 +--
.../manager/service/IMilogEsClusterService.java | 25 ++-
.../log/manager/service/IMilogEsIndexService.java | 25 ++-
.../service/IMilogLogSearchSaveService.java | 25 ++-
.../log/manager/service/LogAnalyseService.java | 25 ++-
.../log/manager/service/LogCountService.java | 25 ++-
.../log/manager/service/LogQueryService.java | 25 ++-
.../log/manager/service/LogSearchSaveService.java | 25 ++-
.../log/manager/service/LogSpaceService.java | 25 ++-
.../log/manager/service/LogStoreService.java | 25 ++-
.../ozhera/log/manager/service/LogTailService.java | 25 ++-
.../log/manager/service/LogTemplateService.java | 25 ++-
.../manager/service/MiLogMetaManageService.java | 25 ++-
.../service/MilogAppMiddlewareRelService.java | 25 ++-
.../manager/service/MilogConfigNacosService.java | 25 ++-
.../manager/service/MilogDictionaryService.java | 25 ++-
.../log/manager/service/MilogMachineService.java | 25 ++-
.../service/MilogMiddlewareConfigService.java | 25 ++-
.../service/MilogStoreSpaceAuthService.java | 25 ++-
.../log/manager/service/MilogStreamService.java | 25 ++-
.../log/manager/service/MqConfigService.java | 25 ++-
.../log/manager/service/SpaceAuthService.java | 25 ++-
.../log/manager/service/StatisticsService.java | 26 +--
.../manager/service/StreamPartitionService.java | 25 ++-
.../service/bind/ConfigLogTypeProcessor.java | 25 ++-
.../service/bind/DataSourceLogTypeProcessor.java | 25 ++-
.../log/manager/service/bind/LogTypeProcessor.java | 25 ++-
.../service/bind/LogTypeProcessorFactory.java | 25 ++-
.../ozhera/log/manager/service/bind/Processor.java | 25 ++-
.../log/manager/service/bind/package-info.java | 25 ++-
.../service/consumer/MioneRocketMqConsumer.java | 25 ++-
.../manager/service/consumer/RocketMqConsumer.java | 25 ++-
.../log/manager/service/env/HeraEnvIpService.java | 25 ++-
.../service/env/HeraEnvIpServiceFactory.java | 25 ++-
.../manager/service/env/MoneHeraEnvIpService.java | 25 ++-
.../service/extension/agent/MilogAgentService.java | 25 ++-
.../extension/agent/MilogAgentServiceFactory.java | 25 ++-
.../extension/agent/MilogAgentServiceImpl.java | 25 ++-
.../extension/common/CommonExtensionService.java | 25 ++-
.../common/CommonExtensionServiceFactory.java | 25 ++-
.../common/DefaultCommonExtensionService.java | 25 ++-
.../DefaultDictionaryExtensionService.java | 25 ++-
.../dictionary/DictionaryExtensionService.java | 25 ++-
.../DictionaryExtensionServiceFactory.java | 25 ++-
.../resource/DefaultResourceExtensionService.java | 25 ++-
.../resource/ResourceExtensionService.java | 25 ++-
.../resource/ResourceExtensionServiceFactory.java | 25 ++-
.../store/DefaultStoreExtensionService.java | 25 ++-
.../extension/store/DorisLogStorageService.java | 25 ++-
.../extension/store/EsLogStorageService.java | 25 ++-
.../service/extension/store/LogStorageService.java | 25 ++-
.../extension/store/StoreExtensionService.java | 25 ++-
.../store/StoreExtensionServiceFactory.java | 25 ++-
.../tail/DefaultTailExtensionService.java | 25 ++-
.../extension/tail/TailExtensionService.java | 25 ++-
.../tail/TailExtensionServiceFactory.java | 25 ++-
.../service/impl/AgentConfigServiceImpl.java | 25 ++-
.../manager/service/impl/EsDataServiceImpl.java | 25 ++-
.../service/impl/EsIndexOperateServiceImpl.java | 25 ++-
.../service/impl/EsIndexTemplateServiceImpl.java | 25 ++-
.../service/impl/HeraAppEnvServiceImpl.java | 25 ++-
.../manager/service/impl/HeraAppServiceImpl.java | 25 ++-
.../service/impl/HeralogHomePageServiceImpl.java | 26 +--
.../manager/service/impl/KafkaMqConfigService.java | 25 ++-
.../manager/service/impl/LogAnalyseService.java | 25 ++-
.../manager/service/impl/LogCountServiceImpl.java | 25 ++-
.../service/impl/LogProcessServiceImpl.java | 25 ++-
.../manager/service/impl/LogQueryServiceImpl.java | 25 ++-
.../service/impl/LogSearchSaveServiceImpl.java | 25 ++-
.../manager/service/impl/LogSpaceServiceImpl.java | 25 ++-
.../manager/service/impl/LogStoreServiceImpl.java | 25 ++-
.../manager/service/impl/LogTailServiceImpl.java | 25 ++-
.../service/impl/LogTemplateServiceImpl.java | 25 ++-
.../service/impl/MiLogMetaManageServiceImpl.java | 25 ++-
.../impl/MilogAppMiddlewareRelServiceImpl.java | 25 ++-
.../service/impl/MilogConfigNacosServiceImpl.java | 25 ++-
.../service/impl/MilogDictionaryServiceImpl.java | 25 ++-
.../service/impl/MilogEsClusterServiceImpl.java | 25 ++-
.../service/impl/MilogEsIndexServiceImpl.java | 25 ++-
.../impl/MilogLogSearchSaveServiceImpl.java | 25 ++-
.../service/impl/MilogMachineServiceImpl.java | 25 ++-
.../impl/MilogMiddlewareConfigServiceImpl.java | 25 ++-
.../manager/service/impl/MilogOpenServiceImpl.java | 25 ++-
.../impl/MilogStoreSpaceAuthServiceImpl.java | 25 ++-
.../service/impl/MilogStreamServiceImpl.java | 25 ++-
.../service/impl/RocketMqConfigService.java | 25 ++-
.../service/impl/StatisticsServiceImpl.java | 25 ++-
.../service/impl/StreamPartitionServiceImpl.java | 25 ++-
.../manager/service/impl/TpcSpaceAuthService.java | 25 ++-
.../service/init_sql/AnalyseGraphTypeService.java | 25 ++-
.../service/init_sql/HeraLogTemplateService.java | 25 ++-
.../service/init_sql/NcosConfigSqlService.java | 25 ++-
.../log/manager/service/init_sql/package-info.java | 25 ++-
.../service/listener/AutoLogAccessListener.java | 25 ++-
.../log/manager/service/nacos/Converter.java | 25 ++-
.../service/nacos/DynamicConfigProvider.java | 25 ++-
.../service/nacos/DynamicConfigPublisher.java | 25 ++-
.../service/nacos/FetchStreamMachineService.java | 25 ++-
.../log/manager/service/nacos/InitService.java | 25 ++-
.../manager/service/nacos/MultipleNacosConfig.java | 25 ++-
.../nacos/impl/NacosFetchStreamMachineService.java | 25 ++-
.../nacos/impl/SpaceConfigNacosProvider.java | 25 ++-
.../nacos/impl/SpaceConfigNacosPublisher.java | 25 ++-
.../nacos/impl/StreamConfigNacosProvider.java | 25 ++-
.../nacos/impl/StreamConfigNacosPublisher.java | 25 ++-
.../log/manager/service/path/LogPathMapping.java | 25 ++-
.../service/path/LogPathMappingFactory.java | 25 ++-
.../manager/service/path/MoneLogPathMapping.java | 25 ++-
.../statement/AndAllStatementMatchParse.java | 25 ++-
.../statement/MustNotStatementMatchParse.java | 25 ++-
.../service/statement/MustStatementMatchParse.java | 25 ++-
.../statement/NotAllStatementMatchParse.java | 25 ++-
.../manager/service/statement/OperatorData.java | 25 ++-
.../manager/service/statement/OperatorSlice.java | 25 ++-
.../statement/OrAllStatementMatchParse.java | 25 ++-
.../service/statement/OrStatementMatchParse.java | 25 ++-
.../log/manager/service/statement/QueryEntity.java | 25 ++-
.../service/statement/StatementMatchParse.java | 25 ++-
.../statement/StatementMatchParseFactory.java | 25 ++-
.../apache/ozhera/log/manager/user/MoneUser.java | 25 ++-
.../log/manager/user/MoneUserDetailService.java | 25 ++-
.../apache/ozhera/log/manager/user/MoneUtil.java | 25 ++-
.../ozhera/log/manager/user/UseDetailInfo.java | 25 ++-
.../ozhera/log/manager/user/UserIDService.java | 25 ++-
.../src/main/resources/config.properties | 14 ++
.../src/main/resources/config/open.properties | 14 ++
ozhera-log/log-manager/src/main/resources/log.sql | 19 +-
.../log-manager/src/main/resources/logback.xml | 20 ++
.../mapper/MilogAnalyseDashboardGraphRefMapper.xml | 20 ++
.../mapper/MilogAnalyseDashboardMapper.xml | 20 ++
.../resources/mapper/MilogAnalyseGraphMapper.xml | 20 ++
.../mapper/MilogAnalyseGraphTypeMapper.xml | 20 ++
.../main/resources/mapper/MilogEsClusterMapper.xml | 20 ++
.../main/resources/mapper/MilogEsIndexMapper.xml | 20 ++
.../main/resources/mapper/MilogLogCountMapper.xml | 20 ++
.../resources/mapper/MilogLogNumAlertMapper.xml | 20 ++
.../resources/mapper/MilogLogProcessMapper.xml | 20 ++
.../resources/mapper/MilogLogSearchSaveMapper.xml | 20 ++
.../mapper/MilogLogTemplateDetailMapper.xml | 20 ++
.../resources/mapper/MilogLogTemplateMapper.xml | 20 ++
.../main/resources/mapper/MilogLogstailMapper.xml | 20 ++
.../src/main/resources/sql/log-data.sql | 31 +--
.../log-manager/src/main/resources/sql/log.sql | 31 +--
.../ozhera/log/manager/AgentHearJobTest.java | 25 ++-
.../apache/ozhera/log/manager/CodeGenerator.java | 25 ++-
.../org/apache/ozhera/log/manager/CommonTest.java | 25 ++-
.../apache/ozhera/log/manager/DevoraFlinkTest.java | 25 ++-
.../log/manager/FunctionalInterfaceTest.java | 25 ++-
.../apache/ozhera/log/manager/HttpClientTest.java | 25 ++-
.../apache/ozhera/log/manager/ManagerUtilTest.java | 25 ++-
.../ozhera/log/manager/MilogAccessHelperTest.java | 25 ++-
.../apache/ozhera/log/manager/RateLimiterTest.java | 25 ++-
.../apache/ozhera/log/manager/TestHttpClient.java | 96 +++++++++
.../manager/bootstrap/LogStoragePluginTest.java | 25 ++-
.../ozhera/log/manager/dao/LogStoreDaoTest.java | 25 ++-
.../ozhera/log/manager/domain/AnalyseLogTest.java | 93 ++++-----
.../ozhera/log/manager/domain/EsClusterTest.java | 87 ++++----
.../ozhera/log/manager/domain/LogProcessTest.java | 127 ++++++------
.../ozhera/log/manager/domain/LogTemplateTest.java | 30 +--
.../ozhera/log/manager/domain/analyse/TopTest.java | 25 ++-
.../esParse/StatementMatchParseFactoryTest.java | 25 ++-
.../manager/esParse/StatementMatchParseTest.java | 25 ++-
.../log/manager/filter/cons/RateLimitConsTest.java | 25 ++-
.../manager/mapper/MilogLogProcessMapperTest.java | 25 ++-
.../log/manager/service/AlertProcessorTest.java | 25 ++-
.../service/DorisLogStorageServiceTest.java | 194 ++++++++---------
.../log/manager/service/EsDataServiceTest.java | 121 +++++------
.../log/manager/service/FlinkAlphaServiceTest.java | 25 ++-
.../manager/service/KafkaMqConfigServiceTest.java | 25 ++-
.../service/MilogAppMiddlewareRelDaoTest.java | 25 ++-
.../log/manager/service/SendAlertLinkTest.java | 25 ++-
.../log/manager/service/StatisticsServiceTest.java | 132 ++++++------
.../apache/ozhera/log/manager/service/TpcTest.java | 25 ++-
.../impl/EsIndexTemplateServiceImplTest.java | 25 ++-
.../service/impl/LogProcessServiceImplTest.java | 25 ++-
.../service/impl/LogStoreServiceImplTest.java | 114 +++++-----
.../service/impl/LogTailServiceImplTest.java | 147 ++++++-------
.../service/impl/LogTemplateServiceImplTest.java | 106 +++++-----
.../impl/MiLogMetaManageServiceImplTest.java | 25 ++-
.../service/impl/MilogAgentServiceImplTest.java | 25 ++-
.../service/impl/MilogLogTailServiceTest.java | 117 ++++++-----
.../impl/MilogMiddlewareConfigServiceImplTest.java | 25 ++-
.../manager/service/impl/MilogOpenServiceTest.java | 25 ++-
.../manager/service/impl/MqConfigServiceTest.java | 229 ++++++++++-----------
.../manager/service/impl/TraceLogServiceTest.java | 25 ++-
.../log/manager/test/ConfigNacosServiceTest.java | 25 ++-
.../log/manager/test/CustomObjectTypeAdapter.java | 25 ++-
.../ozhera/log/manager/test/IntrospectorTest.java | 25 ++-
.../log/manager/test/MilogConfigServiceTest.java | 25 ++-
.../apache/ozhera/log/manager/test/SimpleTest.java | 25 ++-
.../apache/ozhera/log/manager/test/StreamTest.java | 25 ++-
ozhera-log/log-stream/Dockerfile | 14 ++
ozhera-log/log-stream/pom.xml | 21 ++
.../log/stream/bootstrap/MiLogStreamBootstrap.java | 25 ++-
.../ozhera/log/stream/bootstrap/StreamManage.java | 25 ++-
.../log/stream/common/LogStreamConstants.java | 25 ++-
.../ozhera/log/stream/common/SinkJobEnum.java | 25 ++-
.../ozhera/log/stream/common/util/StreamUtils.java | 25 ++-
.../ozhera/log/stream/config/ConfigManager.java | 25 ++-
.../log/stream/config/MilogConfigListener.java | 25 ++-
.../log/stream/exception/StreamException.java | 25 ++-
.../apache/ozhera/log/stream/job/JobManager.java | 25 ++-
.../apache/ozhera/log/stream/job/LogConfig.java | 25 ++-
.../ozhera/log/stream/job/LogDataTransfer.java | 25 ++-
.../ozhera/log/stream/job/LogSendFilter.java | 25 ++-
.../ozhera/log/stream/job/PullConfigJob.java | 25 ++-
.../log/stream/job/ServiceRegistryService.java | 25 ++-
.../ozhera/log/stream/job/SinkJobConfig.java | 25 ++-
.../log/stream/job/compensate/MqMessageDTO.java | 25 ++-
.../job/compensate/StreamCompensateTask.java | 25 ++-
.../stream/job/extension/CompensateMsgConsume.java | 25 ++-
.../extension/CompensateMsgConsumeProvider.java | 25 ++-
.../stream/job/extension/DefaultLogSendFilter.java | 25 ++-
.../ozhera/log/stream/job/extension/MQConfig.java | 25 ++-
.../ozhera/log/stream/job/extension/MQPlugin.java | 25 ++-
.../job/extension/MessageLifecycleManager.java | 25 ++-
.../log/stream/job/extension/MessageSender.java | 25 ++-
.../stream/job/extension/MessageSenderFactory.java | 25 ++-
.../job/extension/MessageSenderProvider.java | 25 ++-
.../job/extension/MqMessagePostProcessing.java | 25 ++-
.../log/stream/job/extension/MqMessageProduct.java | 25 ++-
.../ozhera/log/stream/job/extension/SinkJob.java | 25 ++-
.../log/stream/job/extension/SinkJobProvider.java | 25 ++-
.../job/extension/StreamCommonExtension.java | 25 ++-
.../impl/DefaultMessageLifecycleManager.java | 25 ++-
.../impl/DefaultStreamCommonExtension.java | 25 ++-
.../job/extension/impl/DorisMessageSender.java | 25 ++-
.../stream/job/extension/impl/EsMessageSender.java | 25 ++-
.../extension/impl/RocketCompensateMsgConsume.java | 25 ++-
.../impl/RocketMqCompensateMsgConsumeProvider.java | 25 ++-
.../impl/RocketMqMessagePostProcessing.java | 25 ++-
.../job/extension/impl/RocketMqMessageProduct.java | 25 ++-
.../stream/job/extension/kafka/KafkaConfig.java | 25 ++-
.../job/extension/kafka/KafkaConsumerRunner.java | 25 ++-
.../kafka/KafkaMqMessagePostProcessing.java | 25 ++-
.../stream/job/extension/kafka/KafkaPlugin.java | 25 ++-
.../stream/job/extension/kafka/KafkaSinkJob.java | 25 ++-
.../job/extension/kafka/KafkaSinkJobProvider.java | 25 ++-
.../job/extension/rocketmq/RocketMqSinkJob.java | 25 ++-
.../rocketmq/RocketMqSinkJobProvider.java | 25 ++-
.../job/extension/rocketmq/RocketmqConfig.java | 25 ++-
.../job/extension/rocketmq/RocketmqPlugin.java | 25 ++-
.../ozhera/log/stream/plugin/es/EsConfig.java | 25 ++-
.../ozhera/log/stream/plugin/es/EsPlugin.java | 25 ++-
.../plugin/nacos/LevelFilterConfigListener.java | 25 ++-
.../log/stream/plugin/nacos/LogFilterConfig.java | 25 ++-
.../apache/ozhera/log/stream/sink/SinkChain.java | 25 ++-
.../ozhera/log/stream/sink/SinkProcessor.java | 25 ++-
.../org/apache/ozhera/log/stream/DorisTest.java | 216 +++++++++----------
.../org/apache/ozhera/log/stream/EsPluginTest.java | 25 ++-
.../apache/ozhera/log/stream/LogParserTest.java | 25 ++-
.../ozhera/log/stream/MessageConsumeTest.java | 25 ++-
.../log/stream/MessageSenderFactoryTest.java | 178 ++++++++--------
.../ozhera/log/stream/MqMessageCompensateTest.java | 25 ++-
.../org/apache/ozhera/log/stream/PatterTest.java | 25 ++-
.../org/apache/ozhera/log/stream/StreamTest.java | 25 ++-
.../apache/ozhera/log/stream/TestSinkChain.java | 25 ++-
.../apache/ozhera/log/stream/TestSomething.java | 25 ++-
ozhera-log/pom.xml | 54 +++--
ozhera-operator/README.md | 20 ++
ozhera-operator/README_CN.md | 20 ++
ozhera-operator/ozhera-operator-common/pom.xml | 20 ++
.../ozhera/operator/common/ESIndexConst.java | 25 ++-
.../apache/ozhera/operator/common/ErrorCode.java | 25 ++-
.../apache/ozhera/operator/common/FileUtils.java | 25 ++-
.../apache/ozhera/operator/common/HoConstant.java | 25 ++-
.../ozhera/operator/common/HttpClientUtil.java | 25 ++-
.../ozhera/operator/common/ResourceTypeEnum.java | 25 ++-
ozhera-operator/ozhera-operator-server/Dockerfile | 14 ++
ozhera-operator/ozhera-operator-server/pom.xml | 20 ++
.../org/apache/ozhera/operator/HeraBootstrap.java | 25 ++-
.../controller/OzHeraOperatorController.java | 25 ++-
.../src/main/resources/config.properties | 14 ++
.../src/main/resources/logback.xml | 20 ++
.../resources/operator/ozhera_operator_auth.yaml | 14 ++
.../resources/operator/ozhera_operator_crd.yaml | 14 ++
.../operator/ozhera_operator_deployment.yaml | 14 ++
.../alertManager/ozhera_alertmanager.yaml | 14 ++
.../ozhera_init/cadvisor/ozhera_cadvisor.yaml | 14 ++
.../ozhera_init/demo/ozhera_demo_client.yml | 14 ++
.../ozhera_init/demo/ozhera_demo_server.yml | 14 ++
.../main/resources/ozhera_init/es/ozhera_es.yaml | 14 ++
.../ozhera_init/grafana/ozhera_grafana.yaml | 14 ++
.../resources/ozhera_init/hera-app/ozhera_app.yml | 14 ++
.../resources/ozhera_init/hera-fe/ozhera_fe.yml | 14 ++
.../log-agent-server/ozhera_log_agent-server.yml | 14 ++
.../ozhera_init/log-manager/ozhera_log_manager.yml | 14 ++
.../ozhera_init/log-stream/ozhera_log_stream.yml | 14 ++
.../ozhera_init/mimonitor/ozhera_mimonitor.yml | 14 ++
.../resources/ozhera_init/mysql/ozhera_mysql.yaml | 14 ++
.../resources/ozhera_init/mysql/sql/grafana.sql | 18 ++
.../main/resources/ozhera_init/mysql/sql/hera.sql | 18 ++
.../main/resources/ozhera_init/mysql/sql/nacos.sql | 18 ++
.../main/resources/ozhera_init/mysql/sql/tpc.sql | 18 ++
.../hera_app_config_#_DEFAULT_GROUP.properties | 14 ++
...era_log_manager_open_#_DEFAULT_GROUP.properties | 14 ++
.../hera_trace_config_#_DEFAULT_GROUP.properties | 14 ++
...g_stream_dataId_open_#_DEFAULT_GROUP.properties | 14 ++
.../nacos/config/mi_tpc_#_DEFAULT_GROUP.properties | 14 ++
.../config/mi_tpc_login_#_DEFAULT_GROUP.properties | 14 ++
...imonitor_open_config_#_DEFAULT_GROUP.properties | 14 ++
..._webhook_open_config_#_DEFAULT_GROUP.properties | 14 ++
...us_agent_open_config_#_DEFAULT_GROUP.properties | 14 ++
.../resources/ozhera_init/nacos/ozhera_nacos.yml | 14 ++
.../node-exporter/ozhera_node-exporter.yaml | 14 ++
.../main/resources/ozhera_init/outer/ozhera_lb.yml | 14 ++
.../ozhera_init/outer/ozhera_nodeport.yml | 14 ++
.../ozhera_init/prometheus/ozhera_prometheus.yaml | 14 ++
.../prometheus/ozhera_prometheus_agent.yaml | 14 ++
.../resources/ozhera_init/redis/ozhera_redis.yaml | 14 ++
.../ozhera_init/rocketmq/ozhera_rocketmq.yaml | 14 ++
.../sentinel/sentinbel-dashboard-ingress.yml | 14 ++
.../ozhera_init/sentinel/sentinel-dashboard.yml | 14 ++
.../resources/ozhera_init/tpc-fe/ozhera_tpc_fe.yml | 14 ++
.../tpc-login-fe/ozhera_tpc_login_fe.yml | 14 ++
.../ozhera_init/tpc-login/ozhera_tpc_login.yml | 14 ++
.../main/resources/ozhera_init/tpc/ozhera_tpc.yml | 14 ++
.../trace-etl-es/ozhera_trace_etl_es.yml | 14 ++
.../trace-etl-manager/ozhera_trace_etl_manager.yml | 14 ++
.../trace-etl-server/ozhera_trace_etl_server.yml | 14 ++
.../alertManagerClusterDockerfile | 14 ++
.../alertManagerCluster/alertmanager-cluster.yaml | 14 ++
.../startAlertManagerCluster.sh | 14 ++
.../ozhera_init/vmCluster/vm-k8s-yaml/vmAgent.yaml | 14 ++
.../ozhera_init/vmCluster/vm-k8s-yaml/vmAlert.yaml | 14 ++
.../vmCluster/vm-k8s-yaml/vmInsert.yaml | 14 ++
.../vmCluster/vm-k8s-yaml/vmSelect.yaml | 14 ++
.../vmCluster/vm-k8s-yaml/vmStorage-pv.yaml | 14 ++
.../vmCluster/vm-k8s-yaml/vmStorage.yaml | 14 ++
.../ozhera_init/webhook/ozhera_webhook_server.yaml | 14 ++
.../apache/ozhera/operator/test/SidecarTest.java | 25 ++-
ozhera-operator/ozhera-operator-service/pom.xml | 20 ++
.../apache/ozhera/operator/bo/HeraBootstrap.java | 25 ++-
.../ozhera/operator/bo/HeraBootstrapList.java | 25 ++-
.../apache/ozhera/operator/bo/HeraObjectMeta.java | 25 ++-
.../apache/ozhera/operator/bo/HeraResource.java | 25 ++-
.../org/apache/ozhera/operator/bo/HeraSpec.java | 25 ++-
.../org/apache/ozhera/operator/bo/HeraStatus.java | 25 ++-
.../org/apache/ozhera/operator/bo/PropConf.java | 25 ++-
.../operator/bo/dashboard/GrafanaApiKeyReq.java | 25 ++-
.../operator/bo/dashboard/GrafanaApiKeyRes.java | 25 ++-
.../apache/ozhera/operator/common/K8sUtilBean.java | 25 ++-
.../apache/ozhera/operator/dto/DashboardDTO.java | 25 ++-
.../apache/ozhera/operator/dto/DeployStateDTO.java | 25 ++-
.../ozhera/operator/dto/HeraOperatorDefineDTO.java | 25 ++-
.../ozhera/operator/dto/OperatorStateDTO.java | 25 ++-
.../apache/ozhera/operator/dto/PodStateDTO.java | 25 ++-
.../ozhera/operator/dto/ServiceCheckResource.java | 25 ++-
.../operator/handler/HeraResourceEventHandler.java | 25 ++-
.../apache/ozhera/operator/service/ESService.java | 25 ++-
.../operator/service/HeraBootstrapInitService.java | 25 ++-
.../apache/ozhera/operator/service/IResource.java | 25 ++-
.../ozhera/operator/service/NacosService.java | 25 ++-
.../ozhera/operator/service/RocketMQService.java | 25 ++-
.../ozhera/operator/test/PlaceholderTest.java | 25 ++-
ozhera-operator/pom.xml | 20 ++
ozhera-prometheus-agent/aliAlertMessage.txt | 46 -----
.../ozhera-prometheus-agent-server/Dockerfile | 15 ++
.../ozhera-prometheus-agent-server/build.sh | 15 ++
.../deploy/manifests/config.pp.template | 60 ------
.../src/main/resources/Dockerfile | 15 ++
.../src/main/resources/ddl.sql | 79 -------
.../main/resources/dingding/dingdingbasicCart.ftl | 19 ++
.../resources/dingding/dingdingbasicUpdateCart.ftl | 19 ++
.../src/main/resources/feishu/feishuBasicCart.ftl | 19 ++
.../src/main/resources/feishu/feishuCart.ftl | 19 ++
.../main/resources/feishu/feishuInterfalCart.ftl | 19 ++
.../src/main/resources/mail/mailBasic.ftl | 19 ++
.../src/main/resources/mail/mailCart.ftl | 19 ++
.../src/main/resources/mail/mailInterfal.ftl | 19 ++
702 files changed, 10988 insertions(+), 7571 deletions(-)
delete mode 100644 ozhera-log/.dockerignore
create mode 100644
ozhera-log/log-manager/src/test/java/org/apache/ozhera/log/manager/TestHttpClient.java
delete mode 100644 ozhera-prometheus-agent/aliAlertMessage.txt
delete mode 100644
ozhera-prometheus-agent/ozhera-prometheus-agent-server/deploy/manifests/config.pp.template
delete mode 100644
ozhera-prometheus-agent/ozhera-prometheus-agent-server/src/main/resources/ddl.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
