Method run

version.go:118–160

()

}

func (vt *clusterVersionTracker) run() {
	found := int32(1)
	ev, err := getEffectiveClusterVersion(vt.server)
	if err != nil {
		log.Printf("version: getEffectiveClusterVersion, err: %v", err)
	}

	vt.clusterVersion = ev

	if vt.version == ev {
		log.Printf("version: matching clusterCompatibility"+
			" version: %d found", ev)
		atomic.StoreInt32(&vt.found, found)
		return
	}

	// monitor the effective cluster version until it matches the app version.
	ticker := time.NewTicker(time.Minute)
	defer ticker.Stop()

	for {
		select {
		case <-ticker.C:
			ev, err := getEffectiveClusterVersion(vt.server)
			if err != nil {
				log.Printf("version: getEffectiveClusterVersion, err: %v", err)
				continue
			}

			vt.clusterVersion = ev

			if vt.version != ev {
				continue
			}

			log.Printf("version: matching clusterCompatibility"+
				" version: %d found", ev)

			atomic.StoreInt32(&vt.found, found)
			return
		}
	}
}

// clusterCompatibleForVersion checks whether a compatible cluster found
// If not, then it checks whether the current cluster compatibility