Method configUpdate

engine/vserver.go:652–723

configUpdate updates the services, destinations, checks, and VIPs for a vserver.

()

// configUpdate updates the services, destinations, checks, and VIPs for a
// vserver.
func (v *vserver) configUpdate() {
	newSvcs := v.expandServices()
	for svcKey, newSvc := range newSvcs {
		if svc, ok := v.services[svcKey]; ok {
			if svc.ip.Equal(newSvc.ip) {
				svc.update(newSvc)
				continue
			}
			log.Infof("%v: service %v: new IP address: %v", v, svc, newSvc.ip)
			v.deleteService(svc)
		}
		log.Infof("%v: adding new service: %v", v, newSvc)
		v.services[svcKey] = newSvc
		v.updateState(newSvc.ip)
	}

	for svcKey, svc := range v.services {
		if newSvcs[svcKey] == nil {
			// Service no longer exists
			v.deleteService(svc)
			continue
		}

		// Update destinations for this service
		newDests := v.expandDests(svc)
		for destKey, newDest := range newDests {
			if dest, ok := svc.dests[destKey]; ok {
				dest.update(newDest)
				continue
			}
			log.Infof("%v: service %v: adding new destination: %v", v, svc, newDest)
			svc.dests[destKey] = newDest
		}

		for destKey, dest := range svc.dests {
			if newDests[destKey] == nil {
				// Destination no longer exists
				if dest.active {
					dest.healthy = false
					svc.updateState()
				}
				log.Infof("%v: service %v: deleting destination: %v", v, svc, dest)
				delete(svc.dests, destKey)
			}
		}
	}

	// If a VIP has been re-IP'd or has no services configured, remove the old
	// VIP from the interface.
	needVIPs := make(map[seesaw.IP]bool)
	for _, svc := range v.services {
		needVIPs[svc.ip] = true
	}
	for vip := range v.vips {
		if !needVIPs[vip.IP] {
			log.Infof("%v: unconfiguring no longer needed VIP %v", v, vip.IP)
			v.unconfigureVIP(&vip)
		}