dataexport

Documentation

Index

• Constants
• func NewCRDBSource(ctx context.Context, settings Settings, conn *dbconn.PGConn) (*crdbSource, error)
• func NewMySQLSource(ctx context.Context, settings Settings, conn *dbconn.MySQLConn) (*mysqlSource, error)
• func NewPGSource(ctx context.Context, settings Settings, conn *dbconn.PGConn) (*pgSource, error)
• type PGReplicationSlotSettings
• type Settings
• type Source
  • func InferExportSource(ctx context.Context, settings Settings, conn dbconn.Conn) (Source, error)
• type SourceConn

Constants

const GTIDHelpInstructions = `please ensure that you have GTID-based replication enabled`

Functions

func NewCRDBSource

func NewCRDBSource(
	ctx context.Context, settings Settings, conn *dbconn.PGConn,
) (*crdbSource, error)

func NewMySQLSource

func NewMySQLSource(
	ctx context.Context, settings Settings, conn *dbconn.MySQLConn,
) (*mysqlSource, error)

func NewPGSource

func NewPGSource(ctx context.Context, settings Settings, conn *dbconn.PGConn) (*pgSource, error)

Types

type PGReplicationSlotSettings

type PGReplicationSlotSettings struct {
	SlotName     string
	Plugin       string
	DropIfExists bool
}

type Settings

type Settings struct {
	RowBatchSize int

	PG PGReplicationSlotSettings
}

type Source

type Source interface {
	CDCCursor() string
	Conn(ctx context.Context) (SourceConn, error)
	Close(ctx context.Context) error
}

func InferExportSource

func InferExportSource(ctx context.Context, settings Settings, conn dbconn.Conn) (Source, error)

type SourceConn

type SourceConn interface {
	Export(ctx context.Context, writer io.Writer, table dbtable.VerifiedTable, shard rowverify.TableShard) error
	Close(ctx context.Context) error
}