This is an automated email from the ASF dual-hosted git repository.
gongchao pushed a change to branch 0309-yuluo/feat
in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
from 562ad92a00 Merge branch 'master' into 0309-yuluo/feat
add af56746de1 [feat]: migrate blocking executors to virtual threads
(#4062)
add b39e9b0486 Merge branch 'master' into 0309-yuluo/feat
No new revisions were added by this update.
Summary of changes:
.../hertzbeat/ai/tools/impl/MonitorToolsImpl.java | 10 +-
hertzbeat-alerter/pom.xml | 5 +
.../apache/hertzbeat/alert/AlerterWorkerPool.java | 120 +++++-
.../periodic/PeriodicAlertRuleScheduler.java | 163 +++++++-
.../calculate/realtime/window/AlarmEvaluator.java | 62 +--
.../alert/notice/AlertNoticeDispatch.java | 32 +-
.../hertzbeat/alert/reduce/AlarmCommonReduce.java | 67 ++--
.../hertzbeat/alert/reduce/AlarmGroupReduce.java | 157 +++++++-
.../hertzbeat/alert/reduce/AlarmInhibitReduce.java | 166 ++++++--
.../hertzbeat/alert/AlerterWorkerPoolTest.java | 195 ++++++++--
.../periodic/PeriodicAlertRuleSchedulerTest.java | 213 ++++++++++
.../realtime/window/AlarmEvaluatorTest.java | 115 ++++++
.../alert/notice/AlertNoticeDispatchTest.java | 31 ++
.../alert/reduce/AlarmCommonReduceTest.java | 89 ++++-
.../alert/reduce/AlarmGroupReduceTest.java | 118 +++++-
.../alert/reduce/AlarmInhibitReduceTest.java | 124 +++++-
.../collector/dispatch/WorkerPoolTest.java | 73 ++--
.../dispatch/entrance/CollectServerTest.java | 77 +++-
.../collector/dispatch/CommonDispatcher.java | 4 +-
.../src/main/resources/application.yml | 9 +
.../common/cache/GlobalConnectionCache.java | 116 +++++-
.../collect/common/http/CommonHttpClient.java | 131 ++++++-
.../hertzbeat/collector/dispatch/WorkerPool.java | 74 +++-
.../collector/dispatch/entrance/CollectServer.java | 166 +++++++-
.../entrance/processor/GoCloseProcessor.java | 17 +-
.../entrance/processor/GoOfflineProcessor.java | 12 +-
.../entrance/processor/GoOnlineProcessor.java | 10 +-
.../hertzbeat/collector/timer/TimerDispatcher.java | 29 +-
.../hertzbeat/collector/timer/WheelTimerTask.java | 14 +-
.../common/cache/GlobalConnectionCacheTest.java | 175 +++++++++
.../http/CommonHttpClientVirtualThreadTest.java | 121 ++++++
.../entrance/processor/GoOnlineProcessorTest.java | 43 +--
.../collector/collect/kafka/KafkaCollectImpl.java | 19 +-
.../collect/mongodb/MongodbSingleCollectImpl.java | 19 +-
.../collect/nebulagraph/NgqlCollectImpl.java | 25 +-
.../hertzbeat-collector-rocketmq/pom.xml | 8 +-
.../rocketmq/RocketmqSingleCollectImpl.java | 64 +--
.../rocketmq/RocketmqSingleCollectTest.java | 62 +++
hertzbeat-common-core/pom.xml | 1 +
.../AdmissionMode.java} | 28 +-
.../common/concurrent/BackgroundTaskExecutor.java | 48 +--
.../ManagedExecutor.java} | 23 +-
.../common/concurrent/ManagedExecutors.java | 428 +++++++++++++++++++++
.../common/config/BaseKafkaProperties.java | 0
.../common/config/VirtualThreadProperties.java | 201 ++++++++++
.../hertzbeat/common/entity/dto/sms/SmsConfig.java | 6 +-
.../apache/hertzbeat/common/entity/job/Job.java | 63 ++-
.../hertzbeat/common/entity/job/Metrics.java | 0
.../common/entity/job/RuntimeParamDefine.java | 50 ++-
.../hertzbeat/common/entity/job/SshTunnel.java | 4 +-
.../common/entity/plugin/PluginConfig.java | 9 +-
.../common/entity/push/PushMetricsDto.java | 0
.../common/support/ResourceBundleUtf8Control.java | 0
.../exception/AlertExpressionException.java | 2 +-
.../exception/CommonDataQueueUnknownException.java | 2 +-
.../common/support/exception/CommonException.java | 0
.../exception/ExpressionVisitorException.java | 2 +-
.../common/support/exception/IgnoreException.java | 0
.../support/exception/SendMessageException.java | 0
.../common/support/valid/SqlSecurityException.java | 0
.../hertzbeat/common/util/ResourceBundleUtil.java | 0
.../common/concurrent/ManagedExecutorsTest.java | 184 +++++++++
hertzbeat-common-spring/pom.xml | 1 +
.../hertzbeat/common/config/CommonConfig.java | 8 +-
.../hertzbeat/common/config/SmsConfigBinding.java | 10 +-
.../config/VirtualThreadPropertiesBinding.java | 177 +++++++++
.../hertzbeat/common/entity/job/Configmap.java | 54 ---
.../hertzbeat/common/entity/job/SshTunnel.java | 87 -----
.../hertzbeat/common/support/CommonThreadPool.java | 69 +++-
.../apache/hertzbeat/common/util/IpDomainUtil.java | 169 --------
.../common/config/SmsConfigBindingTest.java | 50 +++
.../common/config/VirtualThreadPropertiesTest.java | 114 ++++++
.../common/support/CommonThreadPoolTest.java | 124 +++---
.../apache/hertzbeat/log/notice/LogSseManager.java | 10 +-
.../hertzbeat/log/notice/LogSseManagerTest.java | 33 +-
.../component/sd/ServiceDiscoveryWorker.java | 2 +-
.../manager/component/status/CalculateStatus.java | 428 ++++++++++++++-------
.../component/validator/ParamValidator.java | 6 +-
.../component/validator/ParamValidatorManager.java | 6 +-
.../validator/impl/ArrayParamValidator.java | 6 +-
.../validator/impl/BooleanParamValidator.java | 6 +-
.../validator/impl/HostParamValidatorAdapter.java | 6 +-
.../validator/impl/JsonParamValidator.java | 6 +-
.../validator/impl/NumberParamValidator.java | 6 +-
.../validator/impl/OptionParamValidator.java | 10 +-
.../validator/impl/PasswordParamValidator.java | 6 +-
.../validator/impl/TextParamValidator.java | 6 +-
.../manager/controller/AppController.java | 4 +-
.../manager/controller/CollectorController.java | 2 +-
.../manager/controller/MonitorsController.java | 14 +-
.../manager/controller/PluginController.java | 2 +-
.../manager/controller/StatusPageController.java | 41 +-
.../controller/StatusPagePublicController.java | 12 +-
.../hertzbeat/manager/pojo/dto/CollectorInfo.java | 50 +--
.../manager/pojo}/dto/CollectorSummary.java | 13 +-
.../manager/pojo/dto/ComponentStatus.java | 63 ++-
.../hertzbeat/manager/pojo/dto/MonitorDto.java | 93 ++++-
.../hertzbeat/manager/pojo/dto/MonitorInfo.java | 134 +++++++
.../hertzbeat/manager/pojo/dto/MonitorParam.java | 81 ++++
.../hertzbeat/manager/pojo/dto/ParamDefineDto.java | 3 +-
.../manager/pojo/dto/ParamDefineInfo.java | 144 +++++++
.../manager/pojo/dto/PluginParametersVO.java | 5 +-
.../hertzbeat/manager/pojo}/dto/PluginUpload.java | 5 +-
.../manager/pojo/dto/StatusPageComponentInfo.java | 95 +++++
.../manager/pojo/dto/StatusPageHistoryInfo.java | 94 +++++
.../pojo/dto/StatusPageIncidentContentInfo.java | 84 ++++
.../manager/pojo/dto/StatusPageIncidentInfo.java | 115 ++++++
.../manager/pojo/dto/StatusPageOrgInfo.java | 99 +++++
.../manager/scheduler/CollectorJobScheduler.java | 4 +-
.../manager/scheduler/ManagerWorkerPool.java | 74 +++-
.../hertzbeat/manager/scheduler/SchedulerInit.java | 4 +-
.../manager/scheduler/netty/ManageServer.java | 143 ++++++-
.../CollectCyclicDataResponseProcessor.java | 9 +-
...yclicServiceDiscoveryDataResponseProcessor.java | 9 +-
.../hertzbeat/manager/service/AppService.java | 4 +-
.../manager/service/CollectorService.java | 2 +-
.../hertzbeat/manager/service/PluginService.java | 2 +-
.../manager/service/StatusPageService.java | 26 +-
.../manager/service/impl/AppServiceImpl.java | 47 ++-
.../manager/service/impl/CollectorServiceImpl.java | 6 +-
.../manager/service/impl/MonitorServiceImpl.java | 26 +-
.../manager/service/impl/PluginServiceImpl.java | 6 +-
.../service/impl/StatusPageServiceImpl.java | 66 ++--
.../component/status/CalculateStatusTest.java | 148 +++++++
.../validator/ParamValidatorManagerTest.java | 12 +-
.../validator/impl/ArrayParamValidatorTest.java | 16 +-
.../validator/impl/BooleanParamValidatorTest.java | 20 +-
.../impl/HostParamValidatorAdapterTest.java | 24 +-
.../validator/impl/JsonParamValidatorTest.java | 12 +-
.../validator/impl/NumberParamValidatorTest.java | 20 +-
.../validator/impl/OptionParamValidatorTest.java | 20 +-
.../validator/impl/PasswordParamValidatorTest.java | 12 +-
.../validator/impl/TextParamValidatorTest.java | 12 +-
.../manager/controller/AppControllerTest.java | 6 +-
.../controller/MetricsFavoriteControllerTest.java | 4 +-
.../manager/controller/MonitorsControllerTest.java | 25 +-
.../controller/StatusPageControllerTest.java | 45 ++-
.../controller/StatusPagePublicControllerTest.java | 4 +-
.../manager/scheduler/ManagerWorkerPoolTest.java | 108 ++++++
.../manager/scheduler/netty/ManageServerTest.java | 153 ++++++++
.../hertzbeat/manager/service/AppServiceTest.java | 11 +-
.../manager/service/MonitorServiceTest.java | 101 ++---
.../manager/service/PluginServiceTest.java | 2 +-
.../manager/service/StatusPageServiceTest.java | 29 +-
hertzbeat-push/pom.xml | 5 +
hertzbeat-remoting/pom.xml | 2 +-
.../remoting/netty/NettyRemotingClient.java | 10 +-
.../remoting/netty/NettyRemotingServer.java | 8 +-
.../hertzbeat/remoting/RemotingServiceTest.java | 23 +-
.../org/apache/hertzbeat/startup/AsyncConfig.java | 41 ++
.../src/main/resources/application-test.yml | 31 ++
.../src/main/resources/application.yml | 32 ++
.../apache/hertzbeat/startup/AsyncConfigTest.java | 88 +++++
.../hertzbeat/warehouse/WarehouseWorkerPool.java | 72 +++-
.../warehouse/store/DataStorageDispatch.java | 4 +-
.../store/history/tsdb/doris/DorisDataStorage.java | 2 +-
.../tsdb/duckdb/DuckdbDatabaseDataStorage.java | 224 ++++++++---
.../warehouse/WarehouseWorkerPoolTest.java | 70 +++-
.../tsdb/duckdb/DuckdbDatabaseDataStorageTest.java | 148 +++++++
home/docs/help/issue.md | 11 +-
home/docs/start/custom-config.md | 6 +
home/docs/start/virtual-thread.md | 122 ++++++
.../current/help/issue.md | 11 +-
.../current/start/custom-config.md | 6 +
.../current/start/virtual-thread.md | 122 ++++++
script/application.yml | 32 ++
.../hertzbeat-mysql-iotdb/conf/application.yml | 32 ++
.../hertzbeat-mysql-tdengine/conf/application.yml | 31 ++
.../conf/application.yml | 32 ++
.../conf/application.yml | 32 ++
.../conf/application.yml | 32 ++
171 files changed, 7422 insertions(+), 1558 deletions(-)
create mode 100644
hertzbeat-alerter/src/test/java/org/apache/hertzbeat/alert/calculate/periodic/PeriodicAlertRuleSchedulerTest.java
create mode 100644
hertzbeat-collector/hertzbeat-collector-common/src/test/java/org/apache/hertzbeat/collector/collect/common/cache/GlobalConnectionCacheTest.java
create mode 100644
hertzbeat-collector/hertzbeat-collector-common/src/test/java/org/apache/hertzbeat/collector/collect/common/http/CommonHttpClientVirtualThreadTest.java
copy
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/{constants/ImportTaskStatusEnum.java
=> concurrent/AdmissionMode.java} (67%)
copy
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity/push/PushMetricsDto.java
=>
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/concurrent/BackgroundTaskExecutor.java
(56%)
copy
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/{constants/ManagerEventTypeEnum.java
=> concurrent/ManagedExecutor.java} (69%)
create mode 100644
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/concurrent/ManagedExecutors.java
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/config/BaseKafkaProperties.java
(100%)
create mode 100644
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/config/VirtualThreadProperties.java
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/entity/dto/sms/SmsConfig.java
(89%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/entity/job/Job.java
(93%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/entity/job/Metrics.java
(100%)
copy
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity/push/PushMetricsDto.java
=>
hertzbeat-common-core/src/main/java/org/apache/hertzbeat/common/entity/job/RuntimeParamDefine.java
(58%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/entity/plugin/PluginConfig.java
(84%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/entity/push/PushMetricsDto.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/ResourceBundleUtf8Control.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/AlertExpressionException.java
(99%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/CommonDataQueueUnknownException.java
(99%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/CommonException.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/ExpressionVisitorException.java
(99%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/IgnoreException.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/exception/SendMessageException.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/support/valid/SqlSecurityException.java
(100%)
rename {hertzbeat-common-spring =>
hertzbeat-common-core}/src/main/java/org/apache/hertzbeat/common/util/ResourceBundleUtil.java
(100%)
create mode 100644
hertzbeat-common-core/src/test/java/org/apache/hertzbeat/common/concurrent/ManagedExecutorsTest.java
copy
hertzbeat-collector/hertzbeat-collector-basic/src/main/java/org/apache/hertzbeat/collector/collect/ipmi2/protocol/ipmi/payload/AbstractIpmiPayload.java
=>
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/config/SmsConfigBinding.java
(70%)
create mode 100644
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/config/VirtualThreadPropertiesBinding.java
delete mode 100644
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity/job/Configmap.java
delete mode 100644
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity/job/SshTunnel.java
delete mode 100644
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/util/IpDomainUtil.java
create mode 100644
hertzbeat-common-spring/src/test/java/org/apache/hertzbeat/common/config/SmsConfigBindingTest.java
create mode 100644
hertzbeat-common-spring/src/test/java/org/apache/hertzbeat/common/config/VirtualThreadPropertiesTest.java
copy
hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity/manager/Collector.java
=>
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/CollectorInfo.java
(62%)
rename
{hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity =>
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo}/dto/CollectorSummary.java
(88%)
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/MonitorInfo.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/MonitorParam.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/ParamDefineInfo.java
rename
{hertzbeat-common-spring/src/main/java/org/apache/hertzbeat/common/entity =>
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo}/dto/PluginUpload.java
(93%)
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/StatusPageComponentInfo.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/StatusPageHistoryInfo.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/StatusPageIncidentContentInfo.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/StatusPageIncidentInfo.java
create mode 100644
hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/pojo/dto/StatusPageOrgInfo.java
create mode 100644
hertzbeat-manager/src/test/java/org/apache/hertzbeat/manager/component/status/CalculateStatusTest.java
create mode 100644
hertzbeat-manager/src/test/java/org/apache/hertzbeat/manager/scheduler/ManagerWorkerPoolTest.java
create mode 100644
hertzbeat-manager/src/test/java/org/apache/hertzbeat/manager/scheduler/netty/ManageServerTest.java
create mode 100644
hertzbeat-startup/src/main/java/org/apache/hertzbeat/startup/AsyncConfig.java
create mode 100644
hertzbeat-startup/src/test/java/org/apache/hertzbeat/startup/AsyncConfigTest.java
create mode 100644
hertzbeat-warehouse/src/test/java/org/apache/hertzbeat/warehouse/store/history/tsdb/duckdb/DuckdbDatabaseDataStorageTest.java
create mode 100644 home/docs/start/virtual-thread.md
create mode 100644
home/i18n/zh-cn/docusaurus-plugin-content-docs/current/start/virtual-thread.md
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
