1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
package transport
import (
"errors"
"net"
"net/url"
"runtime"
"strings"
)
func defaultListenURL(url *url.URL) (net.Listener, error) {
switch url.Scheme {
case "unix":
path := url.Path
if runtime.GOOS == "windows" {
path = strings.TrimPrefix(path, "/")
}
return net.Listen(url.Scheme, path)
case "tcp":
return net.Listen("tcp", url.Host)
default:
return nil, errors.New("unexpected scheme")
}
}
func Listen(endpoint string) (net.Listener, error) {
parsed, err := url.Parse(endpoint)
if err != nil {
return nil, err
}
return listenURL(parsed)
}
|
