(version string, server string)
| 110 | } |
| 111 | |
| 112 | func StartClusterVersionTracker(version string, server string) { |
| 113 | versionTracker = &clusterVersionTracker{server: server + "/pools/default"} |
| 114 | versionTracker.version, _ = cbgt.CompatibilityVersion(version) |
| 115 | go versionTracker.run() |
| 116 | } |
| 117 | |
| 118 | func (vt *clusterVersionTracker) run() { |
| 119 | found := int32(1) |