login-username

Author: OmCheeLin

oap-server-bom/pom.xml

@@ -72,7 +72,7 @@
         <httpcore.version>4.4.16</httpcore.version>
         <httpasyncclient.version>4.1.5</httpasyncclient.version>
         <commons-compress.version>1.21</commons-compress.version>
-        <banyandb-java-client.version>0.9.0-rc3</banyandb-java-client.version>
+        <banyandb-java-client.version>0.9.0-rc4</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>

oap-server/server-starter/src/main/resources/bydb.yml

@@ -45,6 +45,10 @@ global:
   asyncProfilerTaskQueryMaxSize: ${SW_STORAGE_BANYANDB_ASYNC_PROFILER_TASK_QUERY_MAX_SIZE:200}
   # If the BanyanDB server is configured with TLS, configure the TLS cert file path and enable TLS connection.
   sslTrustCAPath: ${SW_STORAGE_BANYANDB_SSL_TRUST_CA_PATH:""}
+  # If the BanyanDB server is configured with Basic Auth, configure the username.
+  username: ${SW_STORAGE_BANYANDB_USERNAME:""}
+  # If the BanyanDB server is configured with Basic Auth, configure the password.
+  password: ${SW_STORAGE_BANYANDB_PASSWORD:""}
   # Cleanup TopN rules in BanyanDB server that are not configured in the bydb-topn.yml config.
   cleanupUnusedTopNRules: ${SW_STORAGE_BANYANDB_CLEANUP_UNUSED_TOPN_RULES:true}
 

oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageClient.java

@@ -70,6 +70,8 @@ public class BanyanDBStorageClient implements Client, HealthCheckable {
     public BanyanDBStorageClient(BanyanDBStorageConfig config) {
         Options options = new Options();
         options.setSslTrustCAPath(config.getGlobal().getSslTrustCAPath());
+        options.setUsername(config.getGlobal().getUsername());
+        options.setPassword(config.getGlobal().getPassword());
         this.client = new BanyanDBClient(config.getTargetArray(), options);
         this.flushTimeout = config.getGlobal().getFlushTimeout();
     }

oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/BanyanDBStorageConfig.java

@@ -96,6 +96,14 @@ public static class Global {
          * single request.
          */
         private int asyncProfilerTaskQueryMaxSize;
+        /**
+         * If the BanyanDB server is configured with Basic Auth, config the username.
+         */
+        private String username;
+        /**
+         * If the BanyanDB server is configured with Basic Auth, config the password.
+         */
+        private String password;
 
         private int resultWindowMaxSize = 10000;
         private int metadataQueryMaxSize = 5000;

test/e2e-v2/cases/storage/banyandb/config/auth-config.yaml

@@ -0,0 +1,5 @@
+users:
+  - username: admin
+    password: 123456
+  - username: test
+    password: 123456

test/e2e-v2/cases/storage/banyandb/docker-compose.yml

@@ -22,6 +22,7 @@ services:
       service: banyandb
     networks:
       - e2e
+    command: standalone --auth-config-file config/auth-config.yaml --stream-root-path /tmp/stream-data --measure-root-path /tmp/measure-data --measure-metadata-cache-wait-duration 1m --stream-metadata-cache-wait-duration 1m
 
   oap:
     extends:
@@ -31,6 +32,8 @@ services:
       - ./config/bydb-topn.yml:/skywalking/config/bydb-topn.yml
     environment:
       SW_STORAGE: banyandb
+      SW_STORAGE_BANYANDB_USERNAME: admin
+      SW_STORAGE_BANYANDB_PASSWORD: 123456
     ports:
       - 12800
     depends_on: