This is an automated email from the ASF dual-hosted git repository.
gaoxingcun pushed a change to branch feature/transport-scheduler-integration
in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
from b6c19f9 feat(core): transport logic (#12)
add 165ed67 add:The first version of the modified schedule
add bf3778c Merge branch 'main' of
https://github.com/apache/hertzbeat-collector-go
new f8a531c resolve conflicts
new 035c808 Merge branch 'main' of
https://github.com/apache/hertzbeat-collector-go
add d3b454b Fix header formatting in README.md (#17)
add 1ca081a fix(transport): fix transport, hertzbeat (#18)
new f5db54b Merge branch 'main' of
https://github.com/apache/hertzbeat-collector-go
new aaf7e1c 1、fix the scheduling accuracy of critical time wheels and the
rescheduling of cyclic tasks 2. Supports JavA-compatible AES encryption and
dynamic key management 3. Solve the problem of concurrent map access through
one-time password preprocessing 4. Add comprehensive operation statistics and
monitoring functions 5. manager message reception
The 4 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:
.github/workflows/lint-pr-title.yml | 1 +
Dockerfile | 63 ++++
Makefile | 11 +-
README.md | 2 +-
.../docker-compose.yml => docker-compose.yml | 4 +-
examples/main.go | 10 +-
internal/cmd/server.go | 19 +-
.../collector/basic/database/jdbc_collector.go | 105 +++---
.../common/collect/dispatch/metrics_collector.go | 10 +-
.../collector/common/collect/result_handler.go | 9 +-
.../common/collect/strategy/strategy_factory.go | 9 -
.../common/dispatcher/common_dispatcher.go | 67 +++-
.../common/dispatcher/hashed_wheel_timer.go | 41 ++-
internal/collector/common/dispatcher/time_wheel.go | 319 ++++++++++++++++-
.../common/dispatcher/wheel_timer_task.go | 57 ++-
internal/collector/common/router/message_router.go | 269 ++++++++++++++
internal/collector/common/transport/transport.go | 28 +-
internal/collector/common/types/job/job_types.go | 9 +-
.../collector/common/types/job/metrics_types.go | 111 ++++--
internal/transport/netty_client.go | 210 +++++++----
internal/transport/processors.go | 299 ++++++++++++++--
internal/util/crypto/aes_util.go | 194 ++++++++++
internal/util/param/param_replacer.go | 397 +++++++++++++++++++++
tools/docker/hcg/Dockerfile | 35 --
tools/make/golang.mk | 22 +-
tools/make/image.mk | 58 ---
26 files changed, 1983 insertions(+), 376 deletions(-)
create mode 100644 Dockerfile
rename tools/docker/docker-compose/docker-compose.yml => docker-compose.yml
(93%)
create mode 100644 internal/collector/common/router/message_router.go
create mode 100644 internal/util/crypto/aes_util.go
create mode 100644 internal/util/param/param_replacer.go
delete mode 100644 tools/docker/hcg/Dockerfile
delete mode 100644 tools/make/image.mk
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
