This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch skipping-offset
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a2f4aeff6 fix(server): initialize journal offset after restart to
prevent consumer message skip
add c19a600a8 feat(rust): add sans-IO frame codec and command dispatch
table (#2967)
add 707ab2435 chore(python): bump SDK to 0.7.4-dev1, modernize CI and deps
(#2992)
add 6180d88e6 feat(go): implement binary reader/writer (#2986)
add 329e62094 Merge branch 'master' into skipping-offset
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/post-merge/action.yml | 14 +-
core/binary_protocol/src/codec.rs | 58 +++
core/binary_protocol/src/codes.rs | 54 +--
core/binary_protocol/src/consensus/operation.rs | 89 ++--
core/binary_protocol/src/dispatch.rs | 450 +++++++++++++++++++++
core/binary_protocol/src/error.rs | 4 +-
core/binary_protocol/src/frame.rs | 32 --
core/binary_protocol/src/framing.rs | 289 +++++++++++++
core/binary_protocol/src/lib.rs | 28 +-
core/binary_protocol/src/message_view.rs | 11 +-
core/binary_protocol/src/primitives/identifier.rs | 19 +-
.../binary_protocol/src/primitives/partitioning.rs | 25 +-
.../src/requests/users/create_user.rs | 5 +-
.../src/requests/users/update_permissions.rs | 5 +-
.../src/responses/clients/client_response.rs | 2 +-
.../src/responses/clients/get_client.rs | 7 +-
.../consumer_groups/get_consumer_group.rs | 15 +-
.../src/responses/streams/get_stream.rs | 5 +-
.../src/responses/system/get_cluster_metadata.rs | 244 +++++++++++
.../{streams/create_stream.rs => system/get_me.rs} | 8 +-
.../login_user.rs => system/get_snapshot.rs} | 48 +--
.../src/responses/system/get_stats.rs | 7 +-
core/binary_protocol/src/responses/system/mod.rs | 6 +
.../src/responses/topics/get_topic.rs | 5 +-
foreign/go/internal/codec/reader.go | 217 ++++++++++
foreign/go/internal/codec/reader_test.go | 358 ++++++++++++++++
foreign/go/internal/codec/roundtrip_test.go | 105 +++++
foreign/go/internal/codec/writer.go | 151 +++++++
foreign/go/internal/codec/writer_test.go | 128 ++++++
foreign/python/Cargo.toml | 11 +-
foreign/python/pyproject.toml | 8 +-
foreign/python/uv.lock | 2 +-
32 files changed, 2186 insertions(+), 224 deletions(-)
create mode 100644 core/binary_protocol/src/dispatch.rs
delete mode 100644 core/binary_protocol/src/frame.rs
create mode 100644 core/binary_protocol/src/framing.rs
create mode 100644
core/binary_protocol/src/responses/system/get_cluster_metadata.rs
copy core/binary_protocol/src/responses/{streams/create_stream.rs =>
system/get_me.rs} (74%)
copy core/binary_protocol/src/responses/{users/login_user.rs =>
system/get_snapshot.rs} (56%)
create mode 100644 foreign/go/internal/codec/reader.go
create mode 100644 foreign/go/internal/codec/reader_test.go
create mode 100644 foreign/go/internal/codec/roundtrip_test.go
create mode 100644 foreign/go/internal/codec/writer.go
create mode 100644 foreign/go/internal/codec/writer_test.go
