Returns the set of cached log entries for a given channel
(ctx context.Context, channel channels.ID, afterSeq uint64)
| 1223 | |
| 1224 | // Returns the set of cached log entries for a given channel |
| 1225 | func (c *DatabaseCollection) GetChangeLog(ctx context.Context, channel channels.ID, afterSeq uint64) (entries []*LogEntry, err error) { |
| 1226 | return c.changeCache().getChannelCache().GetCachedChanges(ctx, channel) |
| 1227 | } |
| 1228 | |
| 1229 | // WaitForSequenceNotSkipped blocks until the given sequence has been received or skipped by the change cache. |
| 1230 | func (c *DatabaseCollection) WaitForSequence(ctx context.Context, sequence uint64) (err error) { |