scheduler

var RegistrarChangesHandler = func(evType store.Event_EventType, key []byte, value []byte) {
	k := string(key)
	v := string(value)

	if len(k) > 0 && k[0] == '/' {
		k = k[1:]
	}

	parts := strings.Split(k, "/")
	if parts[0] != "services" {
		parts = parts[1:]
	}
	if parts[0] == "services" {
		if len(parts) > 4 && parts[4] == api.GRPC {
			onUpdatedAx(evType, parts[1], parts[2], parts[3], v)
		} else if len(parts) > 1 {
			logrus.Debugf(">>> registrar changing: %v, %v, %v", store.EvTypeToString(evType), parts[1], v)
		} else {
			logrus.Debugf(">>> registrar changing: %v, %v, %v", store.EvTypeToString(evType), k, v)
		}
	}
}

var RegistrarOkCallback = func(r *gwk.Registrar, serviceName string) {
	logrus.Debugf("registrar connected: %s, %v", serviceName, r)

	serviceAddDepEntry(serviceName, ":1")

	// 添加依赖服务的条目
	var out = make(map[string]*DepRecord)
	_ = vxconf.LoadSectionTo("server.deps", out)
	for k := range out {
		serviceAddDepEntry(k, ":1")
	}

}