| 72 | ) |
| 73 | |
| 74 | type Queue struct { |
| 75 | opt *taskq.QueueConfig |
| 76 | |
| 77 | sync bool |
| 78 | noDelay bool |
| 79 | |
| 80 | wg sync.WaitGroup |
| 81 | consumer *taskq.Consumer |
| 82 | |
| 83 | scheduler scheduler |
| 84 | |
| 85 | _state int32 |
| 86 | } |
| 87 | |
| 88 | var _ taskq.Queue = (*Queue)(nil) |
| 89 |
nothing calls this directly
no outgoing calls
no test coverage detected