README
¶
go-pgx-cdc
go-pgx-cdc is designed to provide efficient and lightweight Change Data Capture (CDC) for PostgreSQL databases. The architecture leverages PostgreSQL's built-in logical replication capabilities to capture changes in the database and stream these changes to downstream systems, such as Kafka, Elasticsearch etc. The entire system is written in Golang, ensuring low resource consumption and high performance.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector interface {
Start(ctx context.Context)
WaitUntilReady(ctx context.Context) error
Close()
GetConfig() *config.Config
SetMetricCollectors(collectors ...prometheus.Collector)
}
func NewConnector ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.