Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

sink(ticdc): Add Support for Multiple MySQL-Compatible Downstream Addresses in TiCDC for High Availability #11527

Open
wants to merge 52 commits into
base: master
Choose a base branch
from

refactor(DDL Sink): remove leftover TODO tag

d804633
Select commit
Loading
Failed to load commit list.
Open

sink(ticdc): Add Support for Multiple MySQL-Compatible Downstream Addresses in TiCDC for High Availability #11527

refactor(DDL Sink): remove leftover TODO tag
d804633
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Sep 6, 2024 in 1s

66.0231% of diff hit (target 0.0000%)

View this Pull Request on Codecov

66.0231% of diff hit (target 0.0000%)

Annotations

Check warning on line 156 in cdc/sink/ddlsink/mysql/mysql_ddl_sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/ddlsink/mysql/mysql_ddl_sink.go#L154-L156

Added lines #L154 - L156 were not covered by tests

Check warning on line 228 in cdc/sink/ddlsink/mysql/mysql_ddl_sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/ddlsink/mysql/mysql_ddl_sink.go#L228

Added line #L228 was not covered by tests

Check warning on line 137 in cdc/sink/dmlsink/txn/mysql/mysql.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/dmlsink/txn/mysql/mysql.go#L137

Added line #L137 was not covered by tests

Check warning on line 673 in cdc/sink/dmlsink/txn/mysql/mysql.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/dmlsink/txn/mysql/mysql.go#L673

Added line #L673 was not covered by tests

Check warning on line 125 in cdc/sink/validator/validator.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/validator/validator.go#L125

Added line #L125 was not covered by tests

Check warning on line 129 in cdc/sink/validator/validator.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/validator/validator.go#L129

Added line #L129 was not covered by tests

Check warning on line 116 in pkg/retry/options.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/retry/options.go#L112-L116

Added lines #L112 - L116 were not covered by tests

Check warning on line 64 in pkg/retry/retry_with_opt.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/retry/retry_with_opt.go#L61-L64

Added lines #L61 - L64 were not covered by tests

Check warning on line 48 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L48

Added line #L48 was not covered by tests

Check warning on line 81 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L80-L81

Added lines #L80 - L81 were not covered by tests

Check warning on line 116 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L115-L116

Added lines #L115 - L116 were not covered by tests

Check warning on line 174 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L173-L174

Added lines #L173 - L174 were not covered by tests

Check warning on line 179 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L176-L179

Added lines #L176 - L179 were not covered by tests

Check warning on line 270 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L269-L270

Added lines #L269 - L270 were not covered by tests

Check warning on line 279 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L278-L279

Added lines #L278 - L279 were not covered by tests

Check warning on line 297 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L295-L297

Added lines #L295 - L297 were not covered by tests

Check warning on line 372 in pkg/sink/mysql/db_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/db_helper.go#L372

Added line #L372 was not covered by tests

Check warning on line 56 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L55-L56

Added lines #L55 - L56 were not covered by tests

Check warning on line 67 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L66-L67

Added lines #L66 - L67 were not covered by tests

Check warning on line 85 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L84-L85

Added lines #L84 - L85 were not covered by tests

Check warning on line 100 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L97-L100

Added lines #L97 - L100 were not covered by tests

Check warning on line 116 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L115-L116

Added lines #L115 - L116 were not covered by tests

Check warning on line 122 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L122

Added line #L122 was not covered by tests

Check warning on line 142 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L138-L142

Added lines #L138 - L142 were not covered by tests

Check warning on line 146 in pkg/sink/mysql/mysql_connector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/sink/mysql/mysql_connector.go#L145-L146

Added lines #L145 - L146 were not covered by tests