(ctx context.Context, chs []channels.ID)
| 562 | } |
| 563 | |
| 564 | func (c *changeCache) notifyChange(ctx context.Context, chs []channels.ID) { |
| 565 | if c.notifyChangeFunc == nil || len(chs) == 0 { |
| 566 | return |
| 567 | } |
| 568 | c.notifyChangeFunc(ctx, channels.SetFromArrayNoValidate(chs)) |
| 569 | } |
| 570 | |
| 571 | func (c *changeCache) Remove(ctx context.Context, collectionID uint32, docIDs []string, startTime time.Time) (count int) { |
| 572 | return c.channelCache.Remove(ctx, collectionID, docIDs, startTime) |
no test coverage detected