add unix domain socket support for api & metrics services
This commit is contained in:
+5
-2
@@ -53,8 +53,11 @@ type server struct {
|
|||||||
cclose chan struct{}
|
cclose chan struct{}
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewService(addr string, opts ...Option) (service.Service, error) {
|
func NewService(network, addr string, opts ...Option) (service.Service, error) {
|
||||||
ln, err := net.Listen("tcp", addr)
|
if network == "" {
|
||||||
|
network = "tcp"
|
||||||
|
}
|
||||||
|
ln, err := net.Listen(network, addr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -38,8 +38,11 @@ type metricService struct {
|
|||||||
cclose chan struct{}
|
cclose chan struct{}
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewService(addr string, opts ...Option) (service.Service, error) {
|
func NewService(network, addr string, opts ...Option) (service.Service, error) {
|
||||||
ln, err := net.Listen("tcp", addr)
|
if network == "" {
|
||||||
|
network = "tcp"
|
||||||
|
}
|
||||||
|
ln, err := net.Listen(network, addr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user