You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hertzbeat.apache.org by ga...@apache.org on 2025/09/03 05:08:05 UTC
(hertzbeat-collector-go) 09/09: Merge branch 'main' into scheduling # Conflicts: # README.md # go.mod # go.sum # pkg/banner/embed.go # pkg/collector/bootstrap.go # pkg/types/job/job_types.go
This is an automated email from the ASF dual-hosted git repository.
gaoxingcun pushed a commit to branch reconfiguration_scheduling
in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
commit 26d4f53c01b466d9f81ac1bd41f16fc9599b69f1
Merge: cd87976 d43fbad
Author: TJxiaobao <29...@qq.com>
AuthorDate: Wed Sep 3 13:07:38 2025 +0800
Merge branch 'main' into scheduling
# Conflicts:
# README.md
# go.mod
# go.sum
# pkg/banner/embed.go
# pkg/collector/bootstrap.go
# pkg/types/job/job_types.go
.gitignore | 51 ++
.go-version | 1 +
api/cluster_msg.pb.go | 319 +++++++++++
api/cluster_msg.proto | 64 +++
docs/ARCHITECTURE_COMPARISON.md | 255 +++++++++
docs/SCHEDULING_ARCHITECTURE.md | 533 +++++++++++++++++
examples/main_simulation.go | 289 ++++++++++
go.mod | 13 +-
go.sum | 38 ++
pkg/banner/embed.go | 24 +-
pkg/collector/basic/abstract_collect.go | 108 ++++
pkg/collector/basic/database/jdbc_auto_register.go | 36 ++
pkg/collector/basic/database/jdbc_collector.go | 455 +++++++++++++++
.../basic/database/jdbc_collector_test.go | 165 ++++++
pkg/collector/bootstrap.go | 119 ++--
pkg/collector/collect_service.go | 341 +++++++++++
pkg/collector/common/dispatcher/entrance/client.go | 473 ++++++++++++++++
.../dispatcher/entrance/collect_job_service.go | 299 ++++++++++
.../entrance/collect_job_service_test.go | 193 +++++++
.../common/dispatcher/entrance/collect_server.go | 367 ++++++++++++
pkg/collector/common/dispatcher/entrance/config.go | 69 +++
.../dispatcher/entrance/mysql_scheduling_test.go | 380 +++++++++++++
.../common/dispatcher/entrance/processors.go | 248 ++++++++
pkg/collector/common/timer/timer_dispatcher.go | 630 +++++++++++++++++++++
.../common/timer/timer_dispatcher_test.go | 334 +++++++++++
pkg/collector/common/timer/timer_wheel.go | 326 +++++++++++
pkg/collector/common/timer/timer_wheel_test.go | 241 ++++++++
pkg/collector/common/timer/wheel_timer_task.go | 223 ++++++++
pkg/collector/registry.go | 63 +++
pkg/collector/registry/registry_center.go | 251 ++++++++
pkg/collector/worker/metrics_collect.go | 419 ++++++++++++++
.../worker/metrics_collect_integration_test.go | 236 ++++++++
pkg/collector/worker/task_queue.go | 334 +++++++++++
pkg/collector/worker/task_queue_test.go | 257 +++++++++
pkg/collector/worker/worker_pool.go | 363 ++++++++++++
pkg/collector/worker/worker_pool_test.go | 294 ++++++++++
pkg/types/job/job_types.go | 78 ++-
pkg/types/job/metrics_types.go | 313 ++++++++++
pkg/types/job/timeout_types.go | 100 ++++
39 files changed, 9224 insertions(+), 78 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@hertzbeat.apache.org
For additional commands, e-mail: dev-help@hertzbeat.apache.org