-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
remove newtonsoft package, clean nullability
- Loading branch information
stasput
committed
Nov 15, 2024
1 parent
636ea27
commit f0db6cc
Showing
21 changed files
with
123 additions
and
157 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Api/RtqMonitoringTaskMeta.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Api/RtqMonitoringTaskModel.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Api/TimestampRange.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
...kQueue.Monitoring/ElasticsearchClientExtensions/ElasticsearchResponseWrapperExtensions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,6 +1,4 @@ | ||
#nullable disable | ||
|
||
using System; | ||
using System; | ||
using System.Linq; | ||
using System.Text; | ||
using System.Text.Json; | ||
|
4 changes: 1 addition & 3 deletions
4
...utedTaskQueue.Monitoring/ElasticsearchClientExtensions/Responses/Search/HitsCollection.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Indexer/RtqElasticsearchIndexerSettings.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,6 +1,4 @@ | ||
#nullable disable | ||
|
||
using System; | ||
using System; | ||
using System.Text.Json; | ||
using System.Text.Json.Serialization; | ||
|
||
|
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Indexer/TaskMetaProcessor.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Json/JsonObjectExtensions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Storage/Client/TaskSearchClient.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Monitoring/Storage/Writing/RtqElasticsearchOffsetStorage.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,6 +1,4 @@ | ||
#nullable disable | ||
|
||
using System; | ||
using System; | ||
using System.Text.Json; | ||
|
||
using Elasticsearch.Net; | ||
|
23 changes: 11 additions & 12 deletions
23
Cassandra.DistributedTaskQueue.Monitoring/TaskCounter/RtqTaskCounters.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,23 +1,22 @@ | ||
using System.Collections.Generic; | ||
#nullable enable | ||
|
||
using System.Collections.Generic; | ||
using System.Linq; | ||
|
||
using SkbKontur.Cassandra.DistributedTaskQueue.Cassandra.Entities; | ||
|
||
#nullable enable | ||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Monitoring.TaskCounter; | ||
|
||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Monitoring.TaskCounter | ||
public class RtqTaskCounters | ||
{ | ||
public class RtqTaskCounters | ||
{ | ||
public int LostTasksCount { get; set; } | ||
public int LostTasksCount { get; set; } | ||
|
||
public Dictionary<TaskState, int> PendingTaskCountsTotal { get; set; } = null!; | ||
public Dictionary<TaskState, int> PendingTaskCountsTotal { get; set; } = null!; | ||
|
||
public Dictionary<(string TaskName, string TaskTopic), Dictionary<TaskState, int>> PendingTaskCountsByNameAndTopic { get; set; } = null!; | ||
public Dictionary<(string TaskName, string TaskTopic), Dictionary<TaskState, int>> PendingTaskCountsByNameAndTopic { get; set; } = null!; | ||
|
||
public int GetPendingTaskTotalCount() | ||
{ | ||
return PendingTaskCountsTotal.Values.Sum(); | ||
} | ||
public int GetPendingTaskTotalCount() | ||
{ | ||
return PendingTaskCountsTotal.Values.Sum(); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 1 addition & 3 deletions
4
Cassandra.DistributedTaskQueue.Tests/HttpClientForTestsBase.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,6 +1,4 @@ | ||
#nullable disable | ||
|
||
using System; | ||
using System; | ||
using System.Text; | ||
using System.Text.Json; | ||
|
||
|
19 changes: 9 additions & 10 deletions
19
Cassandra.DistributedTaskQueue.Tests/RtqTaskCountersForTests.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,21 +1,20 @@ | ||
#nullable enable | ||
|
||
using System.Collections.Generic; | ||
using System.Linq; | ||
|
||
using SkbKontur.Cassandra.DistributedTaskQueue.Cassandra.Entities; | ||
|
||
#nullable enable | ||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Tests; | ||
|
||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Tests | ||
public class RtqTaskCountersForTests | ||
{ | ||
public class RtqTaskCountersForTests | ||
{ | ||
public int LostTasksCount { get; set; } | ||
public int LostTasksCount { get; set; } | ||
|
||
public Dictionary<TaskState, int> PendingTaskCountsTotal { get; set; } = null!; | ||
public Dictionary<TaskState, int> PendingTaskCountsTotal { get; set; } = null!; | ||
|
||
public int GetPendingTaskTotalCount() | ||
{ | ||
return PendingTaskCountsTotal.Values.Sum(); | ||
} | ||
public int GetPendingTaskTotalCount() | ||
{ | ||
return PendingTaskCountsTotal.Values.Sum(); | ||
} | ||
} |
25 changes: 12 additions & 13 deletions
25
Cassandra.DistributedTaskQueue/Configuration/IRtqTaskDataRegistry.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,23 +1,22 @@ | ||
using System; | ||
#nullable enable | ||
|
||
#nullable enable | ||
using System; | ||
|
||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Configuration | ||
namespace SkbKontur.Cassandra.DistributedTaskQueue.Configuration; | ||
|
||
public interface IRtqTaskDataRegistry | ||
{ | ||
public interface IRtqTaskDataRegistry | ||
{ | ||
string[] GetAllTaskNames(); | ||
string[] GetAllTaskNames(); | ||
|
||
string GetTaskName(Type type); | ||
string GetTaskName(Type type); | ||
|
||
Type GetTaskType(string taskName); | ||
Type GetTaskType(string taskName); | ||
|
||
bool TryGetTaskType(string taskName, out Type? taskType); | ||
bool TryGetTaskType(string taskName, out Type? taskType); | ||
|
||
string[] GetAllTaskTopics(); | ||
string[] GetAllTaskTopics(); | ||
|
||
(string TaskName, string TopicName)[] GetAllTaskNamesWithTopics(); | ||
(string TaskName, string TopicName)[] GetAllTaskNamesWithTopics(); | ||
|
||
string GetTaskTopic(string taskName); | ||
} | ||
string GetTaskTopic(string taskName); | ||
} |
Oops, something went wrong.