diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md index 736fb55dde24..517f366f4ba9 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 f09fb7c312dc..810cefb18106 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 PropertyStore.DeleteResult deleteProperty(String group, String name, Stri } } + 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);