This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch connectors_api
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d6789537 add initial version of connectors http api
add 7bfcb8a6 chore(sdk): Java SDK - publish artifacts to apache maven repo
(#1869)
add 91de567c fix(go): fix go library tests to be runnable and pass (#1870)
add d733c1e9 feat(js): add bdd test support for node sdk via cucumber-js
(#1862)
add 9cad36ab feat(connectors): Extend JSON field transformations in
connectors run… (#1863)
add 62b5ca28 update latest changes
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-check-pr.yml | 4 +-
Cargo.lock | 1 +
bdd/basic_messaging.feature | 8 +-
core/connectors/runtime/src/transform.rs | 2 +-
core/connectors/sdk/Cargo.toml | 1 +
core/connectors/sdk/src/transforms/add_fields.rs | 101 +-
.../connectors/sdk/src/transforms/delete_fields.rs | 37 +-
.../connectors/sdk/src/transforms/filter_fields.rs | 258 +++++
.../sdk/src/transforms/json/add_fields.rs | 187 ++++
.../sdk/src/transforms/json/delete_fields.rs | 149 +++
.../sdk/src/transforms/json/filter_fields.rs | 290 ++++++
core/connectors/sdk/src/transforms/json/mod.rs | 45 +
.../sdk/src/transforms/json/test_utils.rs | 93 ++
.../sdk/src/transforms/json/update_fields.rs | 224 ++++
core/connectors/sdk/src/transforms/mod.rs | 97 +-
.../connectors/sdk/src/transforms/update_fields.rs | 78 ++
.../fetch_messages_request_serializer_test.go | 24 +-
.../binary_serialization/stats_serializer_test.go | 1 +
.../update_topic_serializer_test.go | 11 +-
foreign/java/java-sdk/build.gradle.kts | 44 +-
foreign/node/cucumber.json | 13 +
foreign/node/package-lock.json | 1073 +++++++++++++++++++-
foreign/node/package.json | 2 +
.../partition.utils.test.ts => bdd/auth.ts} | 36 +-
foreign/node/src/bdd/message.ts | 113 +++
foreign/node/src/bdd/stream.ts | 55 +
foreign/node/src/bdd/topic.ts | 59 ++
.../{wire/system/ping.command.ts => bdd/world.ts} | 23 +-
foreign/node/src/tcp.sm.utils.ts | 4 +-
foreign/node/src/wire/message/index.ts | 3 +-
foreign/node/src/wire/message/message.utils.ts | 33 +-
foreign/node/src/wire/message/poll.utils.ts | 7 +-
.../src/wire/message/send-messages.command.test.ts | 23 +-
33 files changed, 2869 insertions(+), 230 deletions(-)
create mode 100644 core/connectors/sdk/src/transforms/filter_fields.rs
create mode 100644 core/connectors/sdk/src/transforms/json/add_fields.rs
create mode 100644 core/connectors/sdk/src/transforms/json/delete_fields.rs
create mode 100644 core/connectors/sdk/src/transforms/json/filter_fields.rs
create mode 100644 core/connectors/sdk/src/transforms/json/mod.rs
create mode 100644 core/connectors/sdk/src/transforms/json/test_utils.rs
create mode 100644 core/connectors/sdk/src/transforms/json/update_fields.rs
create mode 100644 core/connectors/sdk/src/transforms/update_fields.rs
create mode 100644 foreign/node/cucumber.json
copy foreign/node/src/{wire/partition/partition.utils.test.ts => bdd/auth.ts}
(58%)
create mode 100644 foreign/node/src/bdd/message.ts
create mode 100644 foreign/node/src/bdd/stream.ts
create mode 100644 foreign/node/src/bdd/topic.ts
copy foreign/node/src/{wire/system/ping.command.ts => bdd/world.ts} (68%)
