consul_watch.go

package main

import (
        "fmt"
        "github.com/micro/go-micro/registry"
)

func main() {
        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)
        }
}