diff options
| author | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-30 12:36:30 +0300 |
|---|---|---|
| committer | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-30 12:36:30 +0300 |
| commit | 4222eddece906d6f0877022c06b853deb5068472 (patch) | |
| tree | a29b706b3a5aedb28a42b209d5bb72b0ef94d40e /Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs | |
| parent | a802fe75f9538371004f1833e69a69b798892d0c (diff) | |
| download | Tango-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.cs | 16 |
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 }); } } |
