This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/iggy-server-hardening
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard 9ce4dd0fa fix(server-ng): source TLS grace from config, align listener
backlog
discard 931bde2aa feat(server-ng): make VSR repair pacing and eviction ring
configurable
discard 29be858a7 feat(server-ng): make VSR clients table capacity configurable
discard 646e3bc0a fix(server-ng): scale recovery barrier deadline with status
timeout
discard 90d66a13c feat(server-ng): make VSR view-change timing configurable
discard 4cbba2a0b fix(server-ng): forward iggy/vsr so the bare vsr feature
builds
discard d8d19fef4 feat(server-ng): add partition.prepare_queue_depth for
pipeline sizing
discard c94172fa5 chore(repo): retry flaky tests twice in just nextest recipes
discard c93fa9c64 fix(server-ng): fail reads loud when restart recovery
outruns its deadline
discard b3ea6f84c feat(server-ng): make HTTP write admission caps configurable
discard ca21c2bc5 feat(server-ng): add commit broadcast and prepare retransmit
intervals
discard 12df22e92 fix(consensus): bound pipeline asserts by configured depth,
not const
add 64ae1e9cb feat(connectors): use TCP client for Flink sink (#3657)
add d9635b6d7 feat(server-ng): forward follower HTTP requests to VSR
primary (#3744)
add c5fec1ff6 test(integration): spec clients-table durability across node
restart (#3736)
new b2cccceec feat(server-ng): make VSR timing, capacity, and admission
configurable
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 (9ce4dd0fa)
\
N -- N -- N refs/heads/feat/iggy-server-hardening (b2cccceec)
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:
Cargo.lock | 1 +
Cargo.toml | 2 +-
bdd/docker-compose.vsr.yml | 7 +
core/configs/src/server_ng_config/cluster.rs | 19 +
core/configs/src/server_ng_config/validators.rs | 95 ++++
.../tests/cluster/client_table_restart.rs | 382 +++++++++++++
core/integration/tests/cluster/mod.rs | 22 +-
core/integration/tests/mod.rs | 5 +-
core/integration/tests/server/http_vsr.rs | 4 +-
core/server-ng/Cargo.toml | 1 +
core/server-ng/config.toml | 17 +-
core/server-ng/src/http.rs | 104 +++-
core/server-ng/src/http/error.rs | 131 ++++-
core/server-ng/src/http/extractor.rs | 20 +-
core/server-ng/src/http/forward.rs | 632 +++++++++++++++++++++
core/server-ng/src/http/handlers.rs | 6 +-
core/server-ng/src/http/jwt.rs | 47 +-
core/server-ng/src/http/reply.rs | 51 +-
core/server-ng/src/http/state.rs | 36 +-
core/server-ng/src/http/submit.rs | 43 +-
core/server-ng/src/server_error.rs | 2 +
foreign/java/.gitignore | 1 +
.../iggy-connector-library/README.md | 33 ++
.../apache/iggy/connector/config/TcpEndpoint.java | 92 +++
.../apache/iggy/connector/flink/sink/IggySink.java | 91 ++-
.../iggy/connector/flink/sink/IggySinkWriter.java | 39 +-
.../iggy/connector/flink/source/IggySource.java | 24 +-
.../iggy/connector/config/TcpEndpointTest.java | 130 +++++
28 files changed, 1818 insertions(+), 219 deletions(-)
create mode 100644 core/integration/tests/cluster/client_table_restart.rs
create mode 100644 core/server-ng/src/http/forward.rs
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/config/TcpEndpoint.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/config/TcpEndpointTest.java
