This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch partitions_refactor
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 9e65721d2 rename types
add fc5d9005c feat(csharp): add TCP/TLS producer and consumer examples
(#2821)
add 5d3b7934f fix(js): use localhost instead of disabling hostname
verification in … (#2913)
add c15100698 feat(java): add TCP/TLS integration tests and examples
(#2823)
add 261d25557 feat(bdd): support -race option for Go BDD tests (#2914)
add c90b5f8bf feat(java): Add unit tests for message package in Java SDK
(#2918)
add 3f651e03c refactor(java): replace JUnit assertions with AssertJ across
all tests (#2929)
add 51e359f4e feat(go): add TLS integration tests and examples (#2898)
add 428926160 chore(deps): bump black from 24.10.0 to 26.3.1 in
/foreign/python (#2926)
add 909fa5243 chore(deps): bump github.com/containerd/containerd from
1.7.18 to 1.7.29 in /foreign/go (#2935)
add ff4716e91 chore(deps): bump golang.org/x/crypto from 0.42.0 to 0.45.0
in /foreign/go (#2934)
add 6a6f15533 refactor(csharp): implement SDK version handling in login
requests (#2937)
add 658eb8910 ci: unify run-*-examples-from-readme.sh into single
entrypoint with TLS support (#2920)
add a3328c8a2 feat(java): Increase test coverage (#2939)
add edf7adaf3 refactor(rust): empty binary_protocol crate by relocating
its contents (#2942)
add 2ea6d5bd1 feat(cpp): part of low-level bindings, their tests, and e2e
CI config (#2852)
add e5c43adbc Merge branch 'master' into partitions_refactor
No new revisions were added by this update.
Summary of changes:
.github/actions/cpp-bazel/pre-merge/action.yml | 23 +-
.github/actions/go/pre-merge/action.yml | 37 +-
.github/actions/java-gradle/pre-merge/action.yml | 28 +
.../actions/utils/setup-go-with-cache/action.yml | 2 +-
.github/config/components.yml | 22 +-
.github/workflows/_test_bdd.yml | 2 +-
.github/workflows/_test_examples.yml | 46 +-
Cargo.lock | 32 +-
Cargo.toml | 1 +
bdd/docker-compose.yml | 3 +-
bdd/go/Dockerfile | 8 +-
bdd/go/go.mod | 14 +-
bdd/go/go.sum | 28 +-
codecov.yml | 1 +
core/binary_protocol/Cargo.toml | 15 -
.../src/client/binary_clients/mod.rs | 44 -
core/binary_protocol/src/client/mod.rs | 30 -
core/binary_protocol/src/lib.rs | 8 -
core/binary_protocol/src/utils/mod.rs | 20 -
core/cli/Cargo.toml | 14 +-
core/cli/src/args/common.rs | 18 +-
core/cli/src/args/mod.rs | 2 +-
core/cli/src/args/system.rs | 2 +-
.../src/commands}/binary_client/get_client.rs | 4 +-
.../src/commands}/binary_client/get_clients.rs | 4 +-
.../cli => cli/src/commands}/binary_client/mod.rs | 0
.../binary_cluster/get_cluster_metadata.rs | 4 +-
.../cli => cli/src/commands}/binary_cluster/mod.rs | 0
.../create_consumer_group.rs | 4 +-
.../delete_consumer_group.rs | 4 +-
.../binary_consumer_groups/get_consumer_group.rs | 4 +-
.../binary_consumer_groups/get_consumer_groups.rs | 4 +-
.../src/commands}/binary_consumer_groups/mod.rs | 0
.../binary_consumer_offsets/get_consumer_offset.rs | 4 +-
.../src/commands}/binary_consumer_offsets/mod.rs | 0
.../binary_consumer_offsets/set_consumer_offset.rs | 4 +-
.../src/commands}/binary_context/common.rs | 0
.../src/commands}/binary_context/get_contexts.rs | 4 +-
.../cli => cli/src/commands}/binary_context/mod.rs | 0
.../src/commands}/binary_context/use_context.rs | 4 +-
.../src/commands}/binary_message/flush_messages.rs | 4 +-
.../cli => cli/src/commands}/binary_message/mod.rs | 0
.../src/commands}/binary_message/poll_messages.rs | 4 +-
.../src/commands}/binary_message/send_messages.rs | 4 +-
.../binary_partitions/create_partitions.rs | 4 +-
.../binary_partitions/delete_partitions.rs | 4 +-
.../src/commands}/binary_partitions/mod.rs | 0
.../create_personal_access_token.rs | 4 +-
.../delete_personal_access_tokens.rs | 4 +-
.../get_personal_access_tokens.rs | 4 +-
.../commands}/binary_personal_access_tokens/mod.rs | 0
.../commands}/binary_segments/delete_segments.rs | 4 +-
.../src/commands}/binary_segments/mod.rs | 0
.../src/commands}/binary_streams/create_stream.rs | 4 +-
.../src/commands}/binary_streams/delete_stream.rs | 4 +-
.../src/commands}/binary_streams/get_stream.rs | 4 +-
.../src/commands}/binary_streams/get_streams.rs | 4 +-
.../cli => cli/src/commands}/binary_streams/mod.rs | 0
.../src/commands}/binary_streams/purge_stream.rs | 4 +-
.../src/commands}/binary_streams/update_stream.rs | 4 +-
.../src/commands}/binary_system/login.rs | 8 +-
.../src/commands}/binary_system/logout.rs | 6 +-
.../cli => cli/src/commands}/binary_system/me.rs | 4 +-
.../cli => cli/src/commands}/binary_system/mod.rs | 0
.../cli => cli/src/commands}/binary_system/ping.rs | 4 +-
.../src/commands}/binary_system/session.rs | 0
.../src/commands}/binary_system/snapshot.rs | 4 +-
.../src/commands}/binary_system/stats.rs | 4 +-
.../src/commands}/binary_topics/create_topic.rs | 4 +-
.../src/commands}/binary_topics/delete_topic.rs | 4 +-
.../src/commands}/binary_topics/get_topic.rs | 4 +-
.../src/commands}/binary_topics/get_topics.rs | 4 +-
.../cli => cli/src/commands}/binary_topics/mod.rs | 0
.../src/commands}/binary_topics/purge_topic.rs | 4 +-
.../src/commands}/binary_topics/update_topic.rs | 4 +-
.../src/commands}/binary_users/change_password.rs | 4 +-
.../src/commands}/binary_users/create_user.rs | 4 +-
.../src/commands}/binary_users/delete_user.rs | 4 +-
.../src/commands}/binary_users/get_user.rs | 4 +-
.../src/commands}/binary_users/get_users.rs | 4 +-
.../cli => cli/src/commands}/binary_users/mod.rs | 0
.../commands}/binary_users/update_permissions.rs | 4 +-
.../src/commands}/binary_users/update_user.rs | 4 +-
.../src/cli => cli/src/commands}/cli_command.rs | 2 +-
.../src/cli => cli/src/commands}/mod.rs | 0
.../src/commands}/utils/login_session_expiry.rs | 0
.../src/cli => cli/src/commands}/utils/mod.rs | 0
core/cli/src/credentials.rs | 4 +-
{examples/rust => core/cli}/src/lib.rs | 2 +-
core/cli/src/logging.rs | 2 +-
core/cli/src/main.rs | 16 +-
core/common/Cargo.toml | 2 +
core/common/src/lib.rs | 14 +
.../auth.rs => common/src/traits/binary_auth.rs} | 7 +-
.../src/traits}/binary_client.rs | 3 +-
.../src/traits/binary_impls/cluster.rs} | 10 +-
.../src/traits/binary_impls/consumer_groups.rs} | 26 +-
.../src/traits/binary_impls/consumer_offsets.rs} | 17 +-
.../src/traits/binary_impls/messages.rs} | 8 +-
.../src/traits/binary_impls}/mod.rs | 15 +-
.../src/traits/binary_impls/partitions.rs} | 10 +-
.../traits/binary_impls/personal_access_tokens.rs} | 26 +-
.../src/traits/binary_impls/segments.rs} | 7 +-
.../src/traits/binary_impls/streams.rs} | 26 +-
.../src/traits/binary_impls/system.rs} | 30 +-
.../src/traits/binary_impls/topics.rs} | 29 +-
.../src/traits/binary_impls/users.rs} | 38 +-
.../src/traits/binary_mapper.rs} | 4 +-
.../src/traits/binary_transport.rs} | 2 +-
.../binary_clients => common/src/traits}/client.rs | 2 +-
.../src/traits}/cluster_client.rs | 2 +-
.../src/traits}/consumer_group_client.rs | 2 +-
.../src/traits}/consumer_offset_client.rs | 2 +-
.../src/traits}/message_client.rs | 4 +-
core/common/src/traits/mod.rs | 17 +
.../src/traits}/partition_client.rs | 2 +-
.../src/traits}/personal_access_token_client.rs | 4 +-
.../src/traits}/segment_client.rs | 2 +-
.../src/traits}/stream_client.rs | 2 +-
.../src/traits}/system_client.rs | 4 +-
.../src/traits}/topic_client.rs | 4 +-
.../src/traits}/user_client.rs | 4 +-
core/integration/Cargo.toml | 2 +-
core/integration/src/harness/seeds.rs | 6 +-
core/integration/tests/cli/context/common.rs | 2 +-
.../tests/cli/context/test_context_applied.rs | 2 +-
.../tests/cli/context/test_context_list_command.rs | 2 +-
.../tests/cli/context/test_context_use_command.rs | 2 +-
.../integration/tests/cli/system/test_login_cmd.rs | 2 +-
.../tests/cli/system/test_logout_cmd.rs | 2 +-
.../tests/cli/system/test_stats_command.rs | 2 +-
.../connectors/elasticsearch/elasticsearch_sink.rs | 2 +-
.../elasticsearch/elasticsearch_source.rs | 2 +-
.../tests/connectors/iceberg/iceberg_sink.rs | 2 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 2 +-
.../tests/connectors/postgres/postgres_sink.rs | 2 +-
.../tests/connectors/postgres/postgres_source.rs | 2 +-
.../tests/connectors/postgres/restart.rs | 2 +-
.../tests/connectors/quickwit/quickwit_sink.rs | 2 +-
.../tests/connectors/random/random_source.rs | 2 +-
.../tests/connectors/stdout/stdout_sink.rs | 2 +-
core/sdk/Cargo.toml | 1 -
.../src/plotting/text => sdk/src/binary}/mod.rs | 3 +-
core/sdk/src/client_provider.rs | 2 +-
core/sdk/src/client_wrappers/binary_client.rs | 2 +-
.../src/client_wrappers/binary_cluster_client.rs | 2 +-
.../binary_consumer_group_client.rs | 2 +-
.../binary_consumer_offset_client.rs | 2 +-
.../src/client_wrappers/binary_message_client.rs | 2 +-
.../src/client_wrappers/binary_partition_client.rs | 2 +-
.../binary_personal_access_token_client.rs | 2 +-
.../src/client_wrappers/binary_segment_client.rs | 2 +-
.../src/client_wrappers/binary_stream_client.rs | 2 +-
.../src/client_wrappers/binary_system_client.rs | 2 +-
.../sdk/src/client_wrappers/binary_topic_client.rs | 2 +-
core/sdk/src/client_wrappers/binary_user_client.rs | 2 +-
core/sdk/src/clients/binary_cluster.rs | 2 +-
core/sdk/src/clients/binary_consumer_group.rs | 2 +-
core/sdk/src/clients/binary_consumer_offset.rs | 2 +-
core/sdk/src/clients/binary_message.rs | 2 +-
core/sdk/src/clients/binary_partitions.rs | 2 +-
.../src/clients/binary_personal_access_tokens.rs | 2 +-
core/sdk/src/clients/binary_segments.rs | 2 +-
core/sdk/src/clients/binary_streams.rs | 2 +-
core/sdk/src/clients/binary_system.rs | 2 +-
core/sdk/src/clients/binary_topics.rs | 2 +-
core/sdk/src/clients/binary_users.rs | 2 +-
core/sdk/src/clients/client.rs | 2 +-
core/sdk/src/clients/consumer.rs | 4 +-
core/sdk/src/clients/producer.rs | 2 +-
core/sdk/src/http/cluster.rs | 2 +-
core/sdk/src/http/consumer_groups.rs | 2 +-
core/sdk/src/http/consumer_offsets.rs | 2 +-
core/sdk/src/http/messages.rs | 2 +-
core/sdk/src/http/partitions.rs | 2 +-
core/sdk/src/http/personal_access_tokens.rs | 2 +-
core/sdk/src/http/segments.rs | 2 +-
core/sdk/src/http/streams.rs | 2 +-
core/sdk/src/http/system.rs | 2 +-
core/sdk/src/http/topics.rs | 2 +-
core/sdk/src/http/users.rs | 2 +-
core/sdk/src/leader_aware.rs | 2 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/prelude.rs | 10 +-
core/sdk/src/quic/quic_client.rs | 4 +-
.../src/stream_builder/build/build_iggy_client.rs | 2 +-
core/sdk/src/tcp/tcp_client.rs | 2 +-
core/sdk/src/websocket/websocket_client.rs | 2 +-
examples/csharp/Iggy_SDK.Examples.sln | 17 +
examples/csharp/README.md | 15 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj} | 2 +-
.../Iggy_SDK.Examples.TcpTls.Consumer/Program.cs | 113 +
.../Iggy_SDK.Examples.TcpTls.Producer.csproj} | 2 +-
.../Iggy_SDK.Examples.TcpTls.Producer/Program.cs | 141 +
examples/go/README.md | 11 +-
examples/go/getting-started/consumer/main.go | 30 +-
examples/go/getting-started/producer/main.go | 30 +-
examples/go/go.mod | 4 +-
examples/go/go.sum | 4 +-
examples/java/README.md | 22 +
examples/java/build.gradle.kts | 9 +
.../consumer/TcpTlsConsumer.java} | 31 +-
.../producer/TcpTlsProducer.java} | 31 +-
examples/node/package.json | 2 +-
examples/node/test-examples.sh | 145 -
examples/python/README.md | 9 +
examples/rust/README.md | 2 +-
foreign/cpp/BUILD.bazel | 35 +-
foreign/cpp/Cargo.lock | 4744 +++++++++++++++++++-
foreign/cpp/Cargo.toml | 2 +
foreign/cpp/README.md | 10 +-
foreign/cpp/build.rs | 4 +
foreign/cpp/src/client.rs | 206 +
foreign/cpp/src/identifier.rs | 63 +
foreign/cpp/src/lib.rs | 69 +-
.../src/title.rs => foreign/cpp/src/stream.rs | 23 +-
.../src/title.rs => foreign/cpp/src/topic.rs | 26 +-
foreign/cpp/tests/client/low_level_e2e.cpp | 150 +
foreign/cpp/tests/common/test_helpers.hpp | 56 +
foreign/cpp/tests/stream/low_level_e2e.cpp | 272 ++
foreign/cpp/tests/topic/low_level_e2e.cpp | 335 ++
foreign/cpp/tests/{test.cpp => unit_tests.cpp} | 0
.../Implementations/HttpMessageStream.cs | 8 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 3 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../Utils/{BufferSizes.cs => SdkVersion.cs} | 9 +-
.../SdkVersionTests.cs} | 17 +-
foreign/go/client/tcp/tcp_core.go | 3 +-
foreign/go/go.mod | 59 +-
foreign/go/go.sum | 170 +-
foreign/go/tests/tls_test.go | 280 ++
foreign/java/README.md | 1 +
.../pinot/config/IggyStreamConfigTest.java | 85 +-
.../pinot/consumer/IggyMessageBatchTest.java | 46 +-
.../consumer/IggyStreamPartitionMsgOffsetTest.java | 36 +-
.../org/apache/iggy/exception/IggyException.java | 9 -
.../org/apache/iggy/system/ClientInfoDetails.java | 3 +-
.../apache/iggy/topic/CompressionAlgorithm.java | 2 +-
.../iggy/client/async/AsyncConsumerGroupsTest.java | 20 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 170 +-
.../blocking/tcp/IggyTcpClientBuilderTest.java | 32 +-
.../client/blocking/tcp/TlsConnectionTest.java | 183 +
.../org/apache/iggy/config/RetryPolicyTest.java | 96 +
.../ConsumerGroupDetailsTest.java} | 31 +-
.../apache/iggy/consumergroup/ConsumerTest.java | 74 +
.../exception/IggyAuthenticationExceptionTest.java | 77 +
.../exception/IggyAuthorizationExceptionTest.java | 61 +
.../IggyClientExceptionTest.java} | 27 +-
.../iggy/exception/IggyConflictExceptionTest.java | 75 +
.../IggyConnectionClosedExceptionTest.java | 51 +
.../IggyConnectionExceptionTest.java} | 27 +-
.../IggyEmptyResponseExceptionTest.java} | 25 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 89 +
.../IggyInvalidArgumentExceptionTest.java} | 26 +-
.../IggyMalformedResponseExceptionTest.java} | 27 +-
.../IggyMissingCredentialsExceptionTest.java} | 27 +-
.../IggyNotConnectedExceptionTest.java} | 25 +-
.../IggyOperationNotSupportedExceptionTest.java | 60 +
.../IggyProtocolExceptionTest.java} | 27 +-
.../IggyResourceNotFoundExceptionTest.java | 89 +
.../iggy/exception/IggyServerExceptionTest.java | 200 +
.../IggyTimeoutExceptionTest.java} | 30 +-
.../IggyTlsExceptionTest.java} | 27 +-
.../exception/IggyValidationExceptionTest.java | 97 +
.../apache/iggy/identifier/BaseIdentifierTest.java | 131 +
.../apache/iggy/identifier/ConsumerIdTest.java} | 14 +-
.../apache/iggy/identifier/IdentifierTest.java} | 27 +-
.../org/apache/iggy/identifier/StreamIdTest.java} | 14 +-
.../org/apache/iggy/identifier/TopicIdTest.java} | 14 +-
.../org/apache/iggy/identifier/UserIdTest.java} | 14 +-
.../iggy/message/BigIntegerMessageIdTest.java | 72 +
.../apache/iggy/message/BytesMessageIdTest.java | 67 +
.../org/apache/iggy/message/HeaderKeyTest.java | 119 +
.../org/apache/iggy/message/HeaderKindTest.java | 81 +
.../org/apache/iggy/message/HeaderValueTest.java | 432 ++
.../org/apache/iggy/message/MessageStateTest.java} | 39 +-
.../java/org/apache/iggy/message/MessageTest.java | 166 +
.../apache/iggy/message/PartitioningKindTest.java} | 25 +-
.../org/apache/iggy/message/PartitioningTest.java | 77 +
.../org/apache/iggy/message/PollingKindTest.java} | 26 +-
.../apache/iggy/message/PollingStrategyTest.java | 68 +
.../org/apache/iggy/message/UuidMessageIdTest.java | 76 +
.../apache/iggy/serde/BytesDeserializerTest.java | 26 +
.../org/apache/iggy/stream/StreamDetailsTest.java | 57 +
.../ClientInfoDetailsTest.java} | 33 +-
.../iggy/topic/CompressionAlgorithmTest.java | 50 +
.../org/apache/iggy/topic/TopicDetailsTest.java | 60 +
.../org/apache/iggy/user/UserInfoDetailsTest.java | 45 +
.../UserStatusTest.java} | 33 +-
foreign/node/src/e2e/tls.system.e2e.ts | 11 +-
foreign/python/pyproject.toml | 4 +-
foreign/python/uv.lock | 95 +-
scripts/run-bdd-tests.sh | 34 +-
scripts/run-csharp-examples-from-readme.sh | 210 -
scripts/run-examples-from-readme.sh | 372 ++
scripts/run-go-examples-from-readme.sh | 183 -
scripts/run-java-examples-from-readme.sh | 144 -
scripts/run-node-examples-from-readme.sh | 264 --
scripts/run-python-examples-from-readme.sh | 226 -
scripts/run-rust-examples-from-readme.sh | 276 --
scripts/utils.sh | 209 +
301 files changed, 11153 insertions(+), 2746 deletions(-)
delete mode 100644 core/binary_protocol/src/client/binary_clients/mod.rs
delete mode 100644 core/binary_protocol/src/client/mod.rs
delete mode 100644 core/binary_protocol/src/utils/mod.rs
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_client/get_client.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_client/get_clients.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_client/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_cluster/get_cluster_metadata.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_cluster/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/create_consumer_group.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/delete_consumer_group.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/get_consumer_group.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/get_consumer_groups.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_groups/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/get_consumer_offset.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_consumer_offsets/set_consumer_offset.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/common.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/get_contexts.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_context/use_context.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/flush_messages.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/poll_messages.rs (99%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_message/send_messages.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/create_partitions.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/delete_partitions.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_partitions/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/create_personal_access_token.rs
(97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/delete_personal_access_tokens.rs
(96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/get_personal_access_tokens.rs
(97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_personal_access_tokens/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_segments/delete_segments.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_segments/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/create_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/delete_stream.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/get_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/get_streams.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/purge_stream.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_streams/update_stream.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/login.rs (94%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/logout.rs (93%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_system/me.rs
(96%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_system/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/ping.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/session.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/snapshot.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_system/stats.rs (98%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/create_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/delete_topic.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/get_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/get_topics.rs (98%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_topics/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/purge_topic.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_topics/update_topic.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/change_password.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/create_user.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/delete_user.rs (95%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/get_user.rs (97%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/get_users.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/binary_users/mod.rs
(100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/update_permissions.rs (96%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/binary_users/update_user.rs (97%)
rename core/{binary_protocol/src/cli => cli/src/commands}/cli_command.rs (98%)
rename core/{binary_protocol/src/cli => cli/src/commands}/mod.rs (100%)
rename core/{binary_protocol/src/cli =>
cli/src/commands}/utils/login_session_expiry.rs (100%)
rename core/{binary_protocol/src/cli => cli/src/commands}/utils/mod.rs (100%)
copy {examples/rust => core/cli}/src/lib.rs (97%)
rename core/{binary_protocol/src/utils/auth.rs =>
common/src/traits/binary_auth.rs} (86%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/binary_client.rs (92%)
rename core/{binary_protocol/src/client/binary_cluster/mod.rs =>
common/src/traits/binary_impls/cluster.rs} (81%)
rename core/{binary_protocol/src/client/binary_consumer_groups/mod.rs =>
common/src/traits/binary_impls/consumer_groups.rs} (84%)
rename core/{binary_protocol/src/client/binary_consumer_offsets/mod.rs =>
common/src/traits/binary_impls/consumer_offsets.rs} (84%)
rename core/{binary_protocol/src/client/binary_messages/mod.rs =>
common/src/traits/binary_impls/messages.rs} (93%)
copy core/{bench/dashboard/frontend/src/components/tooltips =>
common/src/traits/binary_impls}/mod.rs (82%)
rename core/{binary_protocol/src/client/binary_partitions/mod.rs =>
common/src/traits/binary_impls/partitions.rs} (87%)
rename core/{binary_protocol/src/client/binary_personal_access_tokens/mod.rs
=> common/src/traits/binary_impls/personal_access_tokens.rs} (77%)
rename core/{binary_protocol/src/client/binary_segments/mod.rs =>
common/src/traits/binary_impls/segments.rs} (89%)
rename core/{binary_protocol/src/client/binary_streams/mod.rs =>
common/src/traits/binary_impls/streams.rs} (82%)
rename core/{binary_protocol/src/client/binary_system/mod.rs =>
common/src/traits/binary_impls/system.rs} (82%)
rename core/{binary_protocol/src/client/binary_topics/mod.rs =>
common/src/traits/binary_impls/topics.rs} (87%)
rename core/{binary_protocol/src/client/binary_users/mod.rs =>
common/src/traits/binary_impls/users.rs} (85%)
rename core/{binary_protocol/src/utils/mapper.rs =>
common/src/traits/binary_mapper.rs} (99%)
rename core/{binary_protocol/src/client/binary_transport/mod.rs =>
common/src/traits/binary_transport.rs} (94%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/cluster_client.rs (96%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/consumer_group_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/consumer_offset_client.rs (96%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/message_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/partition_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/personal_access_token_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/segment_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/stream_client.rs (97%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/system_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/topic_client.rs (99%)
rename core/{binary_protocol/src/client/binary_clients =>
common/src/traits}/user_client.rs (99%)
copy core/{bench/report/src/plotting/text => sdk/src/binary}/mod.rs (93%)
copy
examples/csharp/src/{MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Iggy_SDK.Examples.MessageHeaders.Consumer.csproj
=>
TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Iggy_SDK.Examples.TcpTls.Consumer.csproj}
(95%)
create mode 100644
examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Program.cs
copy
examples/csharp/src/{GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Iggy_SDK.Examples.GettingStarted.Producer.csproj
=>
TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Iggy_SDK.Examples.TcpTls.Producer.csproj}
(95%)
create mode 100644
examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Program.cs
copy
examples/java/src/main/java/org/apache/iggy/examples/{gettingstarted/consumer/GettingStartedConsumer.java
=> tcptls/consumer/TcpTlsConsumer.java} (78%)
copy
examples/java/src/main/java/org/apache/iggy/examples/{gettingstarted/producer/GettingStartedProducer.java
=> tcptls/producer/TcpTlsProducer.java} (80%)
delete mode 100755 examples/node/test-examples.sh
create mode 100644 foreign/cpp/src/client.rs
create mode 100644 foreign/cpp/src/identifier.rs
copy core/bench/dashboard/shared/src/title.rs => foreign/cpp/src/stream.rs
(60%)
copy core/bench/dashboard/shared/src/title.rs => foreign/cpp/src/topic.rs (55%)
create mode 100644 foreign/cpp/tests/client/low_level_e2e.cpp
create mode 100644 foreign/cpp/tests/common/test_helpers.hpp
create mode 100644 foreign/cpp/tests/stream/low_level_e2e.cpp
create mode 100644 foreign/cpp/tests/topic/low_level_e2e.cpp
rename foreign/cpp/tests/{test.cpp => unit_tests.cpp} (100%)
copy foreign/csharp/Iggy_SDK/Utils/{BufferSizes.cs => SdkVersion.cs} (76%)
copy foreign/csharp/Iggy_SDK_Tests/{Utils/TestPriorityAttribute.cs =>
UtilityTests/SdkVersionTests.cs} (74%)
create mode 100644 foreign/go/tests/tls_test.go
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/tcp/TlsConnectionTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/config/RetryPolicyTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/http/UsersHttpClientTest.java
=> consumergroup/ConsumerGroupDetailsTest.java} (55%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/consumergroup/ConsumerTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyAuthenticationExceptionTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyAuthorizationExceptionTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyClientExceptionTest.java} (59%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyConflictExceptionTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyConnectionClosedExceptionTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyConnectionExceptionTest.java} (58%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyEmptyResponseExceptionTest.java} (63%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyInvalidArgumentExceptionTest.java} (57%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyMalformedResponseExceptionTest.java} (57%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyMissingCredentialsExceptionTest.java} (56%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyNotConnectedExceptionTest.java} (61%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyOperationNotSupportedExceptionTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyProtocolExceptionTest.java} (58%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyResourceNotFoundExceptionTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyTimeoutExceptionTest.java} (51%)
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> exception/IggyTlsExceptionTest.java} (59%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyValidationExceptionTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/identifier/BaseIdentifierTest.java
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/identifier/package-info.java
=> test/java/org/apache/iggy/identifier/ConsumerIdTest.java} (76%)
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/message/MessageState.java
=> test/java/org/apache/iggy/identifier/IdentifierTest.java} (60%)
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/identifier/package-info.java
=> test/java/org/apache/iggy/identifier/StreamIdTest.java} (76%)
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/identifier/package-info.java
=> test/java/org/apache/iggy/identifier/TopicIdTest.java} (76%)
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/identifier/package-info.java
=> test/java/org/apache/iggy/identifier/UserIdTest.java} (77%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/BigIntegerMessageIdTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/BytesMessageIdTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/HeaderKeyTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/HeaderKindTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/HeaderValueTest.java
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/message/BytesMessageId.java
=> test/java/org/apache/iggy/message/MessageStateTest.java} (52%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/MessageTest.java
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/message/PollingKind.java
=> test/java/org/apache/iggy/message/PartitioningKindTest.java} (65%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/PartitioningTest.java
copy
foreign/java/java-sdk/src/{main/java/org/apache/iggy/message/PollingKind.java
=> test/java/org/apache/iggy/message/PollingKindTest.java} (64%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/PollingStrategyTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/message/UuidMessageIdTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/stream/StreamDetailsTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/http/UsersHttpClientTest.java
=> system/ClientInfoDetailsTest.java} (51%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/topic/CompressionAlgorithmTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/topic/TopicDetailsTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/user/UserInfoDetailsTest.java
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/{client/blocking/SystemClientBaseTest.java
=> user/UserStatusTest.java} (50%)
delete mode 100755 scripts/run-csharp-examples-from-readme.sh
create mode 100755 scripts/run-examples-from-readme.sh
delete mode 100755 scripts/run-go-examples-from-readme.sh
delete mode 100755 scripts/run-java-examples-from-readme.sh
delete mode 100755 scripts/run-node-examples-from-readme.sh
delete mode 100755 scripts/run-python-examples-from-readme.sh
delete mode 100755 scripts/run-rust-examples-from-readme.sh
