etcd_watch.go

package main

import (
	"fmt"
	_	"github.com/micro/go-plugins/registry/etcd"
	"github.com/micro/go-micro/registry"
	"github.com/micro/go-micro/cmd"
)

func main() {
	cmd.Init()
	w, err := registry.Watch()
	if err != nil {
		fmt.Println(err)
		return
	}


	for {
		r, err := w.Next()
		if err != nil {
			fmt.Println("err getting next:", err)
			break
		}

		fmt.Printf("got next %+v %+v\n", r, r.Service)
	}
}