This is an automated email from the ASF dual-hosted git repository.
maciej pushed a change to branch connectors-config
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 3e382d6d9 implement adding sink/source config version
omit 1a44cdafb make connector version optional in config provider
omit fbc6fb678 update endpoints mapping
omit 5bcfd08c0 feat(connectors): extend runtime API with config management
options
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 d8fceb152 feat(connectors): extend runtime API with config management
options
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 (3e382d6d9)
\
N -- N -- N refs/heads/connectors-config (d8fceb152)
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.
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 104 +-
Cargo.toml | 16 +-
DEPENDENCIES.md | 52 +-
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/connectors/runtime/README.md | 2 +-
core/connectors/runtime/config.toml | 2 +-
core/connectors/runtime/example_config/config.toml | 4 +
core/connectors/runtime/runtime.http | 14 +-
core/connectors/runtime/src/api/sink.rs | 28 +-
core/connectors/runtime/src/api/source.rs | 25 +-
core/connectors/runtime/src/configs/connectors.rs | 59 +-
.../src/configs/connectors/local_provider.rs | 269 ++-
core/connectors/runtime/src/error.rs | 1 +
core/connectors/runtime/src/main.rs | 6 +-
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/sdk/Cargo.toml | 2 +-
.../delete_consumer_group_handler.rs | 18 +
core/server/src/bootstrap.rs | 19 +-
core/server/src/http/consumer_groups.rs | 18 +
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 +
.../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 ++++---
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 99 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 92 +-
.../iggy/client/blocking/tcp/IggyTcpClient.java | 71 +-
.../client/blocking/tcp/InternalTcpClient.java | 33 +-
foreign/node/package-lock.json | 2254 ++++++++++----------
foreign/node/package.json | 34 +-
foreign/python/Cargo.toml | 2 +-
web/.npmrc | 1 -
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 | 6 +-
.../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 | 5 +-
196 files changed, 6986 insertions(+), 3182 deletions(-)
copy core/certs/{iggy_cert.pem => iggy_ca_cert.pem} (100%)
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
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
delete mode 100644 web/.npmrc
