This is an automated email from the ASF dual-hosted git repository.
mmodzelewski pushed a change to branch connectors-runtime
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 4de954de3 refactor(connectors): isolate per-connector init failures in
runtime
add 800f580d9 add tests
No new revisions were added by this update.
Summary of changes:
core/connectors/runtime/src/main.rs | 22 ++
core/connectors/runtime/src/sink.rs | 38 +--
core/connectors/runtime/src/source.rs | 48 +--
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/runtime/error_isolation.rs | 324 +++++++++++++++++++++
.../tests/connectors/{delta => runtime}/mod.rs | 2 +-
.../sink_invalid_config.toml} | 2 +-
.../sink_invalid_config}/stdout_invalid.toml | 0
.../sink_invalid_config}/stdout_valid.toml | 0
.../sink_missing_plugin.toml} | 2 +-
.../stdout_missing.toml} | 15 +-
.../sink_missing_plugin_config}/stdout_valid.toml | 2 +-
.../source_invalid_config.toml} | 2 +-
.../source_invalid_config/random_invalid.toml} | 20 +-
.../source_invalid_config/random_valid.toml} | 16 +-
.../source_invalid_state.toml} | 2 +-
.../random_invalid_state.toml} | 21 +-
.../source_invalid_state_config/random_valid.toml} | 16 +-
.../source_missing_plugin.toml} | 2 +-
.../random_missing.toml} | 18 +-
.../random_valid.toml} | 16 +-
.../tests/connectors/stdout/invalid_sink.toml | 20 --
.../tests/connectors/stdout/stdout_sink.rs | 68 +----
23 files changed, 449 insertions(+), 208 deletions(-)
create mode 100644 core/integration/tests/connectors/runtime/error_isolation.rs
copy core/integration/tests/connectors/{delta => runtime}/mod.rs (97%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/sink_invalid_config.toml} (93%)
rename core/integration/tests/connectors/{stdout/invalid_sink_config =>
runtime/sink_invalid_config}/stdout_invalid.toml (100%)
copy core/integration/tests/connectors/{stdout/invalid_sink_config =>
runtime/sink_invalid_config}/stdout_valid.toml (100%)
copy core/integration/tests/connectors/{iceberg/sink_default_credentials.toml
=> runtime/sink_missing_plugin.toml} (92%)
copy
core/integration/tests/connectors/{stdout/invalid_sink_config/stdout_valid.toml
=> runtime/sink_missing_plugin_config/stdout_missing.toml} (68%)
rename core/integration/tests/connectors/{stdout/invalid_sink_config =>
runtime/sink_missing_plugin_config}/stdout_valid.toml (97%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_invalid_config.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_config/random_invalid.toml}
(71%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_config/random_valid.toml}
(80%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_invalid_state.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_state_config/random_invalid_state.toml}
(63%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_invalid_state_config/random_valid.toml}
(81%)
copy core/integration/tests/connectors/{elasticsearch/source.toml =>
runtime/source_missing_plugin.toml} (92%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_missing_plugin_config/random_missing.toml}
(72%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/runtime/source_missing_plugin_config/random_valid.toml}
(80%)
delete mode 100644 core/integration/tests/connectors/stdout/invalid_sink.toml
