Skip to content

feat(datastore,postgres): add logical replication support to Postgres WatchAPI - #3245

Closed
mazdakb wants to merge 1 commit into
mainfrom
postgres-logical-watch
Closed

feat(datastore,postgres): add logical replication support to Postgres WatchAPI#3245
mazdakb wants to merge 1 commit into
mainfrom
postgres-logical-watch

feat(datastore,postgres): add logical logical replication based watch…

c0aa2dc
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Jul 29, 2026 in 1s

69.51% of diff hit (target 76.53%)

View this Pull Request on Codecov

69.51% of diff hit (target 76.53%)

Annotations

Check warning on line 213 in internal/datastore/postgres/gc.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/gc.go#L212-L213

Added lines #L212 - L213 were not covered by tests

Check warning on line 468 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L467-L468

Added lines #L467 - L468 were not covered by tests

Check warning on line 472 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L471-L472

Added lines #L471 - L472 were not covered by tests

Check warning on line 488 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L488

Added line #L488 was not covered by tests

Check warning on line 492 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L490-L492

Added lines #L490 - L492 were not covered by tests

Check warning on line 501 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L500-L501

Added lines #L500 - L501 were not covered by tests

Check warning on line 516 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L514-L516

Added lines #L514 - L516 were not covered by tests

Check warning on line 522 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L520-L522

Added lines #L520 - L522 were not covered by tests

Check warning on line 545 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L544-L545

Added lines #L544 - L545 were not covered by tests

Check warning on line 550 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L549-L550

Added lines #L549 - L550 were not covered by tests

Check warning on line 574 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L573-L574

Added lines #L573 - L574 were not covered by tests

Check warning on line 581 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L578-L581

Added lines #L578 - L581 were not covered by tests

Check warning on line 590 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L589-L590

Added lines #L589 - L590 were not covered by tests

Check warning on line 611 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L595-L611

Added lines #L595 - L611 were not covered by tests

Check warning on line 627 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L626-L627

Added lines #L626 - L627 were not covered by tests

Check warning on line 633 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L632-L633

Added lines #L632 - L633 were not covered by tests

Check warning on line 637 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L636-L637

Added lines #L636 - L637 were not covered by tests

Check warning on line 650 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L646-L650

Added lines #L646 - L650 were not covered by tests

Check warning on line 656 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L655-L656

Added lines #L655 - L656 were not covered by tests

Check warning on line 659 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L658-L659

Added lines #L658 - L659 were not covered by tests

Check warning on line 668 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L667-L668

Added lines #L667 - L668 were not covered by tests

Check warning on line 673 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L672-L673

Added lines #L672 - L673 were not covered by tests

Check warning on line 694 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L693-L694

Added lines #L693 - L694 were not covered by tests

Check warning on line 698 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L696-L698

Added lines #L696 - L698 were not covered by tests

Check warning on line 714 in internal/datastore/postgres/lsn_ledger.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/datastore/postgres/lsn_ledger.go#L713-L714

Added lines #L713 - L714 were not covered by tests