(mgr *cbgt.Manager)
| 187 | } |
| 188 | |
| 189 | func getRemoteClients(mgr *cbgt.Manager) addRemoteClients { |
| 190 | var addRemClients addRemoteClients |
| 191 | if versionTracker != nil && |
| 192 | versionTracker.clusterCompatibleForVersion(FeatureGrpcVersion) { |
| 193 | addRemClients = addGrpcClients |
| 194 | } |
| 195 | |
| 196 | if _, ok := mgr.Options()["SkipScatterGatherOverGrpc"]; ok || |
| 197 | addRemClients == nil { |
| 198 | addRemClients = addIndexClients |
| 199 | } |
| 200 | |
| 201 | return addRemClients |
| 202 | } |
| 203 | |
| 204 | // The indexName/indexUUID is for a user-defined index alias. |
| 205 | // |
no test coverage detected