This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch fix-vergen-hash
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 7f260e44f Merge branch 'master' into fix-vergen-hash
omit ea12d92cd fix(server): print correct git commit hash in CI builds
add b0533d787 fix(server): validate client existence in consumer_group for
leave_consumer_group command and rebalance cg (#2347)
add 5d73772e4 feat(connectors): implement configuration provider trait
(#2345)
add b52166b11 feat(csharp): implement reconnection in tcp client (#2336)
add f7db1281f fix(server): fix store_consumer_offset for consumer groups
(#2351)
add 3dbfc6959 fix(server): delete consumer_group offset, when deleting
consumer_group (#2352)
add e82aa03e7 docs(csharp): add XML documentation comments and remove
unused classes (#2353)
add f82351e79 chore(repo): update deps for rust, node and web (#2354)
add f7aabc21c fix(web): remove password persistence in sign-in form,
rememberMe functionality (#2357)
add 81f282647 docs(csharp): update csharp README.md file and bump
dependencies (#2356)
add 40d6715a1 feat(java): add TLS support to TCP connection (#2358)
add b8a61f9c4 feat(web): add autocomplete and docker-compose improvements
(#2361)
add 5d9cfb3ec fix(web): fix incorrect navigation path in messages
pagination (#2364)
add db89d7d63 feat(cluster): define metadata module and add consensus,
messages modules (#2349)
add 28bb37bba chore(java): fix linting issues and add formatter (#2365)
add a318d99be chore(ci): add workflow to update licenses on Dependabot PRs
(#2367)
new 83c3ec480 fix(server): print correct git commit hash in CI builds
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7f260e44f)
\
N -- N -- N refs/heads/fix-vergen-hash (83c3ec480)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/actions/java-gradle/pre-merge/action.yml | 5 +-
.github/workflows/dependabot-licenses.yml | 62 +
.gitignore | 1 +
Cargo.lock | 116 +-
Cargo.toml | 18 +-
DEPENDENCIES.md | 54 +-
README.md | 6 +-
core/bench/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/certs/{iggy_cert.pem => iggy_ca_cert.pem} | 0
core/certs/iggy_cert.pem | 36 +-
core/certs/iggy_key.pem | 52 +-
core/common/Cargo.toml | 2 +-
core/common/src/types/consensus/mod.rs | 162 ++
core/common/src/types/mod.rs | 1 +
core/connectors/runtime/Cargo.toml | 1 +
core/connectors/runtime/README.md | 3 +-
core/connectors/runtime/config.toml | 3 +-
core/connectors/runtime/example_config/config.toml | 5 +
.../example_config/connectors/quickwit.toml | 2 +
.../runtime/example_config/connectors/random.toml | 2 +
.../runtime/example_config/connectors/stdout.toml | 2 +
core/connectors/runtime/src/api/config.rs | 6 +-
core/connectors/runtime/src/api/models.rs | 9 +-
core/connectors/runtime/src/api/sink.rs | 6 +-
core/connectors/runtime/src/api/source.rs | 6 +-
core/connectors/runtime/src/configs.rs | 459 ----
core/connectors/runtime/src/configs/connectors.rs | 239 +++
.../src/configs/connectors/local_provider.rs | 168 ++
.../connectors/runtime/src/configs/mod.rs | 6 +-
core/connectors/runtime/src/configs/runtime.rs | 189 ++
core/connectors/runtime/src/context.rs | 4 +-
core/connectors/runtime/src/main.rs | 10 +-
core/connectors/runtime/src/manager/sink.rs | 5 +-
core/connectors/runtime/src/manager/source.rs | 5 +-
core/connectors/runtime/src/sink.rs | 7 +-
core/connectors/runtime/src/source.rs | 7 +-
core/connectors/runtime/src/stream.rs | 3 +-
core/connectors/runtime/src/transform.rs | 9 +-
core/connectors/sdk/README.md | 5 +
core/connectors/sinks/README.md | 17 +-
core/connectors/sources/README.md | 17 +-
.../dashboard/shared => consensus}/Cargo.toml | 15 +-
.../ConsumerType.cs => core/consensus/src/lib.rs | 10 +-
core/integration/tests/server/cg.rs | 5 +-
core/integration/tests/server/mod.rs | 15 +-
...umer_group_auto_commit_reconnection_scenario.rs | 201 ++
.../consumer_group_offset_cleanup_scenario.rs | 201 ++
core/integration/tests/server/scenarios/mod.rs | 2 +
core/{tools => metadata}/Cargo.toml | 22 +-
.../metadata/src/impls/metadata.rs | 43 +-
.../http/conn.cc => core/metadata/src/impls/mod.rs | 2 +-
.../memory_journal.rs => metadata/src/lib.rs} | 4 +
core/{server/src/io => metadata/src/stm}/mod.rs | 6 +-
.../memory_journal.rs => metadata/src/stm/mux.rs} | 2 +
.../src/stm/stream.rs} | 1 -
core/sdk/Cargo.toml | 2 +-
.../delete_consumer_group_handler.rs | 18 +
.../partitions/create_partitions_handler.rs | 2 +-
.../partitions/delete_partitions_handler.rs | 2 +-
core/server/src/bootstrap.rs | 19 +-
core/server/src/http/consumer_groups.rs | 18 +
core/server/src/shard/system/consumer_groups.rs | 15 +-
core/server/src/shard/system/consumer_offsets.rs | 92 +-
core/server/src/slab/streams.rs | 74 +-
.../src/streaming/partitions/consumer_offset.rs | 7 +-
core/server/src/streaming/partitions/helpers.rs | 50 +-
core/server/src/streaming/partitions/partition.rs | 7 +-
core/server/src/streaming/partitions/storage.rs | 88 +-
core/server/src/streaming/polling_consumer.rs | 28 +-
core/server/src/streaming/streams/helpers.rs | 8 +-
core/server/src/streaming/topics/consumer_group.rs | 4 +
core/server/src/streaming/topics/helpers.rs | 39 +-
.../Iggy_SDK.Examples.Basic.Consumer/Program.cs | 2 +
.../Iggy_SDK.Examples.Basic.Producer/Program.cs | 1 +
.../Program.cs | 1 +
.../Program.cs | 1 +
.../Program.cs | 1 +
.../Program.cs | 1 +
.../Program.cs | 1 +
.../Program.cs | 1 +
.../Iggy_SDK.Examples.NewSdk.Consumer/Program.cs | 4 +-
.../Iggy_SDK.Examples.NewSdk.Producer/Program.cs | 1 +
foreign/csharp/DEPENDENCIES.md | 4 +-
foreign/csharp/Directory.Packages.props | 4 +-
.../BasicMessagingOperationsSteps.cs | 1 +
.../ConsumerGroupTests.cs | 8 +-
.../FetchMessagesTests.cs | 2 +-
.../Fixtures/IggyServerFixture.cs | 84 +-
.../Fixtures/SystemFixture.cs | 4 +-
.../FlushMessagesTests.cs | 2 +-
.../IggyConsumerTests.cs | 34 +-
.../IggyPublisherTests.cs | 22 +
.../Iggy_SDK.Tests.Integration/PartitionsTests.cs | 4 +-
.../PersonalAccessTokenTests.cs | 4 +-
.../SendMessagesTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 29 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/UsersTests.cs | 6 +-
...ageBatchingSettings.cs => AutoLoginSettings.cs} | 22 +-
.../Configuration/IggyClientConfigurator.cs | 40 +-
.../Configuration/MessagePollingSettings.cs | 26 -
.../Iggy_SDK/Configuration/ReconnectionSettings.cs | 63 +
.../Iggy_SDK/Configuration/TlsConfiguration.cs | 14 +
.../Iggy_SDK/ConnectionStream/IConnectionStream.cs | 2 +-
.../ConnectionStream/TcpConnectionStream.cs | 2 +-
.../ConnectionStream/TcpTslConnectionStream.cs | 55 -
.../csharp/Iggy_SDK/Consumers/AutoCommitMode.cs | 5 -
.../Iggy_SDK/Consumers/IggyConsumer.Logging.cs | 35 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 200 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilder.cs | 19 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs | 7 +-
.../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 8 +
.../csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs | 4 +-
.../csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs | 5 +
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 170 ++
.../csharp/Iggy_SDK/Contracts/Auth/Permissions.cs | 10 +
.../Contracts/Auth/PersonalAccessTokenResponse.cs | 10 +
.../Contracts/Auth/RawPersonalAccessToken.cs | 6 +
.../csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs | 9 +
.../csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs | 22 +
foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs | 14 +
.../csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs | 29 +
foreign/csharp/Iggy_SDK/Contracts/ClientInfo.cs | 26 +
.../ClusterMetadata.cs} | 24 +-
.../AutoCommitMode.cs => Contracts/ClusterNode.cs} | 33 +-
...essageResponseGeneric.cs => ClusterNodeRole.cs} | 21 +-
.../ClusterNodeStatus.cs} | 27 +-
.../csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs | 14 +
.../Iggy_SDK/Contracts/ConsumerGroupMembers.cs | 14 +
.../Iggy_SDK/Contracts/ConsumerGroupResponse.cs | 22 +
.../Contracts/Http/ErrorResponse.cs} | 60 +-
.../Contracts/{ => Http}/MessageSendRequest.cs | 4 +-
.../Iggy_SDK/Contracts/MessageFetchRequest.cs | 30 +
.../csharp/Iggy_SDK/Contracts/MessageResponse.cs | 14 +
.../Contracts/MessageSendRequestGeneric.cs | 28 -
.../csharp/Iggy_SDK/Contracts/OffsetResponse.cs | 14 +
.../csharp/Iggy_SDK/Contracts/PartitionResponse.cs | 23 +
.../Iggy_SDK/Contracts/PollMessagesRequest.cs | 30 -
.../csharp/Iggy_SDK/Contracts/PolledMessages.cs | 17 +
.../Iggy_SDK/Contracts/PolledMessagesGeneric.cs | 33 -
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 94 +
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 119 ++
.../csharp/Iggy_SDK/Contracts/StreamResponse.cs | 27 +
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 85 +
foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs | 42 +
.../csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs | 8 +-
.../AutoCommitMode.cs => Enums/ConnectionState.cs} | 28 +-
foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs | 10 +
foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 10 +
foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs | 22 +
foreign/csharp/Iggy_SDK/Enums/MessageState.cs | 26 -
foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs | 14 +
foreign/csharp/Iggy_SDK/Enums/Protocol.cs | 13 +-
foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs | 25 -
foreign/csharp/Iggy_SDK/Enums/UserStatus.cs | 10 +
foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs | 14 +
.../Exceptions/ConsumerGroupNotFoundException.cs | 12 +-
.../Exceptions/ConsumerNotInitializedException.cs | 15 +-
.../Exceptions/FeatureUnavailableException.cs | 6 +
.../Exceptions/IggyInvalidStatusCodeException.cs | 6 +
...pNameException.cs => IggyZeroBytesException.cs} | 7 +-
.../Exceptions/InvalidBaseAdressException.cs | 7 +-
.../InvalidConsumerGroupNameException.cs | 6 +
.../Exceptions/InvalidResponseException.cs | 6 +
.../Exceptions/MissingLeaderException.cs} | 20 +-
...upNameException.cs => NotConnectedException.cs} | 7 +-
.../Exceptions/PublisherNotInitializedException.cs | 15 +-
.../Iggy_SDK/Exceptions/StreamNotFoundException.cs | 22 +-
.../Exceptions/TcpInvalidResponseException.cs | 25 -
.../csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs | 25 -
.../Iggy_SDK/Exceptions/TopicNotFoundException.cs | 28 +-
.../Iggy_SDK/Extensions/IggyClientExtenstion.cs | 30 +
.../csharp/Iggy_SDK/Factory/IggyClientFactory.cs | 71 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 28 +
foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs | 46 +
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 133 ++
foreign/csharp/Iggy_SDK/Identifier.cs | 48 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs | 23 +
.../csharp/Iggy_SDK/IggyClient/IIggyConsumer.cs | 29 +
.../Iggy_SDK/IggyClient/IIggyConsumerGroup.cs | 74 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs | 41 +
.../csharp/Iggy_SDK/IggyClient/IIggyPartition.cs | 20 +
.../IggyClient/IIggyPersonalAccessToken.cs | 38 +
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 36 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 58 +
foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs | 64 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 75 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs | 76 +
.../Implementations/HttpMessageStream.cs | 106 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 402 +++-
.../Iggy_SDK/IggyClient/ReconnectionEventArgs.cs | 54 +
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 3 +-
.../Iggy_SDK/JsonConverters/MessagesConverter.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Consumer.cs | 30 +
foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs | 50 +
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 148 +-
foreign/csharp/Iggy_SDK/Messages/Message.cs | 33 +
foreign/csharp/Iggy_SDK/Messages/MessageHeader.cs | 28 +
.../BackgroundMessageProcessor.Logging.cs | 5 +
.../Publishers/BackgroundMessageProcessor.cs | 130 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 67 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 28 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilderOfT.cs | 4 +-
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 8 +
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 1 +
foreign/csharp/Iggy_SDK/Utils/EventAggregator.cs | 96 +
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 57 -
.../UtilityTests/EventAggregatorTests.cs | 175 ++
.../Utils/Messages/MessageFactory.cs | 287 ---
foreign/csharp/README.md | 764 ++++---
.../Consumer.java => build.gradle.kts} | 53 +-
foreign/java/dev-support/checkstyle/checkstyle.xml | 198 +-
.../checkstyle/suppressions.xml} | 28 +-
.../apache/iggy/async/AsyncConsumerExample.java | 119 +-
.../java/org/apache/iggy/async/AsyncProducer.java | 187 +-
.../org/apache/iggy/consumer/SimpleConsumer.java | 33 +-
.../org/apache/iggy/producer/SimpleProducer.java | 15 +-
.../iggy-connector-library/build.gradle.kts | 6 -
.../connector/config/IggyConnectionConfig.java | 47 +-
.../apache/iggy/connector/config/OffsetConfig.java | 9 +-
.../iggy/connector/flink/sink/IggyCommittable.java | 7 +-
.../apache/iggy/connector/flink/sink/IggySink.java | 23 +-
.../iggy/connector/flink/sink/IggySinkBuilder.java | 14 +-
.../iggy/connector/flink/sink/IggySinkWriter.java | 50 +-
.../flink/source/IggyPartitionSplitReader.java | 73 +-
.../iggy/connector/flink/source/IggySource.java | 40 +-
.../connector/flink/source/IggySourceBuilder.java | 17 +-
.../flink/source/IggySourceEnumeratorState.java | 9 +-
.../IggySourceEnumeratorStateSerializer.java | 16 +-
.../connector/flink/source/IggySourceReader.java | 26 +-
.../connector/flink/source/IggySourceSplit.java | 13 +-
.../flink/source/IggySourceSplitEnumerator.java | 68 +-
.../flink/source/IggySourceSplitSerializer.java | 10 +-
.../iggy/connector/partition/PartitionInfo.java | 3 +-
.../serialization/JsonDeserializationSchema.java | 5 +-
.../serialization/JsonSerializationSchema.java | 40 +-
.../connector/config/IggyConnectionConfigTest.java | 65 +-
.../iggy/connector/config/OffsetConfigTest.java | 27 +-
.../connector/error/ConnectorExceptionTest.java | 50 +-
.../connector/partition/PartitionInfoTest.java | 4 +-
.../serialization/DeserializationSchemaTest.java | 10 +-
.../serialization/RecordMetadataTest.java | 4 +-
.../serialization/SerializationSchemaTest.java | 7 +-
.../serialization/TypeDescriptorTest.java | 13 +-
.../iggy/flink/example/MultiStreamJoinJob.java | 108 +-
.../iggy/flink/example/SendTestMessages.java | 19 +-
.../iggy/flink/example/StreamTransformJob.java | 82 +-
.../apache/iggy/flink/example/WordCountJob.java | 54 +-
.../iggy/flink/example/model/EnrichedActivity.java | 3 +-
.../apache/iggy/flink/example/model/WordCount.java | 4 +-
.../flink/example/AsyncTcpMessagePollTest.java | 226 +-
.../flink/example/AsyncTcpMessageSendTest.java | 122 +-
.../iggy/flink/example/SendTextDataTest.java | 74 +-
foreign/java/java-sdk/build.gradle.kts | 6 -
.../src/main/java/org/apache/iggy/Iggy.java | 4 +-
.../src/main/java/org/apache/iggy/NonNullApi.java | 9 +-
.../apache/iggy/client/async/MessagesClient.java | 33 +-
.../client/async/tcp/AsyncBytesDeserializer.java | 13 +-
.../client/async/tcp/AsyncBytesSerializer.java | 3 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 135 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 118 +-
.../client/async/tcp/ConsumerGroupsTcpClient.java | 28 +-
.../iggy/client/async/tcp/IggyFrameDecoder.java | 6 +-
.../iggy/client/async/tcp/MessagesTcpClient.java | 13 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 63 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 73 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 34 +-
.../iggy/client/blocking/ConsumerGroupsClient.java | 2 +-
.../client/blocking/ConsumerOffsetsClient.java | 14 +-
.../iggy/client/blocking/IggyBaseClient.java | 1 -
.../apache/iggy/client/blocking/IggyClient.java | 1 -
.../iggy/client/blocking/IggyClientBuilder.java | 1 -
.../iggy/client/blocking/MessagesClient.java | 30 +-
.../iggy/client/blocking/PartitionsClient.java | 1 -
.../blocking/PersonalAccessTokensClient.java | 2 +-
.../apache/iggy/client/blocking/StreamsClient.java | 2 +-
.../apache/iggy/client/blocking/SystemClient.java | 2 +-
.../apache/iggy/client/blocking/TopicsClient.java | 68 +-
.../apache/iggy/client/blocking/UsersClient.java | 2 +-
.../blocking/http/ConsumerGroupsHttpClient.java | 11 +-
.../blocking/http/ConsumerOffsetsHttpClient.java | 20 +-
.../iggy/client/blocking/http/IggyHttpClient.java | 1 -
.../client/blocking/http/InternalHttpClient.java | 26 +-
.../client/blocking/http/MessagesHttpClient.java | 20 +-
.../client/blocking/http/ObjectMapperFactory.java | 4 +-
.../client/blocking/http/PartitionsHttpClient.java | 10 +-
.../http/PersonalAccessTokensHttpClient.java | 22 +-
.../client/blocking/http/StreamsHttpClient.java | 13 +-
.../client/blocking/http/SystemHttpClient.java | 4 +-
.../client/blocking/http/TopicsHttpClient.java | 59 +-
.../iggy/client/blocking/http/UsersHttpClient.java | 33 +-
.../client/blocking/http/error/IggyHttpError.java | 8 +-
.../blocking/http/error/IggyHttpException.java | 1 -
.../client/blocking/tcp/BytesDeserializer.java | 68 +-
.../iggy/client/blocking/tcp/BytesSerializer.java | 22 +-
.../iggy/client/blocking/tcp/CommandCode.java | 252 +--
.../blocking/tcp/ConsumerGroupsTcpClient.java | 3 +-
.../blocking/tcp/ConsumerOffsetTcpClient.java | 9 +-
.../iggy/client/blocking/tcp/IggyTcpClient.java | 103 +-
.../client/blocking/tcp/InternalTcpClient.java | 37 +-
.../client/blocking/tcp/MessagesTcpClient.java | 12 +-
.../client/blocking/tcp/PartitionsTcpClient.java | 1 +
.../tcp/PersonalAccessTokensTcpClient.java | 2 +
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 3 +-
.../iggy/client/blocking/tcp/SystemTcpClient.java | 6 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 30 +-
.../iggy/client/blocking/tcp/UsersTcpClient.java | 53 +-
.../org/apache/iggy/consumergroup/Consumer.java | 1 -
.../apache/iggy/consumergroup/ConsumerGroup.java | 8 +-
.../iggy/consumergroup/ConsumerGroupDetails.java | 10 +-
.../iggy/consumergroup/ConsumerGroupMember.java | 7 +-
.../iggy/consumeroffset/ConsumerOffsetInfo.java | 7 +-
.../org/apache/iggy/identifier/ConsumerId.java | 3 +-
.../org/apache/iggy/identifier/Identifier.java | 3 +-
.../java/org/apache/iggy/identifier/StreamId.java | 3 +-
.../java/org/apache/iggy/identifier/TopicId.java | 3 +-
.../java/org/apache/iggy/identifier/UserId.java | 3 +-
.../apache/iggy/message/BigIntegerMessageId.java | 2 +-
.../org/apache/iggy/message/BytesMessageId.java | 2 +-
.../java/org/apache/iggy/message/HeaderValue.java | 3 +-
.../main/java/org/apache/iggy/message/Message.java | 15 +-
.../org/apache/iggy/message/MessageHeader.java | 17 +-
.../java/org/apache/iggy/message/MessageId.java | 2 +-
.../java/org/apache/iggy/message/Partitioning.java | 8 +-
.../org/apache/iggy/message/PolledMessages.java | 8 +-
.../org/apache/iggy/message/PollingStrategy.java | 1 -
.../org/apache/iggy/message/UuidMessageId.java | 2 +-
.../java/org/apache/iggy/partition/Partition.java | 4 +-
.../PersonalAccessTokenInfo.java | 3 +-
.../RawPersonalAccessToken.java | 3 +-
.../java/org/apache/iggy/stream/StreamBase.java | 9 +-
.../java/org/apache/iggy/stream/StreamDetails.java | 4 +-
.../java/org/apache/iggy/system/ClientInfo.java | 8 +-
.../org/apache/iggy/system/ClientInfoDetails.java | 11 +-
.../org/apache/iggy/system/ConsumerGroupInfo.java | 7 +-
.../main/java/org/apache/iggy/system/Stats.java | 4 +-
.../src/main/java/org/apache/iggy/topic/Topic.java | 4 +-
.../java/org/apache/iggy/topic/TopicDetails.java | 7 +-
.../org/apache/iggy/user/GlobalPermissions.java | 4 +-
.../java/org/apache/iggy/user/IdentityInfo.java | 3 +-
.../java/org/apache/iggy/user/Permissions.java | 7 +-
.../org/apache/iggy/user/StreamPermissions.java | 6 +-
.../main/java/org/apache/iggy/user/TokenInfo.java | 3 +-
.../org/apache/iggy/user/TopicPermissions.java | 8 +-
.../main/java/org/apache/iggy/user/UserInfo.java | 8 +-
.../java/org/apache/iggy/user/UserInfoDetails.java | 7 +-
.../src/test/java/org/apache/iggy/IggyTest.java | 8 +-
.../test/java/org/apache/iggy/TestConstants.java | 4 +-
.../client/async/AsyncClientIntegrationTest.java | 190 +-
.../iggy/client/async/AsyncPollMessageTest.java | 280 +--
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 33 +-
.../blocking/ConsumerGroupsClientBaseTest.java | 26 +-
.../blocking/ConsumerOffsetsClientBaseTest.java | 19 +-
.../iggy/client/blocking/IntegrationTest.java | 34 +-
.../client/blocking/MessagesClientBaseTest.java | 36 +-
.../client/blocking/PartitionsClientBaseTest.java | 5 +-
.../blocking/PersonalAccessTokensBaseTest.java | 15 +-
.../iggy/client/blocking/StreamClientBaseTest.java | 2 +-
.../iggy/client/blocking/SystemClientBaseTest.java | 2 +-
.../iggy/client/blocking/TopicsClientBaseTest.java | 31 +-
.../iggy/client/blocking/UsersClientBaseTest.java | 29 +-
.../http/ConsumerGroupsHttpClientTest.java | 1 -
.../http/ConsumerOffsetsHttpClientTest.java | 1 -
.../client/blocking/http/HttpClientFactory.java | 6 +-
.../blocking/http/MessagesHttpClientTest.java | 1 -
.../blocking/http/PartitionsHttpClientTest.java | 1 -
.../http/PersonalAccessTokensHttpClientTest.java | 1 -
.../client/blocking/http/StreamHttpClientTest.java | 1 -
.../client/blocking/http/SystemHttpClientTest.java | 1 -
.../client/blocking/http/TopicsHttpClientTest.java | 1 -
.../client/blocking/http/UsersHttpClientTest.java | 5 +-
.../client/blocking/tcp/BytesSerializerTest.java | 11 +-
.../blocking/tcp/ConsumerGroupsTcpClientTest.java | 18 +-
.../blocking/tcp/ConsumerOffsetsTcpClientTest.java | 1 -
.../blocking/tcp/IggyTcpClientBuilderTest.java | 35 +-
.../client/blocking/tcp/MessagesTcpClientTest.java | 1 -
.../blocking/tcp/PartitionsTcpClientTest.java | 1 -
.../tcp/PersonalAccessTokensTcpClientTest.java | 1 -
.../client/blocking/tcp/StreamTcpClientTest.java | 1 -
.../client/blocking/tcp/SystemTcpClientTest.java | 4 +-
.../iggy/client/blocking/tcp/TcpClientFactory.java | 6 +-
.../client/blocking/tcp/TopicsTcpClientTest.java | 1 -
.../client/blocking/tcp/UsersTcpClientTest.java | 3 +-
foreign/node/package-lock.json | 2254 ++++++++++----------
foreign/node/package.json | 34 +-
foreign/python/Cargo.toml | 2 +-
web/.npmrc | 1 -
web/docker-compose.yml | 19 +
web/package-lock.json | 389 ++--
web/package.json | 50 +-
.../components/Modals/AddPartitionsModal.svelte | 6 +-
.../lib/components/Modals/AddStreamModal.svelte | 6 +-
web/src/lib/components/Modals/AddTopicModal.svelte | 6 +-
web/src/lib/components/Modals/AddUserModal.svelte | 7 +-
.../components/Modals/DeletePartitionsModal.svelte | 6 +-
.../components/Modals/StreamSettingsModal.svelte | 6 +-
.../components/Modals/TopicSettingsModal.svelte | 6 +-
web/src/routes/auth/sign-in/+page.server.ts | 8 +-
web/src/routes/auth/sign-in/+page.svelte | 7 +-
.../[partitionId=i32]/messages/+page.svelte | 40 +-
402 files changed, 9778 insertions(+), 5864 deletions(-)
create mode 100644 .github/workflows/dependabot-licenses.yml
copy core/certs/{iggy_cert.pem => iggy_ca_cert.pem} (100%)
create mode 100644 core/common/src/types/consensus/mod.rs
delete mode 100644 core/connectors/runtime/src/configs.rs
create mode 100644 core/connectors/runtime/src/configs/connectors.rs
create mode 100644
core/connectors/runtime/src/configs/connectors/local_provider.rs
copy foreign/node/src/stream/index.ts =>
core/connectors/runtime/src/configs/mod.rs (94%)
create mode 100644 core/connectors/runtime/src/configs/runtime.rs
copy core/{bench/dashboard/shared => consensus}/Cargo.toml (72%)
copy foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs =>
core/consensus/src/lib.rs (89%)
create mode 100644
core/integration/tests/server/scenarios/consumer_group_auto_commit_reconnection_scenario.rs
create mode 100644
core/integration/tests/server/scenarios/consumer_group_offset_cleanup_scenario.rs
copy core/{tools => metadata}/Cargo.toml (71%)
copy foreign/csharp/Iggy_SDK/Exceptions/StreamNotFoundException.cs =>
core/metadata/src/impls/metadata.rs (53%)
copy foreign/cpp/sdk/net/http/conn.cc => core/metadata/src/impls/mod.rs (97%)
copy core/{server/src/streaming/segments/memory_journal.rs =>
metadata/src/lib.rs} (94%)
copy core/{server/src/io => metadata/src/stm}/mod.rs (93%)
copy core/{server/src/streaming/segments/memory_journal.rs =>
metadata/src/stm/mux.rs} (94%)
copy core/{server/src/streaming/segments/memory_journal.rs =>
metadata/src/stm/stream.rs} (99%)
rename foreign/csharp/Iggy_SDK/Configuration/{MessageBatchingSettings.cs =>
AutoLoginSettings.cs} (60%)
delete mode 100644
foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs
create mode 100644
foreign/csharp/Iggy_SDK/Configuration/ReconnectionSettings.cs
delete mode 100644
foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs
copy foreign/csharp/Iggy_SDK/{Consumers/AutoCommitMode.cs =>
Contracts/ClusterMetadata.cs} (65%)
copy foreign/csharp/Iggy_SDK/{Consumers/AutoCommitMode.cs =>
Contracts/ClusterNode.cs} (58%)
rename foreign/csharp/Iggy_SDK/Contracts/{MessageResponseGeneric.cs =>
ClusterNodeRole.cs} (72%)
copy foreign/csharp/Iggy_SDK/{Consumers/AutoCommitMode.cs =>
Contracts/ClusterNodeStatus.cs} (70%)
copy foreign/csharp/{Iggy_SDK.Tests.BDD/Context/TestHooks.cs =>
Iggy_SDK/Contracts/Http/ErrorResponse.cs} (51%)
rename foreign/csharp/Iggy_SDK/Contracts/{ => Http}/MessageSendRequest.cs (93%)
delete mode 100644
foreign/csharp/Iggy_SDK/Contracts/MessageSendRequestGeneric.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Contracts/PollMessagesRequest.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Contracts/PolledMessagesGeneric.cs
copy foreign/csharp/Iggy_SDK/{Consumers/AutoCommitMode.cs =>
Enums/ConnectionState.cs} (55%)
delete mode 100644 foreign/csharp/Iggy_SDK/Enums/MessageState.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidConsumerGroupNameException.cs
=> IggyZeroBytesException.cs} (76%)
copy foreign/csharp/{Iggy_SDK.Tests.Integration/Helpers/NameIdHelpers.cs =>
Iggy_SDK/Exceptions/MissingLeaderException.cs} (68%)
copy foreign/csharp/Iggy_SDK/Exceptions/{InvalidConsumerGroupNameException.cs
=> NotConnectedException.cs} (76%)
delete mode 100644
foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs
delete mode 100644 foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs
create mode 100644 foreign/csharp/Iggy_SDK/IggyClient/ReconnectionEventArgs.cs
create mode 100644 foreign/csharp/Iggy_SDK/Utils/EventAggregator.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/UtilityTests/EventAggregatorTests.cs
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/consumergroup/Consumer.java
=> build.gradle.kts} (50%)
copy foreign/java/{java-sdk/src/test/resources/logback-test.xml =>
dev-support/checkstyle/suppressions.xml} (57%)
delete mode 100644 web/.npmrc
