Release v1.0.0 candidate

[eminano]

Description

This release includes the stateless DDL architecture changes, as well as changes to the CLI to make the upgrade to v1 smoother.

Related Issue(s)

• Related to Stateless DDL replication #691
• Related to Add option to init/destroy migrations only #708

Type of Change

• ✨ New feature (non-breaking change that adds functionality)
• 💥 Breaking change (fix or feature that would cause existing functionality to not work as expected)
• 📚 Documentation update
• 🔧 Refactoring (no functional changes)
• 🧹 Code cleanup

Testing

• Unit tests added/updated
• Integration tests added/updated
• Manual testing performed
• All existing tests pass

[github-actions]

Merging this branch changes the coverage (9 decrease, 8 increase)

Impacted Packages	Coverage Δ	🤖
github.com/xataio/pgstream/cmd	0.00% (ø)
github.com/xataio/pgstream/cmd/config	84.26% (+0.19%)	👍
github.com/xataio/pgstream/internal/migrator	0.00% (ø)
github.com/xataio/pgstream/internal/postgres	30.11% (-0.14%)	👎
github.com/xataio/pgstream/internal/postgres/retrier	91.67% (+0.12%)	👍
github.com/xataio/pgstream/internal/searchstore	0.00% (ø)
github.com/xataio/pgstream/internal/searchstore/opensearch	0.00% (ø)
github.com/xataio/pgstream/migrations/postgres/core	0.00% (ø)
github.com/xataio/pgstream/migrations/postgres/injector	0.00% (ø)
github.com/xataio/pgstream/pkg/schemalog	0.00% (-54.14%)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/schemalog/instrumentation	0.00% (ø)
github.com/xataio/pgstream/pkg/schemalog/mocks	0.00% (ø)
github.com/xataio/pgstream/pkg/schemalog/postgres	0.00% (-86.67%)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore	89.09% (+0.99%)	👍
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/schemalog	0.00% (-94.12%)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/stream	35.27% (-0.68%)	👎
github.com/xataio/pgstream/pkg/stream/integration	0.00% (ø)
github.com/xataio/pgstream/pkg/wal	71.31% (+71.31%)	🌟
github.com/xataio/pgstream/pkg/wal/listener/snapshot/builder	0.00% (ø)
github.com/xataio/pgstream/pkg/wal/processor	0.00% (-84.62%)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/wal/processor/filter	94.00% (+8.49%)	👍
github.com/xataio/pgstream/pkg/wal/processor/injector	76.24% (+2.77%)	👍
github.com/xataio/pgstream/pkg/wal/processor/kafka	54.24% (-7.88%)	👎
github.com/xataio/pgstream/pkg/wal/processor/postgres	78.57% (-5.10%)	👎
github.com/xataio/pgstream/pkg/wal/processor/search	80.52% (-2.25%)	👎
github.com/xataio/pgstream/pkg/wal/processor/search/instrumentation	0.00% (ø)
github.com/xataio/pgstream/pkg/wal/processor/search/mocks	0.00% (ø)
github.com/xataio/pgstream/pkg/wal/processor/search/store	71.52% (+1.22%)	👍
github.com/xataio/pgstream/pkg/wal/processor/transformer	82.42% (ø)
github.com/xataio/pgstream/pkg/wal/replication/postgres	69.34% (+1.00%)	👍

---

Coverage by file

Changed files (no unit tests)

