@@ -34,6 +34,7 @@ void TestDefaults() {
34
34
assertNull (builder .getOfflineFlagSourcePath ());
35
35
assertEquals (Resolver .RPC , builder .getResolverType ());
36
36
assertEquals (0 , builder .getKeepAlive ());
37
+ assertNull (builder .getAuthority ());
37
38
}
38
39
39
40
@ Test
@@ -55,6 +56,7 @@ void TestBuilderOptions() {
55
56
.customConnector (connector )
56
57
.resolverType (Resolver .IN_PROCESS )
57
58
.keepAlive (1000 )
59
+ .authority ("test.service" )
58
60
.build ();
59
61
60
62
assertEquals ("https://hosted-flagd" , flagdOptions .getHost ());
@@ -70,6 +72,7 @@ void TestBuilderOptions() {
70
72
assertEquals (connector , flagdOptions .getCustomConnector ());
71
73
assertEquals (Resolver .IN_PROCESS , flagdOptions .getResolverType ());
72
74
assertEquals (1000 , flagdOptions .getKeepAlive ());
75
+ assertEquals ("test.service" , flagdOptions .getAuthority ());
73
76
}
74
77
75
78
@@ -187,4 +190,13 @@ void testRpcProviderFromEnv_portConfigured_usesConfiguredPort() {
187
190
assertThat (flagdOptions .getPort ()).isEqualTo (1534 );
188
191
189
192
}
193
+
194
+
195
+ @ Test
196
+ @ SetEnvironmentVariable (key = AUTHORITY_OVERRIDE , value = "test.service" )
197
+ void testAuthorityOverrideFromEnv () {
198
+ FlagdOptions flagdOptions = FlagdOptions .builder ().build ();
199
+
200
+ assertThat (flagdOptions .getAuthority ()).isEqualTo ("test.service" );
201
+ }
190
202
}
0 commit comments