refactor: remove unsupported postgresql replication

Author: rueiyhuang

redshift_connector/__init__.py

@@ -133,7 +133,6 @@ def connect(
     tcp_keepalive_interval: typing.Optional[int] = None,
     tcp_keepalive_count: typing.Optional[int] = None,
     application_name: typing.Optional[str] = None,
-    replication: typing.Optional[str] = None,
     idp_host: typing.Optional[str] = None,
     db_user: typing.Optional[str] = None,
     app_id: typing.Optional[str] = None,
@@ -218,8 +217,6 @@ def connect(
         Number of failed probes before connection is considered dead. Defaults to None (system default).
     application_name : Optional[str]
         Sets the application name. The default value is None.
-    replication : Optional[str]
-        Used to run in `streaming replication mode <https://www.postgresql.org/docs/12/protocol-replication.html>`_.
     idp_host : Optional[str]
         The hostname of the IdP.
     db_user : Optional[str]
@@ -353,7 +350,6 @@ def connect(
     info.put("profile", profile)
     info.put("provider_name", provider_name)
     info.put("region", region)
-    info.put("replication", replication)
     info.put("role_arn", role_arn)
     info.put("role_session_name", role_session_name)
     info.put("scope", scope)
@@ -455,7 +451,6 @@ def connect(
         tcp_keepalive_interval=info.tcp_keepalive_interval,
         tcp_keepalive_count=info.tcp_keepalive_count,
         application_name=info.application_name,
-        replication=info.replication,
         client_protocol_version=info.client_protocol_version,
         database_metadata_current_db_only=info.database_metadata_current_db_only,
         credentials_provider=info.credentials_provider,

redshift_connector/core.py

@@ -422,7 +422,6 @@ def __init__(
         tcp_keepalive_interval: typing.Optional[int] = None,
         tcp_keepalive_count: typing.Optional[int] = None,
         application_name: typing.Optional[str] = None,
-        replication: typing.Optional[str] = None,
         client_protocol_version: int = DEFAULT_PROTOCOL_VERSION,
         database_metadata_current_db_only: bool = True,
         credentials_provider: typing.Optional[str] = None,
@@ -468,8 +467,6 @@ def __init__(
             Maximum number of TCP keepalive probes to send before dropping the connection if no response is received.  Defaults to None (system default).
         application_name : Optional[str]
             Sets the application name. The default value is None.
-        replication : Optional[str]
-            Used to run in `streaming replication mode <https://www.postgresql.org/docs/12/protocol-replication.html>`_.
         client_protocol_version : int
             The requested server protocol version. The default value is 1 representing `EXTENDED_RESULT_METADATA`. If the requested server protocol cannot be satisfied, a warning will be displayed to the user.
         database_metadata_current_db_only : bool
@@ -552,7 +549,6 @@ def get_calling_module() -> str:
             "user": "",
             "database": database,
             "application_name": application_name,
-            "replication": replication,
             "client_protocol_version": str(self._client_protocol_version),
             "driver_version": DriverInfo.driver_full_name(),
             "os_version": self.client_os_version,
@@ -774,7 +770,7 @@ def get_calling_module() -> str:
         protocol: int = 196608
         val: bytearray = bytearray(i_pack(protocol))
 
-        # Message include parameters name and value (user, database, application_name, replication)
+        # Message include parameters name and value (user, database, application_name)
         for k, v in init_params.items():
             val.extend(k.encode("ascii") + NULL_BYTE + typing.cast(bytes, v) + NULL_BYTE)
         val.append(0)

redshift_connector/redshift_property.py

@@ -94,9 +94,6 @@ def __init__(self: "RedshiftProperty", **kwargs):
             self.profile: typing.Optional[str] = None
             # The AWS region where the cluster specified by cluster_identifier is located.
             self.region: typing.Optional[str] = None
-            # Used to run in streaming replication mode. If your server character encoding is not ascii or utf8,
-            # then you need to provide values as bytes
-            self.replication: typing.Optional[str] = None
             self.role_arn: typing.Optional[str] = None
             self.role_session_name: typing.Optional[str] = None
             # The secret access key for the IAM role or IAM user configured for IAM database authentication

redshift_connector/utils/logging_utils.py

@@ -58,7 +58,6 @@ def mask_secure_info_in_props(info: "RedshiftProperty") -> "RedshiftProperty":
         "profile",
         "provider_name",
         "region",
-        "replication",
         "role_arn",
         "role_session_name",
         "scope",