Get Changes uses high sequence value (math.MaxUint64) as the upper bound. Relies on changes processing to apply HighCachedSequence filtering - same approach used by singleChannelCacheImpl.
(ctx context.Context, options ChangesOptions)
| 839 | // Get Changes uses high sequence value (math.MaxUint64) as the upper bound. Relies on changes processing |
| 840 | // to apply HighCachedSequence filtering - same approach used by singleChannelCacheImpl. |
| 841 | func (b *bypassChannelCache) GetChanges(ctx context.Context, options ChangesOptions) ([]*LogEntry, error) { |
| 842 | startSeq := options.Since.SafeSequence() + 1 |
| 843 | endSeq := uint64(math.MaxUint64) |
| 844 | return b.queryHandler.getChangesInChannelFromQuery(ctx, b.channel.Name, startSeq, endSeq, options.Limit, options.ActiveOnly) |
| 845 | } |
| 846 | |
| 847 | // No cached changes for bypassChannelCache |
| 848 | func (b *bypassChannelCache) GetCachedChanges(options ChangesOptions) (validFrom uint64, changes []*LogEntry) { |