Lines Matching defs:Type
71 type Type struct { struct
75 queue []t
78 dirty set
84 processing set
86 cond *sync.Cond
88 shuttingDown bool
90 metrics queueMetrics
92 unfinishedWorkUpdatePeriod time.Duration
93 clock clock.Clock
114 func (q *Type) Add(item interface{}) {
138 func (q *Type) Len() int {
147 func (q *Type) Get() (item interface{}, shutdown bool) {
171 func (q *Type) Done(item interface{}) {
187 func (q *Type) ShutDown() {
194 func (q *Type) ShuttingDown() bool {
201 func (q *Type) updateUnfinishedWorkLoop() {