This is an automated email from the ASF dual-hosted git repository. hanahmily pushed a commit to branch banyandb-property in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit bac3df5c9739d7e9c0bc082cb1ac0f374948bdba Author: Gao Hongtao <[email protected]> AuthorDate: Sat Jan 4 07:52:21 2025 +0800 Support BanyanDB's new property Signed-off-by: Gao Hongtao <[email protected]> --- oap-server-bom/pom.xml | 2 +- .../plugin/banyandb/BanyanDBStorageClient.java | 33 +++++++++++----------- .../plugin/banyandb/BanyanDBStorageProvider.java | 2 +- test/e2e-v2/script/env | 2 +- 4 files changed, 20 insertions(+), 19 deletions(-) diff --git a/oap-server-bom/pom.xml b/oap-server-bom/pom.xml index 32481c60a7..92ffd3f9c3 100644 --- a/oap-server-bom/pom.xml +++ b/oap-server-bom/pom.xml @@ -72,7 +72,7 @@ <httpcore.version>4.4.13</httpcore.version> <httpasyncclient.version>4.1.5</httpasyncclient.version> <commons-compress.version>1.21</commons-compress.version> - <banyandb-java-client.version>0.8.0-rc0</banyandb-java-client.version> + <banyandb-java-client.version>0.8.0-rc1</banyandb-java-client.version> <kafka-clients.version>3.4.0</kafka-clients.version> <spring-kafka-test.version>2.4.6.RELEASE</spring-kafka-test.version> <consul.client.version>1.5.3</consul.client.version> 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 30e4c63b9e..a00ab5af24 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 @@ -20,6 +20,7 @@ package org.apache.skywalking.oap.server.storage.plugin.banyandb; import io.grpc.Status; import org.apache.skywalking.banyandb.database.v1.BanyandbDatabase; +import org.apache.skywalking.banyandb.property.v1.BanyandbProperty; import org.apache.skywalking.banyandb.v1.client.BanyanDBClient; import org.apache.skywalking.banyandb.v1.client.MeasureBulkWriteProcessor; import org.apache.skywalking.banyandb.v1.client.MeasureQuery; @@ -78,9 +79,12 @@ public class BanyanDBStorageClient implements Client, HealthCheckable { public List<Property> listProperties(String group, String name) throws IOException { try { - List<Property> properties = this.client.findProperties(group, name); + BanyandbProperty.QueryResponse resp = this.client.query(BanyandbProperty.QueryRequest.newBuilder() + .addGroups(group) + .setContainer(name) + .build()); this.healthChecker.health(); - return properties; + return resp.getPropertiesList(); } catch (BanyanDBException ex) { if (ex.getStatus().equals(Status.Code.NOT_FOUND)) { this.healthChecker.health(); @@ -94,9 +98,16 @@ public class BanyanDBStorageClient implements Client, HealthCheckable { public Property queryProperty(String group, String name, String id) throws IOException { try { - Property p = this.client.findProperty(group, name, id); + BanyandbProperty.QueryResponse resp = this.client.query(BanyandbProperty.QueryRequest.newBuilder() + .addGroups(group) + .setContainer(name) + .addIds(id) + .build()); this.healthChecker.health(); - return p; + if (resp.getPropertiesCount() == 0) { + return null; + } + return resp.getProperties(0); } catch (BanyanDBException ex) { if (ex.getStatus().equals(Status.Code.NOT_FOUND)) { this.healthChecker.health(); @@ -108,9 +119,9 @@ public class BanyanDBStorageClient implements Client, HealthCheckable { } } - public DeleteResponse deleteProperty(String group, String name, String id, String... tags) throws IOException { + public DeleteResponse deleteProperty(String group, String name, String id) throws IOException { try { - DeleteResponse result = this.client.deleteProperty(group, name, id, tags); + DeleteResponse result = this.client.deleteProperty(group, name, id); this.healthChecker.health(); return result; } catch (BanyanDBException ex) { @@ -119,16 +130,6 @@ 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); diff --git a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageProvider.java b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageProvider.java index 0d777ba2da..ac70fb5c02 100644 --- a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageProvider.java +++ b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageProvider.java @@ -209,7 +209,7 @@ public class BanyanDBStorageProvider extends ModuleProvider { BanyandbCommon.Metadata.newBuilder() .setName( BanyanDBUITemplateManagementDAO.GROUP)) - .setCatalog(BanyandbCommon.Catalog.CATALOG_UNSPECIFIED) + .setCatalog(BanyandbCommon.Catalog.CATALOG_PROPERTY) .build()); this.modelInstaller.start(); diff --git a/test/e2e-v2/script/env b/test/e2e-v2/script/env index 5e6fc2cded..353e497660 100644 --- a/test/e2e-v2/script/env +++ b/test/e2e-v2/script/env @@ -23,7 +23,7 @@ SW_AGENT_CLIENT_JS_COMMIT=af0565a67d382b683c1dbd94c379b7080db61449 SW_AGENT_CLIENT_JS_TEST_COMMIT=4f1eb1dcdbde3ec4a38534bf01dded4ab5d2f016 SW_KUBERNETES_COMMIT_SHA=1335f15bf821a40a7cd71448fa805f0be265afcc SW_ROVER_COMMIT=0ae8f12d6eb6cc9fa125c603ee57d0b21fc8c6d0 -SW_BANYANDB_COMMIT=7f291fc5c626ea8b0d33c947563f7984cfc4886e +SW_BANYANDB_COMMIT=8dfe616f332848f041b0f184b023d9a256eac39e SW_AGENT_PHP_COMMIT=3192c553002707d344bd6774cfab5bc61f67a1d3 SW_CTL_COMMIT=67cbc89dd7b214d5791321a7ca992f940cb586ba
