WalStream test/sample code

Kibae Shin · Kibae Shin · commit 1ff021921ed0 · 2017-04-03T02:36:53.000+07:00
diff --git a/test/test-walstream.js b/test/test-walstream.js
@@ -0,0 +1,34 @@
+'use strict';
+
+const WalStream = require(__dirname + '/../lib').WalStream;
+
+var lastLsn = null;
+
+var walStream = new WalStream({});
+function proc() {
+  walStream.getChanges('test_slot', lastLsn, {
+    includeXids: false, //default: false
+    includeTimestamp: false, //default: false
+    skipEmptyXacts: true, //default: true
+  }, function(err) {
+    if (err) {
+      console.log('Logical replication initialize error', err);
+      setTimeout(proc, 1000);
+    }
+  });
+}
+
+walStream.on('data', function(msg) {
+  lastLsn = msg.lsn || lastLsn;
+
+  //DO SOMETHING. eg) replicate to other dbms(pgsql, mysql, ...)
+  console.log('log recv', msg);
+}).on('error', function(err) {
+  console.log('Error #2', err);
+  setTimeout(proc, 1000);
+});
+
+proc();
+
+//If want to stop replication
+//walStream.stop();
