fix(core): add custom boot strap region in api client

Author: bytestarter

volcengine-java-sdk-core/src/main/java/com/volcengine/ApiClient.java

@@ -101,12 +101,13 @@ public class ApiClient {
 
     private Integer keepAliveDurationMs = 5 * 60 * 1000;
 
+    private Set<String> customBootstrapRegion;
 
     /*
      * Constructor for ApiClient
      */
     public ApiClient() {
-        ConnectionPool connectionPool=new ConnectionPool(maxIdleConns,keepAliveDurationMs);
+        ConnectionPool connectionPool = new ConnectionPool(maxIdleConns, keepAliveDurationMs);
         httpClient = new OkHttpClient();
         httpClient.setConnectionPool(connectionPool);
 
@@ -147,6 +148,17 @@ private static String getUserAgent() {
         return String.format(format, Version.SDK_NAME, Version.SDK_VERSION, jdkInfo, osInfo, arch);
     }
 
+    /**
+     * Set the User-Agent header's value (by adding to the default header map).
+     *
+     * @param userAgent HTTP request's user agent
+     * @return ApiClient
+     */
+    public ApiClient setUserAgent(String userAgent) {
+        addDefaultHeader("User-Agent", userAgent);
+        return this;
+    }
+
     /**
      * Get base path
      *
@@ -237,7 +249,6 @@ public ApiClient setCredentials(Credentials credentials) {
         return this;
     }
 
-
     /**
      * Get HTTP client
      *
@@ -388,18 +399,6 @@ public Authentication getAuthentication(String authName) {
         return authentications.get(authName);
     }
 
-
-    /**
-     * Set the User-Agent header's value (by adding to the default header map).
-     *
-     * @param userAgent HTTP request's user agent
-     * @return ApiClient
-     */
-    public ApiClient setUserAgent(String userAgent) {
-        addDefaultHeader("User-Agent", userAgent);
-        return this;
-    }
-
     /**
      * Add a default header.
      *
@@ -530,6 +529,26 @@ public ApiClient setWriteTimeout(int writeTimeout) {
         return this;
     }
 
+    /**
+     * Get the custom bootstrapping regions.
+     *
+     * @return Set of custom bootstrapping regions
+     */
+    public Set<String> getCustomBootstrapRegion() {
+        return this.customBootstrapRegion;
+    }
+
+    /**
+     * Set the custom bootstrapping regions.
+     *
+     * @param customBootstrapRegion Set of custom bootstrapping regions
+     * @return Api client
+     */
+    public ApiClient setCustomBootstrapRegion(Set<String> customBootstrapRegion) {
+        this.customBootstrapRegion = customBootstrapRegion;
+        return this;
+    }
+
     /**
      * Format the given parameter object into string.
      *
@@ -1656,7 +1675,7 @@ public Integer getMaxIdleConns() {
 
     public ApiClient setMaxIdleConns(Integer maxIdleConns) {
         this.maxIdleConns = maxIdleConns;
-        this.httpClient.setConnectionPool(new ConnectionPool(maxIdleConns,keepAliveDurationMs));
+        this.httpClient.setConnectionPool(new ConnectionPool(maxIdleConns, keepAliveDurationMs));
         return this;
     }
 
@@ -1666,7 +1685,7 @@ public Integer getKeepAliveDurationMs() {
 
     public ApiClient setKeepAliveDurationMs(Integer keepAliveDurationMs) {
         this.keepAliveDurationMs = keepAliveDurationMs;
-        this.httpClient.setConnectionPool(new ConnectionPool(maxIdleConns,keepAliveDurationMs));
+        this.httpClient.setConnectionPool(new ConnectionPool(maxIdleConns, keepAliveDurationMs));
         return this;
     }
 }

volcengine-java-sdk-core/src/main/java/com/volcengine/interceptor/ResolveEndpointInterceptor.java

@@ -41,6 +41,7 @@ public InterceptorContext intercept(InterceptorContext context) throws ApiExcept
             ResolveEndpointOption option = new ResolveEndpointOption();
             option.setService(service);
             option.setRegion(context.getApiClient().getRegion());
+            option.setCustomBootstrapRegion(context.getApiClient().getCustomBootstrapRegion());
             ResolvedEndpoint resolvedEndpoint = endpointResolver.endpointFor(option);
             context.getRequestContext().setHost(resolvedEndpoint.getEndpoint());
         }