Skip to content

Commit 1d6d5de

Browse files
committed
Fix timestamp
1 parent 1fda68f commit 1d6d5de

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

common/src/main/java/it/renvins/serverpulse/common/DatabaseService.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -215,13 +215,11 @@ private void connect() {
215215
stopRetryTask(); // Stop retrying if we just connected
216216
logger.info("Successfully connected to InfluxDB and ping successful...");
217217
} else {
218-
// Ping failed after client creation
219-
logger.warning("Created InfluxDB instance, but ping failed. Will retry...");
218+
logger.warning("Ping failed. Will retry...");
220219
this.isConnected = false; // Ensure status is false
221220
startRetryTaskIfNeeded(); // Start retry task
222221
}
223222
} catch (Exception e) {
224-
// Handle exceptions during InfluxDBClientFactory.create() or ping()
225223
logger.error("Failed to connect or ping InfluxDB: " + e.getMessage());
226224
this.isConnected = false;
227225
startRetryTaskIfNeeded(); // Start retry task

common/src/main/java/it/renvins/serverpulse/common/MetricsService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package it.renvins.serverpulse.common;
22

33
import java.time.Instant;
4-
import java.time.temporal.TemporalField;
54
import java.util.ArrayList;
65
import java.util.List;
76
import java.util.Map;
@@ -149,7 +148,7 @@ private List<String> buildPoints(SyncMetricsSnapshot snapshot, long usedHeap, lo
149148
.addField("min_ping", minPing)
150149
.addField("max_ping", maxPing)
151150
.addField("avg_ping", avgPing)
152-
.setTimestamp(Instant.now().getNano());
151+
.setTimestamp(Instant.now().toEpochMilli() * 1_000_000);
153152
addConfigTags(generalPoint);
154153
points.add(generalPoint.toLineProtocol());
155154

0 commit comments

Comments
 (0)