Showing 2 of 4 files from the diff.

@@ -140,7 +140,7 @@
Loading
140 140
                tables |= set(node.through_tables)
141 141
                tables |= set([node.table])
142 142
            self.create_triggers(self.database, schema, tables=tables)
143 -
        self.create_logical_replication_slot(self.__name)
143 +
        self.create_replication_slot(self.__name)
144 144
145 145
    def teardown(self):
146 146
        """Drop the database triggers and replication slot."""
@@ -157,7 +157,7 @@
Loading
157 157
                tables |= set(node.through_tables)
158 158
                tables |= set([node.table])
159 159
            self.drop_triggers(self.database, schema=schema, tables=tables)
160 -
        self.drop_logical_replication_slot(self.__name)
160 +
        self.drop_replication_slot(self.__name)
161 161
162 162
    def get_doc_id(self, primary_keys):
163 163
        """Get the Elasticsearch document id from the primary keys."""

@@ -217,9 +217,9 @@
Loading
217 217
        statement = statement.where(sa.and_(*filters))
218 218
        return self.query_all(statement)
219 219
220 -
    def create_logical_replication_slot(self, slot_name):
220 +
    def create_replication_slot(self, slot_name):
221 221
        """
222 -
        Create a logical replication slot.
222 +
        Create a replication slot.
223 223
224 224
        TODO:
225 225
        - Only create the replication slot if it does not exist
@@ -227,7 +227,7 @@
Loading
227 227
228 228
        SELECT * FROM PG_REPLICATION_SLOTS
229 229
        """
230 -
        logger.debug(f'Creating logical replication slot: {slot_name}')
230 +
        logger.debug(f'Creating replication slot: {slot_name}')
231 231
        statement = sa.select(['*']).select_from(
232 232
            sa.func.PG_CREATE_LOGICAL_REPLICATION_SLOT(
233 233
                slot_name,
@@ -236,14 +236,14 @@
Loading
236 236
        )
237 237
        return self.query_one(statement)
238 238
239 -
    def drop_logical_replication_slot(self, slot_name):
239 +
    def drop_replication_slot(self, slot_name):
240 240
        """
241 -
        Drop a logical replication slot.
241 +
        Drop a replication slot.
242 242
243 243
        TODO:
244 244
        - Only drop the replication slot if it exists
245 245
        """
246 -
        logger.debug(f'Dropping logical replication slot: {slot_name}')
246 +
        logger.debug(f'Dropping replication slot: {slot_name}')
247 247
        if self.replication_slots(slot_name):
248 248
            statement = sa.select(['*']).select_from(
249 249
                sa.func.PG_DROP_REPLICATION_SLOT(slot_name),
Files Coverage
pgsync 68.80%
tests/__init__.py 100.00%
Project Totals (10 files) 68.88%
codecov-umbrella
Build #353704540 -
unittests
codecov-umbrella
Build #353704540 -
unittests
codecov-umbrella
Build #353704540 -
unittests
codecov-umbrella
Build #353704540 -
unittests
1
coverage:
2
  status:
3
    project:
4
      default:
5
        threshold: 70%
6

7
codecov:
8
  archive: 
9
    uploads: false
Sunburst
The inner-most circle is the entire project, moving away from the center are folders then, finally, a single file. The size and color of each slice is representing the number of statements and the coverage, respectively.
Icicle
The top section represents the entire project. Proceeding with folders and finally individual files. The size and color of each slice is representing the number of statements and the coverage, respectively.
Grid
Each block represents a single file in the project. The size and color of each block is represented by the number of statements and the coverage, respectively.
Loading