You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by ra...@apache.org on 2026/10/03 01:38:56 UTC
(iggy) branch feat/gateways-3539-phase1-docker-e2e updated (a0f34c9f0 -> ba85b582f)
This is an automated email from the ASF dual-hosted git repository.
ryerraguntla pushed a change to branch feat/gateways-3539-phase1-docker-e2e
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a0f34c9f0 Update Dockerfile
add 985b0ac1f chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in /foreign/node (#4358)
add 88c842ccc chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in /web (#4359)
add fc927ab28 chore(deps): Bump the web group across 1 directory with 8 updates (#4375)
add 73f1f7023 chore(deps): Bump the node group across 2 directories with 6 updates (#4376)
add db581c276 chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in /examples/node (#4377)
add a6bcfd694 chore(deps): Bump devalue from 5.9.2 to 5.9.4 in /web (#4378)
add d7458b8e6 test(go): cover offset, partition, and consumer group command serialization (#4370)
add e4ff95b88 feat(go): add GetMe to the Go SDK (#4371)
add 071121c70 fix(consensus): preserve recovery floors and reject aged-out requests (#4365)
add e51780a53 chore(repo): make repository skills available to Codex (#4360)
add 7c10d8adb fix(sdk): keep a shut down client shut down (#4374)
add 0936d44cc chore(repo): bump all components to patch edge versions after 0.9.0 (#4315)
add 815f345b3 docs: require agent review, comment replies and fewer rebases (#4384)
add c80183499 chore(deps): Bump the go group across 2 directories with 2 updates (#4390)
add ba85b582f Merge branch 'master' into feat/gateways-3539-phase1-docker-e2e
No new revisions were added by this update.
Summary of changes:
.agents/skills/connector-review | 1 +
.agents/skills/connector-runtime | 1 +
.agents/skills/connector-sdk | 1 +
.agents/skills/connector-sink | 1 +
.agents/skills/connector-source | 1 +
.agents/skills/connector-testing | 1 +
.agents/skills/connector-transform | 1 +
.agents/skills/connectors-overview | 1 +
.agents/skills/team-review | 1 +
.agents/skills/team-review-slim | 1 +
.claude/skills/connector-review/SKILL.md | 35 +-
.../skills/connector-review/agents/openai.yaml | 4 +-
.claude/skills/connector-sink/TEMPLATE.md | 2 +-
.claude/skills/team-review-slim/SKILL.md | 31 +-
.../skills/team-review-slim/agents/openai.yaml | 4 +-
.claude/skills/team-review/SKILL.md | 29 +-
.../skills/team-review/agents/openai.yaml | 4 +-
.claude/skills/team-review/references/execution.md | 80 ++
.github/workflows/_common.yml | 7 +-
.pre-commit-config.yaml | 2 +-
AGENTS.md | 20 +-
CONTRIBUTING.md | 22 +
Cargo.lock | 66 +-
Cargo.toml | 10 +-
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 8 +-
bdd/python/uv.lock | 2 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 13 +
core/common/src/traits/client.rs | 7 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 2 +-
core/connectors/sinks/doris_sink/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/rabbitmq_sink/Cargo.toml | 2 +-
core/connectors/sinks/redshift_sink/Cargo.toml | 2 +-
core/connectors/sinks/s3_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/http_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/consensus/src/client_table.rs | 214 ++---
core/consensus/src/impls.rs | 423 +++++++---
core/consensus/src/lib.rs | 2 +-
core/consensus/src/observability.rs | 36 +
core/integration/tests/cluster/partition_dedup.rs | 11 +
core/integration/tests/sdk/client_lifecycle.rs | 21 +-
core/message_bus/src/installer/tcp.rs | 4 +-
core/message_bus/src/lib.rs | 6 +-
core/message_bus/tests/duplicate_client_id.rs | 2 +-
core/partitions/src/iggy_partition.rs | 187 +++--
core/partitions/src/install_backup.rs | 42 +-
core/partitions/src/lib.rs | 4 +-
core/partitions/src/partition_storage.rs | 284 ++++++-
core/partitions/src/state_transfer.rs | 31 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/producer.rs | 242 +++++-
core/sdk/src/http/http_client.rs | 15 +-
core/sdk/src/quic/quic_client.rs | 7 +-
core/sdk/src/tcp/tcp_client.rs | 7 +-
core/sdk/src/vsr.rs | 28 +-
core/sdk/src/websocket/websocket_client.rs | 16 +-
core/server/Cargo.toml | 2 +-
core/server/README.md | 62 ++
core/server/src/boot/mod.rs | 15 -
core/server/src/boot/recovery.rs | 10 +-
core/server/src/dispatch/mod.rs | 7 +-
core/server/src/http/session.rs | 7 +-
core/server/src/http/state.rs | 43 +-
core/server/src/http/submit.rs | 6 +-
core/server/src/partition_helpers.rs | 888 +++++++++++++++++++--
core/server/src/partition_reconciler.rs | 84 +-
core/server/src/responses.rs | 2 +-
core/server/src/server_error.rs | 26 +
core/shard/src/builder.rs | 1 +
core/shard/src/coordinator.rs | 397 +++++----
core/shard/src/lib.rs | 57 +-
core/simulator/src/lib.rs | 316 +++++++-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/package-lock.json | 28 +-
examples/node/package.json | 4 +-
examples/python/uv.lock | 2 +-
.../VsrRequestOutcomeUnknownException.cs | 9 +-
.../Implementations/HttpMessageStream.cs | 9 +-
.../Implementations/TcpMessageStream.Vsr.cs | 13 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../Publishers/BackgroundMessageProcessor.cs | 5 +-
foreign/csharp/Iggy_SDK/Vsr/ConsensusSession.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 1 +
.../ClientTests/HttpTopicOptionsTests.cs | 19 +
.../Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs | 24 +
.../VsrTests/EndpointFailoverTests.cs | 45 ++
.../VsrTests/VsrProtocolDriftTests.cs | 3 +-
foreign/go/client/tcp/tcp_clients_management.go | 9 +
foreign/go/contracts/client.go | 4 +
foreign/go/contracts/version.go | 2 +-
foreign/go/errors/errors.yaml | 4 +
foreign/go/errors/errors_gen.go | 17 +
foreign/go/errors/errors_test.go | 6 +
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/go/internal/command/consumer_group_test.go | 130 +++
foreign/go/internal/command/offset_test.go | 120 +++
foreign/go/internal/command/partition_test.go | 89 +++
foreign/go/internal/command/system.go | 12 +
foreign/go/internal/command/system_test.go | 1 +
foreign/go/internal/vsr/envelope.go | 6 +-
foreign/go/tests/e2e_test.go | 38 +-
.../apache/iggy/client/async/tcp/PollRouter.java | 32 +-
.../client/async/tcp/vsr/VsrRequestEncoder.java | 5 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 6 +
.../AsyncIggyTcpClientTransientFailoverTest.java | 57 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 1 +
foreign/node/package-lock.json | 325 ++++----
foreign/node/package.json | 8 +-
foreign/node/src/wire/error.code.test.ts | 7 +
foreign/node/src/wire/error.code.ts | 1 +
foreign/node/src/wire/vsr/index.ts | 5 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 4 -
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 4 -
foreign/python/tests/test_connectivity.py | 17 +-
foreign/python/uv.lock | 2 +-
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 2 +
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 13 +-
gateways/kafka/docs/IDEMPOTENCE.md | 22 +-
gateways/kafka/src/bridge/error.rs | 21 +
scripts/ci/skills.sh | 104 ++-
web/package-lock.json | 383 ++++-----
web/package.json | 20 +-
151 files changed, 4157 insertions(+), 1435 deletions(-)
create mode 120000 .agents/skills/connector-review
create mode 120000 .agents/skills/connector-runtime
create mode 120000 .agents/skills/connector-sdk
create mode 120000 .agents/skills/connector-sink
create mode 120000 .agents/skills/connector-source
create mode 120000 .agents/skills/connector-testing
create mode 120000 .agents/skills/connector-transform
create mode 120000 .agents/skills/connectors-overview
create mode 120000 .agents/skills/team-review
create mode 120000 .agents/skills/team-review-slim
copy examples/java/gradle.properties => .claude/skills/connector-review/agents/openai.yaml (94%)
copy examples/java/gradle.properties => .claude/skills/team-review-slim/agents/openai.yaml (94%)
copy examples/java/gradle.properties => .claude/skills/team-review/agents/openai.yaml (94%)
create mode 100644 .claude/skills/team-review/references/execution.md
create mode 100644 foreign/go/internal/command/consumer_group_test.go
create mode 100644 foreign/go/internal/command/offset_test.go
create mode 100644 foreign/go/internal/command/partition_test.go