Moved CredentialsSupplier to ServiceTransport

Author: artem-v

services-api/src/main/java/io/scalecube/services/auth/CredentialsSupplier.java

@@ -1,6 +1,10 @@
 package io.scalecube.services.transport.api;
 
+import io.scalecube.services.ServiceReference;
 import io.scalecube.services.registry.api.ServiceRegistry;
+import java.util.Map;
+import java.util.function.Function;
+import reactor.core.publisher.Mono;
 
 public interface ServiceTransport {
 
@@ -28,4 +32,11 @@ public interface ServiceTransport {
 
   /** Shutdowns transport and release occupied resources. */
   void stop();
+
+  /**
+   * Returns credentials for the given {@link ServiceReference}. Credentials are being returned in
+   * most generic form which is {@code Map<String, String>}.
+   */
+  @FunctionalInterface
+  interface CredentialsSupplier extends Function<ServiceReference, Mono<Map<String, String>>> {}
 }

services-api/src/main/java/io/scalecube/services/transport/api/ServiceTransport.java

@@ -7,9 +7,9 @@
 import io.scalecube.services.ServiceInfo;
 import io.scalecube.services.api.ServiceMessage;
 import io.scalecube.services.auth.Authenticator;
-import io.scalecube.services.auth.CredentialsSupplier;
 import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
 import io.scalecube.services.exceptions.UnauthorizedException;
+import io.scalecube.services.transport.api.ServiceTransport.CredentialsSupplier;
 import io.scalecube.services.transport.rsocket.RSocketServiceTransport;
 import io.scalecube.transport.netty.websocket.WebsocketTransportFactory;
 import java.time.Duration;

services-examples/src/main/java/io/scalecube/services/examples/auth/CompositeProfileAuthExample.java

@@ -4,9 +4,9 @@
 import io.scalecube.services.ServiceEndpoint;
 import io.scalecube.services.ServiceInfo;
 import io.scalecube.services.auth.Authenticator;
-import io.scalecube.services.auth.CredentialsSupplier;
 import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
 import io.scalecube.services.exceptions.UnauthorizedException;
+import io.scalecube.services.transport.api.ServiceTransport.CredentialsSupplier;
 import io.scalecube.services.transport.rsocket.RSocketServiceTransport;
 import io.scalecube.transport.netty.websocket.WebsocketTransportFactory;
 import java.time.Duration;

services-examples/src/main/java/io/scalecube/services/examples/auth/PrincipalMapperAuthExample.java

@@ -3,9 +3,9 @@
 import io.scalecube.services.Microservices;
 import io.scalecube.services.ServiceEndpoint;
 import io.scalecube.services.auth.Authenticator;
-import io.scalecube.services.auth.CredentialsSupplier;
 import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
 import io.scalecube.services.exceptions.UnauthorizedException;
+import io.scalecube.services.transport.api.ServiceTransport.CredentialsSupplier;
 import io.scalecube.services.transport.rsocket.RSocketServiceTransport;
 import io.scalecube.transport.netty.websocket.WebsocketTransportFactory;
 import java.time.Duration;

services-examples/src/main/java/io/scalecube/services/examples/auth/ServiceTransportAuthExample.java

@@ -10,14 +10,14 @@
 import io.rsocket.util.ByteBufPayload;
 import io.scalecube.services.Address;
 import io.scalecube.services.ServiceReference;
-import io.scalecube.services.auth.CredentialsSupplier;
 import io.scalecube.services.exceptions.MessageCodecException;
 import io.scalecube.services.exceptions.ServiceException;
 import io.scalecube.services.exceptions.UnauthorizedException;
 import io.scalecube.services.transport.api.ClientChannel;
 import io.scalecube.services.transport.api.ClientTransport;
 import io.scalecube.services.transport.api.DataCodec;
 import io.scalecube.services.transport.api.HeadersCodec;
+import io.scalecube.services.transport.api.ServiceTransport.CredentialsSupplier;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Map;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java

@@ -7,7 +7,6 @@
 import io.netty.util.concurrent.DefaultThreadFactory;
 import io.netty.util.concurrent.Future;
 import io.scalecube.services.auth.Authenticator;
-import io.scalecube.services.auth.CredentialsSupplier;
 import io.scalecube.services.exceptions.ConnectionClosedException;
 import io.scalecube.services.registry.api.ServiceRegistry;
 import io.scalecube.services.transport.api.ClientTransport;