You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2026/05/09 11:37:37 UTC
(iggy) branch master updated: feat(csharp): add mising metrics to StatsResponse (#3221)
This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 86bf41914 feat(csharp): add mising metrics to StatsResponse (#3221)
86bf41914 is described below
commit 86bf419146be1f187898983504af706fc33a60f5
Author: Łukasz Zborek <lu...@gmail.com>
AuthorDate: Sat May 9 13:37:32 2026 +0200
feat(csharp): add mising metrics to StatsResponse (#3221)
---
.../csharp/Iggy_SDK.Tests.Integration/SystemTests.cs | 13 ++++++++-----
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 17 +++++++++++++++++
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 15 +++++++++++++--
3 files changed, 38 insertions(+), 7 deletions(-)
diff --git a/foreign/csharp/Iggy_SDK.Tests.Integration/SystemTests.cs b/foreign/csharp/Iggy_SDK.Tests.Integration/SystemTests.cs
index 40f1392b5..2f3cf278c 100644
--- a/foreign/csharp/Iggy_SDK.Tests.Integration/SystemTests.cs
+++ b/foreign/csharp/Iggy_SDK.Tests.Integration/SystemTests.cs
@@ -18,7 +18,6 @@
using Apache.Iggy.Contracts;
using Apache.Iggy.Enums;
using Apache.Iggy.Exceptions;
-using Apache.Iggy.Kinds;
using Apache.Iggy.Messages;
using Apache.Iggy.Tests.Integrations.Attributes;
using Apache.Iggy.Tests.Integrations.Fixtures;
@@ -111,8 +110,8 @@ public class SystemTests
await tcpClient.CreateTopicAsync(Identifier.String(streamName), "first_topic", 2);
var secondTopic = await tcpClient.CreateTopicAsync(Identifier.String(streamName), "second_topic", 2);
- var consumerGroup = await tcpClient.CreateConsumerGroupAsync(
- Identifier.String(streamName), Identifier.String("second_topic"), "test_consumer_group");
+ var consumerGroup = await tcpClient.CreateConsumerGroupAsync(Identifier.String(streamName),
+ Identifier.String("second_topic"), "test_consumer_group");
await tcpClient.JoinConsumerGroupAsync(Identifier.String(streamName),
Identifier.String("second_topic"), Identifier.String("test_consumer_group"));
var me = await tcpClient.GetMeAsync();
@@ -167,6 +166,11 @@ public class SystemTests
response.KernelVersion.ShouldNotBeNullOrEmpty();
response.IggyServerVersion.ShouldNotBeNullOrEmpty();
response.IggyServerSemver.ShouldNotBe(0u);
+ response.ThreadsCount.ShouldBeGreaterThanOrEqualTo(1u);
+ response.TotalDiskSpace.ShouldBeGreaterThan(0u);
+ response.FreeDiskSpace.ShouldBeGreaterThan(0u);
+ response.FreeDiskSpace.ShouldBeGreaterThan(0u);
+ response.FreeDiskSpace.ShouldBeLessThanOrEqualTo(response.TotalDiskSpace);
}
[Test]
@@ -184,8 +188,7 @@ public class SystemTests
{
var client = await Fixture.CreateAuthenticatedClient(protocol);
- var snapshot = await client.GetSnapshotAsync(
- SnapshotCompression.Deflated,
+ var snapshot = await client.GetSnapshotAsync(SnapshotCompression.Deflated,
[SystemSnapshotType.Test]);
snapshot.ShouldNotBeNull();
diff --git a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
index 0bf3f3fcf..6eb128aa5 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
@@ -158,4 +158,21 @@ public sealed class StatsResponse
/// Cache metrics per partition
/// </summary>
public Dictionary<CacheMetricsKey, CacheMetrics> CacheMetrics { get; init; } = [];
+
+ /// <summary>
+ /// Number of threads in the server process.
+ /// </summary>
+ public uint ThreadsCount { get; init; }
+
+ /// <summary>
+ /// Available (free) disk space for the data directory.
+ /// </summary>
+ [JsonConverter(typeof(SizeConverter))]
+ public ulong FreeDiskSpace { get; init; }
+
+ /// <summary>
+ /// Total disk space for the data directory.
+ /// </summary>
+ [JsonConverter(typeof(SizeConverter))]
+ public ulong TotalDiskSpace { get; init; }
}
diff --git a/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs b/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
index 7ec286d8e..890b66802 100644
--- a/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
+++ b/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
@@ -790,12 +790,20 @@ internal static class BinaryMapper
{
Hits = BinaryPrimitives.ReadUInt64LittleEndian(payload[(position + 12)..(position + 20)]),
Misses = BinaryPrimitives.ReadUInt64LittleEndian(payload[(position + 20)..(position + 28)]),
- HitRatio = BinaryPrimitives.ReadSingleLittleEndian(payload[(position + 28)..(position + 36)])
+ HitRatio = BinaryPrimitives.ReadSingleLittleEndian(payload[(position + 28)..(position + 32)])
};
cacheMetricsList.Add(cacheMetricsKey, cacheMetrics);
+ position += 32;
}
+ var threadsCount = BinaryPrimitives.ReadUInt32LittleEndian(payload[position..(position + 4)]);
+ position += 4;
+ var freeDiskSpace = BinaryPrimitives.ReadUInt64LittleEndian(payload[position..(position + 8)]);
+ position += 8;
+ var totalDiskSpace = BinaryPrimitives.ReadUInt64LittleEndian(payload[position..(position + 8)]);
+ position += 8;
+
return new StatsResponse
{
ProcessId = processId,
@@ -822,7 +830,10 @@ internal static class BinaryMapper
MessagesSizeBytes = totalSizeBytes,
IggyServerVersion = iggyVersion,
IggyServerSemver = iggySemVersion,
- CacheMetrics = cacheMetricsList
+ CacheMetrics = cacheMetricsList,
+ ThreadsCount = threadsCount,
+ FreeDiskSpace = freeDiskSpace,
+ TotalDiskSpace = totalDiskSpace
};
}