blob: 25bd3946d170675d3fcd204f645fd80989b73a1b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
"use strict"
var ReadPreference = require('../topologies/read_preference'),
MongoError = require('../error');
var getReadPreference = function(cmd, options) {
// Default to command version of the readPreference
var readPreference = cmd.readPreference || new ReadPreference('primary');
// If we have an option readPreference override the command one
if(options.readPreference) {
readPreference = options.readPreference;
}
if(typeof readPreference == 'string') {
readPreference = new ReadPreference(readPreference);
}
if(!(readPreference instanceof ReadPreference)) {
throw new MongoError('readPreference must be a ReadPreference instance');
}
return readPreference;
}
module.exports = {
getReadPreference: getReadPreference
}
|
