pkg/config, sink(ticdc): support output raw change event for mq and cloud storage sink #11226
60.9022% of diff hit (target 0.0000%)
View this Pull Request on Codecov
60.9022% of diff hit (target 0.0000%)
Annotations
Check warning on line 320 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L320
Added line #L320 was not covered by tests
Check warning on line 406 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L406
Added line #L406 was not covered by tests
Check warning on line 439 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L432-L439
Added lines #L432 - L439 were not covered by tests
Check warning on line 672 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L672
Added line #L672 was not covered by tests
Check warning on line 715 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L715
Added line #L715 was not covered by tests
Check warning on line 737 in cdc/api/v2/model.go
codecov / codecov/patch
cdc/api/v2/model.go#L730-L737
Added lines #L730 - L737 were not covered by tests
Check warning on line 275 in cdc/model/sink.go
codecov / codecov/patch
cdc/model/sink.go#L275
Added line #L275 was not covered by tests
Check warning on line 447 in cdc/model/sink.go
codecov / codecov/patch
cdc/model/sink.go#L447
Added line #L447 was not covered by tests
Check warning on line 302 in cdc/sink/dmlsink/cloudstorage/cloud_storage_dml_sink.go
codecov / codecov/patch
cdc/sink/dmlsink/cloudstorage/cloud_storage_dml_sink.go#L301-L302
Added lines #L301 - L302 were not covered by tests
Check warning on line 243 in cdc/sink/dmlsink/mq/mq_dml_sink.go
codecov / codecov/patch
cdc/sink/dmlsink/mq/mq_dml_sink.go#L242-L243
Added lines #L242 - L243 were not covered by tests
Check warning on line 127 in cdc/sink/dmlsink/mq/pulsar_dml_sink.go
codecov / codecov/patch
cdc/sink/dmlsink/mq/pulsar_dml_sink.go#L126-L127
Added lines #L126 - L127 were not covered by tests
Check warning on line 184 in cdc/sink/dmlsink/txn/txn_dml_sink.go
codecov / codecov/patch
cdc/sink/dmlsink/txn/txn_dml_sink.go#L183-L184
Added lines #L183 - L184 were not covered by tests
Check warning on line 446 in pkg/config/sink.go
codecov / codecov/patch
pkg/config/sink.go#L446
Added line #L446 was not covered by tests
Check warning on line 616 in pkg/config/sink.go
codecov / codecov/patch
pkg/config/sink.go#L616
Added line #L616 was not covered by tests
Check warning on line 687 in pkg/config/sink.go
codecov / codecov/patch
pkg/config/sink.go#L687
Added line #L687 was not covered by tests
Check warning on line 862 in pkg/config/sink.go
codecov / codecov/patch
pkg/config/sink.go#L857-L862
Added lines #L857 - L862 were not covered by tests
Check warning on line 888 in pkg/config/sink.go
codecov / codecov/patch
pkg/config/sink.go#L884-L888
Added lines #L884 - L888 were not covered by tests
Check warning on line 181 in pkg/sink/codec/csv/csv_message.go
codecov / codecov/patch
pkg/sink/codec/csv/csv_message.go#L178-L181
Added lines #L178 - L181 were not covered by tests