summaryrefslogtreecommitdiff
path: root/plugins/jobs/plugin.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/plugin.go')
-rw-r--r--plugins/jobs/plugin.go20
1 files changed, 1 insertions, 19 deletions
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 9a551d71..51da9421 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -103,27 +103,9 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit
select {
case <-tt.C:
fmt.Printf("---> rate is: %d\n", atomic.LoadUint64(&rate))
- atomic.StoreUint64(&rate, 0)
- }
- }
- }()
-
- go func() {
- tt := time.NewTicker(time.Millisecond * 1000)
- for { //nolint:gosimple
- select {
- case <-tt.C:
fmt.Printf("---> goroutines: %d\n", runtime.NumGoroutine())
- }
- }
- }()
-
- go func() {
- tt := time.NewTicker(time.Millisecond * 1000)
- for { //nolint:gosimple
- select {
- case <-tt.C:
fmt.Printf("---> curr len: %d\n", p.queue.Len())
+ atomic.StoreUint64(&rate, 0)
}
}
}()