Shelikhoo преди 8 години
родител
ревизия
8fe53261cc
променени са 2 файла, в които са добавени 28 реда и са изтрити 0 реда
  1. 7 0
      transport/internet/domainsocket/dial.go
  2. 21 0
      transport/internet/domainsocket/listener.go

+ 7 - 0
transport/internet/domainsocket/dial.go

@@ -0,0 +1,7 @@
+package domainsocket
+
+import "context"
+
+func DialDS(ctx context.Context, path string) {
+
+}

+ 21 - 0
transport/internet/domainsocket/listener.go

@@ -1 +1,22 @@
 package domainsocket
+
+import (
+	"context"
+	"net"
+)
+
+type Listener struct {
+	ln net.Listener
+}
+
+func ListenDS(ctx context.Context, path string) (*Listener, error) {
+	addr := new(net.UnixAddr)
+	addr.Name = path
+	addr.Net = "unixpacket"
+	li, err := net.ListenUnix("unixpacket", addr)
+	if err != nil {
+		return nil, err
+	}
+	vln := &Listener{ln: li}
+	return vln, nil
+}