Syncronization interval now set on config save. (#3421)

Этот коммит содержится в:
Christopher Speller
2016-06-28 15:10:50 -04:00
коммит произвёл Joram Wilander
родитель 22dcf00a3f
Коммит 8005911ff6
4 изменённых файлов: 12 добавлений и 6 удалений

Просмотреть файл

@@ -133,10 +133,6 @@ func main() {
complianceI.StartComplianceDailyJob()
}
if ldapI := einterfaces.GetLdapInterface(); ldapI != nil {
ldapI.StartLdapSyncJob()
}
// wait for kill signal before attempting to gracefully shutdown
// the running service
c := make(chan os.Signal)

Просмотреть файл

@@ -28,8 +28,11 @@ func removeTaskByName(name string) {
delete(tasks, name)
}
func getTaskByName(name string) *ScheduledTask {
return tasks[name]
func GetTaskByName(name string) *ScheduledTask {
if task, ok := tasks[name]; ok {
return task
}
return nil
}
func GetAllTasks() *map[string]*ScheduledTask {

Просмотреть файл

@@ -5,4 +5,5 @@ package model
const (
USER_AUTH_SERVICE_LDAP = "ldap"
LDAP_SYNC_TASK_NAME = "LDAP Syncronization"
)

Просмотреть файл

@@ -186,6 +186,12 @@ func LoadConfig(fileName string) {
Cfg = &config
ClientCfg = getClientConfig(Cfg)
// Actions that need to run every time the config is loaded
if ldapI := einterfaces.GetLdapInterface(); ldapI != nil {
// This restarts the job if nessisary (works for config reloads)
ldapI.StartLdapSyncJob()
}
}
func getClientConfig(c *model.Config) map[string]string {