socket client for Windows

sock-cli.go

package main

import (
	"io"
	"log"
	"net"
	// "time"
)

func reader(r io.Reader) {
	buf := make([]byte, 1024)
	for {
		n, err := r.Read(buf[:])
		if err != nil {
			return
		}
		println("Client got:", string(buf[0:n]))
	}
}

func main() {
	c, err := net.Dial("unix", "c:\\var\\lib\\kubelet\\plugins\\pd.csi.storage.gke.io\\csi.sock")
	if err != nil {
		log.Fatal("Dial error", err)
	}
	println("dialed successfully")
	defer c.Close()

	go reader(c)
	for {
		msg := "hi"
		_, err := c.Write([]byte(msg))
		if err != nil {
			log.Fatal("Write error:", err)
			break
		}
		println("Client sent:", msg)
		time.Sleep(1e9)
	}

}