This is an automated email from the ASF dual-hosted git repository. zhaoqingran pushed a commit to branch script in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
commit 249c5e11f9d71a085d182e33c364841f7506fefe Merge: 9f424d286 eaaf58908 Author: Logic <[email protected]> AuthorDate: Wed Nov 20 17:10:37 2024 +0800 Merge branch 'master' of github.com:apache/hertzbeat into script # Conflicts: # hertzbeat-collector/hertzbeat-collector-common/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/ScriptRequestProcessor.java # hertzbeat-common/src/main/java/org/apache/hertzbeat/common/constants/ScriptTypeConstants.java # hertzbeat-common/src/main/java/org/apache/hertzbeat/common/entity/plugin/Script.java # hertzbeat-common/src/main/java/org/apache/hertzbeat/common/support/exception/ScriptLoadException.java # hertzbeat-common/src/main/java/org/apache/hertzbeat/common/support/valid/ScriptValidator.java # hertzbeat-common/src/main/java/org/apache/hertzbeat/common/util/ScriptUtil.java # hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/netty/process/ScriptResponseProcessor.java .all-contributorsrc | 27 +++ .github/workflows/backend-build-test-reuse.yml | 2 +- CONTRIBUTING.md | 12 +- README.md | 77 +++---- README_CN.md | 77 +++---- {alerter => hertzbeat-alerter}/pom.xml | 0 .../apache/hertzbeat/alert/AlerterProperties.java | 0 .../apache/hertzbeat/alert/AlerterWorkerPool.java | 0 .../hertzbeat/alert/calculate/CalculateAlarm.java | 0 .../alert/config/AlerterAutoConfiguration.java | 0 .../alert/controller/AlertConvergeController.java | 0 .../alert/controller/AlertConvergesController.java | 0 .../alert/controller/AlertDefineController.java | 0 .../alert/controller/AlertDefinesController.java | 0 .../alert/controller/AlertReportController.java | 0 .../alert/controller/AlertSilenceController.java | 0 .../alert/controller/AlertSilencesController.java | 0 .../alert/controller/AlertsController.java | 0 .../hertzbeat/alert/dao/AlertConvergeDao.java | 0 .../org/apache/hertzbeat/alert/dao/AlertDao.java | 0 .../hertzbeat/alert/dao/AlertDefineBindDao.java | 0 .../apache/hertzbeat/alert/dao/AlertDefineDao.java | 0 .../hertzbeat/alert/dao/AlertMonitorDao.java | 0 .../hertzbeat/alert/dao/AlertSilenceDao.java | 0 .../apache/hertzbeat/alert/dto/AlertDefineDTO.java | 0 .../hertzbeat/alert/dto/AlertPriorityNum.java | 0 .../apache/hertzbeat/alert/dto/AlertSummary.java | 0 .../alert/dto/CloudAlertReportAbstract.java | 0 .../hertzbeat/alert/dto/ExportAlertDefineDTO.java | 0 .../alert/dto/GeneralCloudAlertReport.java | 0 .../hertzbeat/alert/dto/TenCloudAlertReport.java | 0 .../enums/CloudServiceAlarmInformationEnum.java | 0 .../hertzbeat/alert/reduce/AlarmCommonReduce.java | 0 .../alert/reduce/AlarmConvergeReduce.java | 0 .../hertzbeat/alert/reduce/AlarmSilenceReduce.java | 0 .../alert/service/AlertConvergeService.java | 0 .../alert/service/AlertDefineImExportService.java | 0 .../alert/service/AlertDefineService.java | 0 .../hertzbeat/alert/service/AlertService.java | 0 .../alert/service/AlertSilenceService.java | 0 .../service/impl/AlertConvergeServiceImpl.java | 0 .../AlertDefineAbstractImExportServiceImpl.java | 0 .../impl/AlertDefineExcelImExportServiceImpl.java | 0 .../impl/AlertDefineJsonImExportServiceImpl.java | 0 .../alert/service/impl/AlertDefineServiceImpl.java | 0 .../impl/AlertDefineYamlImExportServiceImpl.java | 0 .../alert/service/impl/AlertServiceImpl.java | 3 +- .../service/impl/AlertSilenceServiceImpl.java | 0 .../hertzbeat/alert/util/AlertTemplateUtil.java | 0 .../org/apache/hertzbeat/alert/util/DateUtil.java | 0 ...rk.boot.autoconfigure.AutoConfiguration.imports | 0 .../src/main/resources/alerter_en_US.properties | 0 .../src/main/resources/alerter_zh_CN.properties | 0 .../hertzbeat/alert/AlerterWorkerPoolTest.java | 0 .../controller/AlertConvergeControllerTest.java | 0 .../controller/AlertConvergesControllerTest.java | 0 .../controller/AlertDefineControllerTest.java | 0 .../controller/AlertDefinesControllerTest.java | 0 .../controller/AlertReportControllerTest.java | 0 .../controller/AlertSilenceControllerTest.java | 0 .../alert/controller/AlertsControllerTest.java | 0 .../alert/reduce/AlarmCommonReduceTest.java | 0 .../alert/reduce/AlarmConvergeReduceTest.java | 0 .../alert/reduce/AlarmSilenceReduceTest.java | 0 .../alert/service/AlertConvergeServiceTest.java | 0 .../AlertDefineExcelImExportServiceTest.java | 0 .../AlertDefineJsonImExportServiceTest.java | 0 .../alert/service/AlertDefineServiceTest.java | 0 .../AlertDefineYamlImExportServiceTest.java | 0 .../hertzbeat/alert/service/AlertServiceTest.java | 0 .../alert/service/AlertSilenceServiceTest.java | 0 .../alert/util/AlertTemplateUtilTest.java | 0 .../apache/hertzbeat/alert/util/DateUtilTest.java | 0 .../hertzbeat-collector-basic}/pom.xml | 0 .../collect/database/JdbcCommonCollect.java | 0 .../collector/collect/database/JdbcSpiLoader.java | 0 .../collector/collect/dns/DnsCollectImpl.java | 0 .../collector/collect/ftp/FtpCollectImpl.java | 0 .../collector/collect/http/HttpCollectImpl.java | 0 .../collect/http/SslCertificateCollectImpl.java | 0 .../http/promethus/AbstractPrometheusParse.java | 0 .../collect/http/promethus/ParseException.java | 0 .../http/promethus/PrometheusLastParser.java | 0 .../http/promethus/PrometheusMatrixParser.java | 0 .../http/promethus/PrometheusParseCreator.java | 0 .../http/promethus/PrometheusVectorParser.java | 0 .../http/promethus/exporter/ExporterParser.java | 0 .../http/promethus/exporter/MetricFamily.java | 0 .../http/promethus/exporter/MetricType.java | 0 .../collector/collect/httpsd/HttpsdImpl.java | 0 .../constant/DiscoveryClientHealthStatus.java | 0 .../httpsd/constant/DiscoveryClientInstance.java | 0 .../collect/httpsd/discovery/DiscoveryClient.java | 0 .../discovery/DiscoveryClientManagement.java | 0 .../httpsd/discovery/entity/ConnectConfig.java | 0 .../httpsd/discovery/entity/ServerInfo.java | 0 .../httpsd/discovery/entity/ServiceInstance.java | 0 .../discovery/impl/ConsulDiscoveryClient.java | 0 .../discovery/impl/NacosDiscoveryClient.java | 0 .../collector/collect/icmp/IcmpCollectImpl.java | 0 .../collector/collect/imap/ImapCollectImpl.java | 0 .../collector/collect/ipmi2/IpmiCollectImpl.java | 0 .../collector/collect/ipmi2/cache/IpmiConnect.java | 0 .../collector/collect/ipmi2/client/IpmiClient.java | 0 .../collect/ipmi2/client/IpmiConnection.java | 0 .../collect/ipmi2/client/IpmiEncoderDecoder.java | 0 .../collect/ipmi2/client/IpmiHandlerManager.java | 0 .../collect/ipmi2/client/IpmiPacketContext.java | 0 .../collect/ipmi2/client/IpmiSession.java | 0 .../collect/ipmi2/client/UdpConnection.java | 0 .../ipmi2/client/handler/ChassisHandler.java | 0 .../collect/ipmi2/client/handler/IpmiHandler.java | 0 .../ipmi2/client/handler/SensorHandler.java | 0 .../ipmi2/protocol/common/AbstractWireable.java | 0 .../collect/ipmi2/protocol/common/IpmiCode.java | 6 +- .../ipmi2/protocol/common/IpmiEncapsulation.java | 6 +- .../collect/ipmi2/protocol/common/Wireable.java | 0 .../protocol/ipmi/AbstractIpmiSessionWrapper.java | 3 +- .../protocol/ipmi/Ipmi20Ipv4SessionWrapper.java | 0 .../ipmi2/protocol/ipmi/IpmiChannelMediumCode.java | 0 .../ipmi2/protocol/ipmi/IpmiChannelNumberCode.java | 0 .../protocol/ipmi/IpmiChannelPrivilegeLevel.java | 0 .../protocol/ipmi/IpmiChannelProtocolCode.java | 0 .../ipmi2/protocol/ipmi/IpmiCommandName.java | 0 .../ipmi2/protocol/ipmi/IpmiCompletionCode.java | 0 .../collect/ipmi2/protocol/ipmi/IpmiLun.java | 0 .../protocol/ipmi/IpmiNetworkFunctionCode.java | 0 .../ipmi/IpmiSessionAuthenticationType.java | 0 .../ipmi2/protocol/ipmi/IpmiSessionWrapper.java | 0 .../protocol/ipmi/command/AbstractIpmiCommand.java | 1 + .../protocol/ipmi/command/AbstractIpmiRequest.java | 0 .../ipmi/command/AbstractIpmiResponse.java | 0 .../ipmi2/protocol/ipmi/command/IpmiCommand.java | 0 .../ipmi2/protocol/ipmi/command/IpmiRequest.java | 0 .../ipmi2/protocol/ipmi/command/IpmiResponse.java | 0 .../command/chassis/GetChassisStatusRequest.java | 0 .../command/chassis/GetChassisStatusResponse.java | 0 .../command/messaging/CloseSessionRequest.java | 0 .../command/messaging/CloseSessionResponse.java | 0 ...etChannelAuthenticationCapabilitiesRequest.java | 0 ...tChannelAuthenticationCapabilitiesResponse.java | 0 .../protocol/ipmi/command/sdr/GetSdrRequest.java | 0 .../protocol/ipmi/command/sdr/GetSdrResponse.java | 0 .../ipmi/command/sdr/GetSensorReadingRequest.java | 0 .../ipmi/command/sdr/GetSensorReadingResponse.java | 0 .../command/sdr/ReserveSdrRepositoryRequest.java | 0 .../command/sdr/ReserveSdrRepositoryResponse.java | 0 .../ipmi/command/sdr/code/IpmiEntityIdCode.java | 0 .../ipmi/command/sdr/code/IpmiReadingTypeCode.java | 0 .../ipmi/command/sdr/code/IpmiSensorTypeCode.java | 0 .../command/sdr/code/IpmiSensorUnitTypeCode.java | 0 .../protocol/ipmi/payload/AbstractIpmiPayload.java | 0 .../ipmi/payload/AbstractSessionIpmiPayload.java | 0 .../ipmi2/protocol/ipmi/payload/IpmiPayload.java | 0 .../protocol/ipmi/payload/IpmiPayloadType.java | 0 .../protocol/ipmi/payload/MessageStatusCode.java | 0 .../ipmi2/protocol/ipmi/payload/RakpMessage1.java | 0 .../ipmi2/protocol/ipmi/payload/RakpMessage2.java | 0 .../ipmi2/protocol/ipmi/payload/RakpMessage3.java | 0 .../ipmi2/protocol/ipmi/payload/RakpMessage4.java | 0 .../ipmi/payload/RmcpPlusOpenSessionRequest.java | 0 .../ipmi/payload/RmcpPlusOpenSessionResponse.java | 0 .../security/AbstractIpmiAlgorithmWrapper.java | 0 .../protocol/ipmi/security/IpmiAlgorithm.java | 0 .../ipmi/security/IpmiAuthenticationCode.java | 0 .../ipmi/security/IpmiConfidentialityCode.java | 0 .../protocol/ipmi/security/IpmiIntegrityCode.java | 0 .../authentication/AbstractIpmiAuthentication.java | 0 .../authentication/IpmiAuthentication.java | 0 .../IpmiAuthenticationAlgorithmWrapper.java | 0 .../ipmi/security/authentication/None.java | 0 .../ipmi/security/authentication/RakpHmacMd5.java | 0 .../ipmi/security/authentication/RakpHmacSha1.java | 0 .../security/authentication/RakpHmacSha256.java | 0 .../AbstractIpmiConfidentiality.java | 0 .../ipmi/security/confidentiality/AesCbc128.java | 10 +- .../confidentiality/IpmiConfidentiality.java | 0 .../IpmiConfidentialityAlgorithmWrapper.java | 0 .../ipmi/security/confidentiality/None.java | 0 .../ipmi/security/confidentiality/Xrc4128.java | 0 .../ipmi/security/confidentiality/Xrc440.java | 0 .../security/integrity/AbstractIpmiIntegrity.java | 0 .../ipmi/security/integrity/HmacMd5128.java | 0 .../ipmi/security/integrity/HmacSha196.java | 0 .../ipmi/security/integrity/HmacSha256128.java | 0 .../ipmi/security/integrity/IntegrityUtils.java | 0 .../ipmi/security/integrity/IpmiIntegrity.java | 0 .../integrity/IpmiIntegrityAlgorithmWrapper.java | 0 .../protocol/ipmi/security/integrity/Md5128.java | 0 .../protocol/ipmi/security/integrity/None.java | 0 .../collect/ipmi2/protocol/rmcp/Packet.java | 0 .../collect/ipmi2/protocol/rmcp/RmcpData.java | 0 .../ipmi2/protocol/rmcp/RmcpMessageClass.java | 0 .../ipmi2/protocol/rmcp/RmcpMessageStatus.java | 0 .../collect/ipmi2/protocol/rmcp/RmcpPacket.java | 3 +- .../collect/ipmi2/protocol/rmcp/RmcpVersion.java | 0 .../collect/ipmi2/utils/ByteCheckUtils.java | 0 .../collect/ipmi2/utils/ByteConvertUtils.java | 0 .../collect/ipmi2/utils/ByteOrderUtils.java | 0 .../collector/collect/jmx/JmxClassLoader.java | 0 .../collector/collect/jmx/JmxCollectImpl.java | 0 .../collect/memcached/MemcachedCollectImpl.java | 0 .../collector/collect/mqtt/MqttCollectImpl.java | 0 .../collector/collect/nginx/NginxCollectImpl.java | 0 .../collector/collect/ntp/NtpCollectImpl.java | 0 .../collector/collect/pop3/Pop3CollectImpl.java | 0 .../prometheus/PrometheusAutoCollectImpl.java | 0 .../collect/prometheus/parser/MetricFamily.java | 0 .../collect/prometheus/parser/TextParser.java | 0 .../collector/collect/push/PushCollectImpl.java | 0 .../collector/collect/redfish/ConnectSession.java | 0 .../collector/collect/redfish/RedfishClient.java | 0 .../collect/redfish/RedfishCollectImpl.java | 0 .../collect/redfish/RedfishCollectionSchema.java | 0 .../collect/redfish/RedfishConnectSession.java | 0 .../collector/collect/redfish/Session.java | 0 .../collect/redfish/cache/RedfishConnect.java | 0 .../collect/redis/RedisCommonCollectImpl.java | 0 .../collect/script/ScriptCollectImpl.java | 0 .../collector/collect/smtp/SmtpCollectImpl.java | 0 .../collector/collect/snmp/SnmpCollectImpl.java | 0 .../collector/collect/ssh/SshCollectImpl.java | 0 .../collect/telnet/TelnetCollectImpl.java | 0 .../collector/collect/udp/UdpCollectImpl.java | 0 .../collect/websocket/WebsocketCollectImpl.java | 0 .../collect/common/cache/CommonCacheTest.java | 0 .../collect/common/http/CommonHttpClientTest.java | 0 .../collect/common/ssh/CommonSshClientTest.java | 0 .../collect/database/JdbcCommonCollectTest.java | 0 .../collect/database/JdbcSpiLoaderTest.java | 0 .../collector/collect/dns/DnsCollectImplTest.java | 0 .../collector/collect/ftp/FtpCollectImplTest.java | 0 .../collect/http/HttpCollectImplTest.java | 0 .../http/SslCertificateCollectImplTest.java | 0 .../promethus/exporter/ExporterParserTest.java | 0 .../collector/collect/httpsd/HttpsdImplTest.java | 0 .../collect/icmp/IcmpCollectImplTest.java | 0 .../collect/imap/ImapCollectImplTest.java | 0 .../collect/ipmi/IpmiSessionWrapperTest.java | 0 .../collect/ipmi/common/AbstractWireableTest.java | 0 .../ipmi/security/IpmiConfidentialityTest.java | 0 .../collector/collect/jmx/JmxCollectImplTest.java | 0 .../memcached/MemcachedCollectImplTest.java | 0 .../collector/collect/mqtt/MqttCollectTest.java | 0 .../collect/nginx/NginxCollectImplTest.java | 0 .../collector/collect/ntp/NtpCollectImplTest.java | 0 .../collect/pop3/Pop3CollectImplTest.java | 0 .../collect/push/PushCollectImplTest.java | 0 .../collect/redfish/RedfishCollectImplTest.java | 0 .../collect/redis/RedisClusterCollectImplTest.java | 0 .../collect/redis/RedisSingleCollectImplTest.java | 0 .../collect/script/ScriptCollectImplTest.java | 0 .../collect/smtp/SmtpCollectImplTest.java | 0 .../collect/snmp/SnmpCollectImplTest.java | 0 .../collector/collect/ssh/SshCollectImplTest.java | 0 .../collect/telnet/TelnetCollectImplTest.java | 0 .../collector/collect/udp/UdpCollectImplTest.java | 0 .../websocket/WebsocketCollectImplTest.java | 0 .../collector/dispatch/CommonDispatcherTest.java | 0 .../dispatch/MetricsCollectorQueueTest.java | 0 .../collector/dispatch/WorkerPoolTest.java | 0 .../dispatch/entrance/CollectServerTest.java | 0 .../entrance/internal/CollectJobServiceTest.java | 0 .../dispatch/export/NettyDataQueueTest.java | 0 .../dispatch/unit/DataSizeConvertTest.java | 0 .../dispatch/unit/TimeLengthConvertTest.java | 0 .../hertzbeat/collector/util/CollectUtilTest.java | 0 .../collector/util/JsonPathParserTest.java | 0 .../collector/util/PrivateKeyUtilsTest.java | 0 .../collector/util/TimeExpressionUtilTest.java | 0 .../hertzbeat-collector-collector}/pom.xml | 0 .../org/apache/hertzbeat/collector/Collector.java | 0 .../collect/strategy/CollectStrategyFactory.java | 0 .../config/CollectorAutoConfiguration.java | 0 .../collector/dispatch/CommonDispatcher.java | 0 .../collector/dispatch/MetricsCollect.java | 0 .../collector/dispatch/MetricsCollectorQueue.java | 0 ...che.hertzbeat.collector.collect.AbstractCollect | 0 ...rk.boot.autoconfigure.AutoConfiguration.imports | 0 .../src/main/resources/application.yml | 0 .../src/main/resources/banner.txt | 0 .../src/main/resources/logback-spring.xml | 0 .../hertzbeat-collector-common}/pom.xml | 0 .../collector/collect/AbstractCollect.java | 0 .../collect/common/cache/AbstractConnection.java | 0 .../collect/common/cache/CacheIdentifier.java | 0 .../common/cache/ConnectionCommonCache.java | 0 .../collect/common/cache/JdbcConnect.java | 0 .../collector/collect/common/cache/JmxConnect.java | 0 .../collect/common/cache/RedisConnect.java | 0 .../collector/collect/common/cache/SshConnect.java | 0 .../collect/common/http/CommonHttpClient.java | 0 .../collect/common/ssh/CommonSshBlacklist.java | 0 .../collect/common/ssh/CommonSshClient.java | 0 .../config/CollectorAutoConfiguration.java | 0 .../collector/constants/CollectorConstants.java | 0 .../collector/dispatch/CollectDataDispatch.java | 0 .../dispatch/CollectorInfoProperties.java | 0 .../collector/dispatch/DispatchConstants.java | 0 .../collector/dispatch/DispatchProperties.java | 0 .../collector/dispatch/MetricsTaskDispatch.java | 0 .../hertzbeat/collector/dispatch/WorkerPool.java | 0 .../collector/dispatch/entrance/CollectServer.java | 0 .../entrance/internal/CollectJobService.java | 0 .../internal/CollectResponseEventListener.java | 0 .../processor/CollectCyclicDataProcessor.java | 0 .../processor/CollectOneTimeDataProcessor.java | 0 .../processor/DeleteCyclicTaskProcessor.java | 0 .../entrance/processor/GoCloseProcessor.java | 0 .../entrance/processor/GoOfflineProcessor.java | 0 .../entrance/processor/GoOnlineProcessor.java | 0 .../entrance/processor/HeartbeatProcessor.java | 0 .../entrance/processor/ScriptRequestProcessor.java | 0 .../collector/dispatch/export/NettyDataQueue.java | 0 .../collector/dispatch/timer/HashedWheelTimer.java | 0 .../collector/dispatch/timer/Timeout.java | 0 .../hertzbeat/collector/dispatch/timer/Timer.java | 0 .../collector/dispatch/timer/TimerDispatch.java | 0 .../collector/dispatch/timer/TimerDispatcher.java | 19 +- .../collector/dispatch/timer/TimerTask.java | 0 .../collector/dispatch/timer/WheelTimerTask.java | 1 + .../collector/dispatch/unit/DataUnit.java | 0 .../collector/dispatch/unit/TimeLengthUnit.java | 0 .../collector/dispatch/unit/UnitConvert.java | 0 .../dispatch/unit/impl/AbstractUnitConvert.java | 0 .../dispatch/unit/impl/DataSizeConvert.java | 0 .../dispatch/unit/impl/TimeLengthConvert.java | 0 .../hertzbeat/collector/util/CollectUtil.java | 0 .../hertzbeat/collector/util/JsonPathParser.java | 0 .../hertzbeat/collector/util/PrivateKeyUtils.java | 0 .../collector/util/TimeExpressionUtil.java | 0 .../hertzbeat-collector-kafka}/pom.xml | 0 .../collector/collect/kafka/KafkaCollectImpl.java | 0 .../collector/collect/kafka/KafkaConnect.java | 6 +- .../collector/collect/kafka/SupportedCommand.java | 0 .../collector/collect/kafka/KafkaCollectTest.java | 0 .../hertzbeat-collector-mongodb}/pom.xml | 0 .../collector/collect/mongodb/MongodbConnect.java | 0 .../collect/mongodb/MongodbSingleCollectImpl.java | 0 .../collect/mongodb/MongoCollectImplTest.java | 0 .../hertzbeat-collector-nebulagraph}/pom.xml | 0 .../nebulagraph/NebulaGraphCollectImpl.java | 0 .../collect/nebulagraph/NebulaTemplate.java | 0 .../collect/nebulagraph/NgqlCollectImpl.java | 0 .../nebulagraph/NebulaGraphCollectImplTest.java | 0 .../collect/nebulagraph/NgqlCollectImplTest.java | 0 .../hertzbeat-collector-rocketmq}/pom.xml | 0 .../collect/rocketmq/RocketmqCollectData.java | 0 .../rocketmq/RocketmqSingleCollectImpl.java | 0 .../rocketmq/RocketmqSingleCollectTest.java | 0 {collector => hertzbeat-collector}/pom.xml | 14 +- {common => hertzbeat-common}/pom.xml | 0 .../hertzbeat/common/cache/CacheFactory.java | 0 .../common/cache/CaffeineCacheServiceImpl.java | 0 .../hertzbeat/common/cache/CommonCacheService.java | 0 .../common/config/BaseKafkaProperties.java | 0 .../hertzbeat/common/config/CommonConfig.java | 0 .../hertzbeat/common/config/CommonProperties.java | 0 .../common/config/EclipseLinkCustomizer.java | 0 .../common/config/EclipseLinkJpaConfiguration.java | 0 .../hertzbeat/common/constants/AiConstants.java | 0 .../hertzbeat/common/constants/AiTypeEnum.java | 0 .../common/constants/CommonConstants.java | 0 .../common/constants/ConfigConstants.java | 0 .../common/constants/DataQueueConstants.java | 0 .../common/constants/ExportFileConstants.java | 0 .../common/constants/GeneralConfigTypeEnum.java | 0 .../common/constants/NetworkConstants.java | 0 .../hertzbeat/common/constants/PluginType.java | 0 .../common/constants/ScriptTypeConstants.java | 0 .../hertzbeat/common/constants/SignConstants.java | 0 .../hertzbeat/common/entity/alerter/Alert.java | 0 .../common/entity/alerter/AlertConverge.java | 0 .../common/entity/alerter/AlertDefine.java | 0 .../entity/alerter/AlertDefineMonitorBind.java | 0 .../common/entity/alerter/AlertSilence.java | 0 .../entity/alerter/JsonMapAttributeConverter.java | 0 .../hertzbeat/common/entity/dto/AlertReport.java | 0 .../hertzbeat/common/entity/dto/CollectorInfo.java | 0 .../common/entity/dto/CollectorSummary.java | 0 .../apache/hertzbeat/common/entity/dto/Field.java | 0 .../hertzbeat/common/entity/dto/Message.java | 0 .../hertzbeat/common/entity/dto/MetricsData.java | 0 .../common/entity/dto/MetricsHistoryData.java | 0 .../hertzbeat/common/entity/dto/PluginUpload.java | 0 .../common/entity/dto/PromVectorOrMatrix.java | 0 .../apache/hertzbeat/common/entity/dto/Value.java | 0 .../hertzbeat/common/entity/dto/ValueRow.java | 0 .../common/entity/grafana/GrafanaDashboard.java | 0 .../hertzbeat/common/entity/job/Configmap.java | 0 .../apache/hertzbeat/common/entity/job/Job.java | 110 ++++++++-- .../hertzbeat/common/entity/job/Metrics.java | 9 + .../common/entity/job/protocol/DnsProtocol.java | 0 .../common/entity/job/protocol/FtpProtocol.java | 0 .../common/entity/job/protocol/HttpProtocol.java | 0 .../common/entity/job/protocol/HttpsdProtocol.java | 0 .../common/entity/job/protocol/IcmpProtocol.java | 0 .../common/entity/job/protocol/ImapProtocol.java | 0 .../common/entity/job/protocol/IpmiProtocol.java | 0 .../common/entity/job/protocol/JdbcProtocol.java | 0 .../common/entity/job/protocol/JmxProtocol.java | 0 .../common/entity/job/protocol/KafkaProtocol.java | 0 .../entity/job/protocol/MemcachedProtocol.java | 0 .../entity/job/protocol/MongodbProtocol.java | 0 .../common/entity/job/protocol/MqttProtocol.java | 0 .../entity/job/protocol/NebulaGraphProtocol.java | 0 .../common/entity/job/protocol/NginxProtocol.java | 0 .../common/entity/job/protocol/NgqlProtocol.java | 0 .../common/entity/job/protocol/NtpProtocol.java | 0 .../common/entity/job/protocol/Pop3Protocol.java | 0 .../entity/job/protocol/PrometheusProtocol.java | 0 .../common/entity/job/protocol/PushProtocol.java | 0 .../entity/job/protocol/RedfishProtocol.java | 0 .../common/entity/job/protocol/RedisProtocol.java | 0 .../entity/job/protocol/RocketmqProtocol.java | 0 .../common/entity/job/protocol/ScriptProtocol.java | 0 .../common/entity/job/protocol/SmtpProtocol.java | 0 .../common/entity/job/protocol/SnmpProtocol.java | 0 .../common/entity/job/protocol/SshProtocol.java | 0 .../common/entity/job/protocol/TelnetProtocol.java | 0 .../common/entity/job/protocol/UdpProtocol.java | 0 .../entity/job/protocol/WebsocketProtocol.java | 0 .../hertzbeat/common/entity/manager/Bulletin.java | 0 .../hertzbeat/common/entity/manager/Collector.java | 0 .../entity/manager/CollectorMonitorBind.java | 0 .../hertzbeat/common/entity/manager/Define.java | 0 .../common/entity/manager/GeneralConfig.java | 0 .../manager/JsonByteListAttributeConverter.java | 0 .../manager/JsonLongListAttributeConverter.java | 0 .../manager/JsonMapListAttributeConverter.java | 0 .../manager/JsonOptionListAttributeConverter.java | 0 .../manager/JsonStringListAttributeConverter.java | 0 .../entity/manager/JsonTagAttributeConverter.java | 0 .../manager/JsonTagListAttributeConverter.java | 0 .../hertzbeat/common/entity/manager/Monitor.java | 0 .../common/entity/manager/NoticeReceiver.java | 0 .../common/entity/manager/NoticeRule.java | 0 .../common/entity/manager/NoticeTemplate.java | 0 .../hertzbeat/common/entity/manager/Param.java | 0 .../common/entity/manager/ParamDefine.java | 0 .../common/entity/manager/PluginItem.java | 0 .../common/entity/manager/PluginMetadata.java | 0 .../common/entity/manager/StatusPageComponent.java | 0 .../common/entity/manager/StatusPageHistory.java | 0 .../common/entity/manager/StatusPageIncident.java | 0 .../manager/StatusPageIncidentComponentBind.java | 0 .../entity/manager/StatusPageIncidentContent.java | 0 .../common/entity/manager/StatusPageOrg.java | 0 .../hertzbeat/common/entity/manager/Tag.java | 0 .../hertzbeat/common/entity/manager/TagItem.java | 0 .../common/entity/manager/TagMonitorBind.java | 0 .../manager/ZonedDateTimeAttributeConverter.java | 0 .../common/entity/message/ClusterMsg.java | 0 .../common/entity/message/CollectRep.java | 0 .../common/entity/plugin/PluginConfig.java | 0 .../common/entity/plugin/PluginContext.java | 0 .../hertzbeat/common/entity/plugin/Script.java | 0 .../hertzbeat/common/entity/push/PushMetrics.java | 0 .../common/entity/push/PushMetricsDto.java | 0 .../hertzbeat/common/entity/warehouse/History.java | 0 .../hertzbeat/common/queue/CommonDataQueue.java | 0 .../common/queue/impl/InMemoryCommonDataQueue.java | 0 .../common/queue/impl/KafkaCommonDataQueue.java | 0 .../common/queue/impl/RedisCommonDataQueue.java | 0 .../common/serialize/AlertDeserializer.java | 0 .../common/serialize/AlertSerializer.java | 0 .../serialize/KafkaMetricsDataDeserializer.java | 0 .../serialize/KafkaMetricsDataSerializer.java | 0 .../hertzbeat/common/support/CommonThreadPool.java | 0 .../common/support/ResourceBundleUtf8Control.java | 0 .../common/support/SpringContextHolder.java | 0 .../common/support/event/MonitorDeletedEvent.java | 0 .../support/event/SystemConfigChangeEvent.java | 0 .../common/support/exception/CommonException.java | 0 .../support/exception/ScriptLoadException.java | 0 .../support/exception/SendMessageException.java | 0 .../common/support/valid/EmailParamValidator.java | 0 .../hertzbeat/common/support/valid/EmailValid.java | 0 .../common/support/valid/HostParamValidator.java | 0 .../hertzbeat/common/support/valid/HostValid.java | 0 .../support/valid/PhoneNumParamValidator.java | 0 .../common/support/valid/PhoneNumValid.java | 0 .../common/support/valid/ScriptValidator.java | 0 .../org/apache/hertzbeat/common/util/AesUtil.java | 0 .../apache/hertzbeat/common/util/Base64Util.java | 0 .../apache/hertzbeat/common/util/CommonUtil.java | 0 .../org/apache/hertzbeat/common/util/FileUtil.java | 0 .../common/util/IntervalExpressionUtil.java | 0 .../apache/hertzbeat/common/util/IpDomainUtil.java | 0 .../hertzbeat/common/util/JexlCommonFunction.java | 0 .../common/util/JexlExpressionRunner.java | 0 .../org/apache/hertzbeat/common/util/JsonUtil.java | 0 .../apache/hertzbeat/common/util/LruHashMap.java | 0 .../apache/hertzbeat/common/util/MapCapUtil.java | 0 .../apache/hertzbeat/common/util/NetworkUtil.java | 0 .../org/apache/hertzbeat/common/util/Pair.java | 0 .../hertzbeat/common/util/ProtoJsonUtil.java | 0 .../hertzbeat/common/util/ResourceBundleUtil.java | 0 .../apache/hertzbeat/common/util/ResponseUtil.java | 0 .../apache/hertzbeat/common/util/ScriptUtil.java | 0 .../common/util/SnowFlakeIdGenerator.java | 0 .../hertzbeat/common/util/SnowFlakeIdWorker.java | 0 .../apache/hertzbeat/common/util/StrBuffer.java | 0 .../org/apache/hertzbeat/common/util/StrUtil.java | 0 .../hertzbeat/common/util/TimePeriodUtil.java | 0 .../apache/hertzbeat/common/util/TimeZoneUtil.java | 0 .../common/util/export/ExcelExportUtils.java | 0 .../common/util/export/YamlExportUtils.java | 0 .../hertzbeat/common/util/prometheus/Label.java | 0 .../hertzbeat/common/util/prometheus/Metric.java | 0 .../common/util/prometheus/PrometheusUtil.java | 0 .../src/main/message/cluster_msg.proto | 0 .../src/main/message/collect_rep.proto | 0 ...rk.boot.autoconfigure.AutoConfiguration.imports | 0 .../hertzbeat/common/cache/CacheFactoryTest.java | 0 .../hertzbeat/common/cache/CaffeineCacheTest.java | 0 .../common/entity/plugin/PluginContextTest.java | 0 .../queue/impl/InMemoryCommonDataQueueTest.java | 0 .../queue/impl/KafkaCommonDataQueueTest.java | 0 .../queue/impl/RedisCommonDataQueueTest.java | 0 .../common/serialize/AlertDeserializerTest.java | 0 .../common/serialize/AlertSerializerTest.java | 0 .../KafkaMetricsDataDeserializerTest.java | 0 .../serialize/KafkaMetricsDataSerializerTest.java | 0 .../common/support/CommonThreadPoolTest.java | 0 .../support/ResourceBundleUtf8ControlTest.java | 0 .../common/support/SpringContextHolderTest.java | 0 .../support/vaild/EmailParamValidatorTest.java | 0 .../support/vaild/HostParamValidatorTest.java | 0 .../support/vaild/PhoneNumParamValidatorTest.java | 0 .../apache/hertzbeat/common/util/AesUtilTest.java | 0 .../hertzbeat/common/util/Base64UtilTest.java | 0 .../hertzbeat/common/util/CommonUtilTest.java | 0 .../apache/hertzbeat/common/util/FileUtilTest.java | 0 .../common/util/IntervalExpressionUtilTest.java | 0 .../hertzbeat/common/util/IpDomainUtilTest.java | 0 .../common/util/JexlExpressionRunnerTest.java | 0 .../org/apache/hertzbeat/common/util/JexlTest.java | 0 .../apache/hertzbeat/common/util/JsonUtilTest.java | 0 .../hertzbeat/common/util/LruHashMapTest.java | 0 .../hertzbeat/common/util/MapCapUtilTest.java | 0 .../hertzbeat/common/util/NetworkUtilTest.java | 0 .../org/apache/hertzbeat/common/util/PairTest.java | 0 .../hertzbeat/common/util/ProtoJsonUtilTest.java | 0 .../common/util/ResourceBundleUtilTest.java | 0 .../hertzbeat/common/util/ResponseUtilTest.java | 0 .../common/util/SnowFlakeIdGeneratorTest.java | 0 .../hertzbeat/common/util/StrBufferTest.java | 0 .../apache/hertzbeat/common/util/StrUtilTest.java | 0 .../hertzbeat/common/util/TimePeriodUtilTest.java | 0 .../hertzbeat/common/util/TimeZoneUtilTest.java | 0 .../hertzbeat/common/util/entity/PersonTest.java | 0 .../common/util/prometheus/PrometheusUtilTest.java | 0 .../src/test/proto/person.proto | 0 .../src/test/resources/msg.properties | 0 .../src/test/resources/msg_en.properties | 0 .../hertzbeat-collector-kafka-e2e}/pom.xml | 27 ++- .../collect/kafka/KafkaCollectE2eTest.java | 143 +++++++++++++ .../collector-rocketmq => hertzbeat-e2e}/pom.xml | 39 +++- {grafana => hertzbeat-grafana}/pom.xml | 0 .../hertzbeat/grafana/common/GrafanaConstants.java | 6 +- .../grafana/config/GrafanaAutoConfiguration.java | 0 .../hertzbeat/grafana/config/GrafanaInit.java | 0 .../grafana/config/GrafanaProperties.java | 1 + .../grafana/controller/DashboardController.java | 0 .../apache/hertzbeat/grafana/dao/DashboardDao.java | 0 .../hertzbeat/grafana/dao/GrafanaConfigDao.java | 0 .../hertzbeat/grafana/dto/GrafanaConfig.java | 0 .../grafana/service/DashboardService.java | 2 +- .../grafana/service/DatasourceService.java | 0 .../grafana/service/ServiceAccountService.java | 13 +- .../src/main/resources/META-INF/spring.factories | 0 {manager => hertzbeat-manager}/pom.xml | 0 .../java/org/apache/hertzbeat/manager/Manager.java | 0 .../component/alerter/AlertNotifyHandler.java | 0 .../component/alerter/AlertStoreHandler.java | 0 .../manager/component/alerter/DispatcherAlarm.java | 0 .../impl/AbstractAlertNotifyHandlerImpl.java | 0 .../alerter/impl/AliYunAlertNotifyHandlerImpl.java | 0 .../alerter/impl/CommonRobotNotifyResp.java | 0 .../alerter/impl/DbAlertStoreHandlerImpl.java | 0 .../impl/DingTalkRobotAlertNotifyHandlerImpl.java | 0 .../impl/DiscordBotAlertNotifyHandlerImpl.java | 0 .../alerter/impl/EmailAlertNotifyHandlerImpl.java | 0 .../impl/FlyBookAlertNotifyHandlerImpl.java | 0 .../alerter/impl/GotifyAlertNotifyHandlerImpl.java | 0 .../impl/HuaweiCloudSmnAlertNotifyHandlerImpl.java | 0 .../impl/ServerChanAlertNotifyHandlerImpl.java | 0 .../alerter/impl/SlackAlertNotifyHandlerImpl.java | 0 .../alerter/impl/SmsAlertNotifyHandlerImpl.java | 0 .../impl/TelegramBotAlertNotifyHandlerImpl.java | 0 .../alerter/impl/WeChatAlertNotifyHandlerImpl.java | 0 .../impl/WeComAppAlertNotifyHandlerImpl.java | 0 .../impl/WeComRobotAlertNotifyHandlerImpl.java | 0 .../impl/WebHookAlertNotifyHandlerImpl.java | 0 .../component/listener/TimeZoneListener.java | 0 .../manager/component/status/CalculateStatus.java | 0 .../hertzbeat/manager/config/AiProperties.java | 0 .../manager/config/AngularErrorViewResolver.java | 0 .../manager/config/ConfigInitializer.java | 0 .../manager/config/FlywayConfiguration.java | 0 .../manager/config/HeaderRequestInterceptor.java | 0 .../hertzbeat/manager/config/JacksonConfig.java | 0 .../hertzbeat/manager/config/JpaAuditorConfig.java | 0 .../manager/config/RestTemplateConfig.java | 0 .../hertzbeat/manager/config/SchedulerConfig.java | 0 .../manager/config/SecurityCorsConfiguration.java | 0 .../hertzbeat/manager/config/StatusProperties.java | 0 .../hertzbeat/manager/config/SwaggerConfig.java | 0 .../manager/controller/AccountController.java | 0 .../hertzbeat/manager/controller/AiController.java | 0 .../manager/controller/AppController.java | 0 .../manager/controller/BulletinController.java | 0 .../manager/controller/CollectorController.java | 0 .../controller/GeneralConfigController.java | 0 .../manager/controller/I18nController.java | 0 .../manager/controller/MetricsController.java | 0 .../manager/controller/MonitorController.java | 0 .../manager/controller/MonitorsController.java | 0 .../manager/controller/NoticeConfigController.java | 0 .../manager/controller/PluginController.java | 0 .../manager/controller/StatusPageController.java | 0 .../controller/StatusPagePublicController.java | 0 .../manager/controller/SummaryController.java | 0 .../manager/controller/TagController.java | 0 .../apache/hertzbeat/manager/dao/BulletinDao.java | 0 .../apache/hertzbeat/manager/dao/CollectorDao.java | 0 .../manager/dao/CollectorMonitorBindDao.java | 0 .../apache/hertzbeat/manager/dao/DefineDao.java | 0 .../hertzbeat/manager/dao/GeneralConfigDao.java | 0 .../apache/hertzbeat/manager/dao/MonitorDao.java | 0 .../hertzbeat/manager/dao/NoticeReceiverDao.java | 0 .../hertzbeat/manager/dao/NoticeRuleDao.java | 0 .../hertzbeat/manager/dao/NoticeTemplateDao.java | 0 .../org/apache/hertzbeat/manager/dao/ParamDao.java | 0 .../hertzbeat/manager/dao/ParamDefineDao.java | 0 .../hertzbeat/manager/dao/PluginItemDao.java | 0 .../hertzbeat/manager/dao/PluginMetadataDao.java | 0 .../hertzbeat/manager/dao/PluginParamDao.java | 0 .../manager/dao/StatusPageComponentDao.java | 0 .../manager/dao/StatusPageHistoryDao.java | 0 .../dao/StatusPageIncidentComponentBindDao.java | 0 .../manager/dao/StatusPageIncidentDao.java | 0 .../hertzbeat/manager/dao/StatusPageOrgDao.java | 0 .../org/apache/hertzbeat/manager/dao/TagDao.java | 0 .../hertzbeat/manager/dao/TagMonitorBindDao.java | 0 .../nativex/HertzbeatRuntimeHintsRegistrar.java | 0 .../manager/pojo/dto/AiControllerRequestParam.java | 0 .../hertzbeat/manager/pojo/dto/AiMessage.java | 0 .../manager/pojo/dto/AliAiRequestParamDTO.java | 0 .../hertzbeat/manager/pojo/dto/AliAiResponse.java | 0 .../hertzbeat/manager/pojo/dto/AppCount.java | 0 .../manager/pojo/dto/BulletinMetricsData.java | 0 .../manager/pojo/dto/ComponentStatus.java | 0 .../hertzbeat/manager/pojo/dto/Dashboard.java | 0 .../manager/pojo/dto/EmailNoticeSender.java | 0 .../apache/hertzbeat/manager/pojo/dto/FileDTO.java | 0 .../hertzbeat/manager/pojo/dto/Hierarchy.java | 0 .../hertzbeat/manager/pojo/dto/LoginDto.java | 0 .../manager/pojo/dto/MonitorDefineDto.java | 0 .../hertzbeat/manager/pojo/dto/MonitorDto.java | 0 .../pojo/dto/ObjectStoreConfigChangeEvent.java | 0 .../hertzbeat/manager/pojo/dto/ObjectStoreDTO.java | 0 .../manager/pojo/dto/OpenAiRequestParamDTO.java | 0 .../hertzbeat/manager/pojo/dto/OpenAiResponse.java | 0 .../hertzbeat/manager/pojo/dto/ParamDefineDto.java | 0 .../hertzbeat/manager/pojo/dto/PluginParam.java | 0 .../manager/pojo/dto/PluginParametersVO.java | 0 .../manager/pojo/dto/RefreshTokenResponse.java | 0 .../manager/pojo/dto/SmsAlibabaConfig.java | 0 .../manager/pojo/dto/SmsNoticeSender.java | 0 .../manager/pojo/dto/SmsTencentConfig.java | 0 .../hertzbeat/manager/pojo/dto/SystemConfig.java | 0 .../hertzbeat/manager/pojo/dto/SystemSecret.java | 0 .../hertzbeat/manager/pojo/dto/TemplateConfig.java | 0 .../hertzbeat/manager/pojo/dto/TokenDto.java | 0 .../hertzbeat/manager/scheduler/AssignJobs.java | 0 .../manager/scheduler/CollectJobScheduling.java | 0 .../manager/scheduler/CollectorJobScheduler.java | 2 +- .../manager/scheduler/CollectorScheduling.java | 0 .../manager/scheduler/ConcurrentTreeMap.java | 0 .../manager/scheduler/ConsistentHash.java | 0 .../hertzbeat/manager/scheduler/SchedulerInit.java | 2 +- .../manager/scheduler/SchedulerProperties.java | 0 .../manager/scheduler/netty/ManageServer.java | 0 .../CollectCyclicDataResponseProcessor.java | 0 .../CollectOneTimeDataResponseProcessor.java | 0 .../netty/process/CollectorOfflineProcessor.java | 0 .../netty/process/CollectorOnlineProcessor.java | 0 .../netty/process/HeartbeatProcessor.java | 0 .../netty/process/ScriptResponseProcessor.java | 0 .../hertzbeat/manager/service/AccountService.java | 0 .../hertzbeat/manager/service/AppService.java | 0 .../manager/service/AvailableAlertDefineInit.java | 0 .../hertzbeat/manager/service/BulletinService.java | 0 .../manager/service/CollectorService.java | 0 .../hertzbeat/manager/service/ConfigService.java | 0 .../manager/service/GeneralConfigService.java | 0 .../hertzbeat/manager/service/ImExportService.java | 0 .../hertzbeat/manager/service/MonitorService.java | 0 .../manager/service/NoticeConfigService.java | 0 .../manager/service/NoticeDispatchService.java | 0 .../manager/service/ObjectStoreService.java | 0 .../hertzbeat/manager/service/PluginService.java | 0 .../manager/service/StatusPageService.java | 0 .../hertzbeat/manager/service/TagService.java | 0 .../manager/service/TencentSmsClient.java | 0 .../hertzbeat/manager/service/ai/AiService.java | 0 .../manager/service/ai/AlibabaAiServiceImpl.java | 0 .../manager/service/ai/KimiAiServiceImpl.java | 0 .../manager/service/ai/SparkDeskAiServiceImpl.java | 0 .../manager/service/ai/ZhiPuServiceImpl.java | 0 .../service/ai/factory/AiServiceFactoryImpl.java | 0 .../impl/AbstractGeneralConfigServiceImpl.java | 0 .../service/impl/AbstractImExportServiceImpl.java | 0 .../manager/service/impl/AccountServiceImpl.java | 0 .../manager/service/impl/AppServiceImpl.java | 0 .../manager/service/impl/BulletinServiceImpl.java | 0 .../manager/service/impl/CollectorServiceImpl.java | 0 .../manager/service/impl/ConfigServiceImpl.java | 0 .../manager/service/impl/DefaultPluginRunner.java | 0 .../service/impl/ExcelImExportServiceImpl.java | 0 .../service/impl/JsonImExportServiceImpl.java | 0 .../service/impl/MailGeneralConfigServiceImpl.java | 0 .../manager/service/impl/MonitorServiceImpl.java | 10 +- .../service/impl/NoticeConfigServiceImpl.java | 0 .../service/impl/ObjectStoreConfigServiceImpl.java | 0 .../service/impl/ObsObjectStoreServiceImpl.java | 0 .../manager/service/impl/PluginServiceImpl.java | 0 .../service/impl/SmsGeneralConfigServiceImpl.java | 0 .../service/impl/StatusPageServiceImpl.java | 0 .../impl/SystemGeneralConfigServiceImpl.java | 0 .../service/impl/SystemSecretServiceImpl.java | 0 .../manager/service/impl/TagServiceImpl.java | 0 .../service/impl/TemplateConfigServiceImpl.java | 0 .../service/impl/YamlImExportServiceImpl.java | 0 .../manager/support/GlobalExceptionHandler.java | 0 .../support/exception/AlertNoticeException.java | 0 .../manager/support/exception/IgnoreException.java | 0 .../exception/MonitorDatabaseException.java | 0 .../support/exception/MonitorDetectException.java | 0 .../support/exception/MonitorMetricsException.java | 0 .../src/main/resources/application-test.yml | 0 .../src/main/resources/application.yml | 1 + .../src/main/resources/banner.txt | 0 .../db/migration/h2/V160__update_column.sql | 0 .../db/migration/mysql/V160__update_column.sql | 0 .../migration/postgresql/V160__update_column.sql | 0 .../src/main/resources/define/app-a_example.yml | 0 .../src/main/resources/define/app-activemq.yml | 0 .../src/main/resources/define/app-airflow.yml | 0 .../src/main/resources/define/app-almalinux.yml | 0 .../src/main/resources/define/app-api.yml | 0 .../src/main/resources/define/app-api_code.yml | 0 .../src/main/resources/define/app-centos.yml | 0 .../src/main/resources/define/app-cisco_switch.yml | 0 .../src/main/resources/define/app-clickhouse.yml | 0 .../src/main/resources/define/app-coreos.yml | 0 .../src/main/resources/define/app-debian.yml | 0 .../src/main/resources/define/app-dm.yml | 0 .../src/main/resources/define/app-dns.yml | 0 .../src/main/resources/define/app-docker.yml | 0 .../src/main/resources/define/app-doris_be.yml | 0 .../src/main/resources/define/app-doris_fe.yml | 0 .../src/main/resources/define/app-dynamic_tp.yml | 0 .../main/resources/define/app-elasticsearch.yml | 0 .../src/main/resources/define/app-emqx.yml | 0 .../src/main/resources/define/app-euleros.yml | 0 .../src/main/resources/define/app-flink.yml | 0 .../main/resources/define/app-flink_on_yarn.yml | 0 .../src/main/resources/define/app-freebsd.yml | 0 .../src/main/resources/define/app-ftp.yml | 0 .../src/main/resources/define/app-fullsite.yml | 0 .../src/main/resources/define/app-greenplum.yml | 0 .../src/main/resources/define/app-greptime.yml | 0 .../src/main/resources/define/app-h3c_switch.yml | 0 .../src/main/resources/define/app-hadoop.yml | 0 .../src/main/resources/define/app-hbase_master.yml | 0 .../resources/define/app-hbase_regionserver.yml | 0 .../main/resources/define/app-hdfs_datanode.yml | 0 .../main/resources/define/app-hdfs_namenode.yml | 0 .../src/main/resources/define/app-hertzbeat.yml | 0 .../main/resources/define/app-hertzbeat_token.yml | 0 .../src/main/resources/define/app-hive.yml | 0 .../src/main/resources/define/app-hpe_switch.yml | 0 .../src/main/resources/define/app-http_sd.yml | 0 .../main/resources/define/app-huawei_switch.yml | 0 .../src/main/resources/define/app-hugegraph.yml | 0 .../src/main/resources/define/app-iceberg.yml | 0 .../src/main/resources/define/app-influxdb.yml | 0 .../main/resources/define/app-influxdb_promql.yml | 0 .../src/main/resources/define/app-iotdb.yml | 0 .../src/main/resources/define/app-ipmi.yml | 0 .../src/main/resources/define/app-jetty.yml | 0 .../src/main/resources/define/app-jvm.yml | 0 .../src/main/resources/define/app-kafka.yml | 0 .../src/main/resources/define/app-kafka_client.yml | 35 +--- .../src/main/resources/define/app-kafka_promql.yml | 0 .../src/main/resources/define/app-kingbase.yml | 0 .../src/main/resources/define/app-kubernetes.yml | 0 .../src/main/resources/define/app-kvrocks.yml | 0 .../src/main/resources/define/app-linux.yml | 0 .../src/main/resources/define/app-linux_script.yml | 0 .../src/main/resources/define/app-mariadb.yml | 0 .../src/main/resources/define/app-memcached.yml | 0 .../main/resources/define/app-mongodb-atlas.yml | 0 .../src/main/resources/define/app-mongodb.yml | 0 .../src/main/resources/define/app-mqtt.yml | 0 .../src/main/resources/define/app-mysql.yml | 0 .../src/main/resources/define/app-nacos.yml | 0 .../src/main/resources/define/app-nebulaGraph.yml | 0 .../resources/define/app-nebula_graph_cluster.yml | 0 .../main/resources/define/app-netease_mailbox.yml | 0 .../src/main/resources/define/app-nginx.yml | 0 .../src/main/resources/define/app-ntp.yml | 0 .../src/main/resources/define/app-nvidia.yml | 0 .../src/main/resources/define/app-oceanbase.yml | 0 .../src/main/resources/define/app-openai.yml | 0 .../src/main/resources/define/app-opengauss.yml | 0 .../src/main/resources/define/app-opensuse.yml | 0 .../src/main/resources/define/app-oracle.yml | 0 .../src/main/resources/define/app-ping.yml | 0 .../src/main/resources/define/app-pop3.yml | 0 .../src/main/resources/define/app-port.yml | 0 .../src/main/resources/define/app-postgresql.yml | 0 .../src/main/resources/define/app-prestodb.yml | 0 .../src/main/resources/define/app-process.yml | 8 +- .../src/main/resources/define/app-prometheus.yml | 0 .../src/main/resources/define/app-pulsar.yml | 0 .../src/main/resources/define/app-push.yml | 0 .../src/main/resources/define/app-qq_mailbox.yml | 0 .../src/main/resources/define/app-rabbitmq.yml | 0 .../src/main/resources/define/app-redfish.yml | 0 .../src/main/resources/define/app-redhat.yml | 0 .../src/main/resources/define/app-redis.yml | 0 .../main/resources/define/app-redis_cluster.yml | 0 .../main/resources/define/app-redis_sentinel.yml | 0 .../src/main/resources/define/app-rocketmq.yml | 0 .../src/main/resources/define/app-rockylinux.yml | 0 .../src/main/resources/define/app-seatunnel.yml | 0 .../src/main/resources/define/app-shenyu.yml | 0 .../src/main/resources/define/app-smtp.yml | 0 .../src/main/resources/define/app-spark.yml | 0 .../main/resources/define/app-spring_gateway.yml | 0 .../src/main/resources/define/app-springboot2.yml | 0 .../src/main/resources/define/app-springboot3.yml | 0 .../src/main/resources/define/app-sqlserver.yml | 0 .../src/main/resources/define/app-ssl_cert.yml | 0 .../src/main/resources/define/app-storm.yml | 0 .../src/main/resources/define/app-tidb.yml | 0 .../src/main/resources/define/app-tomcat.yml | 0 .../main/resources/define/app-tplink_switch.yml | 0 .../src/main/resources/define/app-ubuntu.yml | 0 .../src/main/resources/define/app-udp_port.yml | 0 .../src/main/resources/define/app-valkey.yml | 0 .../src/main/resources/define/app-vastbase.yml | 0 .../src/main/resources/define/app-website.yml | 0 .../src/main/resources/define/app-websocket.yml | 0 .../src/main/resources/define/app-windows.yml | 233 +++++++-------------- .../main/resources/define/app-windows_script.yml | 0 .../src/main/resources/define/app-yarn.yml | 0 .../src/main/resources/define/app-zookeeper.yml | 0 .../src/main/resources/logback-spring.xml | 0 .../src/main/resources/sureness.yml | 0 .../main/resources/templates/1-EmailTemplate.html | 0 .../resources/templates/10-WeWorkAppTemplate.txt | 0 .../templates/11-HuaweiCloudSmnTemplate.txt | 0 .../resources/templates/12-ServerChanTemplate.txt | 0 .../main/resources/templates/13-GotifyTemplate.txt | 0 .../main/resources/templates/2-WebhookTemplate.txt | 0 .../resources/templates/4-WeWorkRobotTemplate.txt | 0 .../templates/5-DingTalkRobotTemplate.txt | 0 .../resources/templates/6-FlyBookRobotTemplate.txt | 0 .../resources/templates/7-TelegramBotTemplate.txt | 0 .../main/resources/templates/8-SlackTemplate.txt | 0 .../resources/templates/9-DiscordBotTemplate.txt | 0 .../manager/AbstractSpringIntegrationTest.java | 0 .../org/apache/hertzbeat/manager/ManagerTest.java | 0 .../component/alerter/DispatcherAlarmTest.java | 0 .../impl/AliYunAlertNotifyHandlerImplTest.java | 0 .../alerter/impl/DbAlertStoreHandlerImplTest.java | 0 .../DingTalkRobotAlertNotifyHandlerImplTest.java | 0 .../impl/DiscordBotAlertNotifyHandlerImplTest.java | 0 .../impl/EmailAlertNotifyHandlerImplTest.java | 0 .../impl/FlyBookAlertNotifyHandlerImplTest.java | 0 .../impl/GotifyAlertNotifyHandlerImplTest.java | 0 .../HuaweiCloudSmnAlertNotifyHandlerImplTest.java | 0 .../impl/ServerChanAlertNotifyHandlerImplTest.java | 0 .../impl/SlackAlertNotifyHandlerImplTest.java | 0 .../impl/SmsAlertNotifyHandlerImplTest.java | 0 .../TelegramBotAlertNotifyHandlerImplTest.java | 0 .../impl/WeChatAppAlertNotifyHandlerImplTest.java | 0 .../impl/WeComAppAlertNotifyHandlerImplTest.java | 0 .../impl/WeComRobotAlertNotifyHandlerImplTest.java | 0 .../impl/WebHookAlertNotifyHandlerImplTest.java | 0 .../component/listener/TimeZoneListenerTest.java | 0 .../manager/controller/AccountControllerTest.java | 0 .../manager/controller/AiControllerTest.java | 0 .../manager/controller/AppControllerTest.java | 0 .../manager/controller/BulletinControllerTest.java | 0 .../controller/CollectorControllerTest.java | 0 .../controller/GeneralConfigControllerTest.java | 0 .../manager/controller/I18nControllerTest.java | 0 .../manager/controller/MetricsControllerTest.java | 0 .../manager/controller/MonitorControllerTest.java | 0 .../manager/controller/MonitorsControllerTest.java | 0 .../controller/NoticeConfigControllerTest.java | 0 .../manager/controller/PluginControllerTest.java | 0 .../controller/StatusPageControllerTest.java | 0 .../controller/StatusPagePublicControllerTest.java | 0 .../manager/controller/SummaryControllerTest.java | 0 .../manager/controller/TagControllerTest.java | 0 .../hertzbeat/manager/dao/CollectorDaoTest.java | 0 .../hertzbeat/manager/dao/MonitorDaoTest.java | 0 .../hertzbeat/manager/dao/NoticeRuleDaoTest.java | 0 .../apache/hertzbeat/manager/dao/ParamDaoTest.java | 0 .../hertzbeat/manager/dao/ParamDefineDaoTest.java | 0 .../apache/hertzbeat/manager/dao/TagDaoTest.java | 0 .../scheduler/CollectorJobSchedulerTest.java | 0 .../manager/scheduler/ConsistentHashTest.java | 0 .../manager/service/AccountServiceTest.java | 0 .../manager/service/AiServiceFactoryTest.java | 0 .../manager/service/AlibabaAiServiceTest.java | 0 .../hertzbeat/manager/service/AppServiceTest.java | 0 .../service/AvailableAlertDefineInitTest.java | 0 .../manager/service/BulletinServiceTest.java | 0 .../manager/service/CollectorServiceTest.java | 0 .../manager/service/ConfigServiceTest.java | 0 .../manager/service/DefaultPluginRunnerTest.java | 0 .../manager/service/ExcelImExportServiceTest.java | 0 .../manager/service/JsonImExportServiceTest.java | 0 .../manager/service/KimiAiServiceTest.java | 0 .../service/MailGeneralConfigServiceTest.java | 0 .../manager/service/MonitorServiceTest.java | 0 .../manager/service/NoticeConfigServiceTest.java | 0 .../service/ObjectStoreConfigServiceTest.java | 0 .../manager/service/ObsObjectStoreServiceTest.java | 0 .../manager/service/PluginServiceTest.java | 0 .../service/SmsGeneralConfigServiceTest.java | 0 .../manager/service/SparkDeskAiServiceTest.java | 0 .../manager/service/StatusPageServiceTest.java | 0 .../service/SystemGeneralConfigServiceTest.java | 0 .../manager/service/SystemSecretServiceTest.java | 0 .../hertzbeat/manager/service/TagServiceTest.java | 0 .../manager/service/TemplateConfigServiceTest.java | 0 .../manager/service/YamlImExportServiceTest.java | 0 .../manager/service/ZhiPuServiceTest.java | 0 .../org.mockito.plugins.MockMaker | 0 {plugin => hertzbeat-plugin}/pom.xml | 0 .../java/org/apache/hertzbeat/plugin/Plugin.java | 0 .../apache/hertzbeat/plugin/PostAlertPlugin.java | 0 .../apache/hertzbeat/plugin/PostCollectPlugin.java | 0 .../hertzbeat/plugin/runner/PluginRunner.java | 0 .../services/org.apache.hertzbeat.plugin.Plugin | 0 .../org.apache.hertzbeat.plugin.PostAlertPlugin | 0 .../org.apache.hertzbeat.plugin.PostCollectPlugin | 0 .../src/main/resources/assembly/assembly.xml | 0 .../src/main/resources/define/define.yml | 0 {push => hertzbeat-push}/pom.xml | 0 .../push/config/PushAutoConfiguration.java | 0 .../hertzbeat/push/controller/PushController.java | 0 .../push/controller/PushGatewayController.java | 0 .../apache/hertzbeat/push/dao/PushMetricsDao.java | 0 .../apache/hertzbeat/push/dao/PushMonitorDao.java | 0 .../hertzbeat/push/service/PushGatewayService.java | 0 .../apache/hertzbeat/push/service/PushService.java | 0 .../push/service/impl/PushGatewayServiceImpl.java | 0 .../push/service/impl/PushServiceImpl.java | 0 ...rk.boot.autoconfigure.AutoConfiguration.imports | 0 .../push/controller/PushControllerTest.java | 0 .../push/controller/PushGatewayControllerTest.java | 0 .../hertzbeat/push/dao/PushMetricsDaoTest.java | 0 .../hertzbeat/push/dao/PushMonitorDaoTest.java | 0 .../push/service/PushGatewayServiceTest.java | 0 .../hertzbeat/push/service/PushServiceTest.java | 0 {remoting => hertzbeat-remoting}/pom.xml | 0 .../apache/hertzbeat/remoting/RemotingClient.java | 0 .../apache/hertzbeat/remoting/RemotingServer.java | 0 .../apache/hertzbeat/remoting/RemotingService.java | 0 .../remoting/event/NettyEventListener.java | 0 .../remoting/netty/NettyClientConfig.java | 0 .../apache/hertzbeat/remoting/netty/NettyHook.java | 0 .../remoting/netty/NettyRemotingAbstract.java | 0 .../remoting/netty/NettyRemotingClient.java | 0 .../remoting/netty/NettyRemotingProcessor.java | 0 .../remoting/netty/NettyRemotingServer.java | 0 .../remoting/netty/NettyServerConfig.java | 0 .../hertzbeat/remoting/netty/ResponseFuture.java | 0 .../hertzbeat/remoting/RemotingServiceTest.java | 0 {warehouse => hertzbeat-warehouse}/pom.xml | 0 .../hertzbeat/warehouse/WarehouseWorkerPool.java | 0 .../config/WarehouseAutoConfiguration.java | 0 .../warehouse/constants/WarehouseConstants.java | 0 .../controller/MetricsDataController.java | 0 .../apache/hertzbeat/warehouse/dao/HistoryDao.java | 0 .../WareHouseApplicationReadyListener.java | 0 .../warehouse/service/MetricsDataService.java | 0 .../warehouse/service/WarehouseService.java | 0 .../service/impl/MetricsDataServiceImpl.java | 0 .../service/impl/WarehouseServiceImpl.java | 0 .../warehouse/store/DataStorageDispatch.java | 0 .../store/history/AbstractHistoryDataStorage.java | 0 .../warehouse/store/history/HistoryDataReader.java | 0 .../warehouse/store/history/HistoryDataWriter.java | 0 .../history/greptime/GreptimeDbDataStorage.java | 0 .../store/history/greptime/GreptimeProperties.java | 0 .../history/influxdb/InfluxdbDataStorage.java | 0 .../store/history/influxdb/InfluxdbProperties.java | 0 .../store/history/iotdb/IotDbDataStorage.java | 0 .../store/history/iotdb/IotDbProperties.java | 0 .../store/history/jpa/JpaDatabaseDataStorage.java | 0 .../warehouse/store/history/jpa/JpaProperties.java | 0 .../history/tdengine/TdEngineDataStorage.java | 0 .../store/history/tdengine/TdEngineProperties.java | 0 .../vm/VictoriaMetricsClusterDataStorage.java | 5 +- .../vm/VictoriaMetricsClusterProperties.java | 0 .../history/vm/VictoriaMetricsDataStorage.java | 5 +- .../vm/VictoriaMetricsInsertProperties.java | 0 .../history/vm/VictoriaMetricsProperties.java | 0 .../vm/VictoriaMetricsSelectProperties.java | 0 .../realtime/AbstractRealTimeDataStorage.java | 0 .../store/realtime/RealTimeDataReader.java | 0 .../store/realtime/RealTimeDataWriter.java | 0 .../store/realtime/memory/MemoryDataStorage.java | 0 .../store/realtime/memory/MemoryProperties.java | 0 .../realtime/redis/MetricsDataRedisCodec.java | 0 .../store/realtime/redis/RedisDataStorage.java | 0 .../store/realtime/redis/RedisProperties.java | 0 .../redis/client/RedisClientOperation.java | 0 .../redis/client/RedisCommandDelegate.java | 0 .../redis/client/impl/RedisClusterClientImpl.java | 0 .../redis/client/impl/RedisSentinelClientImpl.java | 0 .../redis/client/impl/RedisSimpleClientImpl.java | 0 ...rk.boot.autoconfigure.AutoConfiguration.imports | 0 .../warehouse/WarehouseWorkerPoolTest.java | 0 .../controller/MetricsDataControllerTest.java | 0 .../warehouse/service/MetricsDataServiceTest.java | 0 .../warehouse/service/WarehouseServiceTest.java | 0 .../warehouse/store/MemoryDataStorageTest.java | 0 .../warehouse/store/MetricsDataRedisCodecTest.java | 0 .../warehouse/store/RedisDataStorageTest.java | 0 .../warehouse/store/TdEngineDataStorageTest.java | 0 home/blog/2023-02-10-new-committer.md | 22 +- home/blog/2024-06-11-hertzbeat-v1.6.0-update.md | 4 +- home/blog/2024-11-09-hertzbeat-v1.6.1.md | 91 ++++++++ home/docs/advanced/extend-point.md | 6 + home/docs/community/contribution.md | 10 +- home/docs/community/development.md | 4 +- home/docs/introduce.md | 144 ++++++------- home/docs/start/update-1.6.0.md | 4 +- home/docs/template.md | 106 +++++----- ...24-05-09-hertzbeat-ospp-subject-introduction.md | 6 +- .../2024-06-11-hertzbeat-v1.6.0-update.md | 6 +- .../2024-11-09-hertzbeat-v1.6.1.md | 91 ++++++++ .../current/advanced/extend-point.md | 7 + .../current/community/contribution.md | 12 +- .../current/community/development.md | 4 +- .../current/introduce.md | 144 ++++++------- .../current/start/update-1.6.0.md | 6 +- .../current/template.md | 106 +++++----- .../version-v1.5.x/community/contribution.md | 12 +- .../version-v1.5.x/community/development.md | 4 +- .../version-v1.5.x/introduce.md | 144 ++++++------- .../version-v1.5.x/template.md | 106 +++++----- home/src/pages/team/index.jsx | 13 ++ .../version-v1.5.x/community/contribution.md | 10 +- .../version-v1.5.x/community/development.md | 4 +- home/versioned_docs/version-v1.5.x/introduce.md | 144 ++++++------- home/versioned_docs/version-v1.5.x/template.md | 106 +++++----- material/licenses/LICENSE | 1 + material/licenses/backend/LICENSE | 1 + pom.xml | 19 +- 1072 files changed, 1341 insertions(+), 914 deletions(-) diff --cc hertzbeat-collector/hertzbeat-collector-common/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/ScriptRequestProcessor.java index 1cf4a0a59,000000000..1cf4a0a59 mode 100644,000000..100644 --- a/hertzbeat-collector/hertzbeat-collector-common/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/ScriptRequestProcessor.java +++ b/hertzbeat-collector/hertzbeat-collector-common/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/ScriptRequestProcessor.java diff --cc hertzbeat-common/src/main/java/org/apache/hertzbeat/common/entity/plugin/Script.java index 6f9010f60,000000000..6f9010f60 mode 100644,000000..100644 --- a/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/entity/plugin/Script.java +++ b/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/entity/plugin/Script.java diff --cc hertzbeat-common/src/main/java/org/apache/hertzbeat/common/support/valid/ScriptValidator.java index 2bcccc44f,000000000..2bcccc44f mode 100644,000000..100644 --- a/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/support/valid/ScriptValidator.java +++ b/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/support/valid/ScriptValidator.java diff --cc hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/netty/process/ScriptResponseProcessor.java index 5ffc409e6,000000000..5ffc409e6 mode 100644,000000..100644 --- a/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/netty/process/ScriptResponseProcessor.java +++ b/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/netty/process/ScriptResponseProcessor.java --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
