Process unused sequence notification. Extracts sequence from docID and sends to cache for buffering
(ctx context.Context, docID string, timeReceived channels.FeedTimestamp)
| 581 | |
| 582 | // Process unused sequence notification. Extracts sequence from docID and sends to cache for buffering |
| 583 | func (c *changeCache) processUnusedSequence(ctx context.Context, docID string, timeReceived channels.FeedTimestamp) { |
| 584 | sequenceStr := strings.TrimPrefix(docID, c.metaKeys.UnusedSeqPrefix()) |
| 585 | sequence, err := strconv.ParseUint(sequenceStr, 10, 64) |
| 586 | if err != nil { |
| 587 | base.WarnfCtx(ctx, "Unable to identify sequence number for unused sequence notification with key: %s, error: %v", base.UD(docID), err) |
| 588 | return |
| 589 | } |
| 590 | c.releaseUnusedSequence(ctx, sequence, timeReceived) |
| 591 | |
| 592 | } |
| 593 | |
| 594 | func (c *changeCache) releaseUnusedSequence(ctx context.Context, sequence uint64, timeReceived channels.FeedTimestamp) { |
| 595 | change := &LogEntry{ |
no test coverage detected