subscribeCallback := func(old model.Instance, new model.Instance, err error) {
if new != nil && old == nil {
log.Printf("服务%s 实例%s上线\n",new.ServiceName, new.Ip)
}
if new == nil && old != nil {
log.Printf("服务%s 实例%s下线\n",new.ServiceName, new.Ip)
}
if new != nil && old != nil {
log.Printf("服务%s 实例%s变更\n",new.ServiceName, new.Ip)
}
}
cli.Subscribe(&vo.SubscribeParam{
ServiceName: "ServiceA",
SubscribeCallback: subscribeCallback,
})