pg-logical-replication - npm Package Compare versions

Comparing version 2.0.2 to 2.0.3

dist/logical-replication-service.js

		@@ -85,3 +85,3 @@ "use strict";
		const timestamp = Math.floor(buffer.readUInt32BE(9) * 4294967.296 + buffer.readUInt32BE(13) / 1000 + 946080000000);
		const shouldRespond = buffer.readInt8(17);
		const shouldRespond = !!buffer.readInt8(17);
		this.emit('heartbeat', lsn, timestamp, shouldRespond);
		@@ -88,0 +88,0 @@ }

dist/output-plugins/pgoutput/pgoutput-parser.js

		@@ -74,3 +74,3 @@ "use strict";
		const columns = reader.array(reader.readInt16(), () => this.readRelationColumn(reader));
		const keyColumns = columns.filter(it => it.flags & 0b1).map(it => it.name);
		const keyColumns = columns.filter((it) => it.flags & 0b1).map((it) => it.name);
		const msg = {
		@@ -77,0 +77,0 @@ tag: 'relation',

dist/output-plugins/pgoutput/pgoutput-plugin.js

		@@ -21,4 +21,4 @@ "use strict";
		`publication_names '${this.options.publicationNames.join(',')}'`,
		].join(', ');
		const sql = `START_REPLICATION SLOT "${slotName}" LOGICAL ${lastLsn} (${options})`;
		];
		const sql = `START_REPLICATION SLOT "${slotName}" LOGICAL ${lastLsn} (${options.join(', ')})`;
		return client.query(sql);
		@@ -25,0 +25,0 @@ }

package.json

		{
		"name": "pg-logical-replication",
		"version": "2.0.2",
		"version": "2.0.3",
		"description": "PostgreSQL Location Replication client - logical WAL replication streaming",
		@@ -108,4 +108,6 @@ "main": "dist/index.js",
		"jest-junit"
		]
		],
		"maxConcurrency": 1,
		"maxWorkers": 1
		}
		}

README.md

		@@ -5,3 +5,4 @@ # pg-logical-replication
		- Supported plugins
		- [pgoutput](https://www.postgresql.org/docs/current/protocol-logicalrep-message-formats.html) (Native to PostgreSQL)
		- [pgoutput](https://www.postgresql.org/docs/current/protocol-logicalrep-message-formats.html) (Native to PostgreSQL, Recommended)
		- Use the pgoutput plugin to process huge transactions.
		- [wal2json](https://github.com/eulerto/wal2json)
		@@ -170,2 +171,3 @@ - [decoderbufs](https://github.com/debezium/postgres-decoderbufs)
		### 4-1. `PgoutputPlugin` for [pgoutput](https://www.postgresql.org/docs/current/protocol-logicalrep-message-formats.html) (Native to PostgreSQL)
		- Use the pgoutput plugin to process large-scale transactions.
		### 4-2. `Wal2JsonPlugin` for [wal2json](https://github.com/eulerto/wal2json)
		@@ -172,0 +174,0 @@ ### 4-3. `ProtocolBuffersPlugin` for [decoderbufs](https://github.com/debezium/postgres-decoderbufs)

New alerts