Also client

Author: cfredri4

grpc-client-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/client/channelfactory/NettyChannelFactory.java

@@ -30,6 +30,9 @@
 
 import io.grpc.netty.GrpcSslContexts;
 import io.grpc.netty.NettyChannelBuilder;
+import io.netty.channel.epoll.EpollDomainSocketChannel;
+import io.netty.channel.epoll.EpollEventLoopGroup;
+import io.netty.channel.unix.DomainSocketAddress;
 import io.netty.handler.ssl.SslContextBuilder;
 import net.devh.boot.grpc.client.config.GrpcChannelProperties;
 import net.devh.boot.grpc.client.config.GrpcChannelProperties.Security;
@@ -71,8 +74,15 @@ protected NettyChannelBuilder newChannelBuilder(final String name) {
         if (address == null) {
             address = URI.create(name);
         }
-        return NettyChannelBuilder.forTarget(address.toString())
-                .defaultLoadBalancingPolicy(properties.getDefaultLoadBalancingPolicy());
+        NettyChannelBuilder builder;
+        if (address.getScheme().equals(GrpcChannelProperties.DOMAIN_SOCKET_ADDRESS_SCHEME)) {
+            builder =  NettyChannelBuilder.forAddress(new DomainSocketAddress(address.getPath()))
+                    .channelType(EpollDomainSocketChannel.class)
+                    .eventLoopGroup(new EpollEventLoopGroup());
+        } else {
+            builder = NettyChannelBuilder.forTarget(address.toString());
+        }
+        return builder.defaultLoadBalancingPolicy(properties.getDefaultLoadBalancingPolicy());
     }
 
     @Override

grpc-client-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/client/channelfactory/ShadedNettyChannelFactory.java

@@ -30,6 +30,9 @@
 
 import io.grpc.netty.shaded.io.grpc.netty.GrpcSslContexts;
 import io.grpc.netty.shaded.io.grpc.netty.NettyChannelBuilder;
+import io.grpc.netty.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
+import io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoopGroup;
+import io.grpc.netty.shaded.io.netty.channel.unix.DomainSocketAddress;
 import io.grpc.netty.shaded.io.netty.handler.ssl.SslContextBuilder;
 import net.devh.boot.grpc.client.config.GrpcChannelProperties;
 import net.devh.boot.grpc.client.config.GrpcChannelProperties.Security;
@@ -69,8 +72,15 @@ protected NettyChannelBuilder newChannelBuilder(final String name) {
         if (address == null) {
             address = URI.create(name);
         }
-        return NettyChannelBuilder.forTarget(address.toString())
-                .defaultLoadBalancingPolicy(properties.getDefaultLoadBalancingPolicy());
+        NettyChannelBuilder builder;
+        if (address.getScheme().equals(GrpcChannelProperties.DOMAIN_SOCKET_ADDRESS_SCHEME)) {
+            builder =  NettyChannelBuilder.forAddress(new DomainSocketAddress(address.getPath()))
+                    .channelType(EpollDomainSocketChannel.class)
+                    .eventLoopGroup(new EpollEventLoopGroup());
+        } else {
+            builder = NettyChannelBuilder.forTarget(address.toString());
+        }
+        return builder.defaultLoadBalancingPolicy(properties.getDefaultLoadBalancingPolicy());
     }
 
     @Override

grpc-client-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/client/config/GrpcChannelProperties.java

@@ -53,6 +53,11 @@
 @EqualsAndHashCode
 public class GrpcChannelProperties {
 
+    /**
+     * A constant that defines, the scheme of a Unix domain socket address.
+     */
+    public static final String DOMAIN_SOCKET_ADDRESS_SCHEME = "unix";
+
     // --------------------------------------------------
     // Target Address
     // --------------------------------------------------