4.1.2 • Published 10 years ago
dat-replication-protocol v4.1.2
dat-replication-protocol
Streaming implementation of the dat replication protocol
npm install dat-replication-protocol
Usage
var protocol = require('dat-replication-protocol')
var decode = protocol.decode()
var encode = protocol.encode()
decode.change(function(change, cb) {
// received a change
cb()
})
decode.blob(function(blob, cb) {
// received a blob stream
blob.on('data', function(data) {
console.log(data)
})
blob.on('end', function() {
cb()
})
})
decode.finalize(function(cb) {
// should finalize stuff
cb()
})
// write changes data
encode.change({
key: 'some-row-key',
change: 0,
from: 0,
to: 1,
value: new Buffer('some binary value')
}, functoin() {
console.log('change was flushed')
})
var blob = encode.blob(12) // 12 is the length of the blob
blob.write('hello ')
blob.write('world\n')
blob.end()
encode.finalize() // end the encode stream
// set up the pipeline
e.pipe(d)
Wire format
Basically all changes and blobs are sent as multibuffers (varint prefixed).
--------------------------------------------------
| varint length | single byte id | payload |
--------------------------------------------------
Since blobs can be large they are treated as streams.
License
MIT
4.1.2
10 years ago
4.1.1
10 years ago
4.1.0
10 years ago
4.0.1
10 years ago
4.0.0
10 years ago
3.0.3
10 years ago
3.0.2
10 years ago
3.0.1
10 years ago
3.0.0
10 years ago
2.1.0
10 years ago
2.0.0
10 years ago
1.1.0
10 years ago
1.0.1
10 years ago
1.0.0
10 years ago
0.3.0
10 years ago
0.2.2
10 years ago
0.2.1
10 years ago
0.2.0
10 years ago
0.1.1
10 years ago
0.1.0
10 years ago
0.0.0
10 years ago