forked from xuri/aurora
-
Notifications
You must be signed in to change notification settings - Fork 0
/
currentTubeJobsShowcase.go
139 lines (135 loc) · 5.52 KB
/
currentTubeJobsShowcase.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
package main
import (
"bytes"
"html"
"net/url"
"strconv"
"github.com/Luxurioust/aurora/beanstalk"
)
// currentTubeJobsShowcase return a section include three stats of job, call
// currentTubeJobsShowcaseSections function and get that return value based on
// the given server and tube config.
func currentTubeJobsShowcase(server string, tube string) string {
var buf bytes.Buffer
buf.WriteString(`<section class="jobsShowcase">`)
buf.WriteString(currentTubeJobsShowcaseSections(server, tube))
buf.WriteString(`</section>`)
return buf.String()
}
// currentTubeJobsShowcaseSections constructs a tube job in ready, delayed and
// buried stats table based on the given server and tube config.
func currentTubeJobsShowcaseSections(server string, tube string) string {
stats := []string{"ready", "delayed", "buried"}
var err error
var buf, s, j, b, m, r bytes.Buffer
var bstkConn *beanstalk.Conn
if bstkConn, err = beanstalk.Dial("tcp", server); err != nil {
return `<hr><div class="pull-left"><h3>Next job in "ready" state</h3></div><div class="clearfix"></div><i>empty</i><hr><div class="pull-left"><h3>Next job in "delayed" state</h3></div><div class="clearfix"></div><i>empty</i><hr><div class="pull-left"><h3>Next job in "buried" state</h3></div><div class="clearfix"></div><i>empty</i>`
}
tubeStats := &beanstalk.Tube{
Conn: bstkConn,
Name: tube,
}
peek := []func() (id uint64, body []byte, err error){tubeStats.PeekReady, tubeStats.PeekDelayed, tubeStats.PeekBuried}
for k, stat := range stats {
s.Reset()
j.Reset()
b.Reset()
m.Reset()
r.Reset()
tubes, _ := bstkConn.ListTubes()
jobID, jobBody, err := peek[k]()
if err != nil {
buf.WriteString(`<hr><div class="pull-left"><h3>Next job in "`)
buf.WriteString(stat)
buf.WriteString(`" state</h3></div><div class="clearfix"></div><i>empty</i>`)
continue
}
statsJob, err := bstkConn.StatsJob(jobID)
if err != nil {
continue
}
for _, v := range jobStatsOrder {
s.WriteString(`<tr><td>`)
s.WriteString(v)
s.WriteString(`</td><td>`)
s.WriteString(statsJob[v])
s.WriteString(`</td></tr>`)
}
for _, v := range tubes {
m.WriteString(`<li><a href="?server=`)
m.WriteString(server)
m.WriteString(`&tube=`)
m.WriteString(url.QueryEscape(tube))
m.WriteString(`&action=moveJobsTo&destTube=`)
m.WriteString(url.QueryEscape(v))
m.WriteString(`&state=`)
m.WriteString(stat)
m.WriteString(`">`)
m.WriteString(html.EscapeString(v))
m.WriteString(`</a></li>`)
}
if jobBody != nil {
b.WriteString(`<div class="pull-right"><div style="margin-bottom: 3px;"><a class="btn btn-sm btn-info addSample" data-jobid="`)
b.WriteString(strconv.Itoa(int(jobID)))
b.WriteString(`" href="?server=`)
b.WriteString(server)
b.WriteString(`&tube=`)
b.WriteString(url.QueryEscape(tube))
b.WriteString(`&action=addSample"><i class="glyphicon glyphicon-plus glyphicon-white"></i> Add to samples</a> <div class="btn-group"> <button class="btn btn-info btn-sm dropdown-toggle" data-toggle="dropdown"> <i class="glyphicon glyphicon-arrow-right glyphicon-white"></i> Move all `)
b.WriteString(stat)
b.WriteString(` to </button><ul class="dropdown-menu"><li><input class="moveJobsNewTubeName input-medium" type="text" data-href="?server=`)
b.WriteString(server)
b.WriteString(`&tube=`)
b.WriteString(url.QueryEscape(tube))
b.WriteString(`&action=moveJobsTo&state=`)
b.WriteString(stat)
b.WriteString(`&destTube=" placeholder="New tube name"/></li>`)
b.WriteString(m.String())
b.WriteString(`<li class="divider"></li><li><a href="?server=`)
b.WriteString(server)
b.WriteString(`&tube=`)
b.WriteString(url.QueryEscape(tube))
b.WriteString(`&action=moveJobsTo&destState=buried&state=`)
b.WriteString(stat)
b.WriteString(`">Buried</a></li></ul></div> <a class="btn btn-sm btn-danger" href="?server=`)
b.WriteString(server)
b.WriteString(`&tube=`)
b.WriteString(url.QueryEscape(tube))
b.WriteString(`&state=`)
b.WriteString(stat)
b.WriteString(`&action=deleteAll&count=1" onclick="return confirm('This process might hang a while on tubes with lots of jobs. Are you sure you want to continue?');"><i class="glyphicon glyphicon-trash glyphicon-white"></i> Delete all `)
b.WriteString(stat)
b.WriteString(` jobs</a> <a class="btn btn-sm btn-danger" href="?server=`)
b.WriteString(server)
b.WriteString(`&tube=`)
b.WriteString(url.QueryEscape(tube))
b.WriteString(`&state=`)
b.WriteString(stat)
b.WriteString(`&action=deleteJob&jobid=`)
b.WriteString(strconv.Itoa(int(jobID)))
b.WriteString(`"><i class="glyphicon glyphicon-remove glyphicon-white"></i> Delete</a></div></div>`)
}
if jobBody != nil {
j.WriteString(preformat(jobBody))
}
if jobBody != nil {
r.WriteString(`<hr><div class="pull-left"><h3>Next job in "`)
r.WriteString(stat)
r.WriteString(`" state</h3></div><div class="clearfix"></div><div class="row show-grid"><div class="col-sm-3"><table class="table"><thead><tr><th>Stats:</th><th> </th></tr></thead><tbody>`)
r.WriteString(s.String())
r.WriteString(`</tbody></table></div><div class="col-sm-9"><div class="clearfix"><div class="pull-left"><b>Job data:</b></div>`)
r.WriteString(b.String())
r.WriteString(`</div><pre><code>`)
r.WriteString(j.String())
r.WriteString(`</code></pre></div></div>`)
} else {
r.WriteString(`<hr><div class="pull-left"><h3>Next job in "`)
r.WriteString(stat)
r.WriteString(`" state</h3></div><div class="clearfix"></div><i>empty</i>`)
}
buf.WriteString(r.String())
}
bstkConn.Close()
return buf.String()
}