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 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
add 21ea8b5 Merge pull request #2 from apache/reconfiguration_scheduling
add 40a42a8 Create .asf.yaml for project configuration
add 8865a22 feat: add infra (#3)
add 89ad09e refactor: refactor pro struct (#6)
new 165ed67 add:The first version of the modified schedule
add d9ec038 docs(core): update contributor guides and add Chinese version
(#7)
add 6f38aaa chore(core): update Dockerfile for multi-stage build and
clean up README (#8)
add fe338d7 feat: optimize something (#9)
new bf3778c Merge branch 'main' of
https://github.com/apache/hertzbeat-collector-go
new 8e63c7f add:All protocols are initialized using the init function.
The 3 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:
.asf.yaml | 63 +++
.github/ISSUE_TEMPLATE/bug_report.yml | 78 +++
.github/ISSUE_TEMPLATE/config.yml | 22 +
.github/ISSUE_TEMPLATE/feature_request.yml | 59 ++
.github/ISSUE_TEMPLATE/question.yml | 35 ++
.github/ISSUE_TEMPLATE/task.yml | 42 ++
.github/PULL_REQUEST_TEMPLATED.md | 14 +
.github/dependbot.yml | 31 +
.github/workflows/build-and-test.yml | 42 ++
.github/workflows/invalid-issue-check.yml | 41 ++
.github/workflows/license-check.yml | 33 ++
.github/workflows/lint-pr-title.yml | 65 +++
.github/workflows/linter.yml | 35 ++
.github/workflows/pull-request-robot.yml | 33 ++
.github/workflows/secret-check.yml | 33 ++
.gitignore | 4 +-
.go-version | 1 -
CODE_OF_CONDUCT.md | 76 +++
CONTRIBUTING-CN.md | 132 +++++
CONTRIBUTING.md | 169 ++++++
Dockerfile | 64 ++-
Makefile | 85 +--
NOTICE | 5 +
README-CN.md | 58 ++
README.md | 59 +-
Roadmap.md | 12 +
SECURITY.md | 22 +
api/cluster_msg.pb.go | 94 +--
api/cluster_msg.proto | 12 +-
api/message.pb.go | 319 -----------
api/message.proto | 64 ---
cmd/collector/hertzbeat-collector.yaml | 8 -
cmd/collector/main.go | 26 -
cmd/main.go | 33 ++
cmd/root/root.go | 40 ++
docker-compose.yml | 32 ++
docs/ARCHITECTURE_COMPARISON.md | 20 +
docs/GO_STYLE.md | 366 ++++++++++++
docs/SCHEDULING_ARCHITECTURE.md | 38 ++
docs/img/arch.png | Bin 0 -> 79707 bytes
etc/hertzbeat-collector.yaml | 25 +
examples/main_simulation.go | 289 ----------
go.mod | 3 +
go.sum | 8 +
{pkg => internal}/banner/banner.txt | 3 +-
internal/banner/embed.go | 83 +++
internal/cmd/server.go | 178 ++++++
internal/cmd/version.go | 44 ++
internal/cmd/version/version.go | 74 +++
.../collector/basic/database/jdbc_collector.go | 87 ++-
.../basic/database/jdbc_collector_test.go | 182 ++++++
.../basic => internal/collector/basic/dns}/.keep | 0
.../collector/basic/ftp}/.keep | 0
.../dns => internal/collector/basic/http}/.keep | 0
.../ftp => internal/collector/basic/icmp}/.keep | 0
.../http => internal/collector/basic/imap}/.keep | 0
internal/collector/basic/init.go | 56 ++
.../icmp => internal/collector/basic/ipmi2}/.keep | 0
.../imap => internal/collector/basic/jmx}/.keep | 0
.../collector/basic/memcached}/.keep | 0
.../jmx => internal/collector/basic/modbus}/.keep | 0
.../collector/basic/mqtt}/.keep | 0
.../collector/basic/nginx}/.keep | 0
.../mqtt => internal/collector/basic/ntp}/.keep | 0
.../nginx => internal/collector/basic/plc}/.keep | 0
.../ntp => internal/collector/basic/pop3}/.keep | 0
.../collector/basic/prometheus}/.keep | 0
.../pop3 => internal/collector/basic/push}/.keep | 0
.../collector/basic/redfish}/.keep | 0
.../push => internal/collector/basic/redis}/.keep | 0
.../redfish => internal/collector/basic/s7}/.keep | 0
.../collector/basic/script}/.keep | 0
.../registry => internal/collector/basic/sd}/.keep | 0
.../s7 => internal/collector/basic/smtp}/.keep | 0
.../script => internal/collector/basic/snmp}/.keep | 0
.../sd => internal/collector/basic/ssh}/.keep | 0
.../smtp => internal/collector/basic/telnet}/.keep | 0
.../snmp => internal/collector/basic/udp}/.keep | 0
.../collector/basic/websocket}/.keep | 0
.../collector/common/cache}/.keep | 0
.../collector/common/collect/dispatch}/.keep | 0
.../common/collect/dispatch/metrics_collector.go | 141 +++++
.../collect/metrics/hertzbeat_metrics_collector.go | 17 +
.../collector/common/collect/result_handler.go | 77 +++
.../common/collect/strategy/strategy_factory.go | 129 +++++
.../common/dispatcher/common_dispatcher.go | 244 ++++++++
.../collector/common/dispatcher/entrance}/.keep | 0
.../collector/common/dispatcher/exporter}/.keep | 0
.../common/dispatcher/hashed_wheel_timer.go | 226 ++++++++
internal/collector/common/dispatcher/time_wheel.go | 223 ++++++++
.../common/dispatcher/wheel_timer_task.go | 105 ++++
internal/collector/common/job/job_server.go | 207 +++++++
internal/collector/common/server/server.go | 54 ++
internal/collector/common/server/server_test.go | 18 +
.../collector/common/ssh}/.keep | 0
internal/collector/common/transport/transport.go | 67 +++
.../common/types/collector/collector_types.go | 24 +
.../collector/common/types/config/config_types.go | 38 ++
internal/collector/common/types/err/error_types.go | 36 ++
.../collector/common}/types/job/job_types.go | 21 +-
.../collector/common}/types/job/metrics_types.go | 0
.../types/job/protocol/common_request_protocol.go | 33 ++
.../types/job/protocol/consul_sd_protocol.go | 52 ++
.../common}/types/job/protocol/ssh_protocol.go | 17 +
.../types/job/protocol/zookeeper_sd_protocol.go | 58 ++
.../collector/common}/types/job/timeout_types.go | 18 +-
.../common/types/logger}/logging_types.go | 33 +-
internal/collector/config/config.go | 107 ++++
internal/collector/config/config_test.go | 18 +
.../collector/extension/kafka}/.keep | 0
.../collector/extension/mongodb}/.keep | 0
.../collector/extension/nebulagraph}/.keep | 0
.../collector/extension/rocketmq}/.keep | 0
internal/constants/const.go | 44 ++
{pkg => internal/util}/logger/logger.go | 56 +-
{pkg => internal/util}/logger/logger_test.go | 40 +-
internal/util/timer/timer.go | 27 +
pkg/banner/embed.go | 64 ---
pkg/collector/basic/abstract_collect.go | 108 ----
pkg/collector/basic/database/jdbc_auto_register.go | 36 --
.../basic/database/jdbc_collector_test.go | 165 ------
pkg/collector/bootstrap.go | 116 ----
pkg/collector/collect_service.go | 341 -----------
.../common/collect/strategy/strategy_factory.go | 39 --
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/job/job_server.go | 28 -
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/common/transport/transport.go | 42 --
pkg/collector/config/config.go | 118 ----
pkg/collector/config/config_test.go | 45 --
pkg/collector/extension/nebulagraph/.keep | 0
pkg/collector/extension/rocketmq/.keep | 0
pkg/collector/registry.go | 63 ---
pkg/collector/registry/registry_center.go | 251 --------
pkg/collector/server/server.go | 69 ---
pkg/collector/server/server_test.go | 1 -
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/constants/const.go | 27 -
pkg/types/config_types.go | 21 -
pkg/types/job/protocol/common_request_protocol.go | 16 -
pkg/types/job/protocol/consul_sd_protocol.go | 33 --
pkg/types/job/protocol/zookeeper_sd_protocol.go | 41 --
pkg/util/.keep | 0
tools/ci-config/labeler.yml | 50 ++
tools/github-actions/setup-deps/action.yml | 31 +
tools/linter/codespell/.codespell.ignorewords | 1 +
tools/linter/codespell/.codespell.skip | 4 +
tools/linter/golang-ci/.golangci.yml | 130 +++++
tools/linter/license/.licenserc.yaml | 73 +++
.../linter/markdownlint/markdown_lint_config.yaml | 46 ++
tools/linter/yamllint/.yamllint | 76 +++
tools/make/common.mk | 39 ++
Makefile => tools/make/golang.mk | 58 +-
tools/make/linter.mk | 80 +++
tools/make/tools.mk | 61 ++
tools/scripts/new-line-check.py | 112 ++++
171 files changed, 5373 insertions(+), 8225 deletions(-)
create mode 100644 .asf.yaml
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
create mode 100644 .github/ISSUE_TEMPLATE/config.yml
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.yml
create mode 100644 .github/ISSUE_TEMPLATE/question.yml
create mode 100644 .github/ISSUE_TEMPLATE/task.yml
create mode 100644 .github/PULL_REQUEST_TEMPLATED.md
create mode 100644 .github/dependbot.yml
create mode 100644 .github/workflows/build-and-test.yml
create mode 100644 .github/workflows/invalid-issue-check.yml
create mode 100644 .github/workflows/license-check.yml
create mode 100644 .github/workflows/lint-pr-title.yml
create mode 100644 .github/workflows/linter.yml
create mode 100644 .github/workflows/pull-request-robot.yml
create mode 100644 .github/workflows/secret-check.yml
delete mode 100644 .go-version
create mode 100644 CODE_OF_CONDUCT.md
create mode 100644 CONTRIBUTING-CN.md
create mode 100644 CONTRIBUTING.md
create mode 100644 NOTICE
create mode 100644 README-CN.md
create mode 100644 Roadmap.md
create mode 100644 SECURITY.md
delete mode 100644 api/message.pb.go
delete mode 100644 api/message.proto
delete mode 100644 cmd/collector/hertzbeat-collector.yaml
delete mode 100644 cmd/collector/main.go
create mode 100644 cmd/main.go
create mode 100644 cmd/root/root.go
create mode 100644 docker-compose.yml
create mode 100644 docs/GO_STYLE.md
create mode 100644 docs/img/arch.png
create mode 100644 etc/hertzbeat-collector.yaml
delete mode 100644 examples/main_simulation.go
rename {pkg => internal}/banner/banner.txt (77%)
create mode 100644 internal/banner/embed.go
create mode 100644 internal/cmd/server.go
create mode 100644 internal/cmd/version.go
create mode 100644 internal/cmd/version/version.go
rename {pkg => internal}/collector/basic/database/jdbc_collector.go (79%)
create mode 100644 internal/collector/basic/database/jdbc_collector_test.go
rename {pkg/collector/basic => internal/collector/basic/dns}/.keep (100%)
rename {pkg/collector/basic/database => internal/collector/basic/ftp}/.keep
(100%)
rename {pkg/collector/basic/dns => internal/collector/basic/http}/.keep (100%)
rename {pkg/collector/basic/ftp => internal/collector/basic/icmp}/.keep (100%)
rename {pkg/collector/basic/http => internal/collector/basic/imap}/.keep (100%)
create mode 100644 internal/collector/basic/init.go
rename {pkg/collector/basic/icmp => internal/collector/basic/ipmi2}/.keep
(100%)
rename {pkg/collector/basic/imap => internal/collector/basic/jmx}/.keep (100%)
rename {pkg/collector/basic/ipmi2 => internal/collector/basic/memcached}/.keep
(100%)
rename {pkg/collector/basic/jmx => internal/collector/basic/modbus}/.keep
(100%)
rename {pkg/collector/basic/memcached => internal/collector/basic/mqtt}/.keep
(100%)
rename {pkg/collector/basic/modbus => internal/collector/basic/nginx}/.keep
(100%)
rename {pkg/collector/basic/mqtt => internal/collector/basic/ntp}/.keep (100%)
rename {pkg/collector/basic/nginx => internal/collector/basic/plc}/.keep (100%)
rename {pkg/collector/basic/ntp => internal/collector/basic/pop3}/.keep (100%)
rename {pkg/collector/basic/plc => internal/collector/basic/prometheus}/.keep
(100%)
rename {pkg/collector/basic/pop3 => internal/collector/basic/push}/.keep (100%)
rename {pkg/collector/basic/prometheus =>
internal/collector/basic/redfish}/.keep (100%)
rename {pkg/collector/basic/push => internal/collector/basic/redis}/.keep
(100%)
rename {pkg/collector/basic/redfish => internal/collector/basic/s7}/.keep
(100%)
rename {pkg/collector/basic/redis => internal/collector/basic/script}/.keep
(100%)
rename {pkg/collector/basic/registry => internal/collector/basic/sd}/.keep
(100%)
rename {pkg/collector/basic/s7 => internal/collector/basic/smtp}/.keep (100%)
rename {pkg/collector/basic/script => internal/collector/basic/snmp}/.keep
(100%)
rename {pkg/collector/basic/sd => internal/collector/basic/ssh}/.keep (100%)
rename {pkg/collector/basic/smtp => internal/collector/basic/telnet}/.keep
(100%)
rename {pkg/collector/basic/snmp => internal/collector/basic/udp}/.keep (100%)
rename {pkg/collector/basic/ssh => internal/collector/basic/websocket}/.keep
(100%)
rename {pkg/collector/basic/telnet => internal/collector/common/cache}/.keep
(100%)
rename {pkg/collector/basic/udp =>
internal/collector/common/collect/dispatch}/.keep (100%)
create mode 100644
internal/collector/common/collect/dispatch/metrics_collector.go
rename {pkg =>
internal}/collector/common/collect/metrics/hertzbeat_metrics_collector.go (70%)
create mode 100644 internal/collector/common/collect/result_handler.go
create mode 100644
internal/collector/common/collect/strategy/strategy_factory.go
create mode 100644 internal/collector/common/dispatcher/common_dispatcher.go
rename {pkg/collector/basic/websocket =>
internal/collector/common/dispatcher/entrance}/.keep (100%)
rename {pkg/collector/common/cache =>
internal/collector/common/dispatcher/exporter}/.keep (100%)
create mode 100644 internal/collector/common/dispatcher/hashed_wheel_timer.go
create mode 100644 internal/collector/common/dispatcher/time_wheel.go
create mode 100644 internal/collector/common/dispatcher/wheel_timer_task.go
create mode 100644 internal/collector/common/job/job_server.go
create mode 100644 internal/collector/common/server/server.go
create mode 100644 internal/collector/common/server/server_test.go
rename {pkg/collector/common/collect/dispatch =>
internal/collector/common/ssh}/.keep (100%)
create mode 100644 internal/collector/common/transport/transport.go
create mode 100644 internal/collector/common/types/collector/collector_types.go
create mode 100644 internal/collector/common/types/config/config_types.go
create mode 100644 internal/collector/common/types/err/error_types.go
rename {pkg => internal/collector/common}/types/job/job_types.go (68%)
rename {pkg => internal/collector/common}/types/job/metrics_types.go (100%)
create mode 100644
internal/collector/common/types/job/protocol/common_request_protocol.go
create mode 100644
internal/collector/common/types/job/protocol/consul_sd_protocol.go
rename {pkg => internal/collector/common}/types/job/protocol/ssh_protocol.go
(65%)
create mode 100644
internal/collector/common/types/job/protocol/zookeeper_sd_protocol.go
rename {pkg => internal/collector/common}/types/job/timeout_types.go (89%)
rename {pkg/types => internal/collector/common/types/logger}/logging_types.go
(51%)
create mode 100644 internal/collector/config/config.go
create mode 100644 internal/collector/config/config_test.go
rename {pkg/collector/common/dispatcher/exporter =>
internal/collector/extension/kafka}/.keep (100%)
rename {pkg/collector/common/ssh =>
internal/collector/extension/mongodb}/.keep (100%)
rename {pkg/collector/extension/kafka =>
internal/collector/extension/nebulagraph}/.keep (100%)
rename {pkg/collector/extension/mongodb =>
internal/collector/extension/rocketmq}/.keep (100%)
create mode 100644 internal/constants/const.go
rename {pkg => internal/util}/logger/logger.go (57%)
rename {pkg => internal/util}/logger/logger_test.go (56%)
create mode 100644 internal/util/timer/timer.go
delete mode 100644 pkg/banner/embed.go
delete mode 100644 pkg/collector/basic/abstract_collect.go
delete mode 100644 pkg/collector/basic/database/jdbc_auto_register.go
delete mode 100644 pkg/collector/basic/database/jdbc_collector_test.go
delete mode 100644 pkg/collector/bootstrap.go
delete mode 100644 pkg/collector/collect_service.go
delete mode 100644 pkg/collector/common/collect/strategy/strategy_factory.go
delete mode 100644 pkg/collector/common/dispatcher/entrance/client.go
delete mode 100644
pkg/collector/common/dispatcher/entrance/collect_job_service.go
delete mode 100644
pkg/collector/common/dispatcher/entrance/collect_job_service_test.go
delete mode 100644 pkg/collector/common/dispatcher/entrance/collect_server.go
delete mode 100644 pkg/collector/common/dispatcher/entrance/config.go
delete mode 100644
pkg/collector/common/dispatcher/entrance/mysql_scheduling_test.go
delete mode 100644 pkg/collector/common/dispatcher/entrance/processors.go
delete mode 100644 pkg/collector/common/job/job_server.go
delete mode 100644 pkg/collector/common/timer/timer_dispatcher.go
delete mode 100644 pkg/collector/common/timer/timer_dispatcher_test.go
delete mode 100644 pkg/collector/common/timer/timer_wheel.go
delete mode 100644 pkg/collector/common/timer/timer_wheel_test.go
delete mode 100644 pkg/collector/common/timer/wheel_timer_task.go
delete mode 100644 pkg/collector/common/transport/transport.go
delete mode 100644 pkg/collector/config/config.go
delete mode 100644 pkg/collector/config/config_test.go
delete mode 100644 pkg/collector/extension/nebulagraph/.keep
delete mode 100644 pkg/collector/extension/rocketmq/.keep
delete mode 100644 pkg/collector/registry.go
delete mode 100644 pkg/collector/registry/registry_center.go
delete mode 100644 pkg/collector/server/server.go
delete mode 100644 pkg/collector/server/server_test.go
delete mode 100644 pkg/collector/worker/metrics_collect.go
delete mode 100644 pkg/collector/worker/metrics_collect_integration_test.go
delete mode 100644 pkg/collector/worker/task_queue.go
delete mode 100644 pkg/collector/worker/task_queue_test.go
delete mode 100644 pkg/collector/worker/worker_pool.go
delete mode 100644 pkg/collector/worker/worker_pool_test.go
delete mode 100644 pkg/constants/const.go
delete mode 100644 pkg/types/config_types.go
delete mode 100644 pkg/types/job/protocol/common_request_protocol.go
delete mode 100644 pkg/types/job/protocol/consul_sd_protocol.go
delete mode 100644 pkg/types/job/protocol/zookeeper_sd_protocol.go
delete mode 100644 pkg/util/.keep
create mode 100644 tools/ci-config/labeler.yml
create mode 100644 tools/github-actions/setup-deps/action.yml
create mode 100644 tools/linter/codespell/.codespell.ignorewords
create mode 100644 tools/linter/codespell/.codespell.skip
create mode 100644 tools/linter/golang-ci/.golangci.yml
create mode 100644 tools/linter/license/.licenserc.yaml
create mode 100644 tools/linter/markdownlint/markdown_lint_config.yaml
create mode 100644 tools/linter/yamllint/.yamllint
create mode 100644 tools/make/common.mk
copy Makefile => tools/make/golang.mk (59%)
create mode 100644 tools/make/linter.mk
create mode 100644 tools/make/tools.mk
create mode 100644 tools/scripts/new-line-check.py
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@hertzbeat.apache.org
For additional commands, e-mail: notifications-h...@hertzbeat.apache.org
