(stopCh chan struct{}, logger g.LoggerType, emptyQueueFunc func() bool)
| 664 | } |
| 665 | |
| 666 | func NewTimestampContext(stopCh chan struct{}, logger g.LoggerType, emptyQueueFunc func() bool) *TimestampContext { |
| 667 | return &TimestampContext{ |
| 668 | stopCh: stopCh, |
| 669 | logger: logger, |
| 670 | emptyQueueFunc: emptyQueueFunc, |
| 671 | |
| 672 | TimestampCh: make(chan uint32, 16), |
| 673 | } |
| 674 | } |
| 675 | |
| 676 | // StreamEvents will begin streaming events. It will be blocking, so should be |
| 677 | // executed by a goroutine |
no outgoing calls
no test coverage detected