(ignite-3) branch main updated: IGNITE-27429 Add client observableTs heartbeat propagation test (#7284)

[ptupitsyn]

This is an automated email from the ASF dual-hosted git repository.

ptupitsyn pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 4ce319eb2a6 IGNITE-27429 Add client observableTs heartbeat propagation 
test (#7284)
4ce319eb2a6 is described below

commit 4ce319eb2a6dd9dc20f0cd619ce4a6cf0ca5fdcc
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Tue Dec 23 12:40:37 2025 +0200

    IGNITE-27429 Add client observableTs heartbeat propagation test (#7284)
---
 .../app/client/ItThinClientObservationTsTest.java   | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
index b3a21586aaf..ea3459bdee7 100644
--- 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
+++ 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
@@ -17,8 +17,14 @@
 
 package org.apache.ignite.internal.runner.app.client;
 
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
+import java.time.Duration;
+import org.apache.ignite.client.IgniteClient;
+import org.apache.ignite.client.IgniteClient.Builder;
+import org.apache.ignite.internal.client.TcpIgniteClient;
+import org.apache.ignite.internal.hlc.HybridTimestampTracker;
 import org.apache.ignite.table.Table;
 import org.apache.ignite.table.Tuple;
 import org.apache.ignite.tx.Transaction;
@@ -65,4 +71,19 @@ public class ItThinClientObservationTsTest extends 
ItAbstractThinClientTest {
         assertEquals("client value", directClientValue, directClientValue);
         assertEquals("client value", directSrvValue, directSrvValue);
     }
+
+    @Test
+    public void testObservableTsUpdatesOnHeartbeat() {
+        Builder clientBuilder = IgniteClient.builder()
+                .addresses(getClientAddresses().toArray(new String[0]))
+                .heartbeatInterval(100);
+
+        try (IgniteClient client = clientBuilder.build()) {
+            HybridTimestampTracker tsTracker = ((TcpIgniteClient) 
client).channel().observableTimestamp();
+
+            long initialTs = tsTracker.getLong();
+
+            await().atMost(Duration.ofSeconds(5)).until(() -> 
tsTracker.getLong() > initialTs);
+        }
+    }
 }