feat(core): transport scheduler integration #19
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…uling of cyclic tasks 2. Supports JavA-compatible AES encryption and dynamic key management 3. Solve the problem of concurrent map access through one-time password preprocessing 4. Add comprehensive operation statistics and monitoring functions 5. manager message reception
zqr10159
approved these changes
Sep 27, 2025
Aias00
changed the title
yuluo-yx
reviewed
Sep 27, 2025
| @@ -1,58 +0,0 @@ | |||
| # | |||
yuluo-yx
reviewed
Sep 27, 2025
|
|
||
| .PHONY: go-lint | ||
| go-lint: ## run golang lint | ||
| @$(LOG_TARGET) |
yuluo-yx
reviewed
Sep 27, 2025
| @$(LOG_TARGET) | ||
| @version=$$(cat VERSION); \ | ||
| # todo; 添加交叉编译支持 | ||
| CGO_ENABLED=0 GOOS=$(GOOS) GOARCH=$(GOARCH) go build -o bin/collector -ldflags "$(GO_LDFLAGS)" cmd/main.go |
yuluo-yx
reviewed
Sep 27, 2025
| @@ -1,35 +0,0 @@ | |||
| # Licensed to the Apache Software Foundation (ASF) under one | |||
Member
There was a problem hiding this comment.
将此重构并移动到根目录？
我目前的想法是镜像的编译和打包在 GHA 中进行，脱离本地，并且同时支持多架构编译。并且这样的镜像体积比上面的小
yuluo-yx
reviewed
Sep 27, 2025
| strValue = "" // null values become empty strings | ||
| } else { | ||
| switch config.Type { | ||
| case 0: // number |
Member
There was a problem hiding this comment.
可以抽成常亮放在 types 里面，0 1 2 不具有语义和可读性
yuluo-yx
reviewed
Sep 27, 2025
| } else { | ||
| strValue = fmt.Sprintf("%v", config.Value) | ||
| } | ||
| case 1, 2: // string or password (both are now plain strings after preprocessing) |
yuluo-yx
reviewed
Sep 27, 2025
| Calculates []Calculate `json:"calculates"` | ||
| Units []Unit `json:"units"` | ||
| AliasFields []string `json:"aliasFields"` // Alternative field name | ||
| Calculates interface{} `json:"calculates"` // Can be []Calculate or []string |
yuluo-yx
reviewed
Sep 27, 2025
| driverName = "sqlserver" | ||
| } else if strings.Contains(databaseURL, "@tcp(") { | ||
| // MySQL DSN format (no protocol prefix) | ||
| driverName = "mysql" |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
4 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
1、fix the scheduling accuracy of critical time wheels and the rescheduling of cyclic tasks
2. Supports JavA-compatible AES encryption and dynamic key management
3. Solve the problem of concurrent map access through one-time password preprocessing
4. Add comprehensive operation statistics and monitoring functions
5. manager message reception
todo
1、Send the result to the manager after the task is completed.
...