NewFIFO returns a Store which can be used to queue up items to process.
(keyFunc KeyFunc)
| 348 | // NewFIFO returns a Store which can be used to queue up items to |
| 349 | // process. |
| 350 | func NewFIFO(keyFunc KeyFunc) *FIFO { |
| 351 | f := &FIFO{ |
| 352 | items: map[string]interface{}{}, |
| 353 | queue: []string{}, |
| 354 | keyFunc: keyFunc, |
| 355 | } |
| 356 | f.cond.L = &f.lock |
| 357 | return f |
| 358 | } |
no outgoing calls