franklin/agent/etcd_watcher.go

package main

import (
	"fmt"
	"git.wanbits.io/joe/franklin/comp"
)

func watch() {
	servers := fmt.Sprintf("%s/conf/servers", g_conf.Namespace)
	wc1 := comp.GEtcdc.WatchPrefix(servers)
	apps := fmt.Sprintf("%s/app", g_conf.Namespace)
	wc2 := comp.GEtcdc.WatchPrefix(apps)

	for changed := range wc1 {

	}

	for changed := range wc2 {

	}
}