[skywalking] branch master updated: BanyanDBStorageClient: Add `keepAliveProperty` API. (#11383)

[wusheng]

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

wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 4fa156aed5 BanyanDBStorageClient: Add `keepAliveProperty` API. (#11383)
4fa156aed5 is described below

commit 4fa156aed5be7b232e2c0ca86163625002f09923
Author: Wan Kai <wankai...@foxmail.com>
AuthorDate: Sun Oct 8 18:08:38 2023 +0800

    BanyanDBStorageClient: Add `keepAliveProperty` API. (#11383)
---
 docs/en/changes/changes.md                                     |  1 +
 .../server/storage/plugin/banyandb/BanyanDBStorageClient.java  | 10 ++++++++++
 2 files changed, 11 insertions(+)

diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md
index 736fb55dde..517f366f4b 100644
--- a/docs/en/changes/changes.md
+++ b/docs/en/changes/changes.md
@@ -15,6 +15,7 @@
 * Fix Zipkin trace receiver response: make the HTTP status code from `200` to 
`202`.
 * Update BanyanDB Java Client to 0.5.0.
 * Fix getInstances query in the BanyanDB Metadata DAO.
+* BanyanDBStorageClient: Add `keepAliveProperty` API.
 
 #### UI
 
diff --git 
a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageClient.java
 
b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageClient.java
index f09fb7c312..810cefb181 100644
--- 
a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageClient.java
+++ 
b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageClient.java
@@ -112,6 +112,16 @@ public class BanyanDBStorageClient implements Client, 
HealthCheckable {
         }
     }
 
+    public void keepAliveProperty(long leaseId) throws IOException {
+        try {
+            this.client.keepAliveProperty(leaseId);
+            this.healthChecker.health();
+        } catch (BanyanDBException ex) {
+            healthChecker.unHealth(ex);
+            throw new IOException("fail to keep alive property", ex);
+        }
+    }
+
     public StreamQueryResponse query(StreamQuery q) throws IOException {
         try {
             StreamQueryResponse response = this.client.query(q);