Merge pull request #4147 from heyitsanthony/listener-unix-sockets

pkg/transport: support listeners on unix sockets

pkg/transport/listener.go

@@ -26,7 +26,13 @@ import (
 )
 
 func NewListener(addr string, scheme string, info TLSInfo) (net.Listener, error) {
-	l, err := net.Listen("tcp", addr)
+	nettype := "tcp"
+	if scheme == "unix" {
+		// unix sockets via unix://laddr
+		nettype = scheme
+	}
+
+	l, err := net.Listen(nettype, addr)
 	if err != nil {
 		return nil, err
 	}

pkg/transport/listener_test.go

@@ -241,3 +241,11 @@ func TestTLSInfoConfigFuncs(t *testing.T) {
 		}
 	}
 }
+
+func TestNewListenerUnixSocket(t *testing.T) {
+	l, err := NewListener("testsocket", "unix", TLSInfo{})
+	if err != nil {
+		t.Errorf("error listening on unix socket (%v)", err)
+	}
+	l.Close()
+}