Function NewTimestampContext

driver/mysql/extractor.go:930–938

(stopCh chan struct{}, logger g.LoggerType, emptyQueueFunc func() bool)

}

func NewTimestampContext(stopCh chan struct{}, logger g.LoggerType, emptyQueueFunc func() bool) *TimestampContext {
	return &TimestampContext{
		stopCh:         stopCh,
		logger:         logger,
		emptyQueueFunc: emptyQueueFunc,

		TimestampCh: make(chan uint32, 16),
	}
}
func (tsc *TimestampContext) GetDelay() (d int64) {
	tsc.logger.Debug("TimestampContext.GetDelay", "delay", tsc.delay)
	return tsc.delay