Skip to content

Commit f1b8b40

Browse files
committed
feat: mixer nullable
1 parent f0c059c commit f1b8b40

File tree

3 files changed

+27
-7
lines changed

3 files changed

+27
-7
lines changed

sdk-infrastructure/src/main/java/group/rxcloud/capa/infrastructure/hook/Mixer.java

Lines changed: 25 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,9 @@
2020
import org.slf4j.Logger;
2121
import org.slf4j.LoggerFactory;
2222

23+
import javax.annotation.Nullable;
24+
import java.util.Optional;
25+
2326
/**
2427
* The Inner Runtimes Mixer.
2528
*/
@@ -85,16 +88,36 @@ private static void registerTelemetryHooks(TelemetryHooks telemetryHooks) {
8588
*
8689
* @return the configuration hooks
8790
*/
88-
public static ConfigurationHooks getConfigurationHooks() {
91+
@Nullable
92+
public static ConfigurationHooks configurationHooks() {
8993
return configurationHooks;
9094
}
9195

96+
/**
97+
* Gets configuration hooks.
98+
*
99+
* @return the configuration hooks
100+
*/
101+
public static Optional<ConfigurationHooks> configurationHooksNullable() {
102+
return Optional.ofNullable(configurationHooks);
103+
}
104+
92105
/**
93106
* Gets telemetry hooks.
94107
*
95108
* @return the telemetry hooks
96109
*/
97-
public static TelemetryHooks getTelemetryHooks() {
110+
@Nullable
111+
public static TelemetryHooks telemetryHooks() {
98112
return telemetryHooks;
99113
}
114+
115+
/**
116+
* Gets telemetry hooks.
117+
*
118+
* @return the telemetry hooks
119+
*/
120+
public static Optional<TelemetryHooks> telemetryHooksNullable() {
121+
return Optional.ofNullable(telemetryHooks);
122+
}
100123
}

sdk/src/test/java/group/rxcloud/capa/rpc/CapaRpcClientBuilderTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public class CapaRpcClientBuilderTest {
5252
public void setUp() {
5353
okHttpClient = new OkHttpClient.Builder().build();
5454
defaultObjectSerializer = new DefaultObjectSerializer();
55-
capaRpcClientHttp = new CapaRpcClientHttp(new TestCapaHttp(okHttpClient, defaultObjectSerializer, null, null));
55+
capaRpcClientHttp = new CapaRpcClientHttp(new TestCapaHttp(okHttpClient, defaultObjectSerializer));
5656
}
5757

5858
@Test

sdk/src/test/java/group/rxcloud/capa/rpc/TestCapaHttp.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,6 @@
1818

1919
import group.rxcloud.capa.component.http.CapaHttp;
2020
import group.rxcloud.capa.component.http.HttpResponse;
21-
import group.rxcloud.capa.infrastructure.hook.ConfigurationHooks;
22-
import group.rxcloud.capa.infrastructure.hook.TelemetryHooks;
2321
import group.rxcloud.capa.infrastructure.serializer.CapaObjectSerializer;
2422
import group.rxcloud.cloudruntimes.utils.TypeRef;
2523
import okhttp3.OkHttpClient;
@@ -34,8 +32,7 @@
3432
*/
3533
public class TestCapaHttp extends CapaHttp {
3634

37-
public TestCapaHttp(OkHttpClient httpClient, CapaObjectSerializer objectSerializer,
38-
TelemetryHooks telemetryHooks, ConfigurationHooks configurationHooks) {
35+
public TestCapaHttp(OkHttpClient httpClient, CapaObjectSerializer objectSerializer) {
3936
super(httpClient, objectSerializer);
4037
}
4138

0 commit comments

Comments
 (0)