summaryrefslogtreecommitdiffstats
path: root/cmd/platform/jobserver.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/platform/jobserver.go')
-rw-r--r--cmd/platform/jobserver.go60
1 files changed, 0 insertions, 60 deletions
diff --git a/cmd/platform/jobserver.go b/cmd/platform/jobserver.go
deleted file mode 100644
index 044ee6b6a..000000000
--- a/cmd/platform/jobserver.go
+++ /dev/null
@@ -1,60 +0,0 @@
-// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved.
-// See License.txt for license information.
-package main
-
-import (
- "os"
- "os/signal"
- "syscall"
-
- l4g "github.com/alecthomas/log4go"
- "github.com/spf13/cobra"
-)
-
-var jobserverCmd = &cobra.Command{
- Use: "jobserver",
- Short: "Start the Mattermost job server",
- Run: jobserverCmdF,
-}
-
-func init() {
- jobserverCmd.Flags().Bool("nojobs", false, "Do not run jobs on this jobserver.")
- jobserverCmd.Flags().Bool("noschedule", false, "Do not schedule jobs from this jobserver.")
-}
-
-func jobserverCmdF(cmd *cobra.Command, args []string) {
- // Options
- noJobs, _ := cmd.Flags().GetBool("nojobs")
- noSchedule, _ := cmd.Flags().GetBool("noschedule")
-
- // Initialize
- a, err := initDBCommandContext("config.json")
- if err != nil {
- panic(err.Error())
- }
- defer l4g.Close()
- defer a.Shutdown()
-
- a.LoadLicense()
-
- // Run jobs
- l4g.Info("Starting Mattermost job server")
- if !noJobs {
- a.Jobs.StartWorkers()
- }
- if !noSchedule {
- a.Jobs.StartSchedulers()
- }
-
- signalChan := make(chan os.Signal, 1)
- signal.Notify(signalChan, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
- <-signalChan
-
- // Cleanup anything that isn't handled by a defer statement
- l4g.Info("Stopping Mattermost job server")
-
- a.Jobs.StopSchedulers()
- a.Jobs.StopWorkers()
-
- l4g.Info("Stopped Mattermost job server")
-}