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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
