This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch labeler-impr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 5a499d648 ci: auto-assign issue authors who volunteer to contribute
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 f6c79f17d Merge branch 'master' into labeler-impr
No new revisions were added by this update.
Summary of changes:
.github/workflows/pre-merge.yml | 2 +-
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 +++++++++++++++++
.../connectors/fixtures/influxdb/container.rs | 9 +-
.../connectors/fixtures/influxdb/container_v3.rs | 244 ++
.../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 | 6 +-
.../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 +-
36 files changed, 10568 insertions(+), 2257 deletions(-)
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%)
