Lines Matching defs:Type
65 type Type struct { struct
69 queue []t
72 dirty set
78 processing set
80 cond *sync.Cond
82 shuttingDown bool
84 metrics queueMetrics
86 unfinishedWorkUpdatePeriod time.Duration
87 clock clock.Clock
108 func (q *Type) Add(item interface{}) {
132 func (q *Type) Len() int {
141 func (q *Type) Get() (item interface{}, shutdown bool) {
165 func (q *Type) Done(item interface{}) {
181 func (q *Type) ShutDown() {
188 func (q *Type) ShuttingDown() bool {
195 func (q *Type) updateUnfinishedWorkLoop() {