diff --git a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/http/WebClientCloudEventSender.java b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/http/WebClientCloudEventSender.java index 862d774765..dd719b15e8 100644 --- a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/http/WebClientCloudEventSender.java +++ b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/http/WebClientCloudEventSender.java @@ -20,10 +20,10 @@ import dev.knative.eventing.kafka.broker.contract.DataPlaneContract; import dev.knative.eventing.kafka.broker.core.NamespacedName; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.dispatcher.impl.auth.TokenProvider; import dev.knative.eventing.kafka.broker.core.tracing.TracingSpan; import dev.knative.eventing.kafka.broker.dispatcher.CloudEventSender; import dev.knative.eventing.kafka.broker.dispatcher.impl.ResponseFailureException; +import dev.knative.eventing.kafka.broker.dispatcher.impl.auth.TokenProvider; import dev.knative.eventing.kafka.broker.dispatcher.main.ConsumerVerticleContext; import io.cloudevents.CloudEvent; import io.cloudevents.http.vertx.VertxMessageFactory; diff --git a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticle.java b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticle.java index 376d49b18c..92b3671515 100644 --- a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticle.java +++ b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticle.java @@ -22,15 +22,15 @@ import static io.netty.handler.codec.http.HttpResponseStatus.OK; import dev.knative.eventing.kafka.broker.core.file.FileWatcher; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfig; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.TokenVerifier; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.TokenVerifierImpl; import dev.knative.eventing.kafka.broker.core.reconciler.IngressReconcilerListener; import dev.knative.eventing.kafka.broker.core.reconciler.ResourcesReconciler; import dev.knative.eventing.kafka.broker.receiver.IngressProducer; import dev.knative.eventing.kafka.broker.receiver.IngressRequestHandler; import dev.knative.eventing.kafka.broker.receiver.RequestContext; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfig; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.TokenVerifier; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.TokenVerifierImpl; import dev.knative.eventing.kafka.broker.receiver.impl.handler.AuthenticationHandler; import dev.knative.eventing.kafka.broker.receiver.impl.handler.MethodNotAllowedHandler; import dev.knative.eventing.kafka.broker.receiver.impl.handler.ProbeHandler; diff --git a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/Main.java b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/Main.java index 6e8ba781dd..40b363b463 100644 --- a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/Main.java +++ b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/Main.java @@ -24,11 +24,11 @@ import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; import dev.knative.eventing.kafka.broker.core.file.FileWatcher; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler; import dev.knative.eventing.kafka.broker.core.tracing.TracingConfig; import dev.knative.eventing.kafka.broker.core.utils.Configurations; import dev.knative.eventing.kafka.broker.core.utils.Shutdown; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import io.cloudevents.kafka.CloudEventSerializer; import io.cloudevents.kafka.PartitionKeyExtensionInterceptor; import io.fabric8.kubernetes.client.KubernetesClientBuilder; diff --git a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactory.java b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactory.java index 28350218eb..aefe5d41a3 100644 --- a/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactory.java +++ b/data-plane/receiver/src/main/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactory.java @@ -19,12 +19,12 @@ import dev.knative.eventing.kafka.broker.core.eventtype.EventType; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeCreatorImpl; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.core.security.AuthProvider; import dev.knative.eventing.kafka.broker.receiver.IngressRequestHandler; import dev.knative.eventing.kafka.broker.receiver.impl.IngressProducerReconcilableStore; import dev.knative.eventing.kafka.broker.receiver.impl.ReceiverVerticle; import dev.knative.eventing.kafka.broker.receiver.impl.StrictRequestToRecordMapper; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.receiver.impl.handler.IngressRequestHandlerImpl; import io.cloudevents.CloudEvent; import io.fabric8.kubernetes.api.model.KubernetesResourceList; diff --git a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTest.java b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTest.java index b832a95317..9589827f1b 100644 --- a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTest.java +++ b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTest.java @@ -36,11 +36,11 @@ import dev.knative.eventing.kafka.broker.core.eventbus.ContractPublisher; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler; import dev.knative.eventing.kafka.broker.core.security.AuthProvider; import dev.knative.eventing.kafka.broker.core.testing.CloudEventSerializerMock; import dev.knative.eventing.kafka.broker.receiver.MockReactiveKafkaProducer; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.receiver.impl.handler.ControlPlaneProbeRequestUtil; import dev.knative.eventing.kafka.broker.receiver.impl.handler.IngressRequestHandlerImpl; import dev.knative.eventing.kafka.broker.receiver.main.ReceiverEnv; diff --git a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTracingTest.java b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTracingTest.java index 73d4d03a7d..f550dcf557 100644 --- a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTracingTest.java +++ b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/ReceiverVerticleTracingTest.java @@ -24,9 +24,9 @@ import dev.knative.eventing.kafka.broker.core.ReactiveKafkaProducer; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.core.security.AuthProvider; import dev.knative.eventing.kafka.broker.core.testing.CloudEventSerializerMock; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.receiver.impl.handler.IngressRequestHandlerImpl; import dev.knative.eventing.kafka.broker.receiver.main.ReceiverEnv; import io.cloudevents.CloudEvent; diff --git a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactoryTest.java b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactoryTest.java index a7a99c6edf..c88a31a65a 100644 --- a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactoryTest.java +++ b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/main/ReceiverVerticleFactoryTest.java @@ -22,8 +22,8 @@ import dev.knative.eventing.kafka.broker.core.eventtype.EventType; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.receiver.MockReactiveProducerFactory; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import io.fabric8.kubernetes.client.KubernetesClient; import io.micrometer.core.instrument.MeterRegistry; import io.vertx.core.Vertx; diff --git a/data-plane/tests/src/test/java/dev/knative/eventing/kafka/broker/tests/AbstractDataPlaneTest.java b/data-plane/tests/src/test/java/dev/knative/eventing/kafka/broker/tests/AbstractDataPlaneTest.java index 0873c25218..8e8fb44a46 100644 --- a/data-plane/tests/src/test/java/dev/knative/eventing/kafka/broker/tests/AbstractDataPlaneTest.java +++ b/data-plane/tests/src/test/java/dev/knative/eventing/kafka/broker/tests/AbstractDataPlaneTest.java @@ -33,7 +33,6 @@ import dev.knative.eventing.kafka.broker.core.eventbus.ContractPublisher; import dev.knative.eventing.kafka.broker.core.eventtype.EventTypeListerFactory; import dev.knative.eventing.kafka.broker.core.metrics.Metrics; -import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.core.reconciler.impl.ResourcesReconcilerMessageHandler; import dev.knative.eventing.kafka.broker.core.security.AuthProvider; import dev.knative.eventing.kafka.broker.dispatcher.impl.consumer.CloudEventDeserializer; @@ -45,6 +44,7 @@ import dev.knative.eventing.kafka.broker.receiver.impl.IngressProducerReconcilableStore; import dev.knative.eventing.kafka.broker.receiver.impl.ReceiverVerticle; import dev.knative.eventing.kafka.broker.receiver.impl.StrictRequestToRecordMapper; +import dev.knative.eventing.kafka.broker.receiver.impl.auth.OIDCDiscoveryConfigListener; import dev.knative.eventing.kafka.broker.receiver.impl.handler.IngressRequestHandlerImpl; import dev.knative.eventing.kafka.broker.receiver.main.ReceiverEnv; import io.cloudevents.core.builder.CloudEventBuilder;