This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch persisted_mode_perf
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 2aaef4c54 improvements
add cfd3dff6a feat(cpp): add stream, topic, and partition functions to
high level client (#4022)
add ac5c7bf3a feat(connectors): add the HTTP source webhook gateway
connector (#3798)
add 309662d33 fix(ci): run integration tests when a binary they launch
changes (#4131)
add 6138eb9fd chore(deps): Bump the node group across 2 directories with 3
updates (#4125)
add 3b9320072 chore(deps): Bump github.com/klauspost/compress from 1.19.2
to 1.20.0 in /bdd/go in the go group across 1 directory (#4147)
add 2019e145d chore(deps): Bump the web group across 1 directory with 7
updates (#4124)
add dc54783f2 fix(server): resolve non-Linux clippy errors in shard
binding (#4144)
add 2b2e61253 fix(connectors): draw the retry delay inside the cap instead
of clamping (#4129)
add a4f38467b chore(deps): Bump the python group across 3 directories with
1 update (#4110)
add 4b9d368e3 Merge branch 'master' into persisted_mode_perf
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-source/SKILL.md | 36 +-
.claude/skills/connector-testing/SKILL.md | 51 +
.github/actions/rust/pre-merge/action.yml | 15 +
Cargo.lock | 27 +
Cargo.toml | 2 +
.../features/step_definitions/messaging_steps.cpp | 31 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
bdd/python/uv.lock | 38 +-
.../connectors/http_source_github.toml | 60 +
.../connectors/http_source_partner.toml | 55 +
core/connectors/sdk/src/retry.rs | 91 +-
core/connectors/sinks/doris_sink/README.md | 4 +-
core/connectors/sources/README.md | 3 +-
.../{random_source => http_source}/Cargo.toml | 19 +-
core/connectors/sources/http_source/README.md | 382 +++
core/connectors/sources/http_source/config.toml | 68 +
core/connectors/sources/http_source/src/auth.rs | 463 +++
core/connectors/sources/http_source/src/lib.rs | 2536 ++++++++++++++++
.../sources/http_source/src/management.rs | 1535 ++++++++++
core/connectors/sources/http_source/src/metrics.rs | 497 ++++
core/connectors/sources/http_source/src/routes.rs | 666 +++++
core/connectors/sources/http_source/src/server.rs | 3128 ++++++++++++++++++++
core/connectors/sources/http_source/src/state.rs | 1437 +++++++++
core/connectors/sources/http_source/src/types.rs | 275 ++
core/integration/Cargo.toml | 1 +
.../tests/connectors/fixtures/http/mod.rs | 5 +
.../tests/connectors/fixtures/http/source.rs | 125 +
core/integration/tests/connectors/fixtures/mod.rs | 6 +-
.../tests/connectors/http/http_source.rs | 580 ++++
core/integration/tests/connectors/http/mod.rs | 3 +
.../tests/connectors/{random => http}/source.toml | 2 +-
.../http/source_config/http_github.toml} | 41 +-
.../http/source_config/http_partner.toml} | 37 +-
core/server/src/shard_allocator.rs | 16 +
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/package-lock.json | 10 +-
examples/node/package.json | 2 +-
examples/python/pyproject.toml | 2 +-
examples/python/uv.lock | 40 +-
foreign/cpp/include/iggy.hpp | 1810 +++++++++--
foreign/cpp/src/client.cpp | 192 +-
foreign/cpp/src/client.rs | 157 +-
foreign/cpp/src/lib.rs | 58 +-
foreign/cpp/src/type_conversion.rs | 175 +-
foreign/cpp/src/type_conversions.cpp | 118 +
foreign/cpp/tests/e2e/client.cpp | 86 +-
foreign/cpp/tests/e2e/consumer_group.cpp | 162 +-
foreign/cpp/tests/e2e/message.cpp | 156 +-
foreign/cpp/tests/e2e/partition.cpp | 438 ++-
foreign/cpp/tests/e2e/stream.cpp | 1039 +++----
foreign/cpp/tests/e2e/test_helpers.hpp | 34 +-
foreign/cpp/tests/e2e/topic.cpp | 1795 ++++++-----
foreign/cpp/tests/unit/unit_tests.cpp | 358 ++-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/node/package-lock.json | 142 +-
foreign/node/package.json | 2 +-
foreign/python/uv.lock | 38 +-
web/package-lock.json | 187 +-
web/package.json | 14 +-
62 files changed, 16468 insertions(+), 2800 deletions(-)
create mode 100644
core/connectors/runtime/example_config/connectors/http_source_github.toml
create mode 100644
core/connectors/runtime/example_config/connectors/http_source_partner.toml
copy core/connectors/sources/{random_source => http_source}/Cargo.toml (80%)
create mode 100644 core/connectors/sources/http_source/README.md
create mode 100644 core/connectors/sources/http_source/config.toml
create mode 100644 core/connectors/sources/http_source/src/auth.rs
create mode 100644 core/connectors/sources/http_source/src/lib.rs
create mode 100644 core/connectors/sources/http_source/src/management.rs
create mode 100644 core/connectors/sources/http_source/src/metrics.rs
create mode 100644 core/connectors/sources/http_source/src/routes.rs
create mode 100644 core/connectors/sources/http_source/src/server.rs
create mode 100644 core/connectors/sources/http_source/src/state.rs
create mode 100644 core/connectors/sources/http_source/src/types.rs
create mode 100644 core/integration/tests/connectors/fixtures/http/source.rs
create mode 100644 core/integration/tests/connectors/http/http_source.rs
copy core/integration/tests/connectors/{random => http}/source.toml (94%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/http/source_config/http_github.toml} (53%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/http/source_config/http_partner.toml} (59%)
create mode 100644 foreign/cpp/src/type_conversions.cpp
