This is an automated email from the ASF dual-hosted git repository.
maciej pushed a change to branch update-pr-template
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7ce299bc7 docs(repo): add pre-commit hooks checklist to PR template
add e84daf4e0 perf(ci): optimize hot dependencies in dev profile (#2645)
add d850ab6ff test(connectors): add integration tests for Quickwit sink
(#2636)
add 69d7ed936 ci: add stale PR workflow (#2641)
add 667e69ea4 feat(server,sdk): allow arbitrary (non-string) header key
kind (#2637)
add 8502c9255 Merge branch 'master' into update-pr-template
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 27 +-
.github/workflows/_common.yml | 20 -
.github/workflows/_detect.yml | 2 -
.github/workflows/_test.yml | 2 -
.github/workflows/_test_bdd.yml | 2 -
.github/workflows/_test_examples.yml | 2 -
.github/workflows/pre-merge.yml | 3 -
.github/workflows/stale-prs.yml | 56 +
Cargo.lock | 40 +-
Cargo.toml | 24 +-
DEPENDENCIES.md | 36 +-
bdd/go/tests/tcp_test/messages_steps.go | 8 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
.../src/cli/binary_message/poll_messages.rs | 8 +-
core/cli/Cargo.toml | 2 +-
core/cli/src/args/message.rs | 83 +-
core/common/Cargo.toml | 2 +-
core/common/src/commands/messages/send_messages.rs | 25 +-
core/common/src/types/message/iggy_message.rs | 73 +-
core/common/src/types/message/mod.rs | 5 +-
core/common/src/types/message/user_headers.rs | 2043 ++++++++++++--------
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/integration/Cargo.toml | 4 +
.../tests/cli/message/test_message_poll_command.rs | 9 +-
.../tests/cli/message/test_message_send_command.rs | 18 +-
core/integration/tests/connectors/mod.rs | 1 +
.../{postgres/sink.toml => quickwit/config.toml} | 2 +-
core/integration/tests/connectors/quickwit/mod.rs | 285 +++
.../tests/connectors/quickwit/quickwit_sink.rs | 153 ++
.../tests/connectors/quickwit/sinks/quickwit.toml} | 25 +-
.../server/scenarios/create_message_payload.rs | 21 +-
.../tests/server/scenarios/encryption_scenario.rs | 54 +-
.../server/scenarios/message_headers_scenario.rs | 21 +-
.../server/scenarios/message_size_scenario.rs | 26 +-
.../tests/server/scenarios/offset_scenario.rs | 15 +-
.../tests/server/scenarios/timestamp_scenario.rs | 15 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/prelude.rs | 12 +-
core/server/Cargo.toml | 2 +-
core/server/server.http | 26 +-
core/tools/src/data-seeder/seeder.rs | 10 +-
.../Utils.cs | 2 +-
.../Utils.cs | 2 +-
.../consumer/MessageHeadersConsumer.java | 9 +-
.../producer/MessageHeadersProducer.java | 7 +-
examples/rust/Cargo.toml | 10 +-
examples/rust/README.md | 9 +-
.../message-headers/message-type/consumer/main.rs | 2 +-
.../message-headers/message-type/producer/main.rs | 5 +-
.../typed-headers}/consumer/main.rs | 23 +-
.../producer/main.rs | 50 +-
examples/rust/src/shared/codec.rs | 4 +-
.../FetchMessagesTests.cs | 4 +-
.../Fixtures/FetchMessagesFixture.cs | 4 +-
.../SendMessagesTests.cs | 8 +-
.../csharp/Iggy_SDK/Contracts/MessageResponse.cs | 4 +
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 31 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 73 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs | 24 +-
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 4 +
.../Implementations/HttpMessageStream.cs | 5 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../Iggy_SDK/JsonConverters/HeaderKeyConverter.cs | 46 -
.../Iggy_SDK/JsonConverters/MessageConverter.cs | 25 +-
.../JsonConverters/UserHeadersConverter.cs | 257 +++
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 23 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 2 +-
.../send_messages_request_serializer_test.go | 10 +-
foreign/go/contracts/messages.go | 2 +-
foreign/go/contracts/user_headers.go | 106 +-
foreign/java/gradle.properties | 2 +-
.../client/blocking/http/ObjectMapperFactory.java | 4 +-
.../message/{HeaderValue.java => HeaderEntry.java} | 6 +-
.../java/org/apache/iggy/message/HeaderKey.java} | 45 +-
.../java/org/apache/iggy/message/HeaderKind.java | 16 +
.../java/org/apache/iggy/message/HeaderValue.java | 225 ++-
.../main/java/org/apache/iggy/message/Message.java | 50 +-
.../java/org/apache/iggy/message/Partitioning.java | 7 +-
.../org/apache/iggy/serde/Base64Serializer.java} | 16 +-
.../org/apache/iggy/serde/BytesDeserializer.java | 24 +-
.../org/apache/iggy/serde/BytesSerializer.java | 20 +-
.../apache/iggy/serde/UserHeadersSerializer.java | 44 +
.../client/blocking/tcp/BytesSerializerTest.java | 21 +-
.../apache/iggy/serde/BytesDeserializerTest.java | 85 +-
foreign/node/package.json | 2 +-
foreign/node/src/bdd/message.ts | 64 +-
foreign/node/src/examples/stream-file-to-topic.ts | 85 +-
foreign/node/src/index.ts | 8 +-
foreign/node/src/tcp.sm.utils.ts | 90 +-
foreign/node/src/wire/message/header.type.ts | 137 +-
foreign/node/src/wire/message/header.utils.test.ts | 62 +-
foreign/node/src/wire/message/header.utils.ts | 402 ++--
foreign/node/src/wire/message/index.ts | 11 +-
foreign/node/src/wire/message/poll.utils.ts | 146 +-
.../src/wire/message/send-messages.command.test.ts | 187 +-
foreign/python/Cargo.toml | 4 +-
scripts/check-backwards-compat.sh | 4 +-
.../lib/components/Modals/InspectMessage.svelte | 132 +-
.../RouteComponents/Settings/UsersTab.svelte | 8 +-
web/src/lib/domain/Message.ts | 7 +-
web/src/lib/domain/User.ts | 2 +-
.../routes/dashboard/settings/users/+page.svelte | 10 +-
113 files changed, 4022 insertions(+), 1847 deletions(-)
create mode 100644 .github/workflows/stale-prs.yml
copy core/integration/tests/connectors/{postgres/sink.toml =>
quickwit/config.toml} (94%)
create mode 100644 core/integration/tests/connectors/quickwit/mod.rs
create mode 100644 core/integration/tests/connectors/quickwit/quickwit_sink.rs
copy core/{connectors/runtime/example_config/connectors/stdout.toml =>
integration/tests/connectors/quickwit/sinks/quickwit.toml} (72%)
copy examples/rust/src/{basic =>
message-headers/typed-headers}/consumer/main.rs (75%)
copy examples/rust/src/message-headers/{message-type =>
typed-headers}/producer/main.rs (71%)
delete mode 100644 foreign/csharp/Iggy_SDK/JsonConverters/HeaderKeyConverter.cs
create mode 100644
foreign/csharp/Iggy_SDK/JsonConverters/UserHeadersConverter.cs
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/message/{HeaderValue.java
=> HeaderEntry.java} (81%)
copy
foreign/java/{external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/WordCount.java
=> java-sdk/src/main/java/org/apache/iggy/message/HeaderKey.java} (55%)
copy
foreign/java/java-sdk/src/{test/java/org/apache/iggy/client/blocking/tcp/PartitionsTcpClientTest.java
=> main/java/org/apache/iggy/serde/Base64Serializer.java} (63%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/serde/UserHeadersSerializer.java
