This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch vsr_ts_sdk
in repository https://gitbox.apache.org/repos/asf/iggy.git
from ac7c9871a Merge branch 'master' into vsr_ts_sdk
add f72db6c1a fix
No new revisions were added by this update.
Summary of changes:
.github/actions/node-npm/pre-merge/action.yml | 49 +++-
.github/actions/utils/server-start/action.yml | 15 +-
.github/workflows/_test.yml | 4 +-
codecov.yml | 2 +-
foreign/node/README.md | 36 ++-
foreign/node/scripts/check-vsr-protocol.mjs | 111 ++++++---
foreign/node/src/client/client.connection.test.ts | 175 ++++++++++++-
foreign/node/src/client/client.connection.ts | 224 +++++++++++------
foreign/node/src/client/client.frame.test.ts | 35 ++-
foreign/node/src/client/client.frame.ts | 184 ++++++++++++--
foreign/node/src/client/client.socket.test.ts | 186 ++++++++++----
foreign/node/src/client/client.socket.ts | 150 ++++++++----
foreign/node/src/client/client.type.ts | 2 +
foreign/node/src/e2e/tcp.cluster.e2e.ts | 25 +-
foreign/node/src/index.ts | 6 +
foreign/node/src/stream/consumer-stream.ts | 9 +-
foreign/node/src/wire/command-set.ts | 2 -
foreign/node/src/wire/command.code.ts | 2 +-
.../src/wire/command.utils.test.ts} | 39 ++-
foreign/node/src/wire/command.utils.ts | 8 +-
.../wire/consumer-group/delete-group.command.ts | 19 +-
.../src/wire/consumer-group/get-group.command.ts | 16 +-
.../src/wire/consumer-group/join-group.command.ts | 19 +-
.../src/wire/consumer-group/leave-group.command.ts | 19 +-
.../src/wire/consumer-group/sync-group.command.ts | 3 +-
foreign/node/src/wire/error.code.test.ts | 40 +++
foreign/node/src/wire/error.code.ts | 30 +--
.../src/wire/message/poll-messages.command.test.ts | 271 ++++++++++++++++++++-
.../node/src/wire/message/poll-messages.command.ts | 189 +++++++++++---
foreign/node/src/wire/offset/get-offset.command.ts | 2 +-
foreign/node/src/wire/offset/offset.utils.ts | 4 +-
.../node/src/wire/offset/store-offset.command.ts | 2 +-
foreign/node/src/wire/vsr/index.ts | 20 +-
foreign/node/src/wire/vsr/namespace.test.ts | 15 ++
foreign/node/src/wire/vsr/namespace.ts | 8 +-
foreign/node/src/wire/vsr/reply.test.ts | 29 ++-
foreign/node/src/wire/vsr/reply.ts | 39 +--
foreign/node/src/wire/vsr/session.ts | 14 +-
38 files changed, 1538 insertions(+), 465 deletions(-)
copy foreign/{go/contracts/duration.go => node/src/wire/command.utils.test.ts}
(60%)
create mode 100644 foreign/node/src/wire/error.code.test.ts
