Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2025-01-10 18:07:42 +01:00
Code Issues Projects Releases Wiki Activity

add parameter 'num' to list jobs

Browse Source
This commit is contained in:
Wenkai Yin 2016-07-06 14:12:16 +08:00
parent 86d643c93f
commit 37fc63aacc
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
api/replication_job.go
View File

@ -61,6 +61,7 @@ func (ra *RepJobAPI) List() {
var policyID int64 var policyID int64
var repository, status string var repository, status string
var startTime, endTime *time.Time var startTime, endTime *time.Time
var num int
var err error var err error
policyIDStr := ra.GetString("policy_id") policyIDStr := ra.GetString("policy_id")
@ -71,6 +72,17 @@ func (ra *RepJobAPI) List() {
} }
} }
numStr := ra.GetString("num")
if len(numStr) != 0 {
num, err = strconv.Atoi(numStr)
if err != nil {
ra.CustomAbort(http.StatusBadRequest, fmt.Sprintf("invalid num: %s", numStr))
}
}
if num <= 0 {
num = 200
}
endTimeStr := ra.GetString("end_time") endTimeStr := ra.GetString("end_time")
if len(endTimeStr) != 0 { if len(endTimeStr) != 0 {
i, err := strconv.ParseInt(endTimeStr, 10, 64) i, err := strconv.ParseInt(endTimeStr, 10, 64)
@ -100,7 +112,7 @@ func (ra *RepJobAPI) List() {
repository = ra.GetString("repository") repository = ra.GetString("repository")
status = ra.GetString("status") status = ra.GetString("status")
jobs, err := dao.FilterRepJobs(policyID, repository, status, startTime, endTime, 1000) jobs, err := dao.FilterRepJobs(policyID, repository, status, startTime, endTime, num)
if err != nil { if err != nil {
log.Errorf("failed to filter jobs according policy ID %d, repository %s, status %s: %v", policyID, repository, status, err) log.Errorf("failed to filter jobs according policy ID %d, repository %s, status %s: %v", policyID, repository, status, err)
ra.RenderError(http.StatusInternalServerError, "Failed to query job") ra.RenderError(http.StatusInternalServerError, "Failed to query job")