This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch integration_tests_basics
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 135d5e9d7 fix failing ws tests
add c9def83a0 feat(connectors): Implement influxdb v2 and v3 connector
with separate source and sink crates (#3140)
add b2093e1a0 ci: run finalize_pr on arm runner (#3402)
add 2a7192ee5 ci: auto-assign issue authors who volunteer to contribute
(#3400)
add a8dd3a9c9 test(connectors): share one Elasticsearch container across
tests (#3401)
add af662b367 Merge branch 'master' into integration_tests_basics
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-testing/SKILL.md | 17 +
.config/nextest.toml | 15 +-
...ssue-labeler.yml => issue-labeler-assigner.yml} | 62 +-
.github/workflows/pr-triage-apply.yml | 1 +
.github/workflows/pre-merge.yml | 2 +-
CONTRIBUTING.md | 4 -
Cargo.lock | 47 +-
Cargo.toml | 2 +-
core/connectors/sinks/README.md | 1 +
core/connectors/sinks/influxdb_sink/Cargo.toml | 12 +-
core/connectors/sinks/influxdb_sink/README.md | 124 +
core/connectors/sinks/influxdb_sink/config.toml | 1 +
.../connectors/sinks/influxdb_sink/dependencies.md | 64 +
core/connectors/sinks/influxdb_sink/src/lib.rs | 2712 ++++++++++++-------
.../connectors/sinks/influxdb_sink/src/protocol.rs | 264 ++
core/connectors/sources/README.md | 1 +
core/connectors/sources/influxdb_source/Cargo.toml | 16 +-
core/connectors/sources/influxdb_source/README.md | 190 ++
.../connectors/sources/influxdb_source/config.toml | 1 +
.../sources/influxdb_source/dependencies.md | 70 +
.../sources/influxdb_source/src/common.rs | 1247 +++++++++
core/connectors/sources/influxdb_source/src/lib.rs | 2848 ++++++++++++--------
core/connectors/sources/influxdb_source/src/row.rs | 444 +++
core/connectors/sources/influxdb_source/src/v2.rs | 1473 ++++++++++
core/connectors/sources/influxdb_source/src/v3.rs | 2424 +++++++++++++++++
.../tests/connectors/fixtures/delta/fixture.rs | 5 +-
.../tests/connectors/fixtures/doris/container.rs | 10 +-
.../connectors/fixtures/elasticsearch/container.rs | 20 +-
.../connectors/fixtures/elasticsearch/sink.rs | 20 +-
.../connectors/fixtures/elasticsearch/source.rs | 20 +-
.../tests/connectors/fixtures/http/container.rs | 4 +-
.../tests/connectors/fixtures/iceberg/container.rs | 8 +-
.../connectors/fixtures/influxdb/container.rs | 13 +-
.../connectors/fixtures/influxdb/container_v3.rs | 246 ++
.../tests/connectors/fixtures/influxdb/mod.rs | 5 +
.../tests/connectors/fixtures/influxdb/sink.rs | 6 +-
.../tests/connectors/fixtures/influxdb/sink_v3.rs | 148 +
.../tests/connectors/fixtures/influxdb/source.rs | 5 +-
.../connectors/fixtures/influxdb/source_v3.rs | 144 +
core/integration/tests/connectors/fixtures/mod.rs | 24 +-
.../tests/connectors/fixtures/mongodb/container.rs | 5 +-
.../connectors/fixtures/postgres/container.rs | 14 +-
.../connectors/fixtures/quickwit/container.rs | 10 +-
.../tests/connectors/fixtures/wiremock.rs | 4 +-
.../tests/connectors/influxdb/docker-compose.yml | 28 +
.../{influxdb_sink.rs => influxdb_sink_v3.rs} | 83 +-
.../{influxdb_source.rs => influxdb_source_v3.rs} | 91 +-
core/integration/tests/connectors/influxdb/mod.rs | 2 +
.../{sink_no_metadata.toml => sink_v3.toml} | 18 +-
.../sink_v3_config/config.toml} | 40 +-
.../{api/config.toml => influxdb/source_v3.toml} | 15 +-
.../influxdb/source_v3_config}/config.toml | 38 +-
justfile | 24 +
53 files changed, 10774 insertions(+), 2318 deletions(-)
rename .github/workflows/{issue-labeler.yml => issue-labeler-assigner.yml}
(56%)
create mode 100644 core/connectors/sinks/influxdb_sink/README.md
create mode 100644 core/connectors/sinks/influxdb_sink/dependencies.md
create mode 100644 core/connectors/sinks/influxdb_sink/src/protocol.rs
create mode 100644 core/connectors/sources/influxdb_source/README.md
create mode 100644 core/connectors/sources/influxdb_source/dependencies.md
create mode 100644 core/connectors/sources/influxdb_source/src/common.rs
create mode 100644 core/connectors/sources/influxdb_source/src/row.rs
create mode 100644 core/connectors/sources/influxdb_source/src/v2.rs
create mode 100644 core/connectors/sources/influxdb_source/src/v3.rs
create mode 100644
core/integration/tests/connectors/fixtures/influxdb/container_v3.rs
create mode 100644
core/integration/tests/connectors/fixtures/influxdb/sink_v3.rs
create mode 100644
core/integration/tests/connectors/fixtures/influxdb/source_v3.rs
copy core/integration/tests/connectors/influxdb/{influxdb_sink.rs =>
influxdb_sink_v3.rs} (72%)
copy core/integration/tests/connectors/influxdb/{influxdb_source.rs =>
influxdb_source_v3.rs} (71%)
copy core/integration/tests/connectors/influxdb/{sink_no_metadata.toml =>
sink_v3.toml} (66%)
copy core/integration/tests/connectors/{influxdb_sink.toml =>
influxdb/sink_v3_config/config.toml} (65%)
copy core/integration/tests/connectors/{api/config.toml =>
influxdb/source_v3.toml} (76%)
copy core/{connectors/sources/influxdb_source =>
integration/tests/connectors/influxdb/source_v3_config}/config.toml (62%)
