This is an automated email from the ASF dual-hosted git repository.
zhaoqingran pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
from cd87976 Update README with project description
add 75f4f79 init commit
add 43b688a docs: add docs
add 4116025 feat: add somethings
add ed86475 feat
add d3e4b16 comment
add e7f23a3 feat: optimize
add 9788f7c add:The first version of the reconfiguration scheduling
add d43fbad modified:modify some architecture directories
add 26d4f53 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
new 21ea8b5 Merge pull request #2 from apache/reconfiguration_scheduling
The 1 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:
.gitignore | 51 ++
.go-version | 1 +
api/{message.pb.go => cluster_msg.pb.go} | 94 +--
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, 8952 insertions(+), 125 deletions(-)
create mode 100644 .gitignore
create mode 100644 .go-version
copy api/{message.pb.go => cluster_msg.pb.go} (72%)
create mode 100644 api/cluster_msg.proto
create mode 100644 docs/ARCHITECTURE_COMPARISON.md
create mode 100644 docs/SCHEDULING_ARCHITECTURE.md
create mode 100644 examples/main_simulation.go
create mode 100644 pkg/collector/basic/abstract_collect.go
create mode 100644 pkg/collector/basic/database/jdbc_auto_register.go
create mode 100644 pkg/collector/basic/database/jdbc_collector.go
create mode 100644 pkg/collector/basic/database/jdbc_collector_test.go
create mode 100644 pkg/collector/collect_service.go
create mode 100644 pkg/collector/common/dispatcher/entrance/client.go
create mode 100644
pkg/collector/common/dispatcher/entrance/collect_job_service.go
create mode 100644
pkg/collector/common/dispatcher/entrance/collect_job_service_test.go
create mode 100644 pkg/collector/common/dispatcher/entrance/collect_server.go
create mode 100644 pkg/collector/common/dispatcher/entrance/config.go
create mode 100644
pkg/collector/common/dispatcher/entrance/mysql_scheduling_test.go
create mode 100644 pkg/collector/common/dispatcher/entrance/processors.go
create mode 100644 pkg/collector/common/timer/timer_dispatcher.go
create mode 100644 pkg/collector/common/timer/timer_dispatcher_test.go
create mode 100644 pkg/collector/common/timer/timer_wheel.go
create mode 100644 pkg/collector/common/timer/timer_wheel_test.go
create mode 100644 pkg/collector/common/timer/wheel_timer_task.go
create mode 100644 pkg/collector/registry.go
create mode 100644 pkg/collector/registry/registry_center.go
create mode 100644 pkg/collector/worker/metrics_collect.go
create mode 100644 pkg/collector/worker/metrics_collect_integration_test.go
create mode 100644 pkg/collector/worker/task_queue.go
create mode 100644 pkg/collector/worker/task_queue_test.go
create mode 100644 pkg/collector/worker/worker_pool.go
create mode 100644 pkg/collector/worker/worker_pool_test.go
create mode 100644 pkg/types/job/metrics_types.go
create mode 100644 pkg/types/job/timeout_types.go
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
