Oct 17, 2023 · Oct 2, 2023 · Oct 9, 2023 · Oct 17, 2023 · Oct 17, 2023
diff --git a/README.md b/README.md
 ### Remote mode
 Testgres supports the creation of PostgreSQL nodes on a remote host. This is useful when you want to run distributed tests involving multiple nodes spread across different machines.

 To use this feature, you need to use the RemoteOperations class.
 To use this feature, you need to use the RemoteOperations class. This feature is only supported with Linux.
 Here is an example of how you might set this up:

 ```python
diff --git a/setup.py b/setup.py
    "six>=1.9.0",
    "psutil",
    "packaging",
    "paramiko",
    "fabric",
    "sshtunnel"
 ]
    readme = f.read()

 setup(
    version='1.9.0',
    version='1.9.1',
    name='testgres',
    packages=['testgres', 'testgres.operations'],
    description='Testing utility for PostgreSQL and its extensions',
diff --git a/testgres/__init__.py b/testgres/__init__.py
    First, \
    Any

 from .config import testgres_config

 from .operations.os_ops import OsOperations, ConnectionParams
 from .operations.local_ops import LocalOperations
 from .operations.remote_ops import RemoteOperations

 __all__ = [
    "get_new_node",
    "get_remote_node",
    "NodeBackup",
    "NodeBackup", "testgres_config",
    "TestgresConfig", "configure_testgres", "scoped_config", "push_config", "pop_config",
    "NodeConnection", "DatabaseError", "InternalError", "ProgrammingError", "OperationalError",
    "TestgresException", "ExecUtilException", "QueryException", "TimeoutException", "CatchUpException", "StartNodeException", "InitNodeException", "BackupException",
diff --git a/testgres/cache.py b/testgres/cache.py
                # our initdb caching mechanism breaks this contract.
                pg_control = os.path.join(data_dir, XLOG_CONTROL_FILE)
                system_id = generate_system_id()
                os_ops.write(pg_control, system_id, truncate=True, binary=True, read_and_write=True)
                cur_pg_control = os_ops.read(pg_control, binary=True)
                new_pg_control = system_id + cur_pg_control[len(system_id):]
                os_ops.write(pg_control, new_pg_control, truncate=True, binary=True, read_and_write=True)

                # XXX: build new WAL segment with our system id
                _params = [get_bin_path("pg_resetwal"), "-D", data_dir, "-f"]
diff --git a/testgres/operations/local_ops.py b/testgres/operations/local_ops.py
        with open(filename, "a"):
            os.utime(filename, None)

    def read(self, filename, encoding=None):
        with open(filename, "r", encoding=encoding) as file:
            return file.read()
    def read(self, filename, encoding=None, binary=False):
        mode = "rb" if binary else "r"
        with open(filename, mode) as file:
            content = file.read()
            if binary:
                return content
            if isinstance(content, bytes):
                return content.decode(encoding or 'utf-8')
            return content

    def readlines(self, filename, num_lines=0, binary=False, encoding=None):
        """
Original file line number	Diff line number	Diff line change
Expand Up		@@ -176,7 +176,7 @@ the configuration file, which means that they should be called before `append_co
		### Remote mode
		Testgres supports the creation of PostgreSQL nodes on a remote host. This is useful when you want to run distributed tests involving multiple nodes spread across different machines.

		To use this feature, you need to use the RemoteOperations class.
		To use this feature, you need to use the RemoteOperations class. This feature is only supported with Linux.
		Here is an example of how you might set this up:

		```python
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -12,7 +12,6 @@
		"six>=1.9.0",
		"psutil",
		"packaging",
		"paramiko",
		"fabric",
		"sshtunnel"
		]
Expand All		@@ -30,7 +29,7 @@
		readme = f.read()

		setup(
		version='1.9.0',
		version='1.9.1',
		name='testgres',
		packages=['testgres', 'testgres.operations'],
		description='Testing utility for PostgreSQL and its extensions',
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -46,14 +46,16 @@
		First, \
		Any

		from .config import testgres_config

		from .operations.os_ops import OsOperations, ConnectionParams
		from .operations.local_ops import LocalOperations
		from .operations.remote_ops import RemoteOperations

		__all__ = [
		"get_new_node",
		"get_remote_node",
		"NodeBackup",
		"NodeBackup", "testgres_config",
		"TestgresConfig", "configure_testgres", "scoped_config", "push_config", "pop_config",
		"NodeConnection", "DatabaseError", "InternalError", "ProgrammingError", "OperationalError",
		"TestgresException", "ExecUtilException", "QueryException", "TimeoutException", "CatchUpException", "StartNodeException", "InitNodeException", "BackupException",
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -57,7 +57,9 @@ def call_initdb(initdb_dir, log=logfile):
		# our initdb caching mechanism breaks this contract.
		pg_control = os.path.join(data_dir, XLOG_CONTROL_FILE)
		system_id = generate_system_id()
		os_ops.write(pg_control, system_id, truncate=True, binary=True, read_and_write=True)
		cur_pg_control = os_ops.read(pg_control, binary=True)
		new_pg_control = system_id + cur_pg_control[len(system_id):]
		os_ops.write(pg_control, new_pg_control, truncate=True, binary=True, read_and_write=True)

		# XXX: build new WAL segment with our system id
		_params = [get_bin_path("pg_resetwal"), "-D", data_dir, "-f"]
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -198,9 +198,15 @@ def touch(self, filename):
		with open(filename, "a"):
		os.utime(filename, None)

		def read(self, filename, encoding=None):
		with open(filename, "r", encoding=encoding) as file:
		return file.read()
		def read(self, filename, encoding=None, binary=False):
		mode = "rb" if binary else "r"
		with open(filename, mode) as file:
		content = file.read()
		if binary:
		return content
		if isinstance(content, bytes):
		return content.decode(encoding or 'utf-8')
		return content

		def readlines(self, filename, num_lines=0, binary=False, encoding=None):
		"""
Expand Down