This is an automated email from the ASF dual-hosted git repository.
gaoxingcun pushed a commit to branch feature/transport-scheduler-integration
in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
The following commit(s) were added to
refs/heads/feature/transport-scheduler-integration by this push:
new 818944a modified: 1、Use the key when deleting the test. 2、Reset the
order of magnitude of the request time.
818944a is described below
commit 818944ad4c9c538d24afa356efded5925bad637e
Author: TJxiaobao <[email protected]>
AuthorDate: Sat Sep 27 18:04:48 2025 +0800
modified:
1、Use the key when deleting the test.
2、Reset the order of magnitude of the request time.
---
internal/collector/common/dispatcher/time_wheel.go | 6 ++----
internal/util/param/param_replacer.go | 6 ------
2 files changed, 2 insertions(+), 10 deletions(-)
diff --git a/internal/collector/common/dispatcher/time_wheel.go
b/internal/collector/common/dispatcher/time_wheel.go
index 7940482..d8c7aa1 100644
--- a/internal/collector/common/dispatcher/time_wheel.go
+++ b/internal/collector/common/dispatcher/time_wheel.go
@@ -122,14 +122,12 @@ func (td *TimeDispatch) AddJob(job *jobtypes.Job) error {
// Calculate delay
var delay time.Duration
if job.DefaultInterval > 0 {
- // Manager sends interval in seconds, use it directly
- delay = time.Duration(job.DefaultInterval) * time.Second
- // Delay calculation - debug level only
+ delay = time.Duration(job.DefaultInterval) * time.Millisecond
td.logger.V(1).Info("calculated delay",
"interval", job.DefaultInterval,
"delay", delay)
} else {
- delay = 30 * time.Second // default interval
+ delay = 10 * time.Second
}
// Create timeout
diff --git a/internal/util/param/param_replacer.go
b/internal/util/param/param_replacer.go
index 88e1c14..ff6a944 100644
--- a/internal/util/param/param_replacer.go
+++ b/internal/util/param/param_replacer.go
@@ -385,12 +385,6 @@ func (r *Replacer) decryptPassword(encryptedPassword
string) (string, error) {
return result, nil
}
- // Last resort: known password mapping for testing
- if encryptedPassword == "uecgmMb8ZA0/H1HF/hD2gA==" {
- log.Info("using known password mapping for testing", "input",
encryptedPassword)
- return "231013", nil
- }
-
// If all decryption attempts fail, return original value to allow
system to continue
log.Info("all decryption attempts failed, using original value")
return encryptedPassword, nil
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
