Skip to content

Commit ae99a94

Browse files
Bernd Warmuthwarber
authored andcommitted
chore: move GrpcConnector to common package
Signed-off-by: Bernd Warmuth <bernd.warmuth@dynatrace.com>
1 parent ab929dc commit ae99a94

File tree

5 files changed

+6
-10
lines changed

5 files changed

+6
-10
lines changed
Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,6 @@
1-
package dev.openfeature.contrib.providers.flagd.resolver.grpc;
1+
package dev.openfeature.contrib.providers.flagd.resolver.common;
22

33
import dev.openfeature.contrib.providers.flagd.FlagdOptions;
4-
import dev.openfeature.contrib.providers.flagd.resolver.common.ChannelBuilder;
5-
import dev.openfeature.contrib.providers.flagd.resolver.common.ChannelMonitor;
6-
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionEvent;
7-
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionState;
84
import dev.openfeature.sdk.ImmutableStructure;
95
import io.grpc.ConnectivityState;
106
import io.grpc.ManagedChannel;

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/grpc/GrpcResolver.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import dev.openfeature.contrib.providers.flagd.resolver.Resolver;
1313
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionEvent;
1414
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionState;
15+
import dev.openfeature.contrib.providers.flagd.resolver.common.GrpcConnector;
1516
import dev.openfeature.contrib.providers.flagd.resolver.grpc.cache.Cache;
1617
import dev.openfeature.contrib.providers.flagd.resolver.grpc.strategy.ResolveFactory;
1718
import dev.openfeature.contrib.providers.flagd.resolver.grpc.strategy.ResolveStrategy;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import dev.openfeature.contrib.providers.flagd.FlagdOptions;
44
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionEvent;
5-
import dev.openfeature.contrib.providers.flagd.resolver.grpc.GrpcConnector;
5+
import dev.openfeature.contrib.providers.flagd.resolver.common.GrpcConnector;
66
import dev.openfeature.contrib.providers.flagd.resolver.process.storage.connector.Connector;
77
import dev.openfeature.contrib.providers.flagd.resolver.process.storage.connector.QueuePayload;
88
import dev.openfeature.contrib.providers.flagd.resolver.process.storage.connector.QueuePayloadType;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import dev.openfeature.contrib.providers.flagd.resolver.Resolver;
2020
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionEvent;
2121
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionState;
22-
import dev.openfeature.contrib.providers.flagd.resolver.grpc.GrpcConnector;
22+
import dev.openfeature.contrib.providers.flagd.resolver.common.GrpcConnector;
2323
import dev.openfeature.contrib.providers.flagd.resolver.grpc.GrpcResolver;
2424
import dev.openfeature.contrib.providers.flagd.resolver.grpc.cache.Cache;
2525
import dev.openfeature.contrib.providers.flagd.resolver.process.InProcessResolver;
Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
1-
package dev.openfeature.contrib.providers.flagd.resolver.grpc;
1+
package dev.openfeature.contrib.providers.flagd.resolver.common;
22

33
import com.google.common.collect.Lists;
44
import dev.openfeature.contrib.providers.flagd.FlagdOptions;
5-
import dev.openfeature.contrib.providers.flagd.resolver.common.ConnectionEvent;
65
import dev.openfeature.flagd.grpc.evaluation.Evaluation;
76
import dev.openfeature.flagd.grpc.evaluation.ServiceGrpc;
87
import io.grpc.ManagedChannel;
@@ -30,7 +29,7 @@ class GrpcConnectorTest {
3029
private static final boolean DISCONNECTED = false;
3130

3231
@Mock
33-
private EventStreamObserver mockEventStreamObserver;
32+
private StreamObserver mockEventStreamObserver;
3433

3534
private final ServiceGrpc.ServiceImplBase testServiceImpl = new ServiceGrpc.ServiceImplBase() {
3635
@Override

0 commit comments

Comments
 (0)