This is an automated email from the ASF dual-hosted git repository.
gaoxingcun pushed a change to branch reconfiguration_scheduling
in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
from cd87976 Update README with project description
new 75f4f79 init commit
new 43b688a docs: add docs
new 4116025 feat: add somethings
new ed86475 feat
new d3e4b16 comment
new e7f23a3 feat: optimize
new 9788f7c add:The first version of the reconfiguration scheduling
new d43fbad modified:modify some architecture directories
new 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
The 9 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]