Changed File	Coverage Δ	Total	Covered	Missed	🤖
github.com/xataio/pgstream/cmd/config/config_env.go	90.54% (+0.23%)	222 (-5)	201 (-4)	21 (-1)	👍
github.com/xataio/pgstream/cmd/config/config_yaml.go	89.42% (+0.41%)	189 (-2)	169 (-1)	20 (-1)	👍
github.com/xataio/pgstream/cmd/init_cmd.go	0.00% (ø)	44 (+11)	0	44 (+11)
github.com/xataio/pgstream/cmd/root_cmd.go	0.00% (ø)	90 (+7)	0	90 (+7)
github.com/xataio/pgstream/cmd/run_cmd.go	0.00% (ø)	82 (+4)	0	82 (+4)
github.com/xataio/pgstream/cmd/status_cmd.go	0.00% (ø)	34	0	34
github.com/xataio/pgstream/internal/migrator/migrator.go	0.00% (ø)	45 (+45)	0	45 (+45)
github.com/xataio/pgstream/internal/postgres/errors.go	61.76% (-3.86%)	34 (+2)	21	13 (+2)	👎
github.com/xataio/pgstream/internal/postgres/retrier/pg_querier_retrier.go	91.67% (+0.12%)	72 (+1)	66 (+1)	6	👍
github.com/xataio/pgstream/internal/searchstore/opensearch/opensearch_client.go	0.00% (ø)	209 (+1)	0	209 (+1)
github.com/xataio/pgstream/internal/searchstore/search_api.go	0.00% (ø)	12	0	12
github.com/xataio/pgstream/migrations/postgres/core/migrations.go	0.00% (ø)	107 (+107)	0	107 (+107)
github.com/xataio/pgstream/migrations/postgres/injector/migrations.go	0.00% (ø)	121 (+121)	0	121 (+121)
github.com/xataio/pgstream/pkg/schemalog/instrumentation/instrumented_store.go	0.00% (ø)	0 (-16)	0	0 (-16)
github.com/xataio/pgstream/pkg/schemalog/log_entry.go	0.00% (ø)	0 (-53)	0	0 (-53)
github.com/xataio/pgstream/pkg/schemalog/mocks/store_mock.go	0.00% (ø)	0 (-14)	0	0 (-14)
github.com/xataio/pgstream/pkg/schemalog/postgres/pg_schemalog_store.go	0.00% (-86.67%)	0 (-45)	0 (-39)	0 (-6)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/schemalog/schema.go	0.00% (-21.48%)	0 (-149)	0 (-32)	0 (-117)	💀 💀
github.com/xataio/pgstream/pkg/schemalog/schema_diff.go	0.00% (-88.94%)	0 (-199)	0 (-177)	0 (-22)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/schemalog/store.go	0.00% (ø)	0	0	0
github.com/xataio/pgstream/pkg/schemalog/store_cache.go	0.00% (-90.91%)	0 (-22)	0 (-20)	0 (-2)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/pg_options_generator.go	100.00% (ø)	75 (-8)	75 (-8)	0
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/pg_snapshot_wal_restore.go	95.33% (+95.33%)	107 (+107)	102 (+102)	5 (+5)	🌟
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/snapshot_pg_dump_restore_generator.go	83.11% (-0.70%)	302 (-44)	251 (-39)	51 (-5)	👎
github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/schemalog/snapshot_schemalog_generator.go	0.00% (-94.12%)	0 (-34)	0 (-32)	0 (-2)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/stream/config.go	70.73% (+1.29%)	41 (+5)	29 (+4)	12 (+1)	👍
github.com/xataio/pgstream/pkg/stream/stream.go	0.00% (ø)	126	0	126
github.com/xataio/pgstream/pkg/stream/stream_init.go	5.88% (-0.57%)	102 (+9)	6	96 (+9)	👎
github.com/xataio/pgstream/pkg/stream/stream_run.go	0.00% (ø)	88	0	88
github.com/xataio/pgstream/pkg/stream/stream_status.go	78.41% (+0.76%)	88 (+3)	69 (+3)	19	👍
github.com/xataio/pgstream/pkg/stream/stream_status_checker.go	83.72% (-3.88%)	129	108 (-5)	21 (+5)	👎
github.com/xataio/pgstream/pkg/wal/listener/snapshot/builder/config.go	0.00% (ø)	0	0	0
github.com/xataio/pgstream/pkg/wal/listener/snapshot/builder/wal_listener_snapshot_generator_builder.go	0.00% (ø)	42 (-9)	0	42 (-9)
github.com/xataio/pgstream/pkg/wal/processor/filter/wal_filter.go	94.00% (+8.49%)	50 (-19)	47 (-12)	3 (-7)	👍
github.com/xataio/pgstream/pkg/wal/processor/injector/wal_injector.go	76.24% (+2.77%)	101 (+3)	77 (+5)	24 (-2)	👍
github.com/xataio/pgstream/pkg/wal/processor/kafka/wal_kafka_batch_writer.go	54.24% (-7.88%)	59 (-7)	32 (-9)	27 (+2)	👎
github.com/xataio/pgstream/pkg/wal/processor/postgres/config.go	0.00% (ø)	3	0	3
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_batch_writer.go	79.27% (+3.71%)	82 (-8)	65 (-3)	17 (-5)	👍
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_bulk_ingest_writer.go	72.60% (-1.01%)	73 (+1)	53	20 (+1)	👎
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_schema_observer.go	81.98% (-2.55%)	111 (+14)	91 (+9)	20 (+5)	👎
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_wal_adapter.go	60.00% (-3.33%)	30	18 (-1)	12 (+1)	👎
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_wal_ddl_adapter.go	100.00% (+7.12%)	10 (-285)	10 (-264)	0 (-21)	👍
github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_writer.go	37.14% (ø)	35	13	22
github.com/xataio/pgstream/pkg/wal/processor/search/errors.go	0.00% (ø)	4	0	4
github.com/xataio/pgstream/pkg/wal/processor/search/id_hasher.go	0.00% (ø)	3	0	3
github.com/xataio/pgstream/pkg/wal/processor/search/instrumentation/instrumented_search_store.go	0.00% (ø)	31	0	31
github.com/xataio/pgstream/pkg/wal/processor/search/mocks/mock_search_mapper.go	0.00% (ø)	2	0	2
github.com/xataio/pgstream/pkg/wal/processor/search/search_adapter.go	96.97% (-1.46%)	99 (-28)	96 (-29)	3 (+1)	👎
github.com/xataio/pgstream/pkg/wal/processor/search/search_batch_indexer.go	72.15% (-0.35%)	79 (-1)	57 (-1)	22	👎
github.com/xataio/pgstream/pkg/wal/processor/search/search_msg_batch.go	0.00% (ø)	2	0	2
github.com/xataio/pgstream/pkg/wal/processor/search/search_store_retrier.go	80.56% (ø)	72	58	14
github.com/xataio/pgstream/pkg/wal/processor/search/store.go	50.00% (ø)	8	4	4
github.com/xataio/pgstream/pkg/wal/processor/search/store/search_adapter.go	59.46% (+9.46%)	37 (-7)	22	15 (-7)	👍
github.com/xataio/pgstream/pkg/wal/processor/search/store/search_pg_mapper.go	67.26% (-0.29%)	113 (-1)	76 (-1)	37	👎
github.com/xataio/pgstream/pkg/wal/processor/search/store/search_store.go	77.08% (+0.25%)	144 (-20)	111 (-15)	33 (-5)	👍
github.com/xataio/pgstream/pkg/wal/processor/transformer/wal_transformer.go	71.70% (ø)	53	38	15
github.com/xataio/pgstream/pkg/wal/processor/wal_processor.go	0.00% (-84.62%)	0 (-13)	0 (-11)	0 (-2)	💀 💀 💀 💀 💀
github.com/xataio/pgstream/pkg/wal/replication/postgres/pg_replication_handler.go	68.70% (+1.03%)	131 (-2)	90	41 (-2)	👍
github.com/xataio/pgstream/pkg/wal/wal_data.go	0.00% (ø)	11 (-1)	0	11 (-1)
github.com/xataio/pgstream/pkg/wal/wal_ddl.go	68.18% (+68.18%)	44 (+44)	30 (+30)	14 (+14)	🌟
github.com/xataio/pgstream/pkg/wal/wal_schema_diff.go	85.07% (+85.07%)	67 (+67)	57 (+57)	10 (+10)	🌟

