aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
diff options
context:
space:
mode:
authorRoy Ben Shabat <Roy.mail.net@gmail.com>2025-07-30 12:36:30 +0300
committerRoy Ben Shabat <Roy.mail.net@gmail.com>2025-07-30 12:36:30 +0300
commit4222eddece906d6f0877022c06b853deb5068472 (patch)
treea29b706b3a5aedb28a42b209d5bb72b0ef94d40e /Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
parenta802fe75f9538371004f1833e69a69b798892d0c (diff)
downloadTango-4222eddece906d6f0877022c06b853deb5068472.tar.gz
Tango-4222eddece906d6f0877022c06b853deb5068472.zip
Telemetry source.
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs')
-rw-r--r--Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs16
1 files changed, 8 insertions, 8 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
index 781b3f3e6..2ceb95298 100644
--- a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
+++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
@@ -51,9 +51,9 @@ namespace Tango.Telemetry
return _database.GetCollection<PendingTelemetry>("PendingTelemetries");
}
- private ILiteCollection<TelemetryHistoryModuleCheckPoint> GetModulesCheckpointCollection()
+ private ILiteCollection<TelemetryHistorySourceCheckPoint> GetSourcesCheckpointCollection()
{
- return _database.GetCollection<TelemetryHistoryModuleCheckPoint>("ModuleCheckPoints");
+ return _database.GetCollection<TelemetryHistorySourceCheckPoint>("SourcesCheckPoints");
}
public void UpsertPendingTelemetry(PendingTelemetry pendingTelemetry)
@@ -83,21 +83,21 @@ namespace Tango.Telemetry
}
}
- public TelemetryHistoryModuleCheckPoint GetHistoryModuleCheckPoint(ITelemetryHistoryModule historyModule)
+ public TelemetryHistorySourceCheckPoint GetHistorySourceCheckPoint(ITelemetryHistorySource source)
{
lock (_lock)
{
- var collection = GetModulesCheckpointCollection();
- return collection.FindOne(x => x.ModuleName == historyModule.Name);
+ var collection = GetSourcesCheckpointCollection();
+ return collection.FindOne(x => x.SourceName == source.Name);
}
}
- public void SetHistoryModuleCheckPoint(ITelemetryHistoryModule historyModule, DateTime time, int totalCount)
+ public void SetHistorySourceCheckPoint(ITelemetryHistorySource source, DateTime time, int totalCount)
{
lock (_lock)
{
- var collection = GetModulesCheckpointCollection();
- collection.Upsert(new TelemetryHistoryModuleCheckPoint() { ModuleName = historyModule.Name, Time = time, TotalCount = totalCount });
+ var collection = GetSourcesCheckpointCollection();
+ collection.Upsert(new TelemetryHistorySourceCheckPoint() { SourceName = source.Name, Time = time, TotalCount = totalCount });
}
}