projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch '21123-scheduling-status'
[arvados.git]
/
lib
/
dispatchcloud
/
scheduler
/
scheduler.go
diff --git
a/lib/dispatchcloud/scheduler/scheduler.go
b/lib/dispatchcloud/scheduler/scheduler.go
index ee7ab508839622af6f108cf6b98e6b48f6def603..bc6574a21a538134c618320f9e97511b84d9b307 100644
(file)
--- a/
lib/dispatchcloud/scheduler/scheduler.go
+++ b/
lib/dispatchcloud/scheduler/scheduler.go
@@
-9,6
+9,7
@@
package scheduler
import (
"context"
"sync"
import (
"context"
"sync"
+ "sync/atomic"
"time"
"git.arvados.org/arvados.git/sdk/go/arvados"
"time"
"git.arvados.org/arvados.git/sdk/go/arvados"
@@
-57,6
+58,8
@@
type Scheduler struct {
mLongestWaitTimeSinceQueue prometheus.Gauge
mLast503Time prometheus.Gauge
mMaxContainerConcurrency prometheus.Gauge
mLongestWaitTimeSinceQueue prometheus.Gauge
mLast503Time prometheus.Gauge
mMaxContainerConcurrency prometheus.Gauge
+
+ lastQueue atomic.Value // stores a []QueueEnt
}
// New returns a new unstarted Scheduler.
}
// New returns a new unstarted Scheduler.