support ClusterInfo leader_since (2.12 feature)

Author: scottf

src/main/java/io/nats/client/api/ClusterInfo.java

@@ -16,18 +16,20 @@
 import io.nats.client.support.JsonValue;
 import org.jspecify.annotations.Nullable;
 
+import java.time.ZonedDateTime;
 import java.util.List;
 
 import static io.nats.client.support.ApiConstants.*;
-import static io.nats.client.support.JsonValueUtils.readString;
-import static io.nats.client.support.JsonValueUtils.readValue;
+import static io.nats.client.support.JsonValueUtils.*;
 
 /**
  * Information about the cluster a stream is part of.
  */
 public class ClusterInfo {
+
     private final String name;
     private final String leader;
+    private final ZonedDateTime leaderSince;
     private final List<Replica> replicas;
 
     static ClusterInfo optionalInstance(JsonValue v) {
@@ -38,6 +40,7 @@ static ClusterInfo optionalInstance(JsonValue v) {
         name = readString(v, NAME);
         leader = readString(v, LEADER);
         replicas = Replica.optionalListOf(readValue(v, REPLICAS));
+        leaderSince = readDate(v, LEADER_SINCE);
     }
 
     /**
@@ -58,6 +61,11 @@ public String getLeader() {
         return leader;
     }
 
+    @Nullable
+    public ZonedDateTime getLeaderSince() {
+        return leaderSince;
+    }
+
     /**
      * The members of the RAFT cluster. May be null if there are no replicas.
      * @return the replicas or null
@@ -70,9 +78,10 @@ public List<Replica> getReplicas() {
     @Override
     public String toString() {
         return "ClusterInfo{" +
-                "name='" + name + '\'' +
-                ", leader='" + leader + '\'' +
-                ", replicas=" + replicas +
-                '}';
+            "name='" + name + '\'' +
+            ", leader='" + leader + '\'' +
+            ", leaderSince=" + leaderSince +
+            ", replicas=" + replicas +
+            '}';
     }
 }

src/main/java/io/nats/client/support/ApiConstants.java

@@ -99,6 +99,7 @@ public interface ApiConstants {
     String LAST_SEQ          = "last_seq";
     String LAST_TS           = "last_ts";
     String LEADER            = "leader";
+    String LEADER_SINCE      = "leader_since";
     String LEVEL             = "level";
     String LIMIT             = "limit";
     String LIMITS            = "limits";

src/test/java/io/nats/client/api/ConsumerInfoTests.java

@@ -77,6 +77,7 @@ public void testConsumerInfo() {
         assertNotNull(clusterInfo);
         assertEquals("clustername", clusterInfo.getName());
         assertEquals("clusterleader", clusterInfo.getLeader());
+        assertEquals(DateTimeUtils.parseDateTime("2025-08-29T19:33:21.163377Z"), clusterInfo.getLeaderSince());
         List<Replica> reps = clusterInfo.getReplicas();
         assertNotNull(reps);
         assertEquals(2, reps.size());

src/test/java/io/nats/client/api/StreamInfoTests.java

@@ -131,6 +131,7 @@ private void validateStreamInfo(StreamInfo si) {
         assertNotNull(cli.toString()); // coverage
         assertEquals("clustername", cli.getName());
         assertEquals("clusterleader", cli.getLeader());
+        assertEquals(DateTimeUtils.parseDateTime("2025-08-29T19:33:21.163377Z"), cli.getLeaderSince());
 
         assertNotNull(cli.getReplicas()); // coverage
         assertEquals(2, cli.getReplicas().size());

src/test/resources/data/ConsumerInfo.json

@@ -52,6 +52,7 @@
   "cluster": {
     "name": "clustername",
     "leader": "clusterleader",
+    "leader_since": "2025-08-29T19:33:21.163377Z",
     "replicas": [
       {
         "name": "name0",

src/test/resources/data/StreamInfo.json

@@ -55,6 +55,7 @@
   "cluster": {
     "name": "clustername",
     "leader": "clusterleader",
+    "leader_since": "2025-08-29T19:33:21.163377Z",
     "replicas": [
       {
         "name": "name0",