diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-02 08:55:50 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-02 08:55:50 +0200 |
| commit | 50a40f6e77e9f9a6f65e0596c789f67b91f6a6e1 (patch) | |
| tree | a1eff17c9d0d8afbf7eb55e9f2593c2647c5b62d /internal/server/continuous.go | |
| parent | bbbb7461d19e611e6fab3f24edd5f8e0d2d45b1e (diff) | |
Refactor server path to use injected runtime config (task 329)
Diffstat (limited to 'internal/server/continuous.go')
| -rw-r--r-- | internal/server/continuous.go | 12 |
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{ |
