_pushRangeToPending will push an unused sequence range to pendingLogs
(startSeq, endSeq uint64, timeReceived channels.FeedTimestamp)
| 680 | |
| 681 | // _pushRangeToPending will push an unused sequence range to pendingLogs |
| 682 | func (c *changeCache) _pushRangeToPending(startSeq, endSeq uint64, timeReceived channels.FeedTimestamp) { |
| 683 | |
| 684 | entry := &LogEntry{ |
| 685 | TimeReceived: timeReceived, |
| 686 | Sequence: startSeq, |
| 687 | EndSequence: endSeq, |
| 688 | UnusedSequence: true, |
| 689 | } |
| 690 | heap.Push(&c.pendingLogs, entry) |
| 691 | |
| 692 | } |
| 693 | |
| 694 | // Process unused sequence notification. Extracts sequence from docID and sends to cache for buffering |
| 695 | func (c *changeCache) processUnusedSequenceRange(ctx context.Context, docID string) { |