This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch metric_ssl in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit abb3ca05691e7dd3279417f002feae539ff706e7 Author: HTHou <[email protected]> AuthorDate: Thu Sep 4 15:11:54 2025 +0800 dev --- .../apache/iotdb/metrics/config/MetricConfig.java | 6 ++++++ .../reporter/iotdb/IoTDBSessionReporter.java | 21 ++++++++++++++------- 2 files changed, 20 insertions(+), 7 deletions(-) diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConfig.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConfig.java index 090ef3eae2c..8c179a816e1 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConfig.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConfig.java @@ -79,6 +79,12 @@ public class MetricConfig { private long upTimeInNs = 0; private String internalDatabase = "root.__system"; + private boolean enableSSL = false; + private String keyStorePath = ""; + private String keyStorePassword = ""; + private String trustStorePath = ""; + private String trustStorePassword = ""; + public MetricConfig() { // try to get pid of iotdb instance try { diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBSessionReporter.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBSessionReporter.java index b70ecebfff2..5d9d1105166 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBSessionReporter.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBSessionReporter.java @@ -62,13 +62,20 @@ public class IoTDBSessionReporter extends IoTDBReporter { public IoTDBSessionReporter(AbstractMetricManager metricManager) { this.metricManager = metricManager; - this.sessionPool = - new SessionPool( - ioTDBReporterConfig.getHost(), - ioTDBReporterConfig.getPort(), - ioTDBReporterConfig.getUsername(), - ioTDBReporterConfig.getPassword(), - ioTDBReporterConfig.getMaxConnectionNumber()); + SessionPool.Builder sessionPoolBuilder = + new SessionPool.Builder() + .host(ioTDBReporterConfig.getHost()) + .port(ioTDBReporterConfig.getPort()) + .user(ioTDBReporterConfig.getUsername()) + .password(ioTDBReporterConfig.getPassword()) + .maxSize(ioTDBReporterConfig.getMaxConnectionNumber()); + if () { + sessionPoolBuilder + .useSSL(true) + .trustStore("") + .trustStorePwd(""); + } + this.sessionPool = sessionPoolBuilder.build(); try (SessionDataSetWrapper result = this.sessionPool.executeQueryStatement( "SHOW DATABASES " + metricConfig.getInternalDatabase())) {
