Documentation
¶
Index ¶
Constants ¶
View Source
const ( // DefaultConflictDetectorSlots indicates the default slot count of conflict detector. DefaultConflictDetectorSlots uint64 = 16 * 1024 )
Variables ¶
View Source
var GetDBConnImpl pmysql.Factory = pmysql.CreateMySQLDBConn
GetDBConnImpl is the implementation of pmysql.Factory. Exported for testing. Maybe we can use a better way to do this. Because this is not thread-safe. You can use `SetupSuite` and `TearDownSuite` to do this to get a better way.
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.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.