Please note that the "Total", "Covered", and "Missed" counts above refer to code statements instead of lines of code. The value in brackets refers to the test coverage of that file in the old version of the code.

Changed unit test files

• github.com/xataio/pgstream/cmd/config/config_env_test.go
• github.com/xataio/pgstream/cmd/config/config_yaml_test.go
• github.com/xataio/pgstream/cmd/config/helper_test.go
• github.com/xataio/pgstream/pkg/schemalog/postgres/pg_schemalog_store_test.go
• github.com/xataio/pgstream/pkg/schemalog/schema_diff_test.go
• github.com/xataio/pgstream/pkg/schemalog/schema_test.go
• github.com/xataio/pgstream/pkg/schemalog/store_cache_test.go
• github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/helper_test.go
• github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/pg_options_generator_test.go
• github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/pg_snapshot_wal_restore_test.go
• github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/pgdumprestore/snapshot_pg_dump_restore_generator_test.go
• github.com/xataio/pgstream/pkg/snapshot/generator/postgres/schema/schemalog/snapshot_schemalog_generator_test.go
• github.com/xataio/pgstream/pkg/stream/helper_test.go
• github.com/xataio/pgstream/pkg/stream/integration/helper_test.go
• github.com/xataio/pgstream/pkg/stream/integration/pg_kafka_integration_test.go
• github.com/xataio/pgstream/pkg/stream/integration/pg_pg_integration_test.go
• github.com/xataio/pgstream/pkg/stream/integration/pg_search_integration_test.go
• github.com/xataio/pgstream/pkg/stream/integration/pg_webhook_integration_test.go
• github.com/xataio/pgstream/pkg/stream/integration/setup_test.go
• github.com/xataio/pgstream/pkg/stream/integration/snapshot_pg_integration_test.go
• github.com/xataio/pgstream/pkg/stream/stream_status_checker_test.go
• github.com/xataio/pgstream/pkg/stream/stream_status_test.go
• github.com/xataio/pgstream/pkg/wal/processor/filter/wal_filter_test.go
• github.com/xataio/pgstream/pkg/wal/processor/injector/helper_test.go
• github.com/xataio/pgstream/pkg/wal/processor/injector/wal_injector_test.go
• github.com/xataio/pgstream/pkg/wal/processor/kafka/wal_kafka_batch_writer_test.go
• github.com/xataio/pgstream/pkg/wal/processor/postgres/helper_test.go
• github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_batch_writer_test.go
• github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_schema_observer_test.go
• github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_wal_adapter_test.go
• github.com/xataio/pgstream/pkg/wal/processor/postgres/postgres_wal_ddl_adapter_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/helper_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/search_adapter_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/search_batch_indexer_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/store/helper_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/store/search_pg_mapper_test.go
• github.com/xataio/pgstream/pkg/wal/processor/search/store/search_store_test.go
• github.com/xataio/pgstream/pkg/wal/processor/wal_processor_test.go
• github.com/xataio/pgstream/pkg/wal/wal_ddl_test.go
• github.com/xataio/pgstream/pkg/wal/wal_schema_diff_test.go