in example/main.go [38:84]
func main() {
flag.Usage = func() {
if _, err := fmt.Fprint(flag.CommandLine.Output(), usage); err != nil {
return
}
}
server := flag.String("server", "127.0.0.1:2181", "Zookeeper server address.")
flag.Parse()
if len(flag.Args()) != 2 {
flag.Usage()
return
}
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
client := zk.Client{}
conn, err := client.DialContext(ctx, "tcp", *server)
if err != nil {
fmt.Println("error dialing server:", err)
return
}
cmd := flag.Args()[0]
path := flag.Args()[1]
switch cmd {
case "get":
data, err := conn.GetData(path)
if err != nil {
fmt.Println("getData error:", err)
return
}
fmt.Printf("Data for node %s: %v\n", path, string(data))
case "list":
children, err := conn.GetChildren(path)
if err != nil {
fmt.Println("getChildren error:", err)
return
}
fmt.Printf("Children of node %s: %v\n", path, children)
default:
fmt.Printf("Cannot recognize command \"%s\", exiting.\n", cmd)
}
}