diff --git a/src/NATS.Client.JetStream/Models/AccountStats.cs b/src/NATS.Client.JetStream/Models/AccountStats.cs index cdb1ff39c..ebe93c644 100644 --- a/src/NATS.Client.JetStream/Models/AccountStats.cs +++ b/src/NATS.Client.JetStream/Models/AccountStats.cs @@ -48,7 +48,7 @@ public record AccountStats [System.Text.Json.Serialization.JsonPropertyName("tiers")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] - public IDictionary? Tiers { get; set; } + public IDictionary? Tiers { get; set; } [System.Text.Json.Serialization.JsonPropertyName("api")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.Never)] diff --git a/src/NATS.Client.JetStream/Models/ApiStats.cs b/src/NATS.Client.JetStream/Models/ApiStats.cs index e555e67b9..abd4b31a7 100644 --- a/src/NATS.Client.JetStream/Models/ApiStats.cs +++ b/src/NATS.Client.JetStream/Models/ApiStats.cs @@ -25,4 +25,12 @@ public record ApiStats [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.Never)] [System.ComponentModel.DataAnnotations.Range(0, int.MaxValue)] public int Errors { get; set; } + + /// + /// Inflight API requests + /// + [System.Text.Json.Serialization.JsonPropertyName("inflight")] + [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] + [System.ComponentModel.DataAnnotations.Range(0, ulong.MaxValue)] + public ulong Inflight { get; set; } } diff --git a/src/NATS.Client.JetStream/Models/Tier.cs b/src/NATS.Client.JetStream/Models/Tier.cs index 2a2207c5a..be2a9bc68 100644 --- a/src/NATS.Client.JetStream/Models/Tier.cs +++ b/src/NATS.Client.JetStream/Models/Tier.cs @@ -18,6 +18,22 @@ public record Tier [System.ComponentModel.DataAnnotations.Range(0, int.MaxValue)] public int Storage { get; set; } + /// + /// Reserved Memory for Stream Message storage + /// + [System.Text.Json.Serialization.JsonPropertyName("reserved_memory")] + [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.Never)] + [System.ComponentModel.DataAnnotations.Range(0, ulong.MaxValue)] + public ulong ReservedMemory { get; set; } + + /// + /// Reserved Memory for Stream Message storage + /// + [System.Text.Json.Serialization.JsonPropertyName("reserved_storage")] + [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.Never)] + [System.ComponentModel.DataAnnotations.Range(0, ulong.MaxValue)] + public ulong ReservedStore { get; set; } + /// /// Number of active Streams ///