Method manager

engine/core.go:366–484

manager is responsible for managing and co-ordinating various parts of the seesaw engine.

()

// manager is responsible for managing and co-ordinating various parts of the
// seesaw engine.
func (e *Engine) manager() {
	for {
		// process ha state updates first before processing others
		select {
		case state := <-e.haManager.stateChan:
			log.Infof("Received HA state notification %v", state)
			e.haManager.setState(state)
			continue
		case status := <-e.haManager.statusChan:
			log.V(1).Infof("Received HA status notification (%v)", status.State)
			e.haManager.setStatus(status)
			continue
		default:
		}
		select {
		case state := <-e.haManager.stateChan:
			log.Infof("Received HA state notification %v", state)
			e.haManager.setState(state)

		case status := <-e.haManager.statusChan:
			log.V(1).Infof("Received HA status notification (%v)", status.State)
			e.haManager.setStatus(status)

		case n := <-e.notifier.C:
			log.Infof("Received cluster config notification; %v", &n)
			e.syncServer.notify(&SyncNote{Type: SNTConfigUpdate, Time: time.Now()})

			vua, err := newVserverUserAccess(n.Cluster)
			if err != nil {
				log.Errorf("Ignoring notification due to invalid vserver access configuration: %v", err)
				return
			}

			e.clusterLock.Lock()
			e.cluster = n.Cluster
			e.clusterLock.Unlock()

			e.vserverAccess.update(vua)

			if n.MetadataOnly {
				log.Infof("Only metadata changes found, processing complete.")
				continue
			}

			if ha, err := e.haConfig(); err != nil {
				log.Errorf("Manager failed to determine haConfig: %v", err)
			} else if ha.Enabled {
				e.haManager.enable()
			} else {
				e.haManager.disable()
			}

			node, err := e.thisNode()
			if err != nil {
				log.Errorf("Manager failed to identify local node: %v", err)
				continue
			}
			if !node.VserversEnabled {