mirror of
https://github.com/ClusterCockpit/cc-backend
synced 2025-10-08 23:24:32 +02:00
.github
api
cmd
configs
init
internal
api
archiver
auth
config
graph
importer
metricDataDispatcher
metricdata
repository
routerConfig
taskManager
compressionService.go
ldapSyncService.go
retentionService.go
stopJobsExceedTime.go
taskManager.go
updateDurationService.go
updateFootprintService.go
util
pkg
tools
web
.gitignore
.goreleaser.yaml
LICENSE
Makefile
README.md
ReleaseNotes.md
go.mod
go.sum
gqlgen.yml
startDemo.sh
tools.go
Jan Eitzinger
801607fc16
Convert components to Singletons Restructure main package Reduce dependencies
37 lines
917 B
Go
37 lines
917 B
Go
// Copyright (C) NHR@FAU, University Erlangen-Nuremberg.
|
|
// All rights reserved.
|
|
// Use of this source code is governed by a MIT-style
|
|
// license that can be found in the LICENSE file.
|
|
package taskManager
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/ClusterCockpit/cc-backend/internal/auth"
|
|
"github.com/ClusterCockpit/cc-backend/pkg/log"
|
|
"github.com/go-co-op/gocron/v2"
|
|
)
|
|
|
|
func RegisterLdapSyncService(ds string) {
|
|
interval, err := parseDuration(ds)
|
|
if err != nil {
|
|
log.Warnf("Could not parse duration for sync interval: %v",
|
|
ds)
|
|
return
|
|
}
|
|
|
|
auth := auth.GetAuthInstance()
|
|
|
|
log.Info("Register LDAP sync service")
|
|
s.NewJob(gocron.DurationJob(interval),
|
|
gocron.NewTask(
|
|
func() {
|
|
t := time.Now()
|
|
log.Printf("ldap sync started at %s", t.Format(time.RFC3339))
|
|
if err := auth.LdapAuth.Sync(); err != nil {
|
|
log.Errorf("ldap sync failed: %s", err.Error())
|
|
}
|
|
log.Print("ldap sync done")
|
|
}))
|
|
}
|