chore(flagd): Capitalize ID in providerID, for consistency with Go

Signed-off-by: Maks Osowski <[email protected]>

Author: cupofcat

providers/flagd/README.md

@@ -116,7 +116,7 @@ Given below are the supported configurations:
 | streamDeadlineMs      | FLAGD_STREAM_DEADLINE_MS       | int                      | 600000    | rpc & in-process        |
 | keepAliveTime         | FLAGD_KEEP_ALIVE_TIME_MS       | long                     | 0         | rpc & in-process        |
 | selector              | FLAGD_SOURCE_SELECTOR          | String                   | null      | in-process              |
-| providerId            | FLAGD_SOURCE_PROVIDER_ID       | String                   | null      | in-process              |
+| providerID            | FLAGD_SOURCE_PROVIDER_ID       | String                   | null      | in-process              |
 | cache                 | FLAGD_CACHE                    | String - lru, disabled   | lru       | rpc                     |
 | maxCacheSize          | FLAGD_MAX_CACHE_SIZE           | int                      | 1000      | rpc                     |
 | maxEventStreamRetries | FLAGD_MAX_EVENT_STREAM_RETRIES | int                      | 5         | rpc                     |

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java

@@ -108,10 +108,10 @@ public class FlagdOptions {
     private String selector = fallBackToEnvOrDefault(Config.SOURCE_SELECTOR_ENV_VAR_NAME, null);
 
     /**
-     * ProviderId to be used with flag sync gRPC contract.
+     * ProviderID to be used with flag sync gRPC contract.
      **/
     @Builder.Default
-    private String providerId = fallBackToEnvOrDefault(Config.SOURCE_PROVIDER_ID_ENV_VAR_NAME, null);
+    private String providerID = fallBackToEnvOrDefault(Config.SOURCE_PROVIDER_ID_ENV_VAR_NAME, null);
 
     /**
      * gRPC client KeepAlive in milliseconds. Disabled with 0.

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java

@@ -34,7 +34,7 @@ public class GrpcStreamConnector implements Connector {
     private final BlockingQueue<QueuePayload> blockingQueue = new LinkedBlockingQueue<>(QUEUE_SIZE);
     private final int deadline;
     private final String selector;
-    private final String providerId;
+    private final String providerID;
     private final GrpcConnector<
                     FlagSyncServiceGrpc.FlagSyncServiceStub, FlagSyncServiceGrpc.FlagSyncServiceBlockingStub>
             grpcConnector;
@@ -46,7 +46,7 @@ public class GrpcStreamConnector implements Connector {
     public GrpcStreamConnector(final FlagdOptions options, Consumer<FlagdProviderEvent> onConnectionEvent) {
         deadline = options.getDeadline();
         selector = options.getSelector();
-        providerId = options.getProviderId();
+        providerID = options.getProviderID();
         streamReceiver = new LinkedBlockingQueue<>(QUEUE_SIZE);
         grpcConnector = new GrpcConnector<>(
                 options,
@@ -55,14 +55,14 @@ public GrpcStreamConnector(final FlagdOptions options, Consumer<FlagdProviderEve
                 onConnectionEvent,
                 stub -> {
                     String localSelector = selector;
-                    String localProviderId = providerId;
+                    String localProviderID = providerID;
 
                     final SyncFlagsRequest.Builder syncRequest = SyncFlagsRequest.newBuilder();
                     if (localSelector != null) {
                         syncRequest.setSelector(localSelector);
                     }
-                    if (localProviderId != null) {
-                        syncRequest.setProviderId(localProviderId);
+                    if (localProviderID != null) {
+                        syncRequest.setProviderId(localProviderID);
                     }
 
                     stub.syncFlags(syncRequest.build(), new GrpcStreamHandler(streamReceiver));

providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/FlagdOptionsTest.java

@@ -41,7 +41,7 @@ void TestDefaults() {
         assertEquals(DEFAULT_CACHE, builder.getCacheType());
         assertEquals(DEFAULT_MAX_CACHE_SIZE, builder.getMaxCacheSize());
         assertNull(builder.getSelector());
-        assertNull(builder.getProviderId());
+        assertNull(builder.getProviderID());
         assertNull(builder.getOpenTelemetry());
         assertNull(builder.getCustomConnector());
         assertNull(builder.getOfflineFlagSourcePath());
@@ -62,7 +62,7 @@ void TestBuilderOptions() {
                 .cacheType("lru")
                 .maxCacheSize(100)
                 .selector("app=weatherApp")
-                .providerId("test/provider/id_1")
+                .providerID("test/provider/id_1")
                 .openTelemetry(openTelemetry)
                 .customConnector(connector)
                 .resolverType(Resolver.IN_PROCESS)
@@ -77,7 +77,7 @@ void TestBuilderOptions() {
         assertEquals("lru", flagdOptions.getCacheType());
         assertEquals(100, flagdOptions.getMaxCacheSize());
         assertEquals("app=weatherApp", flagdOptions.getSelector());
-        assertEquals("test/provider/id_1", flagdOptions.getProviderId());
+        assertEquals("test/provider/id_1", flagdOptions.getProviderID());
         assertEquals(openTelemetry, flagdOptions.getOpenTelemetry());
         assertEquals(connector, flagdOptions.getCustomConnector());
         assertEquals(Resolver.IN_PROCESS, flagdOptions.getResolverType());