cdc

Documentation

Index

• type Connector
  • func NewConnector(ctx context.Context, cfg config.Config, listenerFunc replication.ListenerFunc) (Connector, error)

Types

type Connector

type Connector interface {
	Start(ctx context.Context)
	WaitUntilReady(ctx context.Context) error
	Close()
	GetConfig() *config.Config

	// Dynamic table management
	AddTable(ctx context.Context, table publication.Table) error
	RemoveTable(ctx context.Context, schema, tableName string) error
	UpdateTableReplicaIdentity(ctx context.Context, table publication.Table) error
	ListTables(ctx context.Context) (publication.Tables, error)
}

func NewConnector

func NewConnector(ctx context.Context, cfg config.Config, listenerFunc replication.ListenerFunc) (Connector, error)