aboutsummaryrefslogtreecommitdiffhomepage
path: root/storage/job.go
diff options
context:
space:
mode:
Diffstat (limited to 'storage/job.go')
-rw-r--r--storage/job.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/storage/job.go b/storage/job.go
index f8b11d8..20a0efa 100644
--- a/storage/job.go
+++ b/storage/job.go
@@ -8,15 +8,15 @@ import (
"fmt"
"time"
- "github.com/miniflux/miniflux/helper"
"github.com/miniflux/miniflux/model"
+ "github.com/miniflux/miniflux/timer"
)
const maxParsingError = 3
// NewBatch returns a serie of jobs.
func (s *Storage) NewBatch(batchSize int) (jobs model.JobList, err error) {
- defer helper.ExecutionTime(time.Now(), fmt.Sprintf("[Storage:GetJobs] batchSize=%d", batchSize))
+ defer timer.ExecutionTime(time.Now(), fmt.Sprintf("[Storage:GetJobs] batchSize=%d", batchSize))
query := `
SELECT
id, user_id
@@ -29,7 +29,7 @@ func (s *Storage) NewBatch(batchSize int) (jobs model.JobList, err error) {
// NewUserBatch returns a serie of jobs but only for a given user.
func (s *Storage) NewUserBatch(userID int64, batchSize int) (jobs model.JobList, err error) {
- defer helper.ExecutionTime(time.Now(), fmt.Sprintf("[Storage:GetUserJobs] batchSize=%d, userID=%d", batchSize, userID))
+ defer timer.ExecutionTime(time.Now(), fmt.Sprintf("[Storage:GetUserJobs] batchSize=%d, userID=%d", batchSize, userID))
query := `
SELECT
id, user_id