mysql

Documentation

Index

• Variables
• type DDLSink
  • func NewDDLSink(ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, ...) (*DDLSink, error)
  • func (m *DDLSink) Close()
  • func (m *DDLSink) WriteCheckpointTs(_ context.Context, _ uint64, _ []*model.TableInfo) error
  • func (m *DDLSink) WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error

Variables

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

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

Types

type DDLSink

type DDLSink struct {
	// contains filtered or unexported fields
}

DDLSink is a sink that writes DDL events to MySQL.

func NewDDLSink

func NewDDLSink(
	ctx context.Context,
	changefeedID model.ChangeFeedID,
	sinkURI *url.URL,
	replicaConfig *config.ReplicaConfig,
) (*DDLSink, error)

NewDDLSink creates a new DDLSink.

func (*DDLSink) Close

func (m *DDLSink) Close()

Close closes the database connection.

func (*DDLSink) WriteCheckpointTs

func (m *DDLSink) WriteCheckpointTs(_ context.Context, _ uint64, _ []*model.TableInfo) error

WriteCheckpointTs does nothing.

func (*DDLSink) WriteDDLEvent

func (m *DDLSink) WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error

WriteDDLEvent writes a DDL event to the mysql database.