From 577ed27f1bb060080d311342047e31943a02ccbb Mon Sep 17 00:00:00 2001 From: Harrison Healey Date: Thu, 18 May 2017 15:05:57 -0400 Subject: PLT-6408 Framework for job server (#6404) * Added initial job server * Added job server to be ran as part of platform * Added test job to the enterprise repo * Fixed job server not loading license * Renamed job package to jobs * Fixed TE not being buildable * Added JobStatus table to database * Changed fields used by JobStatus * Added APIs to query job status * Added config change listener to server * Added option to run job server from Makefile * Added ability to enable/disable jobs from config * Commented out placeholder for search indexing job * Fixed govet * Removed debug messages and fixed job api init message --- app/job.go | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 app/job.go (limited to 'app/job.go') diff --git a/app/job.go b/app/job.go new file mode 100644 index 000000000..00439e4d2 --- /dev/null +++ b/app/job.go @@ -0,0 +1,28 @@ +// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved. +// See License.txt for license information. + +package app + +import ( + "github.com/mattermost/platform/model" +) + +func GetJobStatus(id string) (*model.JobStatus, *model.AppError) { + if result := <-Srv.Store.JobStatus().Get(id); result.Err != nil { + return nil, result.Err + } else { + return result.Data.(*model.JobStatus), nil + } +} + +func GetJobStatusesByTypePage(jobType string, page int, perPage int) ([]*model.JobStatus, *model.AppError) { + return GetJobStatusesByType(jobType, page*perPage, perPage) +} + +func GetJobStatusesByType(jobType string, offset int, limit int) ([]*model.JobStatus, *model.AppError) { + if result := <-Srv.Store.JobStatus().GetAllByTypePage(jobType, offset, limit); result.Err != nil { + return nil, result.Err + } else { + return result.Data.([]*model.JobStatus), nil + } +} -- cgit v1.2.3-1-g7c22