This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch cg_port
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 6765299e3 Merge branch 'master' into cg_port
add 6deb7a218 code review changes
No new revisions were added by this update.
Summary of changes:
core/binary_protocol/src/consensus/operation.rs | 2 +
core/binary_protocol/src/dispatch.rs | 2 +
core/binary_protocol/src/lib.rs | 2 +-
core/binary_protocol/src/primitives/consumer.rs | 4 +-
core/common/src/traits/binary_impls/messages.rs | 36 +++++++---
core/integration/tests/data_integrity/mod.rs | 13 ++--
core/metadata/src/stm/consumer_group.rs | 95 ++++++++++++-------------
core/metadata/src/stm/mod.rs | 5 ++
core/metadata/src/stm/snapshot.rs | 1 -
core/metadata/src/stm/stream.rs | 72 ++++++++++++-------
core/metadata/src/stm/user.rs | 5 ++
core/server-ng/src/consumer_group.rs | 77 ++++++++------------
core/server-ng/src/dispatch.rs | 10 +--
core/server-ng/src/responses.rs | 6 +-
14 files changed, 188 insertions(+), 142 deletions(-)
