summaryrefslogtreecommitdiff
path: root/internal/server/continuous.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-02 08:55:50 +0200
committerPaul Buetow <paul@buetow.org>2026-03-02 08:55:50 +0200
commit50a40f6e77e9f9a6f65e0596c789f67b91f6a6e1 (patch)
treea1eff17c9d0d8afbf7eb55e9f2593c2647c5b62d /internal/server/continuous.go
parentbbbb7461d19e611e6fab3f24edd5f8e0d2d45b1e (diff)
Refactor server path to use injected runtime config (task 329)
Diffstat (limited to 'internal/server/continuous.go')
-rw-r--r--internal/server/continuous.go12
1 files changed, 7 insertions, 5 deletions
diff --git a/internal/server/continuous.go b/internal/server/continuous.go
index ac5c686..90e5f8a 100644
--- a/internal/server/continuous.go
+++ b/internal/server/continuous.go
@@ -13,10 +13,12 @@ import (
gossh "golang.org/x/crypto/ssh"
)
-type continuous struct{}
+type continuous struct {
+ cfg config.RuntimeConfig
+}
-func newContinuous() *continuous {
- return &continuous{}
+func newContinuous(cfg config.RuntimeConfig) *continuous {
+ return &continuous{cfg: cfg}
}
func (c *continuous) start(ctx context.Context) {
@@ -26,7 +28,7 @@ func (c *continuous) start(ctx context.Context) {
}
func (c *continuous) runJobs(ctx context.Context) {
- for _, job := range config.Server.Continuous {
+ for _, job := range c.cfg.Server.Continuous {
if !job.Enable {
dlog.Server.Debug(job.Name, "Not running job as not enabled")
continue
@@ -53,7 +55,7 @@ func (c *continuous) runJob(ctx context.Context, job config.Continuous) {
outfile := fillDates(job.Outfile)
servers := strings.Join(job.Servers, ",")
if servers == "" {
- servers = config.Server.SSHBindAddress
+ servers = c.cfg.Server.SSHBindAddress
}
args := config.Args{