-
Notifications
You must be signed in to change notification settings - Fork 0
/
cluster-get.js
61 lines (50 loc) · 1.44 KB
/
cluster-get.js
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
var net = require('net')
, once = require('once')
, parallel = require('run-parallel')
, multilevel = require('multilevel')
, parse = function (address) {
var parts = address.split(':')
return {
host: parts[0]
, port: parseInt(parts[1], 10)
}
}
, getFactory = function (config) {
return function (key, callback) {
var tasks = {}
config.servers.forEach(function (address) {
tasks[address] = function (done) {
var con = net.connect(parse(address))
, db = multilevel.client()
done = once(done)
con.pipe(db.createRpcStream()).pipe(con)
con.once('error', done)
db.get(key, function (err, value) {
con.end()
if (err)
done(
null
, { error: err }
)
else
done(
null
, { value: value }
)
})
}
})
parallel(tasks, callback)
}
}
, clusterGet = function (db, config) {
var server = net.createServer(function (con) {
con.pipe(multilevel.server(db)).pipe(con)
}).listen(config.port)
, factory = getFactory(config)
factory.close = function (callback) {
server.close(callback)
}
return factory
}
module.exports = clusterGet