GoZeroPlus/example/etcd/sub/sub.go

package main

import (
	"fmt"
	"time"

	"zero/core/discov"
)

func main() {
	sub := discov.NewSubscriber([]string{"etcd.discovery:2379"}, "028F2C35852D", discov.Exclusive())
	ticker := time.NewTicker(time.Second * 3)
	defer ticker.Stop()

	for {
		select {
		case <-ticker.C:
			fmt.Println("values:", sub.Values())
		}
	}
}