nats-io#636 - JetStream Batch Get Client support

* Modify StreamMsgBatchGetRequest
Ivandemidov00 · Nov 23, 2024 · c633869 · c633869
1 parent 95a495f
commit c633869
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs b/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs
@@ -37,8 +37,7 @@ public record StreamMsgBatchGetRequest
     /// </summary>
     [JsonPropertyName("start_time")]
     [JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingDefault)]
-    [Range(ulong.MinValue, ulong.MaxValue)]
-    public DateTime StartTime { get; set; }
+    public DateTimeOffset StartTime { get; set; }
 
     /// <summary>
     /// The subject used filter messages that should be returned
@@ -60,7 +59,6 @@ public record StreamMsgBatchGetRequest
     /// </summary>
     [JsonPropertyName("multi_last")]
     [JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingDefault)]
-    [Range(ulong.MinValue, ulong.MaxValue)]
     public string[] LastBySubjects { get; set; } = [];
 
     /// <summary>

diff --git a/src/NATS.Client.JetStream/NatsJSJsonSerializer.cs b/src/NATS.Client.JetStream/NatsJSJsonSerializer.cs
@@ -78,6 +78,7 @@ public static class NatsJSJsonSerializer<T>
 [JsonSerializable(typeof(StreamMsgDeleteResponse))]
 [JsonSerializable(typeof(StreamMsgGetRequest))]
 [JsonSerializable(typeof(StreamMsgGetResponse))]
+[JsonSerializable(typeof(StreamMsgBatchGetRequest))]
 [JsonSerializable(typeof(StreamNamesRequest))]
 [JsonSerializable(typeof(StreamNamesResponse))]
 [JsonSerializable(typeof(StreamPurgeRequest))]