cdc

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

• type Connector
  • func NewConnector(ctx context.Context, cfg config.Config, listeners replication.Listeners) (Connector, error)
  • func NewConnectorWithConfigFile(ctx context.Context, configFilePath string, listeners replication.Listeners) (Connector, error)

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

func NewConnector(ctx context.Context, cfg config.Config, listeners replication.Listeners) (Connector, error)

func NewConnectorWithConfigFile

func NewConnectorWithConfigFile(ctx context.Context, configFilePath string, listeners replication.Listeners) (Connector, error)