txn

Documentation

Index

• Constants
• Variables
• func NewMySQLSink(ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, ...) (*dmlSink, error)

Constants

const (
	// DefaultConflictDetectorSlots indicates the default slot count of conflict detector.
	DefaultConflictDetectorSlots uint64 = 16 * 1024
)

Variables

var GetDBConnImpl pmysql.IDBConnectionFactory = &pmysql.DBConnectionFactory{}

GetDBConnImpl is the implementation of pmysql.IDBConnectionFactory. Exported for testing.

Functions

func NewMySQLSink

func NewMySQLSink(
	ctx context.Context,
	changefeedID model.ChangeFeedID,
	sinkURI *url.URL,
	replicaConfig *config.ReplicaConfig,
	errCh chan<- error,
	conflictDetectorSlots uint64,
) (*dmlSink, error)

NewMySQLSink creates a mysql dmlSink with given parameters.