diff options
author | George Goldberg <george@gberg.me> | 2017-09-28 17:11:13 +0100 |
---|---|---|
committer | Corey Hulen <corey@hulen.com> | 2017-09-28 09:11:13 -0700 |
commit | a06830b2f88a8d374c326a1191870cbc7cf7dac2 (patch) | |
tree | 4879ce49de061fba894fe01b54db701c639f0e94 /jobs/testscheduler.go | |
parent | f263d2b9510fb557fe075dee5097cb32e2b1e5e2 (diff) | |
download | chat-a06830b2f88a8d374c326a1191870cbc7cf7dac2.tar.gz chat-a06830b2f88a8d374c326a1191870cbc7cf7dac2.tar.bz2 chat-a06830b2f88a8d374c326a1191870cbc7cf7dac2.zip |
PLT-7644: Improve job scheduler architecture. (#7532)
Diffstat (limited to 'jobs/testscheduler.go')
-rw-r--r-- | jobs/testscheduler.go | 58 |
1 files changed, 0 insertions, 58 deletions
diff --git a/jobs/testscheduler.go b/jobs/testscheduler.go deleted file mode 100644 index d7345f67f..000000000 --- a/jobs/testscheduler.go +++ /dev/null @@ -1,58 +0,0 @@ -// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved. -// See License.txt for license information. - -package jobs - -import ( - "time" - - l4g "github.com/alecthomas/log4go" -) - -type TestScheduler struct { - name string - jobType string - stop chan bool - stopped chan bool -} - -func MakeTestScheduler(name string, jobType string) *TestScheduler { - return &TestScheduler{ - name: name, - jobType: jobType, - stop: make(chan bool, 1), - stopped: make(chan bool, 1), - } -} - -func (scheduler *TestScheduler) Run() { - l4g.Debug("Scheduler %v: Started", scheduler.name) - - defer func() { - l4g.Debug("Scheduler %v: Finished", scheduler.name) - scheduler.stopped <- true - }() - - for { - select { - case <-scheduler.stop: - l4g.Debug("Scheduler %v: Received stop signal", scheduler.name) - return - case <-time.After(86400 * time.Second): - l4g.Debug("Scheduler: %v: Scheduling new job", scheduler.name) - scheduler.AddJob() - } - } -} - -func (scheduler *TestScheduler) AddJob() { - if _, err := CreateJob(scheduler.jobType, nil); err != nil { - l4g.Error("Scheduler %v: failed to create job: %v", scheduler.name, err) - } -} - -func (scheduler *TestScheduler) Stop() { - l4g.Debug("Scheduler %v: Stopping", scheduler.name) - scheduler.stop <- true - <-scheduler.stopped -} |